mqttnet简记

1.mqttnet开源库&＃xff0c;https://github.com/chkr1011/MQTTnet

2.服务器端和客户端

服务器端和客户端两个&＃xff0c;他们需要保持长连接&＃xff0c;主要是通过订阅和发布来进行消息的传递交换。

MQTT 服务端主要用于与多个客户端保持连接&＃xff0c;并处理客户端的发布和订阅等逻辑。一般很少直接从服务端发送消息给客户端&＃xff08;可以使用 mqttServer.Publish(appMsg); 直接发送消息&＃xff09;&＃xff0c;多数情况下服务端都是转发主题匹配的客户端消息&＃xff0c;在系统中起到一个中介的作用。

而客户端主要是通过向服务端订阅它感兴趣&＃xff08;主题&＃xff09;的消息&＃xff0c;另一些客户端向服务端发布&＃xff08;主题&＃xff09;消息&＃xff0c;服务端将订阅和发布的主题进行匹配&＃xff0c;并将消息转发给匹配通过的客户端。

3连接&＃xff0c;通信

&＃xff08;1&＃xff09;服务器端启动服务&＃xff1a;

 public static IMqttServer mqttServer &＃61; null;

// 配置一个mqtt服务.
var optionsBuilder &＃61; new MqttServerOptionsBuilder()
//连接记录数&＃xff0c;默认 一般为2000
.WithConnectionBacklog(2000)
//服务器连接端口
.WithDefaultEndpointPort(port)
//连接验证器
.WithConnectionValidator(ValidatingMqttClients())
//持续会话
.WithPersistentSessions()

;
// 建立一个MQTT服务.
mqttServer &＃61; new MqttFactory().CreateMqttServer();
mqttServer.ApplicationMessageReceived &＃43;&＃61; MqttServer_ApplicationMessageReceived;
mqttServer.ClientSubscribedTopic &＃43;&＃61; MqttServer_ClientSubscribedTopic;
mqttServer.ClientUnsubscribedTopic &＃43;&＃61; MqttServer_ClientUnsubscribedTopic;
mqttServer.ClientConnected &＃43;&＃61; MqttServer_ClientConnected;
mqttServer.ClientDisconnected &＃43;&＃61; MqttServer_ClientDisconnected;

//启动mqtt服务
await Task.Run(async () &＃61;> { await mqttServer.StartAsync(optionsBuilder.Build()); });

&＃xff08;2&＃xff09;客户端

与服务器端连接

连接语句&＃xff1a;

 private IMqttClient mqttClient &＃61; null; 

//实例化 创建客户端对象
var Factory &＃61; new MqttFactory();
mqttClient &＃61; Factory.CreateMqttClient();
mqttClient.ApplicationMessageReceived &＃43;&＃61; MqttClient_ApplicationMessageReceived;
mqttClient.Connected &＃43;&＃61; MqttClient_Connected;
mqttClient.Disconnected &＃43;&＃61; MqttClient_Disconnected;

//调用异步方法连接到服务端

await mqttClient.ConnectAsync(option());

option的信息设置&＃xff1a;

public IMqttClientOptions option()
{
//连接到服务器前&＃xff0c;获取所需要的MqttClientTcpOptions 对象的信息
var options &＃61; new MqttClientOptionsBuilder()
.WithClientId(ClientId)                    // clientid是设备id
.WithTcpServer(IP, Port)              //onenet ip&＃xff1a;183.230.40.39    port:6002
.WithCredentials(UserName,pwd)      //username为产品id       密码为鉴权信息或者APIkey
//.WithTls()//服务器端没有启用加密协议&＃xff0c;这里用tls的会提示协议异常
.WithCleanSession(false)
.WithKeepAlivePeriod(TimeSpan.FromSeconds(2000))
.Build();
return options;
}

连接上以后订阅主题&＃xff1a;

发布主题&＃xff1a;

4.

服务端支持 ClientConnected、ClientDisconnected 和 ApplicationMessageReceived 事件&＃xff0c;分别用来检查客户端连接、客户端断开以及接收客户端发来的消息。

客户端支持 Connected、Disconnected 和 ApplicationMessageReceived 事件&＃xff0c;用来处理客户端与服务端连接、客户端从服务端断开以及客户端收到消息的事情。

5.

通过 mqtt接入onenet&＃xff0c;其实也就是把onenet 平台当做mqtt broker&＃xff0c;连接上稍作改变就可以了。