鴻蒙OS 分布式任務(wù)調(diào)度概述

在 HarmonyO S中，分布式任務(wù)調(diào)度平臺對搭載 HarmonyOS 的多設(shè)備構(gòu)筑的“超級虛擬終端”提供統(tǒng)一的組件管理能力，為應(yīng)用定義統(tǒng)一的能力基線、接口形式、數(shù)據(jù)結(jié)構(gòu)、服務(wù)描述語言，屏蔽硬件差異；支持遠(yuǎn)程啟動、遠(yuǎn)程調(diào)用、業(yè)務(wù)無縫遷移等分布式任務(wù)。

分布式任務(wù)調(diào)度平臺在底層實現(xiàn) Ability（分布式任務(wù)調(diào)度的基本組件）跨設(shè)備的啟動/關(guān)閉、連接及斷開連接以及遷移等能力，實現(xiàn)跨設(shè)備的組件管理：

• 啟動和關(guān)閉：向開發(fā)者提供管理遠(yuǎn)程 Ability 的能力，即支持啟動 Page 模板的 Ability，以及啟動、關(guān)閉 Service 和 Data 模板的 Ability。
• 連接和斷開連接：向開發(fā)者提供跨設(shè)備控制服務(wù)（ Service 和 Data 模板的 Ability ）的能力，開發(fā)者可以通過與遠(yuǎn)程服務(wù)連接及斷開連接實現(xiàn)獲取或注銷跨設(shè)備管理服務(wù)的對象，達到和本地一致的服務(wù)調(diào)度。
• 遷移能力：向開發(fā)者提供跨設(shè)備業(yè)務(wù)的無縫遷移能力，開發(fā)者可以通過調(diào)用 Page 模板 Ability 的遷移接口，將本地業(yè)務(wù)無縫遷移到指定設(shè)備中，打通設(shè)備間壁壘。

約束與限制

• 開發(fā)者需要在 Intent 中設(shè)置支持分布式的標(biāo)記（例如：Intent.FLAG_ABILITYSLICE_MULTI_DEVICE 表示該應(yīng)用支持分布式調(diào)度），否則將無法獲得分布式能力。
• 開發(fā)者通過在 config.json 中添加分布式數(shù)據(jù)傳輸?shù)臋?quán)限申請：{"name": "ohos.permission.servicebus.ACCESS_SERVICE"}，獲取跨設(shè)備連接的能力。
• PA（ Particle Ability，Service 和 Data 模板的 Ability）的調(diào)用支持連接及斷開連接、啟動及關(guān)閉這四類行為，在進行調(diào)度時：
• 開發(fā)者必須在 Intent 中指定 PA 對應(yīng)的 bundleName 和 abilityName。
• 當(dāng)開發(fā)者需要跨設(shè)備啟動、關(guān)閉或連接 PA 時，需要在 Intent 中指定對端設(shè)備的 deviceId。開發(fā)者可通過如設(shè)備管理類 DeviceManager 提供的 getDeviceList 獲取指定條件下匿名化處理的設(shè)備列表，實現(xiàn)對指定設(shè)備 PA 的啟動/關(guān)閉以及連接管理。
• FA（Feature Ability，Page 模板的 Ability）的調(diào)用支持啟動和遷移行為，在進行調(diào)度時：
• 當(dāng)啟動 FA 時，需要開發(fā)者在 Intent 中指定對端設(shè)備的 deviceId、bundleName 和 abilityName。
• FA 的遷移實現(xiàn)相同 bundleName 和 abilityName 的 FA 跨設(shè)備遷移，因此需要指定遷移設(shè)備的 deviceId。

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

場景介紹

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

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

接口說明

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

• 連接遠(yuǎn)程PA

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

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

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

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

• 遷移FA

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

說明

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

開發(fā)步驟

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

// 以下依賴包含分布式調(diào)度平臺開放的接口，用于：連接/斷開連接遠(yuǎn)程 PA、啟動遠(yuǎn)程 FA、通過連接關(guān)系注冊的回調(diào)函數(shù) onAbilityConnectDon e中返回的對端 PA 的代理，實現(xiàn)對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;
   // 為了實現(xiàn)遷移能力，需要引入傳遞遷移所需數(shù)據(jù)的包以及實現(xiàn)遷移能力的接口。
   import ohos.aafwk.ability.IAbilityContinuation;
   import ohos.aafwk.content.IntentParams;
   // 為了實現(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è)備場景下涉及設(shè)備選擇，為此需要引入組網(wǎng)設(shè)備發(fā)現(xiàn)的能力
   import ohos.distributedschedule.interwork.DeviceInfo;
   import ohos.distributedschedule.interwork.DeviceManager;
   // (可選）設(shè)計界面相關(guān)的包函數(shù)，對 FA 界面及按鈕進行繪制
   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;
   import ohos.agp.components.PositionLayout;

• （可選）編寫一個基本的 FA 用于使用分布式能力。

// 調(diào)用 AbilitySlice 模板實現(xiàn)一個用于控制基礎(chǔ)功能的 FA
   // Ability 和 AbilitySlice 類均需要實現(xiàn) IAbilityContinuation 及其方法，才可以實現(xiàn) FA 遷移。AbilitySlice 的代碼示例如下
   public class SampleSlice extends AbilitySlice implements IAbilityContinuation {
       @Override
       public void onStart(Intent intent) {
           super.onStart(intent);
           // 開發(fā)者可以自行進行界面設(shè)計
           // 為按鈕設(shè)置統(tǒng)一的背景色
           // 例如通過PositionLayout指定大小可以實現(xià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();
       }
   }
   }

說明

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

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

// 建議開發(fā)者按照自己的界面進行按鈕設(shè)計
   // 開發(fā)者可以自行實現(xiàn)如 createButton 的方法，新建一個顯示文字 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)程啟動FA的按鈕
       btnStartRemoteFA = createButton("StartRemoteFA", buttonBg, config);
       btnStartRemoteFA.setClickedListener(mStartRemoteFAListener);
       linear.addComponent(btnStartRemoteFA);
       // 構(gòu)建遠(yuǎn)程啟動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)度方法，實際開發(fā)中請開發(fā)者根據(jù)需要選擇能力調(diào)度方式。代碼示例中未體現(xiàn)按鈕如位置、樣式等具體的設(shè)置方法，詳請參考 JAVA UI框架。

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

// ISelectResult 是一個自定義接口，用來處理指定設(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());
       });
       // 以選擇首個設(shè)備作為目標(biāo)設(shè)備為例
       // 開發(fā)者也可按照具體場景，通過別的方式進行設(shè)備選擇
       String selectDeviceId = deviceIds.get(0);
       listener.onSelectResult(selectDeviceId);    
   }
   }

上述實例中涉及對在線組網(wǎng)設(shè)備的查詢，該項能力需要開發(fā)者在對應(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"
           }
       ]
   }
   }

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

// 啟動一個指定 bundleName 和 abilityName 的 FA
   private ClickedListener mStartRemoteFAListener = new ClickedListener() {
       @Override
       public void onClick(Component arg0) {
           // 啟動遠(yuǎn)程PA
           scheduleRemoteAbility(new ISelectResult() {
               @Override
               void onSelectResult(String deviceId) {
                   if (deviceId != null) {
                       Intent intent = new Intent();
                       // 通過scheduleRemoteAbility指定目標(biāo)設(shè)備deviceId
                       // 指定待啟動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接口實現(xiàn)跨設(shè)備啟動FA
                       startAbility(intent);
                   }
               }
           });
       }
   };
   };

• 為啟動和關(guān)閉 PA 定義回調(diào)，實現(xiàn)啟動和關(guān)閉 PA 的能力。

對于 PA 的啟動、關(guān)閉、連接等操作都需要開發(fā)者提供目標(biāo)設(shè)備的 deviceId。開發(fā)者可以通過 DeviceManager 相關(guān)接口得到當(dāng)前組網(wǎng)下的設(shè)備列表，并以彈窗的形式供用戶選擇，也可以按照實際需要實現(xiàn)其他個性化的處理方式。在點擊事件回調(diào)函數(shù)中，需要開發(fā)者指定得到 deviceId 后的處理邏輯，即實現(xiàn)類似上例中 listener.onSelectResult(String deviceId) 的方法，代碼示例如下：

// 啟動遠(yuǎn)程 PA
   private ClickedListener mStartRemotePAListener = new ClickedListener() {
       @Override
       public void onClick(Component arg0) {
           // 啟動遠(yuǎn)程PA
           scheduleRemoteAbility(new ISelectResult() {
               @Override
               void onSelectResult(String deviceId) {
                   if (deviceId != null) {
                       Intent intentToStartPA = new Intent();
                       // bundleName和abilityName與待啟動PA對應(yīng)
                       // 例如：bundleName = "com.huawei.helloworld"
                       //       abilityName = "com.huawei.helloworld.SampleParticleAbility"
                       Operation operation = new Intent.OperationBuilder()
                               .withDeviceId(deviceId)
                               .withBundleName(bundleName)
                               .withAbilityName(abilityName)
                               .withFlags(Intent.FLAG_ABILITYSLICE_MULTI_DEVICE)
                               .build();
                       intentToStartPA.setOperation(operation);
                       startAbility(intentToStartPA);
                   }
               }
           });
       }
   };
    
   // 關(guān)閉遠(yuǎn)程 PA，和啟動類似開發(fā)者需要指定待關(guān)閉 PA 對應(yīng)的 bundleName 和 abilityName
   private ClickedListener mStopRemotePAListener = new ClickedListener() {
       @Override
       public void onClick(Component arg0) {
           scheduleRemoteAbility(new ISelectResult() {
               @Override
               void onSelectResult(String deviceId) {
                   if (deviceId != null) {
                       Intent intentToStopPA = new Intent();
                       // bundleName和abilityName與待關(guān)閉PA對應(yīng)
                       // 例如：bundleName = "com.huawei.helloworld"
                       //       abilityName = "com.huawei.helloworld.SampleParticleAbility"
                       Operation operation = new Intent.OperationBuilder()
                               .withDeviceId(deviceId)
                               .withBundleName(bundleName)
                               .withAbilityName(abilityName)
                               .withFlags(Intent.FLAG_ABILITYSLICE_MULTI_DEVICE)
                               .build();
                       intentToStopPA.setOperation(operation);
                       stopAbility(intentToStopPA);
                   }
               }
           });
       }
   };
   };

說明

啟動和關(guān)閉的行為類似，開發(fā)者只需在 Intent 中指定待調(diào)度 PA 的 deviceId、bundleName 和 abilityName，并以 operation 的形式封裝到 Intent 內(nèi)。通過 AbilitySlice（Ability）包含的 startAbility()和 stopAbility()接口即可實現(xiàn)相應(yīng)功能。

• 設(shè)備 A 連接設(shè)備 B 側(cè)的 PA，利用連接關(guān)系調(diào)用該 PA 執(zhí)行特定任務(wù)，以及斷開連接。

// 當(dāng)連接完成時，用來提供管理已連接 PA 的能力
   private MyRemoteProxy mProxy = null;
   // 用于管理連接關(guān)系
   private IAbilityConnection conn = new IAbilityConnection() {
       @Override
       public void onAbilityConnectDone(ElementName element, IRemoteObject remote, int resultCode) {
           // 跨設(shè)備PA連接完成后，會返回一個序列化的IRemoteObject對象
           // 通過該對象得到控制遠(yuǎn)端服務(wù)的代理
           mProxy = new MyRemoteProxy(remote);
           btnConnectRemotePA.setText("connectRemoteAbility done");
        }
    
       @Override
       public void onAbilityDisconnectDone(ElementName element, int resultCode) {
           // 當(dāng)已連接的遠(yuǎn)端PA關(guān)閉時，會觸發(fā)該回調(diào)
           // 支持開發(fā)者按照返回的錯誤信息進行PA生命周期管理
           disconnectAbility(conn);
       }
   };
   };

僅通過啟動/關(guān)閉兩種方式對 PA 進行調(diào)度無法應(yīng)對需長期交互的場景，因此，分布式任務(wù)調(diào)度平臺向開發(fā)者提供了跨設(shè)備PA連接及斷開連接的能力。為了對已連接 PA 進行管理，開發(fā)者需要實現(xiàn)一個滿足 IAbilityConnection 接口的連接狀態(tài)檢測實例，通過該實例可以對連接及斷開連接完成時設(shè)置具體的處理邏輯，例如：獲取控制對端 PA 的代理等。進一步為了使用該代理跨設(shè)備調(diào)度 PA，開發(fā)者需要在本地及對端分別實現(xiàn)對外接口一致的代理。一個具備加法能力的代理示例如下：

// 以連接提供加法計算能力的 PA 為例。為了提供跨設(shè)備連接能力，需要在本地發(fā)起連接側(cè)和對端被連接側(cè)分別實現(xiàn)代理。
   // 發(fā)起連接側(cè)的代理示例如下
   public class MyRemoteProxy implements IRemoteBroker{
       private static final int ERR_OK = 0;
       private static final int COMMAND_PLUS = IRemoteObject.MIN_TRANSACTION_ID;
       private final IRemoteObject remote;
    
       public MyRemoteProxy(
           /* [in] */ IRemoteObject remote) {
           this.remote = remote;
       }
    
       @Override
       public IRemoteObject asObject() {
           return remote;
       }
    
       public int plus(
           /* [in] */ int a,
           /* [in] */ int b) throws RemoteException {
           MessageParcel data = MessageParcel.obtain();
           MessageParcel reply = MessageParcel.obtain();
           // option不同的取值，決定采用同步或異步方式跨設(shè)備控制PA
           // 本例需要同步獲取對端PA執(zhí)行加法的結(jié)果，因此采用同步的方式，即MessageOption.TF_SYNC
           // 具體MessageOption的設(shè)置，可參考相關(guān)API文檔
           MessageOption option = new MessageOption(MessageOption.TF_SYNC);
           data.writeInt(a);
           data.writeInt(b);
    
           try {
               remote.sendRequest(COMMAND_PLUS, data, reply, option);
               int ec = reply.readInt();
               if (ec != ERR_OK) {
                   throw new RemoteException();
               }
               int result = reply.readInt();
               return result;
           } catch (RemoteException e) {
               throw new RemoteException();
           } finally {
               data.reclaim();
               reply.reclaim();
           }
       }
   }
   }

此外，對端待連接的 PA 需要實現(xiàn)對應(yīng)的客戶端，代碼示例如下所示：

// 以計算加法為例，對端實現(xiàn)的客戶端如下
   public class MyRemote extends RemoteObject implements IRemoteBroker{
       private static final int ERR_OK = 0;
       private static final int ERROR = -1;
       private static final int COMMAND_PLUS = IRemoteObject.MIN_TRANSACTION_ID;
    
       public MyRemote() {
           super("MyService_Remote");
       }
    
       @Override
       public IRemoteObject asObject() {
           return this;
       }
    
       @Override
       public boolean onRemoteRequest(int code, MessageParcel data, MessageParcel reply, MessageOption option) {
           if (code != COMMAND_PLUS) {
               reply.writeInt(ERROR);
               return false;
           }
           int value1 = data.readInt();
           int value2 = data.readInt();
           int sum = value1 + value2;
           reply.writeInt(ERR_OK);
           reply.writeInt(sum);
           return true;
       }
   }
   }

對端除了要實現(xiàn)如上所述的客戶端外，待連接的 PA 還需要作如下修改：

// 為了返回給連接方可調(diào)用的代理，需要在該 PA 中實例化客戶端，例如作為該 PA 的成員變量
   private MyProxy remote = new MyProxy();
   // 當(dāng)該 PA 接收到連接請求時，即將該客戶端轉(zhuǎn)化為代理返回給連接發(fā)起側(cè)
   @Override
   protected IRemoteObject onConnect(Intent intent) {
       super.onConnect(intent);
       return remote.asObject();
   }
   }

完成上述步驟后，可以通過點擊事件實現(xiàn)連接、利用連接關(guān)系控制 PA 以及斷開連接等行為，代碼示例如下：

// 連接遠(yuǎn)程PA
   private ClickedListener mConnectRemotePAListener = new ClickedListener() {
       @Override
       public void onClick(Component arg0) {
           scheduleRemoteAbility(new ISelectResult() {
               @Override
               void onSelectResult(String deviceId) {
                   if (deviceId != null) {
                       Intent connectPAIntent = new Intent();
                       // bundleName和abilityName與待連接的PA一一對應(yīng)
                       // 例如：bundleName = "com.huawei.helloworld"
                       //       abilityName = "com.huawei.helloworld.SampleParticleAbility"
                       Operation operation = new Intent.OperationBuilder()
                               .withDeviceId(deviceId)
                               .withBundleName(bundleName)
                               .withAbilityName(abilityName)
                               .withFlags(Intent.FLAG_ABILITYSLICE_MULTI_DEVICE)
                               .build();
                       connectPAIntent.setOperation(operation);
                       connectAbility(connectPAIntent, conn);
                   }
               }
           });
       }
   };
   // 控制已連接PA執(zhí)行加法
   private ClickedListener mControlPAListener = new ClickedListener() {
       @Override
       public void onClick(Component arg0) {
           if (mProxy != null) {
               int ret = -1;
               try {
                   ret = mProxy.plus(10, 20);
               } catch (RemoteException e) {
                   e.printStackTrace();
               }
               btnControlRemotePA.setText("ControlRemotePA result = " + ret);
           }
       }
   };
   // 與遠(yuǎn)程PA斷開連接
   private ClickedListener mDisconnectRemotePAListener = new ClickedListener() {
       @Override
       public void onClick(Component arg0) {
           // 按鈕復(fù)位
           btnConnectRemotePA.setText("ConnectRemotePA");
           btnControlRemotePA.setText("ControlRemotePA");
           disconnectAbility(conn);
       }
   };
   };

說明

通過連接/斷開連接遠(yuǎn)程 PA，與跨設(shè)備 PA 建立長期的管理關(guān)系。例如在本例中，通過連接關(guān)系得到遠(yuǎn)程 PA 的控制代理后，實現(xiàn)跨設(shè)備計算加法并將結(jié)果返回到本地顯示。在實際開發(fā)中，開發(fā)者可以根據(jù)需要實現(xiàn)多種分布式場景，例如：跨設(shè)備位置/電量等信息的采集、跨設(shè)備計算資源互助等。

• 設(shè)備 A 將運行時的 FA 遷移到設(shè)備 B，實現(xiàn)業(yè)務(wù)在設(shè)備間無縫遷移。

// 跨設(shè)備遷移FA
   // 本地FA設(shè)置當(dāng)前運行任務(wù)
   private ClickedListener mContinueAbilityListener = new ClickedListener() {
       @Override
       public void onClick(Component arg0) {
           // 用戶選擇設(shè)備后實現(xiàn)業(yè)務(wù)遷移
           scheduleRemoteAbility(new ISelectResult() {
               @Override
               public void onSelectResult(String deviceId) {
                   continueAbility(deviceId);
               }
           });
       }
   };
   };

此外，不同于啟動行為，F(xiàn)A 的遷移還涉及到狀態(tài)數(shù)據(jù)的傳遞。為此，繼承的 IAbilityContinuation 接口為開發(fā)者提供遷移過程中特定事件的管理能力。通過自定義遷移事件相關(guān)的行為，最終實現(xiàn)對 Ability 的遷移。具體的定義可以參考相關(guān)的 API 文檔，此處主要以較為常用的兩個事件，包括遷移發(fā)起端完成遷移的回調(diào) onCompleteContinuation(int result)以及接收到遠(yuǎn)端遷移行為傳遞數(shù)據(jù)的回調(diào) onRestoreData(IntentParams restoreData)。其他還包括遷移到遠(yuǎn)端設(shè)備的 FA 關(guān)閉的回調(diào) onRemoteTerminated()、用于本地遷移發(fā)起時保存狀態(tài)數(shù)據(jù)的回調(diào) onSaveData(IntentParams saveData)和本地發(fā)起遷移的回調(diào) onStartContinuation()。按照實際應(yīng)用自定義特定場景對應(yīng)的回調(diào)，可以完成多種場景下 FA 的遷移任務(wù)。

@Override
   public boolean onSaveData(IntentParams saveData) {
       String exampleData = String.valueOf(System.currentTimeMillis());
       saveData.setParam("continueParam", exampleData);
       return true;
   }
    
   @Override
   public boolean onRestoreData(IntentParams restoreData) {
       // 遠(yuǎn)端FA遷移傳來的狀態(tài)數(shù)據(jù)，開發(fā)者可以按照特定的場景對這些數(shù)據(jù)進行處理
       Object data = restoreData.getParam("continueParam");
       return true;
   }
    
   @Override
   public void onCompleteContinuation(int result) {
       btnContinueRemoteFA.setText("ContinueAbility Done");
   }
   }

說明

1.FA 遷移可以打通設(shè)備間的壁壘，有助于不同能力的設(shè)備進行互助。前文以一個簡單的例子介紹如何通過分布式任務(wù)調(diào)度提供的能力，實現(xiàn) FA 跨設(shè)備的遷移（包括 FA 啟動及狀態(tài)數(shù)據(jù)的同步）。 2.FA 遷移過程中，遠(yuǎn)端 FA 首先接收到發(fā)起端 FA 傳輸?shù)臄?shù)據(jù)，再執(zhí)行啟動，即 onRestoreData() 發(fā)生在 onStart() 之前。

審核編輯 黃宇