基于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