鴻蒙OS 發(fā)布式任務(wù)調(diào)度開發(fā)指導(dǎo)

場(chǎng)景介紹

開發(fā)者在應(yīng)用中集成分布式調(diào)度能力，通過調(diào)用指定能力的分布式接口，實(shí)現(xiàn)跨設(shè)備能力調(diào)度。根據(jù) Ability 模板及意圖的不同，分布式任務(wù)調(diào)度向開發(fā)者提供以下六種能力：?jiǎn)?dòng)遠(yuǎn)程 FA、啟動(dòng)遠(yuǎn)程 PA、關(guān)閉遠(yuǎn)程 PA、連接遠(yuǎn)程 PA、斷開連接遠(yuǎn)程 PA 和 FA 跨設(shè)備遷移。下面以設(shè)備 A（本地設(shè)備）和設(shè)備 B（遠(yuǎn)端設(shè)備）為例，進(jìn)行場(chǎng)景介紹：

1. 設(shè)備 A 啟動(dòng)設(shè)備 B 的 FA：在設(shè)備 A 上通過本地應(yīng)用提供的啟動(dòng)按鈕，啟動(dòng)設(shè)備 B 上對(duì)應(yīng)的 FA。例如：設(shè)備 A 控制設(shè)備 B 打開相冊(cè)，只需開發(fā)者在啟動(dòng) FA 時(shí)指定打開相冊(cè)的意圖即可。
2. 設(shè)備 A 啟動(dòng)設(shè)備 B 的 PA：在設(shè)備 A 上通過本地應(yīng)用提供的啟動(dòng)按鈕，啟動(dòng)設(shè)備 B 上指定的 PA。例如：開發(fā)者在啟動(dòng)遠(yuǎn)程服務(wù)時(shí)通過意圖指定音樂播放服務(wù)，即可實(shí)現(xiàn)設(shè)備 A 啟動(dòng)設(shè)備 B 音樂播放的能力。
3. 設(shè)備 A 關(guān)閉設(shè)備 B 的 PA：在設(shè)備 A 上通過本地應(yīng)用提供的關(guān)閉按鈕，關(guān)閉設(shè)備 B 上指定的 PA。類似啟動(dòng)的過程，開發(fā)者在關(guān)閉遠(yuǎn)程服務(wù)時(shí)通過意圖指定音樂播放服務(wù)，即可實(shí)現(xiàn)關(guān)閉設(shè)備 B 上該服務(wù)的能力。
4. 設(shè)備 A 連接設(shè)備 B 的 PA：在設(shè)備 A 上通過本地應(yīng)用提供的連接按鈕，連接設(shè)備 B 上指定的 PA。連接后，通過其他功能相關(guān)按鈕實(shí)現(xiàn)控制對(duì)端 PA 的能力。通過連接關(guān)系，開發(fā)者可以實(shí)現(xiàn)跨設(shè)備的同步服務(wù)調(diào)度，實(shí)現(xiàn)如大型計(jì)算任務(wù)互助等價(jià)值場(chǎng)景。
5. 設(shè)備 A 與設(shè)備 B 的 PA 斷開連接：在設(shè)備 A 上通過本地應(yīng)用提供斷開連接的按鈕，將之前已連接的 PA 斷開連接。
6. 設(shè)備 A 的 FA 遷移至設(shè)備B：設(shè)備 A 上通過本地應(yīng)用提供的遷移按鈕，將設(shè)備 A 的業(yè)務(wù)無縫遷移到設(shè)備B中。通過業(yè)務(wù)遷移能力，打通設(shè)備 A 和設(shè)備 B 間的壁壘，實(shí)現(xiàn)如文檔跨設(shè)備編輯、視頻從客廳到房間跨設(shè)備接續(xù)播放等場(chǎng)景。

接口說明

分布式調(diào)度平臺(tái)提供的連接和斷開連接 PA、啟動(dòng)遠(yuǎn)程 FA、啟動(dòng)和關(guān)閉 PA 以及遷移 FA 的能力，是實(shí)現(xiàn)更多價(jià)值性場(chǎng)景的基礎(chǔ)。

連接遠(yuǎn)程PA

connectAbility(Intent intent, IAbilityConnection conn)接口提供連接指定設(shè)備上 PA 的能力，Intent 中指定待連接 PA 的設(shè)備 deviceId、bundleName 和 abilityName。當(dāng)連接成功后，通過在 conn 定義的 onAbilityConnectDone 回調(diào)中獲取對(duì)端 PA 的服務(wù)代理，兩者的連接關(guān)系則由 conn 維護(hù)。具體的參數(shù)定義如下表所示：

啟動(dòng)遠(yuǎn)程FA/PA

startAbility(Intent intent) 接口提供啟動(dòng)指定設(shè)備上 FA 和 PA 的能力，Intent 中指定待啟動(dòng) FA/PA 的設(shè)備 deviceId、bundleName 和 abilityName。具體參數(shù)定義如下表所示：

分布式調(diào)度平臺(tái)還會(huì)提供與上述功能相對(duì)應(yīng)的斷開遠(yuǎn)程 PA 的連接和關(guān)閉遠(yuǎn)程 PA 的接口，相關(guān)的參數(shù)與連接、啟動(dòng)的接口類似。

• 斷開遠(yuǎn)程 PA 連接：disconnectAbility (IAbilityConnection conn)。
• 關(guān)閉遠(yuǎn)程 PA：boolean stopAbility (Intent intent)。

遷移FA

continueAbility(String deviceId)接口提供將本地FA遷移到指定設(shè)備上的能力，需要開發(fā)者在調(diào)用時(shí)指定目標(biāo)設(shè)備的 deviceId。具體參數(shù)定義如下表所示：

說明

Ability 和 AbilitySlice 類均需要實(shí)現(xiàn) IAbilityContinuation 及其方法，才可以實(shí)現(xiàn) FA 遷移。

開發(fā)步驟

1. 導(dǎo)入功能依賴的包。

   // 以下依賴包含分布式調(diào)度平臺(tái)開放的接口，用于：連接/斷開連接遠(yuǎn)程 PA、啟動(dòng)遠(yuǎn)程 FA、通過連接關(guān)系注冊(cè)的回調(diào)函數(shù) onAbilityConnectDon e中返回的對(duì)端 PA 的代理，實(shí)現(xiàn)對(duì)PA的控制
   import ohos.aafwk.ability.AbilitySlice;
   import ohos.aafwk.ability.IAbilityConnection;
   import ohos.aafwk.content.Intent;
   import ohos.aafwk.content.Operation;
   import ohos.bundle.ElementName;
   // 為了實(shí)現(xiàn)遷移能力，需要引入傳遞遷移所需數(shù)據(jù)的包以及實(shí)現(xiàn)遷移能力的接口。
   import ohos.aafwk.ability.IAbilityContinuation;
   import ohos.aafwk.content.IntentParams;
   // 為了實(shí)現(xiàn)跨設(shè)備指令及數(shù)據(jù)通信，需要集成 HarmonyOS 提供的 RPC 接口
   import ohos.rpc.IRemoteObject;
   import ohos.rpc.IRemoteBroker;
   import ohos.rpc.MessageParcel;
   import ohos.rpc.MessageOption;
   import ohos.rpc.RemoteException;
   import ohos.rpc.RemoteObject;
   //（可選）多設(shè)備場(chǎng)景下涉及設(shè)備選擇，為此需要引入組網(wǎng)設(shè)備發(fā)現(xiàn)的能力
   import ohos.distributedschedule.interwork.DeviceInfo;
   import ohos.distributedschedule.interwork.DeviceManager;
   // (可選）設(shè)計(jì)界面相關(guān)的包函數(shù)，對(duì) FA 界面及按鈕進(jìn)行繪制
   import ohos.agp.components.Button;
   import ohos.agp.components.Component;
   import ohos.agp.components.Component.ClickedListener;
   import ohos.agp.components.ComponentContainer.LayoutConfig;
   import ohos.agp.components.element.ShapeElement;
   import ohos.agp.components.PositionLayout;

1. （可選）編寫一個(gè)基本的 FA 用于使用分布式能力。

   // 調(diào)用 AbilitySlice 模板實(shí)現(xiàn)一個(gè)用于控制基礎(chǔ)功能的 FA
   // Ability 和 AbilitySlice 類均需要實(shí)現(xiàn) IAbilityContinuation 及其方法，才可以實(shí)現(xiàn) FA 遷移。AbilitySlice 的代碼示例如下
   public class SampleSlice extends AbilitySlice implements IAbilityContinuation {
       @Override
       public void onStart(Intent intent) {
           super.onStart(intent);
           // 開發(fā)者可以自行進(jìn)行界面設(shè)計(jì)
           // 為按鈕設(shè)置統(tǒng)一的背景色
           // 例如通過PositionLayout指定大小可以實(shí)現(xiàn)簡(jiǎn)單界面
           PositionLayout layout = new PositionLayout(this);
           LayoutConfig config = new LayoutConfig(LayoutConfig.MATCH_PARENT, LayoutConfig.MATCH_PARENT);
           layout.setLayoutConfig(config);
           ShapeElement buttonBg = new ShapeElement();
           buttonBg.setRgbColor(new RgbColor(0,125,255));
           addComponents(layout, buttonBg, config);
           super.setUIContent(layout);
       }
    
       @Override
       public void onInactive() {
           super.onInactive();
       }
    
       @Override
       public void onActive() {
           super.onActive();
       }
    
       @Override
       public void onBackground() {
           super.onBackground();
       }
    
       @Override
       public void onForeground(Intent intent) {
           super.onForeground(intent);
       }
    
       @Override
       public void onStop() {
           super.onStop();
       }
   }

說明

此步驟展示了一個(gè)簡(jiǎn)單 FA 的實(shí)現(xiàn)過程，實(shí)際開發(fā)中請(qǐng)開發(fā)者根據(jù)需要進(jìn)行設(shè)計(jì)。

1. （可選）為不同的能力設(shè)置相應(yīng)的控制按鈕。

   // 建議開發(fā)者按照自己的界面進(jìn)行按鈕設(shè)計(jì)
   // 開發(fā)者可以自行實(shí)現(xiàn)如 createButton 的方法，新建一個(gè)顯示文字 text，背景色為 buttonBg 以及大小尺寸位置符合 config 設(shè)置的按鈕，用來與用戶發(fā)生交互
   // private Button createButton(String text, ShapeElement buttonBg, LayoutConfig config)
   // 按照順序在 PositionLayout 中依次添加按鈕的示例
   private void addComponents(PositionLayout linear, ShapeElement buttonBg, LayoutConfig config) {
       // 構(gòu)建遠(yuǎn)程啟動(dòng)FA的按鈕
       btnStartRemoteFA = createButton("StartRemoteFA", buttonBg, config);
       btnStartRemoteFA.setClickedListener(mStartRemoteFAListener);
       linear.addComponent(btnStartRemoteFA);
       // 構(gòu)建遠(yuǎn)程啟動(dòng)PA的按鈕
       btnStartRemotePA = createButton("StartRemotePA", buttonBg, config);
       btnStartRemotePA.setClickedListener(mStartRemotePAListener);
       linear.addComponent(btnStartRemotePA);
       // 構(gòu)建遠(yuǎn)程關(guān)閉PA的按鈕
       btnStopRemotePA = createButton("StopRemotePA", buttonBg, config);
       btnStopRemotePA.setClickedListener(mStopRemotePAListener);
       linear.addComponent(btnStopRemotePA);
       // 構(gòu)建連接遠(yuǎn)程PA的按鈕
       btnConnectRemotePA = createButton("ConnectRemotePA", buttonBg, config);
       btnConnectRemotePA.setClickedListener(mConnectRemotePAListener);
       linear.addComponent(btnConnectRemotePA);
       // 構(gòu)建控制連接PA的按鈕
       btnControlRemotePA = createButton("ControlRemotePA", buttonBg, config);
       btnControlRemotePA.setClickedListener(mControlPAListener);
       linear.addComponent(btnControlRemotePA);
       // 構(gòu)建與遠(yuǎn)程PA斷開連接的按鈕
       btnDisconnectRemotePA = createButton("DisconnectRemotePA", buttonBg, config);
       btnDisconnectRemotePA.setClickedListener(mDisconnectRemotePAListener);
       linear.addComponent(btnDisconnectRemotePA);
       // 構(gòu)建遷移FA的按鈕
       btnContinueRemoteFA = createButton("ContinueRemoteFA", buttonBg, config);
       btnContinueRemoteFA.setClickedListener(mContinueAbilityListener);
       linear.addComponent(btnContinueRemoteFA);
   }

說明

此處只展示了基于按鈕控制的能力調(diào)度方法，實(shí)際開發(fā)中請(qǐng)開發(fā)者根據(jù)需要選擇能力調(diào)度方式。代碼示例中未體現(xiàn)按鈕如位置、樣式等具體的設(shè)置方法，詳請(qǐng)參考 JAVA UI框架。

1. 通過設(shè)備管理 DeviceManager 提供的 getDeviceList 接口獲取設(shè)備列表，用于指定目標(biāo)設(shè)備。

   // ISelectResult 是一個(gè)自定義接口，用來處理指定設(shè)備 deviceId 后執(zhí)行的行為
    interface ISelectResult {
        void onSelectResult(String deviceId);
    }
    
   // 獲得設(shè)備列表，開發(fā)者可在得到的在線設(shè)備列表中選擇目標(biāo)設(shè)備執(zhí)行操作
   private void scheduleRemoteAbility(ISelectResult listener) {
       // 調(diào)用DeviceManager的getDeviceList接口，通過FLAG_GET_ONLINE_DEVICE標(biāo)記獲得在線設(shè)備列表
       List<DeviceInfo> onlineDevices = DeviceManager.getDeviceList(DeviceInfo.FLAG_GET_ONLINE_DEVICE);
       // 判斷組網(wǎng)設(shè)備是否為空
       if (onlineDevices.isEmpty()) {
           listener.onSelectResult(null);
           return;
       }
       int numDevices = onlineDevices.size();
       ArrayList<String> deviceIds = new ArrayList<>(numDevices);
       ArrayList<String> deviceNames = new ArrayList<>(numDevices);
       onlineDevices.forEach((device) -> {
           deviceIds.add(device.getDeviceId());
           deviceNames.add(device.getDeviceName());
       });
       // 以選擇首個(gè)設(shè)備作為目標(biāo)設(shè)備為例
       // 開發(fā)者也可按照具體場(chǎng)景，通過別的方式進(jìn)行設(shè)備選擇
       String selectDeviceId = deviceIds.get(0);
       listener.onSelectResult(selectDeviceId);    
   }

上述實(shí)例中涉及對(duì)在線組網(wǎng)設(shè)備的查詢，該項(xiàng)能力需要開發(fā)者在對(duì)應(yīng)的 config.json 中聲明獲取設(shè)備列表及設(shè)備信息的權(quán)限，如下所示：

   {
       "reqPermissions": [
           {
               "name": "ohos.permission.DISTRIBUTED_DEVICE_STATE_CHANGE"
           }, 
           {
               "name": "ohos.permission.GET_DISTRIBUTED_DEVICE_INFO"
           }, 
           {
               "name": "ohos.permission.GET_BUNDLE_INFO"
           }
       ]
   }

1. 為啟動(dòng)遠(yuǎn)程 FA 的按鈕設(shè)置點(diǎn)擊回調(diào)，實(shí)現(xiàn)啟動(dòng)遠(yuǎn)程 FA 的能力。

   // 啟動(dòng)一個(gè)指定 bundleName 和 abilityName 的 FA
   private ClickedListener mStartRemoteFAListener = new ClickedListener() {
       @Override
       public void onClick(Component arg0) {
           // 啟動(dòng)遠(yuǎn)程PA
           scheduleRemoteAbility(new ISelectResult() {
               @Override
               void onSelectResult(String deviceId) {
                   if (deviceId != null) {
                       Intent intent = new Intent();
                       // 通過scheduleRemoteAbility指定目標(biāo)設(shè)備deviceId
                       // 指定待啟動(dòng)FA的bundleName和abilityName
                       // 例如：bundleName = "com.huawei.helloworld"
                       //       abilityName = "com.huawei.helloworld.SampleFeatureAbility"
                       // 設(shè)置分布式標(biāo)記，表明當(dāng)前涉及分布式能力
                       Operation operation = new Intent.OperationBuilder()
                               .withDeviceId(deviceId)
                               .withBundleName(bundleName)
                               .withAbilityName(abilityName)
                               .withFlags(Intent.FLAG_ABILITYSLICE_MULTI_DEVICE)
                               .build();
                       intent.setOperation(operation);
                       // 通過AbilitySlice包含的startAbility接口實(shí)現(xiàn)跨設(shè)備啟動(dòng)FA
                       startAbility(intent);
                   }
               }
           });
       }
   };