harmony 鸿蒙@ohos.distributedMissionManager (分布式任务管理)

  • 2022-08-09
  • 浏览 (861)

@ohos.distributedMissionManager (分布式任务管理)

分布式任务管理模块提供跨设备任务管理能力，包括注册和取消任务状态监听、开始和停止同步远端设备任务列表、通过任务ID和包名进行迁移任务等。

说明：

本模块首批接口从API version 9开始支持。后续版本的新增接口，采用上角标单独标记接口的起始版本。

本模块接口为系统接口。

导入模块

import distributedMissionManager from '@ohos.distributedMissionManager';

distributedMissionManager.registerMissionListener

registerMissionListener(parameter: MissionDeviceInfo, options: MissionCallback, callback: AsyncCallback<void>): void;

注册任务状态监听。使用callback异步回调。

需要权限：ohos.permission.MANAGE_MISSIONS

系统能力：SystemCapability.Ability.AbilityRuntime.Mission

参数：

参数名 类型 必填 说明
parameter MissionDeviceInfo 是 注册监听时的设备信息。
options MissionCallback 是 注册的回调方法。
callback AsyncCallback<void> 是 回调函数，注册监听成功，err为undefined，否则为错误对象。

示例：

  import distributedMissionManager from '@ohos.distributedMissionManager'
  import { BusinessError } from '@ohos.base';
  
  // 实现回调函数
  function NotifyMissionsChanged(deviceId: string): void {
    console.log('NotifyMissionsChanged deviceId ' + JSON.stringify(deviceId));
  }
  function NotifySnapshot(deviceId: string, missionId: number): void {
    console.log('NotifySnapshot deviceId ' + JSON.stringify(deviceId));
    console.log('NotifySnapshot missionId ' + JSON.stringify(missionId));
  }
  function NotifyNetDisconnect(deviceId: string, state: number): void {
    console.log('NotifyNetDisconnect deviceId ' + JSON.stringify(deviceId));
    console.log('NotifyNetDisconnect state ' + JSON.stringify(state));
  }
  try {
    // 调用registerMissionListener接口
    distributedMissionManager.registerMissionListener(
      { deviceId: "" },
      {
        notifyMissionsChanged: NotifyMissionsChanged,
        notifySnapshot: NotifySnapshot,
        notifyNetDisconnect: NotifyNetDisconnect
      },
      (error: BusinessError) => {
        if (error.code != 0) {
          console.error('registerMissionListener failed, cause: ' + JSON.stringify(error))
        }
        console.info('registerMissionListener finished')
      });
  } catch (error) {
    console.error('registerMissionListener failed, cause: ' + JSON.stringify(error))
  }

distributedMissionManager.registerMissionListener

registerMissionListener(parameter: MissionDeviceInfo, options: MissionCallback): Promise<void>

注册任务状态监听。使用promise异步回调。

需要权限：ohos.permission.MANAGE_MISSIONS

系统能力：SystemCapability.Ability.AbilityRuntime.Mission

参数：

参数名 类型 必填 说明
parameter MissionDeviceInfo 是 注册监听时的设备信息。
options MissionCallback 是 注册的回调方法。

返回值：

类型 说明
Promise<void> 无返回结果的Promise对象。

示例：

  import distributedMissionManager from '@ohos.distributedMissionManager'
  import { BusinessError } from '@ohos.base';

  // 实现回调函数
  function NotifyMissionsChanged(deviceId: string): void {
    console.log('NotifyMissionsChanged deviceId ' + JSON.stringify(deviceId));
  }
  function NotifySnapshot(deviceId: string, missionId: number): void {
    console.log('NotifySnapshot deviceId ' + JSON.stringify(deviceId));
    console.log('NotifySnapshot missionId ' + JSON.stringify(missionId));
  }
  function NotifyNetDisconnect(deviceId: string, state: number): void {
    console.log('NotifyNetDisconnect deviceId ' + JSON.stringify(deviceId));
    console.log('NotifyNetDisconnect state ' + JSON.stringify(state));
  }
  try {
      // 调用registerMissionListener接口
      distributedMissionManager.registerMissionListener(
        { deviceId: "" },
        {
          notifyMissionsChanged: NotifyMissionsChanged,
          notifySnapshot: NotifySnapshot,
          notifyNetDisconnect: NotifyNetDisconnect
        }).then((data: void) => {
          console.info('registerMissionListener finished, ' + JSON.stringify(data));
      }).catch((error: BusinessError) => {
          console.error('registerMissionListener failed, cause: ' + JSON.stringify(error));
      })
  } catch (error) {
      console.error('registerMissionListener failed, cause: ' + JSON.stringify(error))
  }

distributedMissionManager.unRegisterMissionListener

unRegisterMissionListener(parameter: MissionDeviceInfo, callback: AsyncCallback<void>): void;

取消任务状态监听。使用callback异步回调。

需要权限：ohos.permission.MANAGE_MISSIONS

系统能力：SystemCapability.Ability.AbilityRuntime.Mission

参数：

参数名 类型 必填 说明
parameter MissionDeviceInfo 是 注册监听时的设备信息。
callback AsyncCallback<void> 是 回调函数，取消监听成功，err为undefined，否则为错误对象。

示例：

  import distributedMissionManager from '@ohos.distributedMissionManager'
  import { BusinessError } from '@ohos.base';

  try {
    distributedMissionManager.unRegisterMissionListener(
      { deviceId: "" },
      (error: BusinessError) => {
        if (error.code != 0) {
            console.error('unRegisterMissionListener failed, cause: ' + JSON.stringify(error))
        }
        console.info('unRegisterMissionListener finished')
    })
  } catch (error) {
      console.error('unRegisterMissionListener failed, cause: ' + JSON.stringify(error))
  }

distributedMissionManager.unRegisterMissionListener

unRegisterMissionListener(parameter: MissionDeviceInfo): Promise<void>

取消任务状态监听。使用promise异步回调。

需要权限：ohos.permission.MANAGE_MISSIONS

系统能力：SystemCapability.Ability.AbilityRuntime.Mission

参数：

参数名 类型 必填 说明
parameter MissionDeviceInfo 是 注册监听时的设备信息。

返回值：

类型 说明
Promise<void> 无返回结果的Promise对象。

示例：

  import distributedMissionManager from '@ohos.distributedMissionManager'
  import { BusinessError } from '@ohos.base';

  try {
    distributedMissionManager.unRegisterMissionListener({deviceId: ""}).then(() => {
      console.info('unRegisterMissionListener finished successfully');
    }).catch((error: BusinessError) => {
        console.error('unRegisterMissionListener failed, cause: ' + JSON.stringify(error));
    })
  } catch (error) {
      console.error('unRegisterMissionListener failed, cause: ' + JSON.stringify(error))
  }

distributedMissionManager.startSyncRemoteMissions

startSyncRemoteMissions(parameter: MissionParameter, callback: AsyncCallback<void>): void;

开始同步远端设备的任务列表。使用callback异步回调。

需要权限：ohos.permission.MANAGE_MISSIONS

系统能力：SystemCapability.Ability.AbilityRuntime.Mission

参数：

参数名 类型 必填 说明
parameter MissionParameter 是 同步信息。
callback AsyncCallback<void> 是 回调函数，同步远端任务列表成功时，err为undefined，否则返回错误对象。

示例：

  import distributedMissionManager from '@ohos.distributedMissionManager'
  import { BusinessError } from '@ohos.base';

  try {
    distributedMissionManager.startSyncRemoteMissions(
      {
        deviceId: "",
        fixConflict: false,
        tag: 0
      },
      (error: BusinessError) => {
        if (error.code != 0) {
          console.error('startSyncRemoteMissions failed, cause: ' + JSON.stringify(error))
        }
        console.info('startSyncRemoteMissions finished')}
    )
  } catch (error) {
    console.error('startSyncRemoteMissions failed, cause: ' + JSON.stringify(error))
  }

distributedMissionManager.startSyncRemoteMissions

startSyncRemoteMissions(parameter: MissionParameter): Promise<void>

开始同步远端设备的任务列表。使用promise异步回调。

需要权限：ohos.permission.MANAGE_MISSIONS

系统能力：SystemCapability.Ability.AbilityRuntime.Mission

参数：

参数名 类型 必填 说明
parameter MissionParameter 是 同步信息。

返回值：

类型 说明
Promise<void> 无返回结果的Promise对象。

示例：

  import distributedMissionManager from '@ohos.distributedMissionManager'
  import { BusinessError } from '@ohos.base';

  try {
    distributedMissionManager.startSyncRemoteMissions(
      {
        deviceId: "",
        fixConflict: false,
        tag: 0
      }
    ).then(() => {
        console.info('startSyncRemoteMissions finished successfully');
      }).catch((error: BusinessError) => {
      console.error('startSyncRemoteMissions failed, cause: ' + JSON.stringify(error));
    })
  } catch (error) {
    console.error('startSyncRemoteMissions failed, cause: ' + JSON.stringify(error))
  }

distributedMissionManager.stopSyncRemoteMissions

stopSyncRemoteMissions(parameter: MissionDeviceInfo, callback: AsyncCallback<void>): void;

停止同步远端设备的任务列表。使用callback异步回调。

需要权限：ohos.permission.MANAGE_MISSIONS

系统能力：SystemCapability.Ability.AbilityRuntime.Mission

参数：

参数名 类型 必填 说明
parameter MissionDeviceInfo 是 同步信息。
callback AsyncCallback<void> 是 回调函数，停止同步远端任务列表成功时，err为undefined，否则为错误对象。

示例：

  import distributedMissionManager from '@ohos.distributedMissionManager'
  import { BusinessError } from '@ohos.base';

  try {
    distributedMissionManager.stopSyncRemoteMissions(
      {
        deviceId: ""
      },
      (error: BusinessError) => {
        if (error.code != 0) {
          console.error('stopSyncRemoteMissions failed, cause: ' + JSON.stringify(error))
        }
        console.info('stopSyncRemoteMissions finished')}
    )
  } catch (error) {
    console.error('stopSyncRemoteMissions failed, cause: ' + JSON.stringify(error))
  }

distributedMissionManager.stopSyncRemoteMissions

stopSyncRemoteMissions(parameter: MissionDeviceInfo): Promise<void>

停止同步远端设备的任务列表。使用promise异步回调。

需要权限：ohos.permission.MANAGE_MISSIONS

系统能力：SystemCapability.Ability.AbilityRuntime.Mission

参数：

参数名 类型 必填 说明
parameter MissionDeviceInfo 是 同步信息。

返回值：

类型 说明
Promise<void> 无返回结果的promise对象。

示例：

  import distributedMissionManager from '@ohos.distributedMissionManager'
  import { BusinessError } from '@ohos.base';

  try {
    distributedMissionManager.stopSyncRemoteMissions(
      {
        deviceId: ""
      }).then((data: void) => {
        console.info('stopSyncRemoteMissions finished successfully');
      }).catch((error: BusinessError) => {
      console.error('stopSyncRemoteMissions failed, cause: ' + JSON.stringify(error));
    })
  } catch (error) {
    console.error('stopSyncRemoteMissions failed, cause: ' + JSON.stringify(error))
  }

distributedMissionManager.continueMission

continueMission(parameter: ContinueDeviceInfo, options: ContinueCallback, callback: AsyncCallback<void>): void;

通过指定任务ID（missionId）的方式进行迁移任务。使用callback异步回调。

需要权限：ohos.permission.MANAGE_MISSIONS，ohos.permission.DISTRIBUTED_DATASYNC

系统能力：SystemCapability.Ability.AbilityRuntime.Mission

参数：

参数名 类型 必填 说明
parameter ContinueDeviceInfo 是 迁移信息。
options ContinueCallback 是 迁移任务完成回调函数。
callback AsyncCallback<void> 是 回调函数，迁移任务完成时，err为undefined，否则返回错误对象。

错误码：

以下错误码的详细介绍请参见分布式调度错误码。

错误码ID 错误信息
16300501 The system ability work abnormally.
16300502 Failed to get the missionInfo of the specified missionId.
16300503 The application is not installed on the remote end and installation-free is not supported.
16300504 The application is not installed on the remote end but installation-free is supported, try again with freeInstall flag.
16300505 The operation device must be the device where the application to be continued is located or the target device to be continued.
16300506 The local continuation task is already in progress.

示例：

  import distributedMissionManager from '@ohos.distributedMissionManager'
  import { BusinessError } from '@ohos.base';

  // 实现回调函数
  function onContinueDone(resultCode: number): void {
    console.log('onContinueDone resultCode: ' + JSON.stringify(resultCode));
  };
  try {
    // 调用continueMission接口
    distributedMissionManager.continueMission(
      {
        srcDeviceId: "",
        dstDeviceId: "",
        missionId: 1,
        wantParam: {"key": "value"}
      },
      { onContinueDone: onContinueDone },
      (error: BusinessError) => {
        if (error.code != 0) {
          console.error('continueMission failed, cause: ' + JSON.stringify(error))
        }
        console.info('continueMission finished')
    })
  } catch (error) {
    console.error('continueMission failed, cause: ' + JSON.stringify(error))
  }

distributedMissionManager.continueMission

continueMission(parameter: ContinueDeviceInfo, options: ContinueCallback): Promise<void>

通过指定任务ID（missionId）的方式进行迁移任务。使用promise异步回调。

需要权限：ohos.permission.MANAGE_MISSIONS，ohos.permission.DISTRIBUTED_DATASYNC

系统能力：SystemCapability.Ability.AbilityRuntime.Mission

参数：

参数名 类型 必填 说明
parameter ContinueDeviceInfo 是 迁移信息。
options ContinueCallback 是 迁移任务完成回调函数。

返回值：

类型 说明
Promise<void> 无返回结果的promise对象。

错误码：

以下错误码的详细介绍请参见分布式调度错误码。

错误码ID 错误信息
16300501 The system ability work abnormally.
16300502 Failed to get the missionInfo of the specified missionId.
16300503 The application is not installed on the remote end and installation-free is not supported.
16300504 The application is not installed on the remote end but installation-free is supported, try again with freeInstall flag.
16300505 The operation device must be the device where the application to be continued is located or the target device to be continued.
16300506 The local continuation task is already in progress.

示例：

  import distributedMissionManager from '@ohos.distributedMissionManager'
  import { BusinessError } from '@ohos.base';

  // 实现回调函数
  function onContinueDone(resultCode: number): void {
    console.log('onContinueDone resultCode: ' + JSON.stringify(resultCode));
  };
  try {
    // 调用continueMission接口
    distributedMissionManager.continueMission(
      {
        srcDeviceId: "",
        dstDeviceId: "",
        missionId: 1,
        wantParam: {"key": "value"}
      },
      { onContinueDone: onContinueDone }).then(() => {
        console.info('continueMission finished successfully');
      }).catch((error: BusinessError) => {
      console.error('continueMission failed, cause: ' + JSON.stringify(error));
    })
  } catch (error) {
    console.error('continueMission failed, cause: ' + JSON.stringify(error))
  }

distributedMissionManager.continueMission10+

continueMission(parameter: ContinueMissionInfo, callback: AsyncCallback<void>): void;

通过指定包名（bundleName）的方式进行迁移任务。使用callback异步回调。

需要权限：ohos.permission.MANAGE_MISSIONS，ohos.permission.DISTRIBUTED_DATASYNC

系统能力：SystemCapability.Ability.AbilityRuntime.Mission

参数：

参数名 类型 必填 说明
parameter ContinueMissionInfo 是 迁移信息。
callback AsyncCallback<void> 是 回调函数，通过指定包名迁移任务完成时，err为undefined，否则为错误对象。

错误码：

以下错误码的详细介绍请参见分布式调度错误码。

错误码ID 错误信息
16300501 The system ability work abnormally.
16300503 The application is not installed on the remote end and installation-free is not supported.
16300504 The application is not installed on the remote end but installation-free is supported, try again with freeInstall flag.
16300505 The operation device must be the device where the application to be continued is located or the target device to be continued.
16300506 The local continuation task is already in progress.
16300507 Failed to get the missionInfo of the specified bundle name.

示例：

  import distributedMissionManager from '@ohos.distributedMissionManager'
  import { BusinessError } from '@ohos.base';

  try {
    distributedMissionManager.continueMission(
      {
        srcDeviceId: "",
        dstDeviceId: "",
        bundleName: "ohos.test.continueapp",
        wantParam: {"key": "value"}
      },
      (error: BusinessError) => {
        if (error.code != 0) {
          console.error('continueMission failed, cause: ' + JSON.stringify(error))
        }
        console.info('continueMission finished')
    })
  } catch (error) {
    console.error('continueMission failed, cause: ' + JSON.stringify(error))
  }

distributedMissionManager.continueMission10+

continueMission(parameter: ContinueMissionInfo): Promise<void>

通过指定包名（bundleName）的方式进行迁移任务。使用Promise异步回调。

需要权限：ohos.permission.MANAGE_MISSIONS，ohos.permission.DISTRIBUTED_DATASYNC

系统能力：SystemCapability.Ability.AbilityRuntime.Mission

参数：

参数名 类型 必填 说明
parameter ContinueMissionInfo 是 迁移信息。

返回值：

类型 说明
Promise<void> 无返回结果的promise对象。

错误码：

以下错误码的详细介绍请参见分布式调度错误码。

错误码ID 错误信息
16300501 The system ability work abnormally.
16300503 The application is not installed on the remote end and installation-free is not supported.
16300504 The application is not installed on the remote end but installation-free is supported, try again with freeInstall flag.
16300505 The operation device must be the device where the application to be continued is located or the target device to be continued.
16300506 The local continuation task is already in progress.
16300507 Failed to get the missionInfo of the specified bundle name.

示例：

  import distributedMissionManager from '@ohos.distributedMissionManager'
  import { BusinessError } from '@ohos.base';

  try {
      distributedMissionManager.continueMission(
        {
          srcDeviceId: "",
          dstDeviceId: "",
          bundleName: "ohos.test.continueapp",
          wantParam: {"key": "value"}
        }
      ).then(() => {
          console.info('continueMission finished successfully');
      }).catch((error: BusinessError) => {
          console.error('continueMission failed, cause: ' + JSON.stringify(error));
      })
  } catch (error) {
      console.error('continueMission failed, cause: ' + JSON.stringify(error))
  }

distributedMissionManager.on(‘continueStateChange’)10+

on(type: ‘continueStateChange’, callback: Callback<{ state: ContinueState, info: ContinuableInfo }>): void

注册当前任务流转状态的监听。

需要权限：ohos.permission.MANAGE_MISSIONS

系统能力：SystemCapability.Ability.AbilityRuntime.Mission

参数：

参数名 类型 必填 说明
type string 是 当前任务流转状态，取值为’continueStateChange’。
callback Callback<{ state: ContinueState, info: ContinuableInfo }> 是 回调函数，返回当前任务的流转状态和流转信息。

示例：

  import distributedMissionManager from '@ohos.distributedMissionManager'

  try {
    distributedMissionManager.on('continueStateChange', (data) => {
      console.info("continueStateChange on:" + JSON.stringify(data));
    });
  } catch (error) {
    console.error("continueStateChange err: " + JSON.stringify(error));
  }

distributedMissionManager.off(‘continueStateChange’)10+

off(type: ‘continueStateChange’, callback?: Callback<{ state: ContinueState, info: ContinuableInfo }>): void

取消当前任务流转的状态监听。

需要权限：ohos.permission.MANAGE_MISSIONS

系统能力：SystemCapability.Ability.AbilityRuntime.Mission

参数：

参数名 类型 必填 说明
type string 是 当前任务流转状态，取值为’continueStateChange’。
callback Callback<{ state: ContinueState, info: ContinuableInfo }> 否 回调函数，返回当前任务的流转状态和流转信息。
参数不填写，取消type对应的所有回调监听。

示例：

  import distributedMissionManager from '@ohos.distributedMissionManager'

  try {
    distributedMissionManager.off('continueStateChange', (data) => {
      console.info("continueStateChange off:" + JSON.stringify(data));
    });
  } catch (err) {
    console.error("continueStateChange err: " + JSON.stringify(err));
  }

MissionCallback

开始同步后，建立的回调函数。

需要权限：ohos.permission.MANAGE_MISSIONS

系统能力：SystemCapability.Ability.AbilityRuntime.Mission

名称 类型 可读 可写 说明
notifyMissionsChanged function 是 否 通知任务变化，返回设备ID。
notifySnapshot function 是 否 通知快照变化，返回设备ID，任务ID。
notifyNetDisconnect function 是 否 通知断开连接，返回设备ID，网络状态。

MissionParameter

同步时所需参数的枚举。

需要权限：ohos.permission.MANAGE_MISSIONS

系统能力：SystemCapability.Ability.AbilityRuntime.Mission

名称 类型 可读 可写 说明
deviceId string 是 是 表示设备ID。
fixConflict boolean 是 是 表示是否存在版本冲突。
tag number 是 是 表示特定的标签。

MissionDeviceInfo

注册监听时所需参数的枚举。

需要权限：ohos.permission.MANAGE_MISSIONS

系统能力：SystemCapability.Ability.AbilityRuntime.Mission

名称 类型 可读 可写 说明
deviceId string 是 是 表示设备ID。

ContinueState10+

当前任务流转状态的枚举。

系统能力：SystemCapability.Ability.AbilityRuntime.Mission

名称 值 说明
ACTIVE 0 表示当前任务流转处于激活状态。
INACTIVE 1 表示当前任务流转处于未激活状态。

你可能感兴趣的鸿蒙文章

harmony 鸿蒙接口

harmony 鸿蒙系统公共事件定义(待停用)

harmony 鸿蒙系统公共事件定义

harmony 鸿蒙开发说明

harmony 鸿蒙企业设备管理概述（仅对系统应用开放）

harmony 鸿蒙BundleStatusCallback

harmony 鸿蒙@ohos.bundle.innerBundleManager (innerBundleManager模块)

harmony 鸿蒙@ohos.distributedBundle (分布式包管理)

harmony 鸿蒙@ohos.bundle (Bundle模块)

harmony 鸿蒙@ohos.enterprise.EnterpriseAdminExtensionAbility (企业设备管理扩展能力)

0  赞
  • 所属分类： 后端技术
  • 本文标签： 鸿蒙 软件
  • 版权声明： 原创文章如转载，请注明本文链接: https://www.seaxiang.com/blog/611f9f77dc4b4520970140c3806585c0
热门推荐
标签云
Linux Java Spring Spring Boot docker 大数据 前端 生活 maven golang 软件 spring cloud fintech mac vscode 其他 区块链 以太坊 V神 开发者 技术 股票 git greenplum 分布式事务 chrome mysql flink kafka 设计模式 原理 鸿蒙 seo
最新文章
本文目录