軟總線是什么？

分布式軟總線是手機(jī)、平板、智能穿戴、智慧屏、車機(jī)等分布式設(shè)備的通信基座，為設(shè)備之間的互聯(lián)互通提供了統(tǒng)一的分布式通信能力。

本篇講到的知識(shí)點(diǎn)：

• 啟動(dòng)遠(yuǎn)程FA（Feature Ability）
• 連接遠(yuǎn)程PA（Particle Ability），發(fā)送控制命令&遠(yuǎn)端處理數(shù)據(jù)（場(chǎng)景1：傳遞加法數(shù)據(jù)，遠(yuǎn)端計(jì)算后返回給客戶端。場(chǎng)景2：傳遞數(shù)據(jù)，遠(yuǎn)端Service接收后更新遠(yuǎn)端的UI。）
• FA跨設(shè)備遷移（可回遷）
• 混合打包
• 其他奇怪的知識(shí)

技術(shù)要求和環(huán)境要求：

• 基本組件熟練使用，ServiceAbility，CommonEventManager（公共事件開發(fā)）
• 兩臺(tái)HarmonyOS 2.0的真機(jī) 或 DevEco Studio 2.2 Beta1(分布式模擬器的自動(dòng)開啟，可同時(shí)模擬運(yùn)行兩臺(tái)設(shè)備，且自動(dòng)組網(wǎng))。

獲取DevEco Studio 2.2 Beta1（HUAWEI DevEco Studio - HarmonyOS應(yīng)用開發(fā)官網(wǎng)）

Service Ability（開發(fā)-連接Service (harmonyos.com)）

公共事件開發(fā)指導(dǎo)（開發(fā)-公共事件開發(fā)指導(dǎo) (harmonyos.com)））

其他

• 真機(jī)分布式通信要求：同一局域網(wǎng)內(nèi)，登錄相同華為賬號(hào)，開啟藍(lán)牙 (可行方案)，這樣在 設(shè)定-超級(jí)終端 中 附近我的設(shè)備 即可查看到另外一臺(tái)設(shè)備。
• 分布式模擬器 會(huì)自動(dòng)組網(wǎng)，不需要手動(dòng)做其他操作。（設(shè)定的超級(jí)終端中看不出來(lái)已經(jīng)組網(wǎng)成功）
• 運(yùn)行到真機(jī)上需要進(jìn)行簽名，模擬器則不需要。

代碼下載

gitee HarmonySoftBus（HarmonySoftBus: Harmony軟總線的第一次嘗試，入門使用。 (gitee.com)）

github HarmonySoftBus（GitHub - cl18652469346/HarmonySoftBus: SoftBus Demo）

先看下效果

代碼結(jié)構(gòu)

• adapter：DevicesListAdapter，用于向ListContainer控件中填充設(shè)備數(shù)據(jù)。
• component：SelectDeviceDialog封裝了設(shè)備選擇彈框
• proxy：定義了連接遠(yuǎn)程和調(diào)用遠(yuǎn)程service（PA）的接口、實(shí)現(xiàn)類以及代理。
• service：RemoteService為被控制端service，供手機(jī)端遠(yuǎn)程調(diào)用。

申請(qǐng)權(quán)限

在entry\src\main\config.json中申請(qǐng)以下4個(gè)權(quán)限：

1. ohos.permission.DISTRIBUTED_DEVICE_STATE_CHANGE：用于允許監(jiān)聽分布式組網(wǎng)內(nèi)的設(shè)備狀態(tài)變化。
2. ohos.permission.GET_DISTRIBUTED_DEVICE_INFO：用于允許獲取分布式組網(wǎng)內(nèi)的設(shè)備列表和設(shè)備信息。
3. ohos.permission.GET_BUNDLE_INFO：用于查詢其他應(yīng)用的信息。
4. ohos.permission.DISTRIBUTED_DATASYNC：用于允許不同設(shè)備間的數(shù)據(jù)交換。

此外，還需要在實(shí)現(xiàn)Ability的代碼中顯式聲明需要使用多設(shè)備協(xié)同訪問(wèn)的權(quán)限，示例代碼如下：

獲取組網(wǎng)內(nèi)在線的其他設(shè)備DeviceInfo(Id&Name)

獲取自身設(shè)備的Id

啟動(dòng)遠(yuǎn)程FA

和普通畫面的啟動(dòng)類似，withDeviceId("") 為本地畫面跳轉(zhuǎn)。

跨設(shè)備啟動(dòng)需要攜帶 遠(yuǎn)程設(shè)備的DeviceID，以及設(shè)置 "支持分布式調(diào)度系統(tǒng)中的多設(shè)備啟動(dòng)"Flag。

連接遠(yuǎn)程PA，發(fā)送控制命令&遠(yuǎn)端處理數(shù)據(jù)

第一步: 客戶端創(chuàng)建遠(yuǎn)程連接代理類

public class MyRemoteProxy implements IRemoteBroker {
    /**
     * 遠(yuǎn)端響應(yīng)成功的標(biāo)識(shí)
     */
    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;
    }
    
    // 攜帶數(shù)據(jù)向遠(yuǎn)端Sevice發(fā)送請(qǐng)求
    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();   // 返回成功后拿到遠(yuǎn)端計(jì)算的結(jié)果。
                }
            }
        } catch (RemoteException e) {
            LogUtils.error(TAG, "RemoteException:");
        } finally {
            ec = ERR_OK;
            if (result != -1) {
                ec = result;
            }
            data.reclaim();
            reply.reclaim();
        }
        return ec;
    }
}

• 實(shí)現(xiàn)IRemoteBroker接口,asObject返回遠(yuǎn)程RemoteObject對(duì)象
• 創(chuàng)建構(gòu)造方法（參數(shù)為connectAbility成功時(shí)回調(diào)方法onAbilityConnectDone中的遠(yuǎn)程操作對(duì)象）
• 封裝向遠(yuǎn)端發(fā)送請(qǐng)求的方法，便于后續(xù)進(jìn)行控制 (本例中是簡(jiǎn)單的加法請(qǐng)求)

MessageOption.TF_SYNC代表同步，意味著會(huì)在sendRequest時(shí)阻塞等待來(lái)自遠(yuǎn)端Service的返回。

遠(yuǎn)端Service返回值是 reply，reply.readInt() 默認(rèn)會(huì)返回0，代表請(qǐng)求成功。若是想攜帶其他返回值，需要在遠(yuǎn)端Service中進(jìn)行處理，下一步會(huì)講到。

第二步: 遠(yuǎn)端Service中，創(chuàng)建RemoteObject并處理請(qǐng)求

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();
}

onRemoteRequest 接收來(lái)自 sendRequest(requestType, data, reply, option); 傳遞過(guò)來(lái)的請(qǐng)求類型，數(shù)據(jù)，返回值，請(qǐng)求類型。

一般不需要處理reply，客戶端reply.readInt() 也會(huì)拿到0(表示請(qǐng)求成功)，若是需要在遠(yuǎn)端接收到請(qǐng)求后，需要額外返回?cái)?shù)據(jù)給客戶端，則需要進(jìn)行write操作。

第三步: 連接遠(yuǎn)端Service

重點(diǎn)都標(biāo)記了下，這塊沒(méi)啥好講的，ServiceAbility的基本連接操作。

第四步: 發(fā)送命令，遠(yuǎn)端Service處理數(shù)據(jù)(返回?cái)?shù)據(jù)、更新UI)

場(chǎng)景1：傳遞加法數(shù)據(jù)，遠(yuǎn)端計(jì)算后返回給客戶端

場(chǎng)景2：傳遞數(shù)據(jù)，遠(yuǎn)端Service接收后更新遠(yuǎn)端的UI

遠(yuǎn)端Service在onRemoteRequest中處理更新UI的請(qǐng)求，遠(yuǎn)端利用公共事件，進(jìn)行UI的更新。(意味著也就可以 控制音樂(lè)的播放，暫停 等等)

FA跨設(shè)備遷移（可回遷）

跨端遷移開發(fā)指導(dǎo)（專題-跨端遷移開發(fā)指導(dǎo) (harmonyos.com)） 目的: 實(shí)現(xiàn)正在編輯的頁(yè)面，流轉(zhuǎn)的另外一臺(tái)設(shè)備，利用分布式的能力提高用戶的體驗(yàn)。

步驟一

想要遷移的Ability以及其下所有的AbilitySlice都必須需要實(shí)現(xiàn)一個(gè)接口:IAbilityContinuation

坑點(diǎn)1：哪怕你知識(shí)想將Ability其中一個(gè)Slice進(jìn)行遷移，也必須將Ability的所有的slice都要實(shí)現(xiàn)該接口

onStartContinuationFA請(qǐng)求遷移后，系統(tǒng)首先回調(diào)此方法，開發(fā)者可以在此回調(diào)中決策當(dāng)前是否可以執(zhí)行遷移，比如，彈框讓用戶確認(rèn)是否開始遷移。

onSaveData(IntentParams saveData)如果onStartContinuation()返回true，則系統(tǒng)回調(diào)此方法，開發(fā)者在此回調(diào)中保存必須傳遞到目標(biāo)端設(shè)備上，用于恢復(fù)FA狀態(tài)的數(shù)據(jù)。

onRestoreData(IntentParams restoreData)發(fā)起端設(shè)備上FA完成保存數(shù)據(jù)后，系統(tǒng)在目標(biāo)端設(shè)備上回調(diào)此方法，開發(fā)者在此回調(diào)中接受用于恢復(fù)FA狀態(tài)的數(shù)據(jù)。

onCompleteContinuation(int result) 目標(biāo)端設(shè)備上恢復(fù)數(shù)據(jù)一旦完成，系統(tǒng)就會(huì)在發(fā)起端設(shè)備上回調(diào)FA的此方法，以便通知應(yīng)用遷移流程已結(jié)束。

坑點(diǎn)2: 不要忘記 return true; Ability中也要。

坑點(diǎn)3: onRestoreData進(jìn)行UI的恢復(fù)時(shí)，需要切換到UI線程，否則...(沒(méi)報(bào)錯(cuò)Log)

步驟二

可回遷的遷移

回遷(若是已經(jīng)回遷了，再進(jìn)行回遷，會(huì)報(bào)錯(cuò)。 先try-catch了)

混合打包

目前OpenHarmony上的應(yīng)用有以下三種

• 直接運(yùn)行的 安卓應(yīng)用
• 使用DevEco Studio編寫的OpenHarmony應(yīng)用
• 已有開發(fā)好的 安卓應(yīng)用，想擁有 OpenHarmony的一些特性，從而進(jìn)行混合打包。apk邏輯無(wú)需變化，即可擁有OpenHarmony特性，例如 服務(wù)卡片（專題-Java卡片開發(fā)指導(dǎo) (harmonyos.com)））。

如何進(jìn)行混合打包？

篇幅原因，將會(huì)在另外一篇中詳細(xì)介紹。 請(qǐng)移步: 安卓應(yīng)用如何混合打包擁有OpenHarmony的卡片服務(wù)？（安卓應(yīng)用如何混合打包擁有OpenHarmony特性？ (huawei.com)））

奇怪的知識(shí)

針對(duì)：分布式數(shù)據(jù)服務(wù)開發(fā)指導(dǎo) （開發(fā)-分布式數(shù)據(jù)服務(wù)開發(fā)指導(dǎo) (harmonyos.com)）

設(shè)計(jì)字段：

單版本分布式數(shù)據(jù)庫(kù)的介紹比較簡(jiǎn)單。存儲(chǔ)key-value， value若是復(fù)雜點(diǎn)沒(méi)介紹。若想value中存儲(chǔ)很多其他數(shù)據(jù)，可進(jìn)行以下操作。

以上時(shí)創(chuàng)建單版本分布式數(shù)據(jù)庫(kù)時(shí)，設(shè)置Schema對(duì)象，從而設(shè)計(jì)了數(shù)據(jù)庫(kù)中的字段。

數(shù)據(jù)存儲(chǔ)：

存入的時(shí)候，需要以json的格式進(jìn)行寫入。

查詢：

坑點(diǎn): 下次查詢時(shí)，需要query.reset();