Harmony軟總線的簡單使用

軟總線是什么？

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

本篇講到的知識點：

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

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

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

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

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

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

其他

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

代碼下載

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：定義了連接遠程和調(diào)用遠程service（PA）的接口、實現(xiàn)類以及代理。
• service：RemoteService為被控制端service，供手機端遠程調(diào)用。

申請權(quán)限

在entry\src\main\config.json中申請以下4個權(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：用于查詢其他應用的信息。
4. ohos.permission.DISTRIBUTED_DATASYNC：用于允許不同設(shè)備間的數(shù)據(jù)交換。

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

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

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

啟動遠程FA

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

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

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

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

复制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;
    }
    
    // 攜帶數(shù)據(jù)向遠端Sevice發(fā)送請求
    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();   // 返回成功后拿到遠端計算的結(jié)果。
                }
            }
        } catch (RemoteException e) {
            LogUtils.error(TAG, "RemoteException:");
        } finally {
            ec = ERR_OK;
            if (result != -1) {
                ec = result;
            }
            data.reclaim();
            reply.reclaim();
        }
        return ec;
    }
}

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

MessageOption.TF_SYNC代表同步，意味著會在sendRequest時阻塞等待來自遠端Service的返回。

遠端Service返回值是 reply，reply.readInt() 默認會返回0，代表請求成功。若是想攜帶其他返回值，需要在遠端Service中進行處理，下一步會講到。

第二步: 遠端Service中，創(chuàng)建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();
}

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

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

第三步: 連接遠端Service

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

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

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

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

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

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

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

步驟一

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

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

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

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

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

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

坑點2: 不要忘記 return true; Ability中也要。

坑點3: onRestoreData進行UI的恢復時，需要切換到UI線程，否則...(沒報錯Log)

步驟二

可回遷的遷移

回遷(若是已經(jīng)回遷了，再進行回遷，會報錯。 先try-catch了)

混合打包

目前OpenHarmony上的應用有以下三種

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

如何進行混合打包？

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

奇怪的知識

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

設(shè)計字段：

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

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

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

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

查詢：

坑點: 下次查詢時，需要query.reset();