大家好，我是 V 哥。今天我们将深入鸿蒙 6.0（API21）的分布式能力，探讨如何通过网络协同服务实现跨设备互通，结合 ArkTS 开发实践，提供一套完整的技术方案与代码示例。

联系V哥获取 鸿蒙学习资料

---

一、技术背景与核心概念

鸿蒙系统的分布式软总线（Distributed Soft Bus）是跨设备协同的底层基石，它通过近场感知、设备发现与连接管理，实现了设备间的低功耗、高速率通信。而**远程过程调用（RPC）**是上层应用实现跨设备功能的核心接口，其通过软总线驱动完成数据传输与接口调用。

关键流程：
设备发现 → 服务注册 → RPC 接口绑定 → 跨设备方法调用 → 数据同步

---

二、开发环境配置

在 module.json5 中添加必要依赖与权限：

{
  "module": {
    "dependencies": {
      "@ohos.distributedHardware.distributedDeviceManager": "^1.0", // 设备管理模块
      "@ohos.app.ability.featureAbility": "^1.0",                    // Ability 调用
      "@ohos.rpc": "^1.0"                                            // RPC 核心接口
    },
    "requestPermissions": [
      {
        "name": "ohos.permission.DISTRIBUTED_DEVICE_STATE_CHANGE"    // 监听设备状态
      },
      {
        "name": "ohos.permission.GET_DISTRIBUTED_DEVICE_INFO"       // 获取设备信息
      }
    ]
  }
}

---

三、核心实现步骤（ArkTS 案例）

场景说明：

实现一个跨设备文本同步功能，例如在手机端输入文字，实时显示在平板端。

---

步骤 1：设备发现与连接管理

使用 DistributedDeviceManager（简称 DDM）获取目标设备的 NetworkId：

import deviceManager from '@ohohs.distributedHardware.distributedDeviceManager';

// 初始化设备管理器
const dm = deviceManager.getDistributedDeviceManager(getContext(this) as common.UIAbilityContext);

// 监听设备变化（如新增/断开设备）
dm.on('deviceChange', (deviceInfo: deviceManager.DeviceInfo[]) => {
  for (let info of deviceInfo) {
    if (info.deviceType === deviceManager.DeviceType.TAB) { // 假设目标设备是平板
      console.info('发现目标设备:', info.networkId);
      // 触发后续服务绑定逻辑
    }
  }
});

---

步骤 2：服务端接口定义与注册

服务端（如平板设备）需定义一个远程服务接口，用于接收客户端（手机）的文本数据。

1.定义远程服务接口（Stub）
创建一个继承自 RemoteObject 的服务端类，实现 onRemoteMessageRequest 方法：

import rpc from '@ohos.rpc';

class TextSyncStub extends rpc.RemoteObject {
  constructor(descriptor: string) {
    super(descriptor); // 接口标识符，需与客户端一致
  }

  // 处理客户端发送的文本数据
  onRemoteMessageRequest(code: number, data: rpc.MessageSequence, reply: rpc.MessageSequence, option: rpc.MessageOption): boolean | Promise<boolean> {
    if (code === 1) { // 自定义方法标识码
      const receivedText = data.readString(); // 读取客户端发送的文本
      console.info('服务端接收到文本:', receivedText);
      // 在本地 UI 中更新文本（示例）
      this.onTextReceived(receivedText);
      return true;
    }
    return false;
  }

  // 本地回调：更新 UI（需结合 Ability 生命周期）
  onTextReceived(text: string) {
    // 示例：更新 UIAbility 中的 @State 变量
    this.textContent = text;
  }
}

2.在服务端 Ability 中注册服务
服务端 Ability 需通过 SAMgr（系统能力管理器）注册服务：

import rpc from '@ohos.rpc';
import featureAbility from '@ohos.app.ability.featureAbility';

@Entry
@Component
struct TextSyncServer {
  private stub: TextSyncStub | null = null;

  aboutToAppear() {
    // 创建 Stub 实例
    this.stub = new TextSyncStub('com.example.textsync.service');
    // 注册系统能力（System Ability）
    featureAbility.registerSystemAbility(1001, this.stub); // 1001 为自定义的 SA ID
  }
}

---

步骤 3：客户端绑定服务并发送数据

客户端（如手机）通过 NetworkId 绑定服务端的远程服务，并调用其接口发送数据。

1.绑定服务端 Ability
客户端需构造 Want 对象，指定目标设备的 NetworkId 与服务描述符：

import rpc from '@ohos.rpc';
import featureAbility from '@ohos.app.ability.featureAbility';

// 获取目标设备 NetworkId（通过 DDM 发现）
const targetNetworkId = '12:34:56:78:90:AB'; // 示例设备 ID

// 构造 Want 对象
const want: Want = {
  deviceId: targetNetworkId, // 目标设备 ID
  bundleName: 'com.example.textsync', // 服务端应用包名
  abilityName: 'TextSyncServer', // 服务端 Ability 名称
  parameters: {
    // 可选参数
  }
};

// 绑定服务
featureAbility.connectAbility(want, {
  onConnect: (proxy: rpc.RemoteObject) => {
    console.info('客户端绑定服务成功:', proxy);
    this.proxy = proxy; // 保存代理对象
  },
  onDisconnect: () => {
    console.warn('服务连接断开');
    this.proxy = null;
  },
  onFailed: (errCode: number) => {
    console.error('绑定服务失败，错误码:', errCode);
  }
});

2.通过 Proxy 调用远程方法
客户端通过代理对象 proxy 调用服务端方法，发送文本数据：

// 发送文本到服务端
async sendTextToServer(text: string) {
  if (this.proxy) {
    const data = new rpc.MessageSequence();
    const reply = new rpc.MessageSequence();
    data.writeString(text); // 将文本写入数据包
    // 调用服务端方法（code 为 1，需与服务端一致）
    const result = await this.proxy.sendMessageRequest(1, data, reply);
    if (result) {
      console.info('发送成功');
    } else {
      console.error('发送失败');
    }
  }
}

---

四、完整 UI 交互案例

服务端 UI（平板端）

展示接收到的文本：

@Component
struct TextDisplay {
  @State text: string = '';

  build() {
    Column() {
      Text(this.text)
        .fontSize(30)
        .textAlign(TextAlign.Center)
        .width('100%')
        .height('100%')
    }
  }
}

客户端 UI（手机端）

输入文本并发送：

@Component
struct TextInput {
  @State inputText: string = '';
  private proxy: rpc.RemoteObject | null = null;

  build() {
    Column() {
      TextInput({ placeholder: '输入文本' })
        .onChange((value: string) => {
          this.inputText = value;
        })
      Button('发送到平板')
        .onClick(() => {
          this.sendTextToServer(this.inputText);
        })
    }
  }
}

---

五、关键注意事项与性能优化

1.设备兼容性

• 确保目标设备已开启超级终端功能，并且网络状态正常。
• 检查目标设备是否支持鸿蒙 6.0 及其 API 特性。

2.软总线连接稳定性

• 通过 DistributedDeviceManager 监听设备状态变化，动态断开或重连。
• 使用 onDisconnect 回调处理异常断开情况。

3.数据序列化与反序列化

• 通过 MessageSequence 传递数据时，需保证客户端与服务端的字段类型与顺序一致。
• 对于复杂数据（如 PixelMap），需通过 Parcel 接口实现自定义序列化。

4.性能优化

• 减少跨设备传输的数据量：对大图片等数据，建议在客户端进行压缩后再发送。
• 异步处理：服务端的 onRemoteMessageRequest 方法应尽量异步处理数据，避免阻塞主线程。
• 连接复用：避免频繁建立与断开连接，可缓存已连接的 proxy 对象。

---

六、扩展场景：跨设备图片同步

结合前文提到的 PixelMap 处理能力，可进一步实现图片的跨设备同步：
1.客户端将 PixelMap 转为 ArrayBuffer（通过 getPixelBytes()）。
2.使用 MessageSequence 的 writeArrayBuffer() 方法发送。
3.服务端通过 readArrayBuffer() 接收，并用 image.createPixelMap() 重建图像。

---

总结

通过鸿蒙 6.0 的网络协同服务（RPC + 软总线），开发者可以轻松实现跨设备的数据互通。关键在于：

• 服务端：定义并注册远程接口（Stub），处理来自客户端的请求。
• 客户端：发现设备、绑定服务（Proxy），并调用其方法发送数据。

我是 V 哥，下期将解析如何结合分布式软总线与 PixelMap 实现跨设备实时滤镜同步（如手机拍摄后实时推送到平板渲染）。如果你在跨设备通信中遇到问题，欢迎在评论区留言，我们共同探讨！