軟總線是什么？分布式軟總線是手機、平板、智能穿戴、智慧屏、車機等分布式設備的通信基座，為設備之間的互聯互通提供了統一的分布式通信能力。

本篇講到的知識點：

啟動遠程 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，供手機端遠程調用。

申請權限

在 entrysrcmainconfig.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;

}

}

@Overrideprotected IRemoteObject onConnect（Intent intent） {

super.onConnect（intent）;

return remote.asObject（）;

}

onRemoteRequest 接收來自 sendRequest（requestType，data，reply，option）；傳遞過來的請求類型，數據，返回值，請求類型。

一般不需要處理 reply，客戶端 reply.readInt（） 也會拿到 0（表示請求成功），若是需要在遠端接收到請求后，需要額外返回數據給客戶端，則需要進行 write 操作。

第三步：連接遠端 Service

代碼如下圖：

重點都標記了下，這塊沒啥好講的，ServiceAbility 的基本連接操作。

第四步：發送命令，遠端 Service 處理數據（返回數據、更新 UI）

場景 1：傳遞加法數據，遠端計算后返回給客戶端。

場景 2：傳遞數據，遠端 Service 接收后更新遠端的 UI。

遠端 Service 在 onRemoteRequest 中處理更新 UI 的請求，遠端利用公共事件，進行 UI 的更新。（意味著也就可以控制音樂的播放，暫停等等）

FA 跨設備遷移（可回遷）

跨端遷移開發指導：

https://developer.harmonyos.com/cn/docs/documentation/doc-guides/hop-cross-device-migration-guidelines-0000001146058939

目的：實現正在編輯的頁面，流轉的另外一臺設備，利用分布式的能力提高用戶的體驗。

步驟一

想要遷移的 Ability 以及其下所有的 AbilitySlice 都必須需要實現一個接口：IAbilityContinuation。

坑點 1：哪怕你知識想將 Ability 其中一個 Slice 進行遷移，也必須將 Ability 的所有的 slice 都要實現該接口。

onStartContinuation FA 請求遷移后，系統首先回調此方法，開發者可以在此回調中決策當前是否可以執行遷移，比如，彈框讓用戶確認是否開始遷移。

onSaveData（IntentParams saveData）如果 onStartContinuation（） 返回 true，則系統回調此方法，開發者在此回調中保存必須傳遞到目標端設備上，用于恢復 FA 狀態的數據。

onRestoreData（IntentParams restoreData）發起端設備上 FA 完成保存數據后，系統在目標端設備上回調此方法，開發者在此回調中接受用于恢復 FA 狀態的數據。

onCompleteContinuation（int result）目標端設備上恢復數據一旦完成，系統就會在發起端設備上回調 FA 的此方法，以便通知應用遷移流程已結束。

坑點 2：不要忘記 return true；Ability 中也要。

坑點 3：onRestoreData 進行 UI 的恢復時，需要切換到 UI 線程，否則。。。（沒報錯 Log）

步驟二

可回遷的遷移：

回遷（若是已經回遷了，再進行回遷，會報錯。先 try-catch 了）：

混合打包

目前鴻蒙上的應用有以下三種：

直接運行的安卓應用。

使用 DevEco Studio 編寫的鴻蒙應用。

已有開發好的安卓應用，想擁有鴻蒙的一些特性，從而進行混合打包。apk 邏輯無需變化，即可擁有鴻蒙特性，例如服務卡片。

如何進行混合打包？篇幅原因，將會在另外一篇中詳細介紹。請移步：安卓應用如何混合打包擁有鴻蒙的卡片服務？

https://developer.huawei.com/consumer/cn/blog/topic/03637432111020021

奇怪的知識

針對：分布式數據服務開發指導。

https://developer.harmonyos.com/cn/docs/documentation/doc-guides/database-mdds-guidelines-0000001113961404

①設計字段

單版本分布式數據庫的介紹比較簡單。存儲 key-value，value 若是復雜點沒介紹。若想 value 中存儲很多其他數據，可進行以下操作。

以上時創建單版本分布式數據庫時，設置 Schema 對象，從而設計了數據庫中的字段。

②數據存儲

存入的時候，需要以 json 的格式進行寫入。

③查詢

坑點：下次查詢時，需要 query.reset（）;

編輯：jq