devbox
繁依Fanyi0
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

华为Harmony鸿蒙开发笔记六：Ability跨设备分布式任务调度_connectpaintent.setoperation(operation);connectabi

作者：繁依Fanyi0 | 2024-03-14 19:32:53

赞

踩

connectpaintent.setoperation(operation);connectability(connectpaintent,conn)

目前来看，鸿蒙应用的跨设备分布式调度并不复杂，跟在本应用内调用没有太大却区别，只是多了权限管理和设备管理的相关参数和配置。

这里我将官方文档的代码整理一下，等待以后验证。

首先配置权限，根据已经验证了的DataAbility可知，权限是配置在请求方的Ability的配置文件里的

  1.       {
  2.         "skills": [
  3.           {
  4.             "entities": [
  5.               "entity.system.home"
  6.             ],
  7.             "actions": [
  8.               "action.system.home"
  9.             ]
  10.           }
  11.         ],
  12.         "orientation": "unspecified",
  13.         "name": "com.example.distributeddemo.MainAbility",
  14.         "icon": "$media:icon",
  15.         "description": "$string:mainability_description",
  16.         "label": "DistributedDemo",
  17.         "type": "page",
  18.         "launchType": "standard",
  19.         "reqPermissions": [
  20.           {
  21.             "name": "ohos.permission.DISTRIBUTED_DATASYNC"
  22.           }
  23.         ]
  24.       }

上面reqPermissions就是配置权限，使该Ability支持任务调度，然后就是改造AbilitySlice

首先要实现IAbilityContinuation接口，并实现接口方法，并在onStart里显式申明权限

  1. public class SampleSlice extends AbilitySlice implements IAbilityContinuation {
  2.     @Override
  3.     public void onStart(Intent intent) {
  4.         // 开发者显示声明需要使用的权限
  5.         requestPermissionsFromUser(new String[]{"ohos.permission.DISTRIBUTED_DATASYNC"}, 0);
  6.         super.onStart(intent);        
  7.     }
  8. }

然后编写UI，添加几个按钮：

  1. <?xml version="1.0" encoding="utf-8"?>
  2. <DirectionalLayout
  3.     xmlns:ohos="http://schemas.huawei.com/res/ohos"
  4.     ohos:height="match_parent"
  5.     ohos:width="match_parent"
  6.     ohos:orientation="vertical">
  7.     <Button
  8.         ohos:id="$+id:btn_start_remote_fa"
  9.         ohos:width="match_content"
  10.         ohos:height="match_content"
  11.         ohos:text="远程启动FA"
  12.         ohos:text_size="19fp"
  13.         ohos:text_color="#FFFFFF"
  14.         ohos:top_padding="8vp"
  15.         ohos:layout_alignment="center"
  16.         ohos:bottom_padding="8vp"
  17.         ohos:right_padding="70vp"
  18.         ohos:left_padding="70vp"
  19.         ohos:top_margin="10vp"
  20.         ohos:background_element="$graphic:background_button"
  21.         ohos:center_in_parent="true"
  22.         ohos:bottom_margin="10vp"/>
  23.     <Button
  24.         ohos:id="$+id:btn_continue_remote_fa"
  25.         ohos:width="match_content"
  26.         ohos:height="match_content"
  27.         ohos:text="远程迁移FA"
  28.         ohos:text_size="19fp"
  29.         ohos:text_color="#FFFFFF"
  30.         ohos:top_padding="8vp"
  31.         ohos:layout_alignment="center"
  32.         ohos:bottom_padding="8vp"
  33.         ohos:right_padding="70vp"
  34.         ohos:left_padding="70vp"
  35.         ohos:top_margin="10vp"
  36.         ohos:background_element="$graphic:background_button"
  37.         ohos:center_in_parent="true"
  38.         ohos:bottom_margin="10vp"/>
  39.     <Button
  40.         ohos:id="$+id:btn_start_remote_pa"
  41.         ohos:width="match_content"
  42.         ohos:height="match_content"
  43.         ohos:text="远程启动PA"
  44.         ohos:text_size="19fp"
  45.         ohos:text_color="#FFFFFF"
  46.         ohos:top_padding="8vp"
  47.         ohos:layout_alignment="center"
  48.         ohos:bottom_padding="8vp"
  49.         ohos:right_padding="70vp"
  50.         ohos:left_padding="70vp"
  51.         ohos:top_margin="10vp"
  52.         ohos:background_element="$graphic:background_button"
  53.         ohos:center_in_parent="true"
  54.         ohos:bottom_margin="10vp"/>
  55.     <Button
  56.         ohos:id="$+id:btn_stop_remote_pa"
  57.         ohos:width="match_content"
  58.         ohos:height="match_content"
  59.         ohos:text="远程关闭PA"
  60.         ohos:text_size="19fp"
  61.         ohos:text_color="#FFFFFF"
  62.         ohos:top_padding="8vp"
  63.         ohos:layout_alignment="center"
  64.         ohos:bottom_padding="8vp"
  65.         ohos:right_padding="70vp"
  66.         ohos:left_padding="70vp"
  67.         ohos:top_margin="10vp"
  68.         ohos:background_element="$graphic:background_button"
  69.         ohos:center_in_parent="true"
  70.         ohos:bottom_margin="10vp"/>
  71.     <Button
  72.         ohos:id="$+id:btn_connect_remote_pa"
  73.         ohos:width="match_content"
  74.         ohos:height="match_content"
  75.         ohos:text="连接远程PA"
  76.         ohos:text_size="19fp"
  77.         ohos:text_color="#FFFFFF"
  78.         ohos:top_padding="8vp"
  79.         ohos:layout_alignment="center"
  80.         ohos:bottom_padding="8vp"
  81.         ohos:right_padding="70vp"
  82.         ohos:left_padding="70vp"
  83.         ohos:top_margin="10vp"
  84.         ohos:background_element="$graphic:background_button"
  85.         ohos:center_in_parent="true"
  86.         ohos:bottom_margin="10vp"/>
  87.     <Button
  88.         ohos:id="$+id:btn_control_remote_pa"
  89.         ohos:width="match_content"
  90.         ohos:height="match_content"
  91.         ohos:text="控制连接PA"
  92.         ohos:text_size="19fp"
  93.         ohos:text_color="#FFFFFF"
  94.         ohos:top_padding="8vp"
  95.         ohos:layout_alignment="center"
  96.         ohos:bottom_padding="8vp"
  97.         ohos:right_padding="70vp"
  98.         ohos:left_padding="70vp"
  99.         ohos:top_margin="10vp"
  100.         ohos:background_element="$graphic:background_button"
  101.         ohos:center_in_parent="true"
  102.         ohos:bottom_margin="10vp"/>
  103.     <Button
  104.         ohos:id="$+id:btn_disconnect_remote_pa"
  105.         ohos:width="match_content"
  106.         ohos:height="match_content"
  107.         ohos:text="断开远程PA"
  108.         ohos:text_size="19fp"
  109.         ohos:text_color="#FFFFFF"
  110.         ohos:top_padding="8vp"
  111.         ohos:layout_alignment="center"
  112.         ohos:bottom_padding="8vp"
  113.         ohos:right_padding="70vp"
  114.         ohos:left_padding="70vp"
  115.         ohos:top_margin="10vp"
  116.         ohos:background_element="$graphic:background_button"
  117.         ohos:center_in_parent="true"
  118.         ohos:bottom_margin="10vp"/>
  119.  
  120. </DirectionalLayout>

初始化按钮，并添加点击事件：

  1.     private MyRemoteProxy mProxy = null;
  2.     private Button btnConnectRemotePA;
  3.     private Button btnControlRemotePA;
  4.     private Button btnContinueRemoteFA;
  5.  
  6.     @Override
  7.     public void onStart(Intent intent) {
  8.         super.onStart(intent);
  9.         super.setUIContent(ResourceTable.Layout_ability_main);
  10.         requestPermissionsFromUser(new String[]{"ohos.permission.DISTRIBUTED_DATASYNC"}, 0);
  11.         InsideListener listener = new InsideListener();
  12.         findComponentById(ResourceTable.Id_btn_start_remote_fa).setClickedListener(listener);
  13.         findComponentById(ResourceTable.Id_btn_start_remote_pa).setClickedListener(listener);
  14.         findComponentById(ResourceTable.Id_btn_stop_remote_pa).setClickedListener(listener);
  15.         btnContinueRemoteFA = (Button) findComponentById(ResourceTable.Id_btn_continue_remote_fa);
  16.         btnContinueRemoteFA.setClickedListener(listener);
  17.         btnConnectRemotePA = (Button) findComponentById(ResourceTable.Id_btn_connect_remote_pa);
  18.         btnConnectRemotePA.setClickedListener(listener);
  19.         btnControlRemotePA = (Button) findComponentById(ResourceTable.Id_btn_control_remote_pa);
  20.         btnControlRemotePA.setClickedListener(listener);
  21.         findComponentById(ResourceTable.Id_btn_disconnect_remote_pa).setClickedListener(listener);
  22.     }
  23.  
  24. class InsideListener implements Component.ClickedListener {
  25.  
  26.         @Override
  27.         public void onClick(Component component) {
  28.             switch (component.getId()) {
  29.                 case ResourceTable.Id_btn_start_remote_fa:
  30.                     HiLog.info(LABEL_LOG, "MainAbilitySlice btn_start_remote_fa");
  31.                     
  32.                     break;
  33.                 case ResourceTable.Id_btn_continue_remote_fa:
  34.                     HiLog.info(LABEL_LOG, "MainAbilitySlice btn_continue_remote_fa");
  35.                     
  36.                     break;
  37.                 case ResourceTable.Id_btn_start_remote_pa:
  38.                     HiLog.info(LABEL_LOG, "MainAbilitySlice btn_start_remote_pa");
  39.                     
  40.                     break;
  41.                 case ResourceTable.Id_btn_stop_remote_pa:
  42.                     HiLog.info(LABEL_LOG, "MainAbilitySlice btn_stop_remote_pa");
  43.                     break;
  44.                 case ResourceTable.Id_btn_connect_remote_pa:
  45.                     HiLog.info(LABEL_LOG, "MainAbilitySlice btn_connect_remote_pa");
  46.                     
  47.                     break;
  48.                 case ResourceTable.Id_btn_control_remote_pa:
  49.                     HiLog.info(LABEL_LOG, "MainAbilitySlice btn_control_remote_pa");
  50.                     break;
  51.                 case ResourceTable.Id_btn_disconnect_remote_pa:
  52.                     HiLog.info(LABEL_LOG, "MainAbilitySlice btn_disconnect_remote_pa");
  53.                     
  54.                     break;
  55.                 default:
  56.                     break;
  57.             }
  58.         }
  59.     }

通过设备管理DeviceManager提供的getDeviceList接口获取设备列表，并选择一个设备：

  1.  // ISelectResult是一个自定义接口，用来处理指定设备deviceId后执行的行为
  2.     interface ISelectResult {
  3.         void onSelectResult(String deviceId);
  4.     }
  5.  
  6.     // 获得设备列表，开发者可在得到的在线设备列表中选择目标设备执行操作
  7.     private void scheduleRemoteAbility(ISelectResult listener) {
  8.         // 调用DeviceManager的getDeviceList接口，通过FLAG_GET_ONLINE_DEVICE标记获得在线设备列表
  9.         List<DeviceInfo> onlineDevices = DeviceManager.getDeviceList(DeviceInfo.FLAG_GET_ONLINE_DEVICE);
  10.         // 判断组网设备是否为空
  11.         if (onlineDevices.isEmpty()) {
  12.             listener.onSelectResult(null);
  13.             return;
  14.         }
  15.         int numDevices = onlineDevices.size();
  16.         ArrayList<String> deviceIds = new ArrayList<>(numDevices);
  17.         ArrayList<String> deviceNames = new ArrayList<>(numDevices);
  18.         onlineDevices.forEach((device) -> {
  19.             deviceIds.add(device.getDeviceId());
  20.             deviceNames.add(device.getDeviceName());
  21.         });
  22.         // 以选择首个设备作为目标设备为例
  23.         // 开发者也可按照具体场景，通过别的方式进行设备选择
  24.         String selectDeviceId = deviceIds.get(0);
  25.         listener.onSelectResult(selectDeviceId);
  26.     }

各个按钮对应的点击事件：

  1. class InsideListener implements Component.ClickedListener {
  2.  
  3.         @Override
  4.         public void onClick(Component component) {
  5.             switch (component.getId()) {
  6.                 case ResourceTable.Id_btn_start_remote_fa:
  7.                     HiLog.info(LABEL_LOG, "MainAbilitySlice btn_start_remote_fa");
  8.                     // 启动远程PA
  9.                     scheduleRemoteAbility(new ISelectResult() {
  10.                         @Override
  11.                         public void onSelectResult(String deviceId) {
  12.                             if (deviceId != null) {
  13.                                 Intent intent = new Intent();
  14.                                 // 通过scheduleRemoteAbility指定目标设备deviceId
  15.                                 // 指定待启动FA的bundleName和abilityName
  16.                                 // 例如：bundleName = "com.huawei.helloworld"
  17.                                 //       abilityName = "com.huawei.helloworld.SampleFeatureAbility"
  18.                                 // 设置分布式标记，表明当前涉及分布式能力
  19.                                 Operation operation = new Intent.OperationBuilder()
  20.                                         .withDeviceId(deviceId)
  21.                                         .withBundleName("目标bundleName")
  22.                                         .withAbilityName("目标abilityName")
  23.                                         .withFlags(Intent.FLAG_ABILITYSLICE_MULTI_DEVICE)
  24.                                         .build();
  25.                                 intent.setOperation(operation);
  26.                                 // 通过AbilitySlice包含的startAbility接口实现跨设备启动FA
  27.                                 startAbility(intent);
  28.                             }
  29.                         }
  30.                     });
  31.                     break;
  32.                 case ResourceTable.Id_btn_continue_remote_fa:
  33.                     HiLog.info(LABEL_LOG, "MainAbilitySlice btn_continue_remote_fa");
  34.                     // 用户选择设备后实现业务迁移
  35.                     scheduleRemoteAbility(new ISelectResult() {
  36.                         @Override
  37.                         public void onSelectResult(String deviceId) {
  38.                             continueAbility(deviceId);
  39.                         }
  40.                     });
  41.                     break;
  42.                 case ResourceTable.Id_btn_start_remote_pa:
  43.                     HiLog.info(LABEL_LOG, "MainAbilitySlice btn_start_remote_pa");
  44.                     // 启动远程PA
  45.                     scheduleRemoteAbility(new ISelectResult() {
  46.                         @Override
  47.                         public void onSelectResult(String deviceId) {
  48.                             if (deviceId != null) {
  49.                                 Intent intentToStartPA = new Intent();
  50.                                 // bundleName和abilityName与待启动PA对应
  51.                                 // 例如：bundleName = "com.huawei.helloworld"
  52.                                 //       abilityName = "com.huawei.helloworld.SampleParticleAbility"
  53.                                 Operation operation = new Intent.OperationBuilder()
  54.                                         .withDeviceId(deviceId)
  55.                                         .withBundleName("目标bundleName")
  56.                                         .withAbilityName("目标abilityName")
  57.                                         .withFlags(Intent.FLAG_ABILITYSLICE_MULTI_DEVICE)
  58.                                         .build();
  59.                                 intentToStartPA.setOperation(operation);
  60.                                 startAbility(intentToStartPA);
  61.                             }
  62.                         }
  63.                     });
  64.                     break;
  65.                 case ResourceTable.Id_btn_stop_remote_pa:
  66.                     HiLog.info(LABEL_LOG, "MainAbilitySlice btn_stop_remote_pa");
  67.                     scheduleRemoteAbility(new ISelectResult() {
  68.                         @Override
  69.                         public void onSelectResult(String deviceId) {
  70.                             if (deviceId != null) {
  71.                                 Intent intentToStopPA = new Intent();
  72.                                 // bundleName和abilityName与待关闭PA对应
  73.                                 // 例如：bundleName = "com.huawei.helloworld"
  74.                                 //       abilityName = "com.huawei.helloworld.SampleParticleAbility"
  75.                                 Operation operation = new Intent.OperationBuilder()
  76.                                         .withDeviceId(deviceId)
  77.                                         .withBundleName("目标bundleName")
  78.                                         .withAbilityName("目标abilityName")
  79.                                         .withFlags(Intent.FLAG_ABILITYSLICE_MULTI_DEVICE)
  80.                                         .build();
  81.                                 intentToStopPA.setOperation(operation);
  82.                                 stopAbility(intentToStopPA);
  83.                             }
  84.                         }
  85.                     });
  86.                     break;
  87.                 case ResourceTable.Id_btn_connect_remote_pa:
  88.                     HiLog.info(LABEL_LOG, "MainAbilitySlice btn_connect_remote_pa");
  89.                     scheduleRemoteAbility(new ISelectResult() {
  90.                         @Override
  91.                         public void onSelectResult(String deviceId) {
  92.                             if (deviceId != null) {
  93.                                 Intent connectPAIntent = new Intent();
  94.                                 // bundleName和abilityName与待连接的PA一一对应
  95.                                 // 例如：bundleName = "com.huawei.helloworld"
  96.                                 //       abilityName = "com.huawei.helloworld.SampleParticleAbility"
  97.                                 Operation operation = new Intent.OperationBuilder()
  98.                                         .withDeviceId(deviceId)
  99.                                         .withBundleName("目标bundleName")
  100.                                         .withAbilityName("目标abilityName")
  101.                                         .withFlags(Intent.FLAG_ABILITYSLICE_MULTI_DEVICE)
  102.                                         .build();
  103.                                 connectPAIntent.setOperation(operation);
  104.                                 connectAbility(connectPAIntent, conn);
  105.                             }
  106.                         }
  107.                     });
  108.                     break;
  109.                 case ResourceTable.Id_btn_control_remote_pa:
  110.                     HiLog.info(LABEL_LOG, "MainAbilitySlice btn_control_remote_pa");
  111.                     if (mProxy != null) {
  112.                         int ret = -1;
  113.                         try {
  114.                             ret = mProxy.plus(10, 20);
  115.                         } catch (RemoteException e) {
  116.                             e.printStackTrace();
  117.                         }
  118.                         btnControlRemotePA.setText("控制连接 result = " + ret);
  119.                     }
  120.                     break;
  121.                 case ResourceTable.Id_btn_disconnect_remote_pa:
  122.                     HiLog.info(LABEL_LOG, "MainAbilitySlice btn_disconnect_remote_pa");
  123.                     btnConnectRemotePA.setText("连接远程PA");
  124.                     btnControlRemotePA.setText("控制连接PA");
  125.                     disconnectAbility(conn);
  126.                     break;
  127.                 default:
  128.                     break;
  129.             }
  130.         }
  131.     }

最后，FA跨设备迁移的生命周期方法：

流程参见;https://blog.csdn.net/y280903468/article/details/111770977

  1. @Override
  2.     public boolean onSaveData(IntentParams saveData) {
  3.         String exampleData = String.valueOf(System.currentTimeMillis());
  4.         saveData.setParam("continueParam", exampleData);
  5.         return true;
  6.     }
  7.  
  8.     @Override
  9.     public boolean onRestoreData(IntentParams restoreData) {
  10.         // 远端FA迁移传来的状态数据，开发者可以按照特定的场景对这些数据进行处理
  11.         Object data = restoreData.getParam("continueParam");
  12.         return true;
  13.     }
  14.  
  15.     @Override
  16.     public void onCompleteContinuation(int result) {
  17.         btnContinueRemoteFA.setText("ContinueAbility Done");
  18.     }

 

https://download.csdn.net/download/y280903468/14004469

声明：本文内容由网友自发贡献，转载请注明出处：【wpsshop博客】
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号