消息通信

边缘节点提供了MQTT Broker作为应用间的消息分发模块,因此边缘应用之间可通过订阅或发布topic消息的模式收发消息。

MQTT Topic规范

边缘应用之间的Topic需要满足如下格式,且每级字段长度不超过64字节。

{srcApp}/{messageType}/{destApp}/{method}

参数 说明
{srcApp} 表示发布消息的边缘应用,{srcApp}应与创建的容器应用名称保持一致
{messageType} 表示消息的类型,目前仅支持三种:
· request: 表示消息为请求消息
· response:表示消息为响应消息
· notify:表示消息为事件通知消息
{destApp} 表示发布消息的目的边缘应用,{destApp}应与创建的容器应用名称保持一致
{method} 表示方法名,用于标识消息的作用

注意:oasis为代理应用的专用名称,容器应用名不可设定为oasis。

MQTT Topic使用

若需要获取其它边缘应用的MQTT消息,需要先订阅相应的topic。针对“request”和“response”的请求与响应模式,发布方的边缘应用应先订阅“response”的topic,再发布“request”的topic消息才能接收响应回复。

MQTT API接口

函数名 说明
MQTTAsync_connect MQTT client连接处理
MQTTAsync_send 发布MQTT消息
MQTTAsync_subscribe 订阅单条Topic消息
MQTTAsync_unsubscribe 取消订阅单条Topic消息
MQTTAsync_subscribeMany 订阅多条Topic消息
MQTTAsync_unsubscribeMany 取消订阅多条Topic消息

其他使用方法可参考Paho-MQTT C

© H3C IoT all right reserved,powered by Gitbook更新时间: 2021-11-24 17:53:45

results matching ""

    No results matching ""