热门开源项目OpenHarmony

另一个具有代表性的OpenHarmony发行版KaihongOS，是面向全场景的万物智联技术底座，在OpenHarmony基础上技术创新和系统能力增强，深开鸿打造丰富KaihongOS产品矩阵，助力千行百业数智化转型，引领行业变革，构建万物智联新时代。是由原华为终端BG软件部总裁（现任深开鸿CEO）王成录牵头打造。

OpenHarmony在GitCode的地址：GitCode - 全球开发者的开源社区,开源代码托管平台

2.1.技术架构

OpenHarmony整体遵从分层设计，从下向上依次为：内核层、系统服务层、框架层和应用层。系统功能按照“系统 > 子系统 > 组件”逐级展开，在多设备部署场景下，支持根据实际需求裁剪某些非必要的组件。OpenHarmony技术架构如下所示：

热门开源项目OpenHarmony-LMLPHP

详细介绍可参考第2章的GitCode链接。

2.2.分布式软总线

这里我们选择分布式软总线来进行说明。

分布式软总线在GitCode的链接：GitCode - 全球开发者的开源社区,开源代码托管平台

在现实生活中，设备之间的通信方式多种多样，比如WIFI和蓝牙等，这些不同的通信方式在使用上存在较大差异，易导致各种通信问题。此外，还面临设备间通信链路融合共享以及冲突无法解决等挑战。分布式软总线通过实现近场设备间统一的分布式通信管理能力，提供一种不区分具体链路的设备发现、连接、组网和传输的通用能力。其主要功能如下：

通过使用分布式软总线提供的API，业务方可以在设备间实现高速通信，无需关注通信的具体细节，从而能够更高效地进行业务平台的部署与运行。

2.2.1.架构

热门开源项目OpenHarmony-LMLPHP

2.2.2.代码介绍

2.2.2.1.代码目录

/foundation/communication/dsoftbus
├── interfaces            # 接口代码
├── core                  # 核心代码
│   ├── common            # 通用代码
│   ├── adapter           # 适配层代码
│   ├── authentication    # 认证代码
│   ├── bus_center        # 组网代码
│   ├── connection        # 连接代码
│   ├── discovery         # 发现代码
│   ├── transmission      # 传输代码
│   └── frame             # 框架代码
├── sdk                   # 运行业务进程代码
│   ├── bus_center        # 组网代码
│   ├── discovery         # 发现代码
│   ├── transmission      # 传输代码
│   └── frame             # 框架代码
└── components            # 依赖组件代码

2.2.2.2.说明

约束：

须知：

2.2.2.3.发现组网和传输

2.2.2.3.1.发现

发布流程

a.上层应用需要对外发布自身能力时，调用服务发布接口发布自身能力。

// 发布回调
typedef struct {
    void (*OnPublishSuccess)(int publishId); //发布成功时回调
    void (*OnPublishFail)(int publishId, PublishFailReason reason);//发布失败时回调
} IPublishCallback;

// 发布服务
int PublishService(const char *pkgName, const PublishInfo *info, const IPublishCallback *cb);

b.上层应用不再需要对外发布自身能力时，调用UnpublishService接口注销服务。

// 注销服务
int UnPublishService(const char *pkgName, int publishId);

发现流程

a.上层应用需要发现特定能力设备时，调用发现接口启动发现。

// 发现回调
typedef struct {
    void (*OnDeviceFound)(const DeviceInfo *device); //发现设备回调
    void (*OnDiscoverFailed)(int subscribeId, DiscoveryFailReason failReason); //启动发现失败回调
    void (*OnDiscoverySuccess)(int subscribeId); //启动发现成功回调
} IDiscoveryCallback;

// 发现服务
int StartDiscovery(const char *pkgName, const SubscribeInfo *info, const IDiscoveryCallback *cb);

b.当软总线发现到设备时，通过回调接口通知业务所发现的设备信息。

c.上层应用不再需要发现时，调用StopDiscovery接口停止设备发现。

// 停止服务
int StopDiscovery(const char *pkgName, int subscribeId);

2.2.2.3.2.组网

a.发起组网请求，携带组网连接地址信息，并且提供组网执行结果回调函数。

// 组网连接地址
typedef struct {
    ConnectionAddrType type;
    union {
        struct BrAddr {
            char brMac[BT_MAC_LEN];
        } br;
        struct BleAddr {
            char bleMac[BT_MAC_LEN];
        } ble;
        struct IpAddr {
            char ip[IP_STR_MAX_LEN];
            int port;
        } ip;
    } info;
} 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(ConnectionAddr *target, OnJoinLNNResult cb);

b.等待组网结果，JoinLNN()返回成功表示软总线接受了组网请求，组网结果通过回调函数通知业务；组网回调函数中addr参数内容和JoinLNN()的入参互相匹配；retCode如果为0，表示组网成功，此时networkId为有效值，后续传输、退网等接口均需使用该参数；retCode如果不为0，表示组网失败，此时networkId为无效值。

c.使用传输相关接口进行数据传输。

d.发送退网请求，携带组网成功后返回的networkId，并且提供退网执行结果回调。

// 退网执行结果回调
typedef void (*OnLeaveLNNResult)(const char *networkId, int32_t retCode);

// 退网请求
int32_t LeaveLNN(const char *networkId, OnLeaveLNNResult cb);

e.等待退网完成，OnLeaveLNNResult()的networkId和退网请求接口中的networkId互相匹配；retCode为0表示退网成功，否则退网失败。退网成功后，networkId变为无效值，后续不应该被继续使用。

f.使用节点（即设备）注册和注销接口，监听网络中节点状态变化等事件。

// 事件掩码
#define EVENT_NODE_STATE_ONLINE 0x1
#define EVENT_NODE_STATE_OFFLINE 0x02
#define EVENT_NODE_STATE_INFO_CHANGED 0x04
#define EVENT_NODE_STATE_MASK 0x07

// 节点信息
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); // 节点信息变化事件回调
} INodeStateCb;

//  注册节点状态事件回调
int32_t RegNodeDeviceStateCb(INodeStateCb *callback);

// 注销节点状态事件回调
int32_t UnregNodeDeviceStateCb(INodeStateCb *callback);

2.2.2.3.3.传输

a.创建会话服务，并设置会话相关回调，用户可在回调中处理打开/关闭和消息接收事件。

// 会话管理回调
typedef struct {
    int (*OnSessionOpened)(int sessionId, int result);
    void (*OnSessionClosed)(int sessionId);
    void (*OnBytesReceived)(int sessionId, const void *data, unsigned int dataLen);
    void (*OnMessageReceived)(int sessionId, const void *data, unsigned int dataLen);
} ISessionListener;

// 创建会话服务
int CreateSessionServer(const char *pkgName, const char *sessionName, const ISessionListener* listener);

b.创建会话，用于收发数据。

// 创建会话
int OpenSession(const char *mySessionName, const char *peerSessionName, const char *peerDeviceId, const char *groupId, const SessionAttribute* attr);

c.通过sessionId向对端设备发送数据。

// 发送字节数据
int SendBytes(int sessionId, const void *data, unsigned int len);
// 发送消息数据
int SendMessage(int sessionId, const void *data, unsigned int len);

d.通过sessionId关闭会话。

// 关闭会话
void CloseSession(int sessionId);

e.删除会话服务。

// 删除会话服务
int RemoveSessionServer(const char *pkgName, const char *sessionName);

3.开源地址

OpenHarmony-GitCode：GitCode - 全球开发者的开源社区,开源代码托管平台

OpenHarmony-OpenAtom Foundation：OpenAtom OpenHarmony

分布式软总线-GitCode：GitCode - 全球开发者的开源社区,开源代码托管平台

ak2111