鸿蒙软总线，超详细教程来啦！_专栏

软总线是什么？分布式软总线是手机、平板、智能穿戴、智慧屏、车机等分布式设备的通信基座，为设备之间的互联互通提供了统一的分布式通信能力。

本篇讲到的知识点：

启动远程 FA（Feature Ability）

连接远程 PA（Particle Ability），发送控制命令&远端处理数据（场景 1：传递加法数据，远端计算后返回给客户端。场景 2：传递数据，远端 Service 接收后更新远端的 UI。）

FA 跨设备迁移（可回迁）

混合打包

其他奇怪的知识

技术要求和环境要求：
基本组件熟练使用，ServiceAbility，CommonEventManager（公共事件开发）

两台 HarmonyOS 2.0 的真机或 DevEco Studio 2.2 Beta1（分布式模拟器的自动开启，可同时模拟运行两台设备，且自动组网）。

获取 DevEco Studio 2.2 Beta1：
https://developer.harmonyos.com/cn/develop/deveco-studio?utm_source=product&utm_medium=link&utm_campaign=DS&utm_content=2.1#download_beta

Service Ability：

https://developer.harmonyos.com/cn/docs/documentation/doc-guides/ability-service-connecting-0000000000044469

公共事件开发指导：

https://developer.harmonyos.com/cn/docs/documentation/doc-guides/ability-notification-fwk-common-event-0000000000029871

其他：
真机分布式通信要求：同一局域网内，登录相同华为账号，开启蓝牙（可行方案），这样在设定-超级终端中附近我的设备即可查看到另外一台设备。

分布式模拟器会自动组网，不需要手动做其他操作。（设定的超级终端中看不出来已经组网成功）

运行到真机上需要进行签名，模拟器则不需要。

代码下载

gitee HarmonySoftBus：

https://gitee.com/shmily_cl/HarmonySoftBus

github HarmonySoftBus：

https://github.com/cl18652469346/HarmonySoftBus

先看下效果：

代码结构

代码结构如上图：
adapter：DevicesListAdapter，用于向 ListContainer 控件中填充设备数据。

component：SelectDeviceDialog 封装了设备选择弹框。

proxy：定义了连接远程和调用远程 service（PA）的接口、实现类以及代理。

service：RemoteService 为被控制端 service，供手机端远程调用。

申请权限

在 entry\src\main\config.json 中申请以下 4 个权限：

ohos.permission.DISTRIBUTED_DEVICE_STATE_CHANGE：用于允许监听分布式组网内的设备状态变化。

ohos.permission.GET_DISTRIBUTED_DEVICE_INFO：用于允许获取分布式组网内的设备列表和设备信息。

ohos.permission.GET_BUNDLE_INFO：用于查询其他应用的信息。

ohos.permission.DISTRIBUTED_DATASYNC：用于允许不同设备间的数据交换。

此外，还需要在实现 Ability 的代码中显式声明需要使用多设备协同访问的权限，示例代码如下：
图片

获取组网内在线的其他设备 DeviceInfo（Id&Name）：

图片

获取自身设备的 Id：

图片

启动远程 FA：

图片

和普通画面的启动类似，withDeviceId("") 为本地画面跳转。

跨设备启动需要携带远程设备的 DeviceID，以及设置 "支持分布式调度系统中的多设备启动"Flag。

连接远程 PA，发送控制命令&远端处理数据

第一步：客户端创建远程连接代理类

代码如下：

public class MyRemoteProxy implements IRemoteBroker {
/**

远端响应成功的标识
*/
public static final int ERR_OK = 0;
private static final String TAG = MyRemoteProxy.class.getSimpleName();
private final IRemoteObject remote;
public MyRemoteProxy(IRemoteObject remote) {
this.remote = remote;
}

@Override
public IRemoteObject asObject() {
return remote;
}

// 携带数据向远端Sevice发送请求
public int senDataToRemote(int requestType, Map paramMap) {
MessageParcel data = MessageParcel.obtain();
MessageParcel reply = MessageParcel.obtain();
MessageOption option = new MessageOption(MessageOption.TF_SYNC);
int ec = 1;
int result = -1;
try {
if (paramMap.get("inputString") instanceof String) {
String inputString = (String) paramMap.get("inputString");
data.writeInt(requestType);
data.writeString(inputString);
remote.sendRequest(requestType, data, reply, option);
}
ec = reply.readInt();
if (ec != ERR_OK) {
LogUtils.error(TAG, "RemoteException:");
} else {
if (requestType == ConnectManagerIml.REQUEST_PLUS) {
result = reply.readInt(); // 返回成功后拿到远端计算的结果。
}
}
} catch (RemoteException e) {
LogUtils.error(TAG, "RemoteException:");
} finally {
ec = ERR_OK;
if (result != -1) {
ec = result;
}
data.reclaim();
reply.reclaim();
}
return ec;
}
}

①实现 IRemoteBroker 接口，asObject 返回远程 RemoteObject 对象。

②创建构造方法（参数为 connectAbility 成功时回调方法 onAbilityConnectDone 中的远程操作对象）。

③封装向远端发送请求的方法，便于后续进行控制（本例中是简单的加法请求）。

图片

MessageOption.TF_SYNC 代表同步，意味着会在 sendRequest 时阻塞等待来自远端 Service 的返回。

远端 Service 返回值是 reply，reply.readInt() 默认会返回 0，代表请求成功。若是想携带其他返回值，需要在远端 Service 中进行处理，下一步会讲到。

第二步：远端 Service 中，创建 RemoteObject 并处理请求

代码如下：

public class MyRemote extends RemoteObject implements IRemoteBroker {
private MyRemote() {
super("===MyService_Remote");
}
@Override
public IRemoteObject asObject() {
return this;
}
@Override
public boolean onRemoteRequest(int code, MessageParcel data, MessageParcel reply, MessageOption option) {
LogUtils.info(TAG, "===onRemoteRequest......");
int requestType = data.readInt();
String inputString = "";
if (code == REQUEST_SEND_DATA) {
inputString = data.readString();
publishInput(requestType, inputString);
} else if (code == REQUEST_PLUS) {
int a = data.readInt();
int b = data.readInt();
reply.writeInt(ERR_OK);
reply.writeInt(a + b);
publishPlusResult(requestType, String.valueOf(a + b));
}
return true;
}
}
@Override
protected IRemoteObject onConnect(Intent intent) {
super.onConnect(intent);
return remote.asObject();
}