項目概述

可能有些同學已經接觸過了標準系統(tǒng)上的軟總線應用開發(fā)，但是你玩過輕量系統(tǒng)上的軟總線應用嗎？現(xiàn)在它來了。我們利用OpenAtom OpenHarmony 3.1 Release(以下簡稱“OpenHarmony”)版本的輕量系統(tǒng)軟總線能力，將智能燃氣檢測設備和智能窗戶通風設備組成一個輕量級分布式網絡，實現(xiàn)設備之間的相互控制。 原理圖如下：

以下是實際操作效果： 當家中的燃氣告警時，無需任何操作，直接控制窗戶通風系統(tǒng)中的電機工作。

開發(fā)說明

從上面的視頻中可以看到，相關案例設備的應用界面都可以分成外設交互頁面和軟總線操作頁面兩大塊。在下面的系統(tǒng)框圖中可以看到相關頁面和其依賴的相關輕量系統(tǒng)能力。例如外設交互界面通過自定義JSI接口與設備硬件打交道，軟總線操作界面則通過輕量系統(tǒng)的設備管理能力、軟總線能力來實現(xiàn)設備間的發(fā)現(xiàn)、認證、傳輸?shù)溶浛偩€操作。

在下面的內容中我們將以智能燃氣告警器設備為例，將相關開發(fā)過程分成JS應用端開發(fā)、自定義JSI實現(xiàn)、開發(fā)板端代碼三部分來說明：

JS應用開發(fā)

燃氣告警器JS應用是基于3.1 release版本，并結合方舟開發(fā)框架（ArkUI）、分布式組網等特性，使用JS語言開發(fā)的一款分布式安全廚房應用。為了體現(xiàn)了 OpenHarmony輕量級分布式特性，不僅需要考慮頁面該如何設計、應用怎樣同外設交互，還需要考慮兩個輕量級設備間如何進行設備認證，設備間如何進行通訊等問題。

所以在相關應用中設計了操作頁面，報警頁面以及設備認證頁面。其中首頁是設置燃氣濃度閾值，以及顯示當前燃氣濃度；報警頁面是當首頁檢測到當前燃氣濃度達到或高于我們設置的閾值時，會從首頁跳轉到報警界面；設備認證頁面則是對兩臺設備進行分布式組網。

代碼結構如下圖：

外設交互頁面開發(fā)

相關界面如上圖所示，我們將首頁頁面分成三個部分：頂部標簽、燃氣濃度顯示、設置告警閾值。接下來是具體的解析內容：

1）頂部標簽解析

頂部標簽中除了相關文本界面，主要是頂部兩個按鈕，分別用來顯示當前Wi-Fi連接狀態(tài)以及跳轉到設備認證頁面。

GetKey() { com.get({ // 獲取wifi狀態(tài) key: 'storage_key', success: (data)=> { let res = JSON.parse(data) if (res.wifi) { if(res.wifi == 'connected') { this.isWifi = true; } else { this.isWifi = false; } } ..... }, }); }, changePage(operation) { router.replace({ uri:"pages/dm/dm" // 跳轉到設備認證頁面 });}

2）燃氣濃度顯示

主要是獲取當前燃氣濃度，并實時刷新到相關界面上。

onInit() { setTimeout(()=>{ setInterval(()=>this.GetKey(),500) // 每500ms 獲取一次 },3000); }, GetKey() { com.get({ key: 'storage_key', success: (data)=> { let res = JSON.parse(data) if (res.CurrentGasCONC) { this.currentValue = res.CurrentGasCONC; this.progressPercent = ((this.currentValue ) /300) * 100 if(this.currentValue >this.PresetValue && !this.isChange){ this.isChange = true; router.replace({ uri:"pages/warn/warn" // 燃氣數(shù)值超標后自動跳轉告警頁面 }); } } }, ...... });},

3）設置報警閾值

首頁界面中對于報警閾值的處理，主要包含減小預設閾值和增大預設閾值，都是通過調用相關SetKey操作完成的。

reduceProgress(){ //減小預設閾值 if (this.PresetValue <= 0) { this.PresetValue = 0 }else{ this.PresetValue = parseInt(this.PresetValue) - 20 } this.isChange = false; this.setProgress = ((this.PresetValue ) /300) * 100 this.SetKey( 'GasThreshold', this.PresetValue ); }, addProgress(){ //增大預設閾值 if (this.PresetValue >= 300) { this.PresetValue = 300 }else{ this.PresetValue = parseInt(this.PresetValue) + 20 } this.isChange = false; this.setProgress = ((this.PresetValue ) /300) * 100 this.SetKey( 'GasThreshold', this.PresetValue ); }, SetKey(key1, value1) { com.set({ key: key1 + '', value: value1 + '', // success or failed 狀態(tài)打印 });},設備認證頁面開發(fā)

相關界面如上圖所示，我們將設備認證步驟分成四個步驟：發(fā)現(xiàn)設備、發(fā)起認證、允許認證、輸入PIN碼。接下來是具體的解析內容：

1）發(fā)現(xiàn)設備解析

設備認證因設備狀態(tài)不同顯示對應的UI，上圖顯示的UI對應設備狀態(tài)”status = start“。

startDevice(){ this.subscribeId = Math.floor(Math.random() * 10000 + 1000) var info = { "subscribeId": this.subscribeId, // 特定隨機的 "mode": 0xAA, // 設置主動發(fā)現(xiàn)模式，除此之外還有被動模式DISCOVER_MODE_PASSIVE "medium": 0, // 自動選擇發(fā)現(xiàn)介質，目前用的是coap "freq": 2, // 發(fā)送發(fā)現(xiàn)消息的頻率，目前用的是HIGH 還有LOW/MID/SUPER_HIGH "isSameAccount": false, // 取消同一賬號下才能發(fā)現(xiàn)的限制 "isWakeRemote": false, // 目前輕量系統(tǒng)沒有睡眠模式，所以不用睡眠喚醒功能 "capability": 0 // 目前使用DDMP devicemanager.startDeviceDiscovery(info); // 開始設備發(fā)現(xiàn)},2）發(fā)起認證解析

AuthenticateDevice(){ // 發(fā)起認證 let extraInfo = { targetPkgName: 'test', appName: "Newname", appDescription: "testAPP", business: '0', displayOwner: 0 }; let AuthParam = { authType: 1, // 以PIN 碼方式進行認證校驗 appIcon:null, appThumbnail:null, extraInfo: extraInfo }; let _this = this; devicemanager.authenticateDevice(this.statusInfo, AuthParam, { // 省略了相關success 和fail 回調處理，完整代碼見參考鏈接}，

3）允許認證解析

當設備狀態(tài)”status = join-pin“，允許相關認證動作并且顯示相關PIN碼。

joinAuthOk() { this.joinPin() //切換顯示PIN碼界面 this.initStatue() //獲取PIN碼并顯示 devicemanager.setUserOperation(0) }, initStatue() { this.log('initStatue') const data = devicemanager.getAuthenticationParam() // 參數(shù)值轉換為 JSON 字符串寫入data this.log('getAuthenticationParam:' + JSON.stringify(data)) // Authentication type, 1 for pin code. // ode ==1,pin碼 if (data && data.authType == 1) { // 完整代碼見參考鏈接 }},

4）輸入PIN碼解析

當設備狀態(tài)"status = main-pin"，進到相關PIN碼輸入、校驗界面。

mainInputPin(s) { // 輸入六位數(shù)字 if (this.pinNumb == 6) return if (this.pinNumb < 6) { this.pin[this.pinNumb] = s ++this.pinNumb } if (this.pinNumb == 6) { console.log("verifyAuthInfo ok") this.verifyAuthInfo(this.pin.join('')) // PIN碼校驗 }????},?

自定義JSI原理和實現(xiàn)

JSI是OpenHarmony輕量和小型系統(tǒng)的一種JS API實現(xiàn)機制，適合封裝IO、CPU密集型、OS底層等能力給到JS應用調用，通過JSI可以實現(xiàn)JS與C/C++代碼互相訪問。與OpenHarmony 輕量級系統(tǒng)中涉及到的 audio、device、sensor 等需要與硬件打交道的JSI 模塊類似，CommunicationKit 和DeviceManager模塊同樣首先要加入到相關的配置文件中。ace_lite_engine 通過JSI::SetModuleAPI將JS應用中使用的關鍵字映射成C++函數(shù)。具體操作如下：

foundation/ace/ace_engine_lite/frameworks/module_manager/ohos_module_config.h中的OHOS_MODULES新增如下字段：

{"CommunicationKit", InitNativeApiCommunicationKit},{"devicemanager",InitDeviceManagerModule},

加載自定義模塊

如上所示，在JS應用外設控制界面中數(shù)據(jù)讀取和命令下發(fā)時，引入了CommunicationKit模塊，現(xiàn)在我們就看一下相關具體內容：

InitNativeApiCommunicationKit函數(shù)相關內容如下：

vendor/team_x/common/communicationkit/native_utils/src/nativeapi_communication_kit.cppvoid InitNativeApiCommunicationKit(JSIValue exports) { JSI::SetModuleAPI(exports, "get", NativeapiCommunicationKit::Get); // 與JS應用中的關鍵字一致 JSI::SetModuleAPI(exports, "set", NativeapiCommunicationKit::Set);} 相關C++實現(xiàn)NativeapiCommunicationKit::Get 和Set 的方式類似，我們參考輕量系統(tǒng)源碼中其他模塊的實現(xiàn)，使用ExecuteAsyncWork函數(shù)。根據(jù)給定的參數(shù)創(chuàng)建一個異步工作，并將其分派給主應用程序任務處理程序。其獲取燃氣濃度邏輯在ExecuteGet實現(xiàn)，設置輕量系統(tǒng)燃氣告警閾值由ExecuteSet實現(xiàn)。函數(shù)args參數(shù)用來接收JS端傳過來的參數(shù)(JSIValue數(shù)組)，argsNum表示該數(shù)組長度。

ExecuteAsyncWork(thisVal, args, argsNum, ExecuteGet, false);ExecuteAsyncWork(thisVal,args,argsNum,ExecuteSet,false);

加載設備管理模塊

與自定義模塊類似，JS應用使用軟總線接口時，需要在應用執(zhí)行前加載設備管理模塊。設備管理模塊也是OpenHarmony系統(tǒng)中的重要組成部分，我們在標準系統(tǒng)中是通過NAPI的方式來加載相關模塊，而在我們輕量系統(tǒng)中，設備管理模塊是通過JSI的方式來加載的。首先看到InitDeviceManagerModule函數(shù)相關內容如下：

foundation/distributedhardware/devicemanager/interfaces/kits/js_mini/src/native_devicemanager_js.cppvoid InitDeviceManagerModule(JSIValue exports) { JSI::SetModuleAPI(exports, "createDeviceManager", DeviceManagerModule::CreateDeviceManager); ...... JSI::SetModuleAPI(exports, "startDeviceDiscovery", DeviceManagerModule::StartDeviceDiscoverSync); JSI::SetModuleAPI(exports, "stopDeviceDiscovery", DeviceManagerModule::StopDeviceDiscoverSync); JSI::SetModuleAPI(exports, "authenticateDevice", DeviceManagerModule::AuthenticateDevice); JSI::SetModuleAPI(exports, "verifyAuthInfo", DeviceManagerModule::VerifyAuthInfo); JSI::SetModuleAPI(exports, "setUserOperation", DeviceManagerModule::SetUserOperationSync); JSI::SetModuleAPI(exports, "getAuthenticationParam", DeviceManagerModule::GetAuthenticationParamSync); ......}

開發(fā)板端代碼開發(fā)說明

如下圖所示，我們從輕量系統(tǒng)軟總線設備的系統(tǒng)啟動流程出發(fā)，來分析軟總線應用執(zhí)行的相關要點。第一步：首先初始化軟總線server；第二步：注冊與軟總線相關的服務，例如PRC、設備管理DeviceManager服務；第三步：JS engine加載DeviceManager接口聲明；第四步：具體的RPC通信操作流程。

初始化軟總線服務

輕量系統(tǒng)設備啟動的啟動過程中，會注冊相關初始化軟總線服務線程。該線程中的主要內容就是調用InitSoftBusServer函數(shù)。該函數(shù)會初始化與軟總線相關的配置、發(fā)現(xiàn)、認證等相關操作。

軟總線相關服務注冊

服務是OpenHarmony系統(tǒng)中的一個重要概念，不同的功能模塊，不同線程/進程之間的調用接口，都統(tǒng)一抽象成了服務。利用服務機制，操作系統(tǒng)、驅動框架等提供的能力都能被包裝成服務提供給到應用調用。下面給大家具體介紹軟總線相關的服務注冊細節(jié)和要點。

SAMGR：作為中介者，管理Provider提供的能力，同時幫助Consumer發(fā)現(xiàn)Provider的能力。

Provider：服務的提供者，為系統(tǒng)提供能力（對外接口）。

PRC服務注冊

RPC：(Remote Procedure Call)用于跨設備跨進程間的通信，在輕量系統(tǒng)軟總線應用中，我們利用RPC能力實現(xiàn)了安全廚房項目中兩個設備的關聯(lián)控制，RPC服務注冊的具體內容如下：

1.創(chuàng)建相關的靜態(tài)服務對象；

static MiniService g_miniService = { .GetName = GetName, // 相關服務名為mini_sa_rpc .Initialize = Initialize, .MessageHandle = MessageHandle, .GetTaskConfig = GetTaskConfig, SERVER_IPROXY_IMPL_BEGIN, .Invoke = FeatureInvoke, // 對外提供Invoke方法，供RPC相關client端程序調用 IPROXY_END,}; 2.注冊相關的服務和缺省對象；

SAMGR_GetInstance()->RegisterService((Service *)&g_miniService); SAMGR_GetInstance()->RegisterDefaultFeatureApi(MINI_SERVICE,GET_IUNKNOWN(g_miniService));

設備管理服務注冊

如果沒注冊設備管理服務，那么相關軟總線能力也就無從談起。在輕量系統(tǒng)啟動時，執(zhí)行相關設備管理服務初始化動作，具體內容如下：

1)創(chuàng)建相關的靜態(tài)服務對象；

static DeviceManagerSamgrService service = { .GetName = GetName, // 相關服務名為dev_mgr_svc .Initialize = Initialize, .MessageHandle = MessageHandle, .GetTaskConfig = GetTaskConfig,}; 2)注冊相關的服務和缺省對象；

SAMGR_GetInstance()->RegisterService((Service *)&service)) ；SAMGR_GetInstance()->RegisterDefaultFeatureApi(DEVICE_MANAGER_SERVICE_NAME, GET_IUNKNOWN(service))； 3)執(zhí)行相關初始化動作。DeviceManager服務的初始化函數(shù)將完成相關狀態(tài)回調注冊和傳輸通道初始化，然后執(zhí)行相關Publish動作，做好接收發(fā)現(xiàn)消息的準備。

設備間RPC通信

在標準系統(tǒng)應用開發(fā)中，我們可以通過分布式數(shù)據(jù)庫和啟動遠程Ability的方式實現(xiàn)設備之間的通信，而在輕量系統(tǒng)中則通過RPC的方法來實現(xiàn)。在前面的內容中我們講了服務的概念，下面是拓展的相關原理圖：

Consumer：服務的消費者，調用服務提供的功能（對外接口）。

在完成軟總線組網后，如果檢測到燃氣度數(shù)超標后，按如下步驟即可實現(xiàn)對智能通風設備的控制：

1.獲取軟總線網絡中的相關節(jié)點信息；

GetAllNodeDeviceInfo("com.ohos.devicemanagerui", &nodeInfo, &infoNum); 2.獲取遠程節(jié)點發(fā)布的mini_sa_rpc服務中對應的IUnknown方法；

IUnknown *miniDefApi = SAMGR_GetInstance()->GetRemoteDefaultFeatureApi(nodeInfo[0]->networkId, "mini_sa_rpc"); 3.查詢服務所發(fā)布的相關能力，獲取指向具體API接口的指針miniInterface；

miniDefApi->QueryInterface(miniDefApi, 0, (void **) &miniInterface); 4.調用相關mini_sa_rpc對外提供的Invoke能力；

miniInterface->Invoke(miniInterface, 1, &reply, NULL, NULL);

操作體驗

1. 提前準備好安全廚房場景中的智能窗戶通風設備和智能燃氣告警設備，并完成相關的編譯和應用安裝動作；

2. 提前準備好正常工作的無線路由設備（請保證預設熱點名稱：test_wifi 密碼：12345678；是否能連接互聯(lián)網均可）

3. 將燃氣檢測設備和窗戶通風設備上電，確認兩個設備應用啟動正常和操作正常；

4. 按如下步驟將通風設備、燃氣檢測設備組成一個軟總線網絡：

● 分別點擊兩個設備應用界面右上角的軟總線配置圖標，進入軟總線配置界面；

● 點擊智能燃氣檢測設備應用發(fā)現(xiàn)圖標，間隔3S后點擊發(fā)起認證圖標；

● 點擊智能通風設備軟總線配置界面下的允許認證圖標，正常情況下會顯示一個6位數(shù)的PIN碼；

● 點擊智能燃氣檢測設備應用輸入PIN碼按鈕，進入數(shù)字鍵盤輸入PIN碼；

● 分別點擊兩個應用軟總線配置圖標左上角的返回按鍵，進入設備控制界面。

5. 設置燃氣檢測設備的閾值低于實際讀取的燃氣數(shù)值，燃氣檢測應用進入警報界面的同時會控制電機工作，自動通風換氣，保證家居的安全。待到實際燃氣數(shù)值低于設置的閾值時，則關閉電機。

參考鏈接

本項目中涉及到的參考資料和相關文檔路徑如下：

歐智通BES2600WM開發(fā)板快速上手學習路徑：

https://growing.openharmony.cn/mainPlay/learnPathMaps?id=17

輕量系統(tǒng)應用開發(fā)軟總線視頻課程：

https://www.bilibili.com/video/BV1BS4y1A7ry/?vd_source=fa133082ba4f0aaa5d2dae4f0a981ab3

設備管理模塊文檔：

https://gitee.com/openharmony/device_manager/blob/master/README_zh.md

智能燃氣檢測系統(tǒng)樣例：

https://growing.openharmony.cn/mainPlay/detail?sampleId=3935

智能窗戶通風系統(tǒng)樣例：

https://growing.openharmony.cn/mainPlay/detail?sampleId=3936

總結

從本文中可以看到與標準系統(tǒng)一樣應用都是調用設備管理模塊提供的相關接口來實現(xiàn)的軟總線發(fā)現(xiàn)、認證等功能，但是不同的地方在于標準系統(tǒng)使用了預制的DeviceManager_UI.hap來顯示PIN碼、輸入PIN碼。而輕量系統(tǒng)軟總線應用中，相關PIN碼顯示、PIN碼輸入需要自己調用相關接口。

與標準系統(tǒng)軟總線應用相比，目前輕量系統(tǒng)軟總線應用只實現(xiàn)了輕量系統(tǒng)設備之前數(shù)據(jù)流轉功能，輕量系統(tǒng)分布式拉起、分布式數(shù)據(jù)庫等功能待后續(xù)更新迭代。下一步還將研究如何利用軟總線來連接輕量系統(tǒng)和標準系統(tǒng)，敬請大家期待。

豐富多樣的OpenHarmony開發(fā)樣例離不開廣大合作伙伴和開發(fā)者的貢獻，如果你也想把自己開發(fā)的樣例分享出來，歡迎提交到OpenHarmony知識體系SIG倉庫。

審核編輯：何安