基于MQTT Topic通信
1. 指定Topic进行订阅
发起订阅函数:SubscribeTopic()
,传入参数topic
为要订阅的MQTT Topic
消息订阅回调函数:OnTopicMessage()
,回调函数参数类MqttMessage
MqttMessage
类结构:
属性名称 | 属性类型 | 是否必填 | 描述 |
---|---|---|---|
qos | int |
是 | MQTT QoS 等级 |
topic | string |
是 | 完整MQTT Topic |
payload | byte[] |
是 | 报文内容 |
示例代码:
linkKit.SubscribeTopic("/sdkproduct/sdkdevice1/user/get");
linkKit.OnTopicMessage = e =>
{
Console.WriteLine($"Topic: {e.Topic}, Qos: {e.Qos}, Payload: {Encoding.UTF8.GetString(e.Payload)}");
};
2. 指定Topic进行消息发布
发布消息函数:PublishTopic()
,传入参数topic
为要发布的MQTT Topic
,payload
为要发布的消息内容
示例代码:
linkKit.PublishTopic("sys/data", payload);
3. 指定Topic进行取消订阅
取消订阅函数:UnsubscribeTopic()
,传入参数topic
为要取消订阅的MQTT Topic
示例代码:
linkKit.UnsubscribeTopic("/sdkproduct/sdkdevice1/user/get");
最后修改时间: 1 年前