天天看点

鸿蒙os分布式总线,润小云解读鸿蒙OS系列(六):分布式软总线之discovery+COAP全流程...

简介

Discovery 是一种基于coap 通信协议的设备发现机制;Coap(Constrained Application Protocol)是一种可以使用在资源受限的物联网设备上,并支持可靠传输的轻量化类web协议。它详细规范定义在 RFC 7252, coap 协议支持IP多播, 即可以同时向多个设备发送请求,鸿蒙OS的设备发现功能也是基于这个特性;用户使用discovery功能时,需要保证发现端设备与被发现端设备在同一个局域网内,并且都能收到对方coap协议报文;目前discovery服务仅支持基于Wi-Fi通信方式的设备发现机制。

代码分析

代码目录结构如下图:

鸿蒙os分布式总线,润小云解读鸿蒙OS系列(六):分布式软总线之discovery+COAP全流程...

Discovery 对外提供PublishService() 接口来实现设备的发现功能,其函数实现解读如下:

鸿蒙os分布式总线,润小云解读鸿蒙OS系列(六):分布式软总线之discovery+COAP全流程...
鸿蒙os分布式总线,润小云解读鸿蒙OS系列(六):分布式软总线之discovery+COAP全流程...
鸿蒙os分布式总线,润小云解读鸿蒙OS系列(六):分布式软总线之discovery+COAP全流程...

PublishService主要的代码流程图如下,由于篇幅有限我们本次不做详细的介绍。

鸿蒙os分布式总线,润小云解读鸿蒙OS系列(六):分布式软总线之discovery+COAP全流程...

被发现端主要是通过PublishService()这个函数发布服务。PublishService()函数的实现在discovery_service.c文件中,我们来看看这个函数的主流程代码;

鸿蒙os分布式总线,润小云解读鸿蒙OS系列(六):分布式软总线之discovery+COAP全流程...

函数参数三个:

moduleName:调用者的模块名称

info:PublishInfo结构体,发布的信息

cb:发布成功或者失败的回调函数

在函数实现中,我们可以看到权限检查,参数检验,信号量创建之类等代码;这里就不做介绍;我们从初始化服务 InitService()函数看,

鸿蒙os分布式总线,润小云解读鸿蒙OS系列(六):分布式软总线之discovery+COAP全流程...

InitCommonManager() 函数主要是调用InitLocalDeviceInfo()给g_deviceInfo结构体初始化;

RegisterWifiCallback(WifiEventTrigger)函数将WifiEventTrigger(unsigned int para)函数赋值给全局变量g_wifiCallback

最主要看CoapInit()函数

鸿蒙os分布式总线,润小云解读鸿蒙OS系列(六):分布式软总线之discovery+COAP全流程...
鸿蒙os分布式总线,润小云解读鸿蒙OS系列(六):分布式软总线之discovery+COAP全流程...
鸿蒙os分布式总线,润小云解读鸿蒙OS系列(六):分布式软总线之discovery+COAP全流程...

这里面我们优先分析下CoapInitSocket() 和 CreateCoapListenThread()

CoapInitSocket()函数实现如下:

鸿蒙os分布式总线,润小云解读鸿蒙OS系列(六):分布式软总线之discovery+COAP全流程...
鸿蒙os分布式总线,润小云解读鸿蒙OS系列(六):分布式软总线之discovery+COAP全流程...

可以看到CoapInitSocket()函数里面其实就是调用了socket()函数创建了socket,然后调用bind()绑定到指定的ip跟port,然后将socket描述符赋值给全局变量g_serverFd。以便后面GetCoapServerSocket()函数调用获取socket描述符。

CreateCoapListenThread() 创建线程接收消息,函数实现如下;

鸿蒙os分布式总线,润小云解读鸿蒙OS系列(六):分布式软总线之discovery+COAP全流程...

CoapReadHandle 接收并处理收到的消息

鸿蒙os分布式总线,润小云解读鸿蒙OS系列(六):分布式软总线之discovery+COAP全流程...

HandleReadEvent函数实现如下,我们分别看看CoapSocketRecv()、COAP_SoftBusDecode()、PostServiceDiscover()函数;

鸿蒙os分布式总线,润小云解读鸿蒙OS系列(六):分布式软总线之discovery+COAP全流程...

CoapSocketRecv()实现就是调用recvfrom()接收消息。

鸿蒙os分布式总线,润小云解读鸿蒙OS系列(六):分布式软总线之discovery+COAP全流程...

收到消息放到recvBuffer里面  然后调用COAP_SoftBusDecode()解码收到的消息。解码之后放到decodePacket里面然后调用PostServiceDiscover()函数对接收到的消息进行回应。

PostServiceDiscover()函数代码如下:

鸿蒙os分布式总线,润小云解读鸿蒙OS系列(六):分布式软总线之discovery+COAP全流程...

其中GetServiceDiscoverInfo(),这个函数可以获取到对端的ip 和remoteUrl。

鸿蒙os分布式总线,润小云解读鸿蒙OS系列(六):分布式软总线之discovery+COAP全流程...
鸿蒙os分布式总线,润小云解读鸿蒙OS系列(六):分布式软总线之discovery+COAP全流程...

这里可以获取到设备信息,也就是deviceInfo 结构体成员如下:

鸿蒙os分布式总线,润小云解读鸿蒙OS系列(六):分布式软总线之discovery+COAP全流程...

获取到这些信息之后我们就可以调用CoapResponseService()函数回复消息了。这里就看看主要的回复消息流程,其他的流程有兴趣可以自己继续钻研。

鸿蒙os分布式总线,润小云解读鸿蒙OS系列(六):分布式软总线之discovery+COAP全流程...
鸿蒙os分布式总线,润小云解读鸿蒙OS系列(六):分布式软总线之discovery+COAP全流程...
鸿蒙os分布式总线,润小云解读鸿蒙OS系列(六):分布式软总线之discovery+COAP全流程...

调用socket()创建socket 并将socket描述符返回跟全局变量g_clientFd,以便后面函数GetCoapClientSocket()获取socket描述符。

鸿蒙os分布式总线,润小云解读鸿蒙OS系列(六):分布式软总线之discovery+COAP全流程...

调用sendto发送消息。

此文档只是介绍了收发消息的主要流程,其他的细节这里并没有详细介绍。感兴趣的同学可以根据这个主流程继续钻研下其他的功能实现。