鴻蒙實戰開發：【分布式軟總線組件】
簡介
現實中多設備間通信方式多種多樣(WIFI、藍牙等)，不同的通信方式使用差異大，導致通信問題多；同時還面臨設備間通信鏈路的融合共享和沖突無法處理等挑戰。分布式軟總線實現近場設備間統一的分布式通信管理能力，提供不區分鏈路的設備間發現連接、組網和傳輸能力，主要功能如下：
- 發現連接：提供基于Wifi、藍牙等通信方式的設備發現連接能力。
- 設備組網：提供統一的設備組網和拓撲管理能力，為數據傳輸提供已組網設備信息。
- 數據傳輸：提供數據傳輸通道，支持消息、字節、流、文件的數據傳輸能力。
業務方通過使用分布式軟總線提供的API實現設備間的高速通信，不用關心通信細節，進而實現業務平臺的高效部署與運行能力。
系統架構
圖 1 分布式軟總線組件架構圖
約束
- 組網設備需在同一局域網中 或者 距離相近的近場設備間。
- 組網之前，需先完成設備綁定，綁定流程參見安全子系統中說明。
- 傳輸完成數據收發之后，業務要主動關閉會話，釋放資源。
說明
使用說明
須知： 使用跨設備通信時，必須添加權限
ohos.permission.DISTRIBUTED_DATASYNC和ohos.permission.DISTRIBUTED_SOFTBUS_CENTER，該權限類型為 dangerous 。
設備主動發現手機時，手機需打開超級終端的允許被“附近設備”發現開關（設置-超級終端-我的設備-允許被發現-附近設備），才能被設備發現。
1、發現
- 發布流程
- 上層應用需要對外發布自身能力時，調用服務發布接口發布自身能力。
// 發布回調 typedef struct { /** Callback for publish result */ void (*OnPublishResult)(int publishId, PublishResult reason); } IPublishCb; // 發布服務 int32_t PublishLNN(const char *pkgName, const PublishInfo *info, const IPublishCb *cb); - 上層應用不再需要對外發布自身能力時，調用StopPublishLNN接口注銷服務。
// 注銷服務 int32_t StopPublishLNN(const char *pkgName, int32_t publishId);
- 發現流程
- 上層應用需要發現特定能力設備時，調用發現接口啟動發現。
// 發現回調 typedef struct { /** Callback that is invoked when a device is found */ void (*OnDeviceFound)(const DeviceInfo *device); /** Callback for a subscription result */ void (*OnDiscoverResult)(int32_t refreshId, RefreshResult reason); } IRefreshCallback; // 發現服務 int32_t RefreshLNN(const char *pkgName, const SubscribeInfo *info, const IRefreshCallback *cb); - 當軟總線發現到設備時，通過回調接口通知業務所發現的設備信息。
- 上層應用不再需要發現時，調用StopRefreshLNN接口停止設備發現。
// 停止發現 int32_t StopRefreshLNN(const char *pkgName, int32_t refreshId);
2、組網
- 發起組網請求，攜帶組網連接地址信息，并且提供組網執行結果回調函數。
// 組網連接地址 typedef struct { ConnectionAddrType type; union { struct BrAddr { char brMac[BT_MAC_LEN]; } br; struct BleAddr { char bleMac[BT_MAC_LEN]; uint8_t udidHash[UDID_HASH_LEN]; } ble; struct IpAddr { char ip[IP_STR_MAX_LEN]; uint16_t port; } ip; } info; char peerUid[MAX_ACCOUNT_HASH_LEN]; } ConnectionAddr; // 組網連接地址類型 typedef enum { CONNECTION_ADDR_WLAN = 0, CONNECTION_ADDR_BR, CONNECTION_ADDR_BLE, CONNECTION_ADDR_ETH, CONNECTION_ADDR_MAX } ConnectionAddrType; // 組網請求執行結果回調 typedef void (*OnJoinLNNResult)(ConnectionAddr *addr, const char *networkId, int32_t retCode); // 發起組網請求 int32_t JoinLNN(const char *pkgName, ConnectionAddr *target, OnJoinLNNResult cb); - 等待組網結果，JoinLNN()返回成功表示軟總線接受了組網請求，組網結果通過回調函數通知業務；組網回調函數中addr參數內容和JoinLNN()的入參互相匹配；retCode如果為0，表示組網成功，此時networkId為有效值，后續傳輸、退網等接口均需使用該參數；retCode如果不為0，表示組網失敗，此時networkId為無效值。
- 使用傳輸相關接口進行數據傳輸。
- 發送退網請求，攜帶組網成功后返回的networkId，并且提供退網執行結果回調。
// 退網執行結果回調 typedef void (*OnLeaveLNNResult)(const char *networkId, int32_t retCode); // 退網請求 int32_t LeaveLNN(const char *pkgName, const char *networkId, OnLeaveLNNResult cb); - 等待退網完成，OnLeaveLNNResult()的networkId和退網請求接口中的networkId互相匹配；retCode為0表示退網成功，否則退網失敗。退網成功后，networkId變為無效值，后續不應該被繼續使用。
- 使用節點（即設備）注冊和注銷接口，監聽網絡中節點狀態變化等事件。
// 事件掩碼 #define EVENT_NODE_STATE_ONLINE 0x1 #define EVENT_NODE_STATE_OFFLINE 0x02 #define EVENT_NODE_STATE_INFO_CHANGED 0x04 #define EVENT_NODE_STATUS_CHANGED 0x08 #define EVENT_NODE_STATE_MASK 0xF // 節點信息 typedef struct { char networkId[NETWORK_ID_BUF_LEN]; char deviceName[DEVICE_NAME_BUF_LEN]; uint16_t deviceTypeId; } NodeBasicInfo; // 節點狀態事件回調 typedef struct { uint32_t events; // 組網事件掩碼 void (*onNodeOnline)(NodeBasicInfo *info); // 節點上線事件回調 void (*onNodeOffline)(NodeBasicInfo *info); // 節點下線事件回調 void (*onNodeBasicInfoChanged)(NodeBasicInfoType type, NodeBasicInfo *info); // 節點信息變化事件回調 void (*onNodeStatusChanged)(NodeStatusType type, NodeStatus *status); // 設備運行狀態變化事件回調 } INodeStateCb; // 注冊節點狀態事件回調 int32_t RegNodeDeviceStateCb(const char *pkgName, INodeStateCb *callback); // 注銷節點狀態事件回調 int32_t UnregNodeDeviceStateCb(INodeStateCb *callback);
3、傳輸
- 創建Socket。
typedef struct { char *name; // 本端Socket名稱 char *peerName; // 對端Socket名稱 char *peerNetworkId; // 對端Socket的網絡ID char *pkgName; // 調用者包名 TransDataType dataType; // 傳輸的數據類型，需要與發送方法一致 } SocketInfo; // 創建Socket int32_t Socket(SocketInfo info); - 服務端啟動監聽，客戶端進行綁定。
// Socket回調函數 typedef struct { void (*OnBind)(int32_t socket, PeerSocketInfo info); void (*OnShutdown)(int32_t socket, ShutdownReason reason); void (*OnBytes)(int32_t socket, const void *data, uint32_t dataLen); void (*OnMessage)(int32_t socket, const void *data, uint32_t dataLen); void (*OnStream)(int32_t socket, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param); void (*OnFile)(int32_t socket, FileEvent *event); void (*OnQos)(int32_t socket, QoSEvent eventId, const QosTV *qos, uint32_t qosCount); } ISocketListener; typedef enum { QOS_TYPE_MIN_BW, // 最小帶寬 QOS_TYPE_MAX_LATENCY, // 最大建鏈時延 QOS_TYPE_MIN_LATENCY, // 最小建鏈時延 QOS_TYPE_MAX_WAIT_TIMEOUT, // 最大超時時間 QOS_TYPE_MAX_BUFFER, // 最大緩存 QOS_TYPE_FIRST_PACKAGE, // 首包大小 QOS_TYPE_MAX_IDLE_TIMEOUT, // 最大空閑時間 QOS_TYPE_TRANS_RELIABILITY, // 傳輸可靠性 QOS_TYPE_BUTT, } QosType; typedef struct { QosType qos; int32_t value; } QosTV; // 監聽Socket，由服務端開啟。 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener); // 綁定Socket，由客戶端開啟。 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener); - 通過Socket向對端設備發送數據。
// 發送字節數據 int32_t SendBytes(int32_t socket, const void *data, uint32_t len); // 發送消息數據 int32_t SendMessage(int32_t socket, const void *data, uint32_t len); // 發送流數據# 分布式軟總線組件 int32_t SendStream(int32_t socket, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param); // 發送文件 int32_t SendFile(int32_t socket, const char *sFileList[], const char *dFileList[], uint32_t fileCnt); - 關閉Socket。
// 關閉Socket void Shutdown(int32_t socket);
審核編輯 黃宇
聲明：本文內容及配圖由入駐作者撰寫或者入駐合作網站授權轉載。文章觀點僅代表作者本人，不代表電子發燒友網立場。文章及其配圖僅供工程師學習之用，如有內容侵權或者其他違規問題，請聯系本站處理。
舉報投訴
-
總線
+關注
關注
10文章
2891瀏覽量
88162 -
分布式
+關注
關注
1文章
908瀏覽量
74558 -
鴻蒙
+關注
關注
57文章
2369瀏覽量
42899
發布評論請先 登錄
相關推薦
HarmonyOS Next 應用元服務開發-分布式數據對象遷移數據權限與基礎數據
設備文件訪問實現文件的遷移，難以獲取文件同步完成的時間。為了保證更高的成功率，文件的遷移不建議繼續通過該方式實現，推薦使用分布式數據對象攜帶資產的方式。開發者此前通過跨設備文件訪問實現的文件遷移依然生效
發表于 12-24 09:40
【書籍評測活動NO.53】鴻蒙操作系統設計原理與架構
的底層設計邏輯出發，針對不同關鍵子系統的目標功能和實現路徑做實際分析解讀，幫助開發者理解鴻蒙操作系統的底層邏輯，開發更適合系統邏輯的架構代碼。
以分布式
發表于 12-16 15:10
鴻蒙ArkTS聲明式開發：跨平臺支持列表【分布式遷移標識】 通用屬性
組件的分布式遷移標識，指明了該組件在分布式遷移場景下可以將特定狀態恢復到對端設備。
鴻蒙開發接口數據管理：【@ohos.data.distributedData (分布式數據管理)】
分布式數據管理為應用程序提供不同設備間數據庫的分布式協同能力。通過調用分布式數據各個接口，應用程序可將數據保存到分布式數據庫中，并可對分布式
HarmonyOS開發實例：【分布式數據服務】
分布式數據服務(Distributed Data Service，DDS)為應用程序提供不同設備間數據分布式的能力。
HarmonyOS實戰案例：【分布式賬本】
Demo基于Open Harmony系統使用ETS語言進行編寫，本Demo主要通過設備認證、分布式拉起、分布式數據管理等功能來實現。
OpenHarmony南向開發案例：【分布式畫板】
使用OpenHarmony3.1-Release開發的應用。通過OpenHarmony的分布式技術，使多人能夠一起畫畫。
鴻蒙HarmonyOS開發實戰：【分布式音樂播放】
本示例使用fileIo獲取指定音頻文件，并通過AudioPlayer完成了音樂的播放完成了基本的音樂播放、暫停、上一曲、下一曲功能；并使用DeviceManager完成了分布式設備列表的顯示和分布式能力完成了音樂播放狀態的跨設備分享。
鴻蒙實戰項目開發：【短信服務】
兩位前阿里高級研發工程師聯合打造的 《鴻蒙NEXT星河版OpenHarmony開發文檔》 里面內容包含了（ArkTS、ArkUI開發組件、Stage模型、多端部署、
發表于 03-03 21:29
鴻蒙OS 分布式任務調度
鴻蒙OS 分布式任務調度概述 在 HarmonyO S中，分布式任務調度平臺對搭載 HarmonyOS 的多設備構筑的“超級虛擬終端”提供統一的組件管理能力，為應用定義統一的能力基線、
工商網監
評論