OpenHarmony ソースコード分析: 分散タスクスケジューリング (I)

[[434413]]

詳細については、以下をご覧ください。

51CTOとHuaweiが共同で構築したHongmengテクノロジーコミュニティ

https://harmonyos..com

序文

HarmonyOS は、ローカル プログラムでのリモート タスクの呼び出しをサポートします。この機能は、下位レベルの分散タスク スケジューリング サブシステムによってサポートされており、オープン ソースの OpenHarmony コードに提供されています。分散タスク スケジューリング サブシステムをより包括的に理解し把握するために、分散リモート起動という単純な機能から始めて、Hongmeng のオープン ソース コードを使用して詳細な調査を行いました。

以下のテキストで特に指定がない限り、ここで言及されている Harmony システムは、オープン ソースの Harmony システム (OpenHarmony 3.0 LTS バージョン) を指します。

OpenHarmony アーキテクチャ図

概要

オープンソースの Hongmeng ドキュメントから始めましょう:

分散タスク スケジューリング モジュールは、マスター スレーブ デバイス サービス プロキシ メカニズムを通じて OpenHarmony オペレーティング システム上に分散サービス プラットフォームを確立し、マスター デバイス (OpenHarmony を搭載したスマート スクリーン デバイス) がスレーブ デバイス (IP カメラ、スポーツ ウォッチ、その他の小メモリ OpenHarmony デバイス) の FA を起動することをサポートします。

スマート スクリーンの番組開始リマインダーを例にとると、スマート スクリーンのお気に入り番組メニューで、[番組開始後にリマインダーを表示する] ボタンをクリックします。プログラムが開始すると、スマート スクリーンにスポーツ ウォッチのプログラム開始リマインダー FA が表示されます。この FA を通じて、ユーザーはお気に入りのプログラムが開始されたことをすぐに知ることができ、コラボレーションと相互支援の効果が得られます。

FA: 機能アビリティは、ユーザーと対話するために使用されるインターフェースを備えたアビリティを表します。

リモート スタート: デバイス間で FA を開始します。これは、ローカルで FA を開始することに対応します。

オープンソースの Hongmeng システム内のアプリケーションは、能力に基づいて FA と PA に分けられます。 FA はインターフェースを備えたアプリケーションであると簡単に理解できます。

分散サービスプラットフォーム

分散タスク スケジューリングの前提は、デバイスが分散サービス プラットフォームを確立し、独自の機能を登録する必要があることです。

オープンソースの Hongmeng は、軽量、小型、標準の 3 種類のデバイスをサポートしています。

標準デバイスでは、オープンソースの Hongmeng では分散サービス プラットフォームがデフォルトでオンになっており、開発者は通常、分散タスク スケジューリング機能を使用するために追加の作業を行う必要はありません。

軽量で小型のデバイスでは、スタートアップ コード自体に分散サービス プラットフォーム関数の呼び出しを実装する必要があります。詳細については、「分散ソフトバスサブシステム」を参照してください。関連するコードリポジトリと呼び出し API については、[Distributed Soft Bus]、[Distributed Soft Bus Lite] を参照してください。

同じLAN

上記のコード ウェアハウスの説明では、次の点が繰り返し強調されています。

検出エンドデバイスと検出対象エンドデバイスが同じLAN内にあることを確認する必要がある。

これは、オープンソースの Hongmeng システムは現在 coap プロトコルを使用しており、当面は coap プロトコルのみをサポートしているためです。ソースコードからもわかるように、今後はBLEやUSBなど他の方式にも拡張される予定です。

 /**
 * @brief サービスの公開に使用されるBluetooth、Wi-Fi 、 USBなどのメディアを列挙します。
 *
 *現在、メディアは 協力する。
 *
 */
 typedef列挙型{
    /** 自動メディア選択 */
    自動 = 0、
    /** ブルートゥース */
    BLE = 1、
    /** Wi-Fi */
    2,
    /** USB */
    USB = 3、
 } ExchangeMedium;

オープンソースの Hongmeng CoAP プロトコルで使用されるデフォルトのポートは 5684 で、UDP ブロードキャストを介してローカル エリア ネットワークに公開されます。デバッグ中にデバイスが見つからない場合は、このポートを介してパケットをキャプチャして分析できます。

 #COAP_DEFAULT_PORT 5684 を定義します

分散タスクスケジューリングプロセス

たまたま、オープンソースの Hongmeng 標準システムをサポートする開発ボード Hi3516D を 2 つ持っています。そこで、標準システムの分散タスク スケジューリングを例に、オープン ソース Hongmeng システムの分散タスク スケジューリング プロセスについて説明します。開発言語が異なることを除けば、軽量システムと小規模システムの基本的な手順は同じです。

オープンソースの Hongmeng システム開発 FA は現在、js/eTS 言語のみをサポートしています。

このデモは分散計算機を参照します。説明の便宜上、多くの簡略化が行われており、ここではエラー処理は無視されています。

特定の API リファレンス コード リポジトリ: DeviceManager コンポーネント。

ステップ1: デバイスマネージャーを作成する

deviceManagerをインポートする  '@ohos.distributedHardware.deviceManager' ; 
 
自分自身 = this とします。
 deviceManager.createDeviceManager( "com.example.myapplication" , (err, val)=>{self.deviceManager_ = val;});

DeviceManager 関連のインターフェースを使用する前に、createDeviceManager インターフェースを通じて DeviceManager インスタンスを作成する必要があります。

ステップ2: 信頼できるデバイスのリストを取得する

var 配列 = this.deviceManager_.getTrustedDeviceListSync();

ステップ3: 周辺機器の動的監視用のコールバック関数を登録する

this.deviceManager_ です。 on ( 'deviceFound' 、 (データ) => {
    extraInfo = {
 "targetPkgName" : 'com.example.myapplication' ,
 "appName" : '分散例' ,
 "appDescription" : 'シンプルな分散例' ,
 「ビジネス」 : '0'  
    };
    authParam = {とする
「認証タイプ」 : 1,
 "アプリアイコン" : '' ,
 「アプリサムネイル」 : '' ,
 "追加情報" : 追加情報
    };
    self.deviceManager_.authenticateDevice(data.device, authParam, (err) => { ... });
 });
 this.deviceManager_ です。 ( ' deviceStateChange' 、 (データ) => { ... });

ステップ4: 近くにある新しいデバイスを検出して認証する

SUBSCRIBE_ID = Math.floor(65536 * Math.random());
 var 情報 = {
    購読ID: SUBSCRIBE_ID、
    モード: 0xAA、
    中: 2,
    頻度: 2,
    isSameAccount: false 、
    isWakeRemote: true 、
    能力: 0
 };
 this.deviceManager_.startDeviceDiscover(情報);

新しいデバイスを一緒に使用する前に、認証する必要があります。オープンソースの Hongmeng システムにはユーザー登録メカニズムがないため、認証には別の開発フレームワークのサポートが必要です。オープンソースの Hongmeng は、簡単に使用できるポップアップ PIN コード認証メカニズムをサポートするために、標準システムにシンプルな HAP プログラムを提供します。

現在のバージョンでは PIN コード認証のみがサポートされており、PIN コード認証には認証プロンプト インターフェイス、PIN コード表示インターフェイス、および PIN コード入力インターフェイスを提供する必要があります。

現在、システムにはネイティブ レイヤーを介してポップアップを直接表示する機能がないため、ここでは一時的な FA を使用して、対応するインターフェイスにポップアップを表示します。

FA は、システム アプリケーションとしてプリセットされている DeviceManager_UI.hap です。

具体的な動作は次のとおりです。

1. リモートデバイスの画面に大きな6桁のPINが表示されます
2. 制御装置はPINコード入力ウィンドウをポップアップします
3. ユーザーはリモートデバイスに表示された PIN コードを制御デバイスに入力し、検証後にリモート制御を続行できます。
4. PIN コードが正常に入力されると、デバイスは信頼できるデバイスとなり、システムに保存されます。次回接続するときに再度確認する必要はありません。

ステップ5: リモートでFAを呼び出す

上記の手順 1 ～ 4 は標準的な周辺機器管理手順であるため、後で使用するために関数ライブラリにカプセル化できます。

信頼できるデバイス配列を取得した後、適切なポップアップ ウィンドウまたは選択インターフェイスで、接続するデバイスの 1 つを選択するようにユーザーに求めることができます。

 findDevices:関数(){
      自分自身 = this とします。
      this.remoteDevices.registerDeviceListCallback(() => {
          var リスト = 新しい配列();
          var devs = self.remoteDevices.deviceList;
          console.info( 'myapplication: リモートデバイスが更新されました、count=' + devs.length);
 (var i = 0; i < devs.length; i++)の場合{
              console.info( 'myapplication: デバイス ' + i + '/' + devs.length +
 ' デバイスID = ' + devs[i]. デバイスID + ' デバイス名 = ' + devs[i]. デバイス名
              + 'デバイスタイプ=' + devs[i].デバイスタイプ);
              リスト[i + 1] = {
名前: devs[i].デバイス名、
                  実行: devs[i].deviceId
              };
          }
          self.devList = リスト;
      });
  },

リモートFAを開始する手順:

機能の能力をインポート  '@ohos.ability.featureability' ; 
 
 ...... 
 
機能アビリティ.開始アビリティ({
    欲しい：{
        バンドル名: 'com.example.myapplication' ,
        能力名: 'com.example.myapplication.MainAbility' 、
        デバイスID: this.devList[idx].did、
        パラメータ:
            isFA: 'FA'  
        }
    }
 }）。それから((データ)=>{
    console.log( "myapplication: 起動機能が終了しました:" + JSON.stringify(data));
 });

リクエストを受信すると、リモート デバイスは対応するパラメータを使用して対応する FA を起動し、起動時にパラメータを取得できます。

準備完了() {
    featureAbility.getWant((エラー、欲しい) => {
        console.info( 'myapplication: featureAbility.getWant =' + JSON.stringify(want.parameters));
        // ここでisFAは上記のリモートリクエストのパラメータです
        want.parameters.isFA の場合、 want.parameters.isFA === 'FA'となります。
            this.initKVManager(()=>{
                console.log( 'myapplication: kvmanager が起動しました。' )
            });
        }
それ以外{
            this.findDevices();
        }
    }); 
 
 },

具体的な API については、Huawei の Hongmeng 開発ドキュメントを参照してください。一部の内容はオープンソースの Hongmeng システムと異なる場合がありますのでご了承ください。ご自身で判断してください。

コンパイルして実行する

上記の手順は、DevEco Studio 3.0.0.600 x64 で正常に記述され、2 つの Hi3516D デバイス間で正常に実行されます。コード（配布されたリモートブート.zip）を添付します。

オープンソースの Hongmeng システムに HAP プログラムをインストールする場合は、まず署名し、DevEco Studio で関連する設定を行う必要があります。具体的な手順については、オープンソースの Hongmeng ドキュメントを参照してください。

HAP プログラムをアップロードしてインストールするには、開発ツール hdc を使用する必要があります。詳細についてはドキュメントを参照してください。

まとめ

オープンソースの Hongmeng システムの分散タスク スケジューリングの基本機能は当初から改善されていましたが、使用方法のドキュメントが比較的分散しており、サブシステムごとに参照する必要があり、少し不便です。

次のステップでは、分散ソフト バスと分散データについて学習し、オープン ソースの Hongmeng システムがアプリケーション間のデータ相互作用機能をどのようにカプセル化しているかを確認します。

また、ソースコードを見ると、オープンソースの Hongmeng システムにはすでに分散アプリケーションフロー (移行) 操作機能が搭載されており、時間があるときに学習することができます。

詳細については、以下をご覧ください。

51CTOとHuaweiが共同で構築したHongmengテクノロジーコミュニティ

https://harmonyos..com