最近项目里面需要用到MQTT，刚开始听到这个词一脸茫然，不知道是什么，最后通过自己百度整理一点资料，希望最大家有帮助。
在这里需要引用MQTTnet，可在解决方案在右键单击-选择“管理解决方案的 NuGet 程序包”-在“浏览”选项卡下面搜索 MQTTnet，为服务端项目和客户端项目都安装上 MQTTnet 库。示例中使用的是2.4版本，不同版本最低要求的.net版本或其它支持，在NuGet选中MQTTNet，右侧可以看到具体描述
1.首先创建一个winform项目作为服务端，MqttService
下面是代码的实例
复制代码
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279private MqttServer mqttServer=null; public Server_Form() { InitializeComponent(); MqttNetTrace.TraceMessagePublished += MqttNetTrace_TraceMessagePublished; this.button2.Enabled = false; } /// <summary> /// 开启连接 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void button1_Click(object sender, EventArgs e) { try { this.button1.Enabled = false; this.button2.Enabled = true; StartMqttServer(); } catch (Exception ex) { this.textBox1.AppendText("" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff") + "" + ex.Message + "" + " rnrn"); } } /// <summary> /// 断开连接 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void button2_Click(object sender, EventArgs e) { this.button1.Enabled = true; this.button2.Enabled = false; mqttServer.StopAsync(); this.textBox1.AppendText("" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff") + "MQTT服务停止成功！" + " rnrn"); } /// <summary> /// 清除日志 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void button3_Click(object sender, EventArgs e) { this.textBox1.Text = ""; } #region 自定义方法 /// <summary> /// MQTT服务开启 /// </summary> private void StartMqttServer() { if (mqttServer == null) { try { var options = new MqttServerOptions { ConnectionValidator = p => { if (p.ClientId == "c001") { if (p.Username != "u001" || p.Password != "p001") { return MqttConnectReturnCode.ConnectionRefusedBadUsernameOrPassword; } } return MqttConnectReturnCode.ConnectionAccepted; } }; mqttServer = new MqttServerFactory().CreateMqttServer(options) as MqttServer; mqttServer.ApplicationMessageReceived += MqttServer_ApplicationMessageReceived; mqttServer.ClientConnected += MqttServer_ClientConnected; mqttServer.ClientDisconnected += MqttServer_ClientDisconnected; } catch (Exception ex) { this.textBox1.AppendText("" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff") + "" + ex.Message + "" + " rnrn"); return; } } mqttServer.StartAsync(); this.textBox1.AppendText("" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff") + "MQTT服务启动成功！" + " rnrn"); } /// <summary> /// 客户端连接触发的事件 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void MqttServer_ClientConnected(object sender, MqttClientConnectedEventArgs e) { try { this.textBox1.AppendText("" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff") + "客户端[{" + e.Client.ClientId + "}]已连接，协议版本：{" + e.Client.ProtocolVersion + "}" + " rnrn"); } catch (Exception ex) { this.textBox1.AppendText("" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff") + "" + ex.Message + "" + " rnrn"); } } /// <summary> /// 客户端断开触发的事件 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void MqttServer_ClientDisconnected(object sender, MqttClientDisconnectedEventArgs e) { try { this.textBox1.AppendText("" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff") + "客户端[{" + e.Client.ClientId + "}]已断开连接！" + "" + " rnrn"); } catch (Exception ex) { this.textBox1.AppendText("" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff") + "" + ex.Message + "" + " rnrn"); } } /// <summary> /// 消息事件 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void MqttServer_ApplicationMessageReceived(object sender, MqttApplicationMessageReceivedEventArgs e) { try { this.textBox1.AppendText("" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff") + "客户端[{" + e.ClientId + "}]>> 主题：{" + e.ApplicationMessage.Topic + "} 负荷：{" + Encoding.UTF8.GetString(e.ApplicationMessage.Payload) + "} Qos：{" + e.ApplicationMessage.QualityOfServiceLevel + "} 保留：{" + e.ApplicationMessage.Retain + "}" + " rnrn"); } catch (Exception ex) { this.textBox1.AppendText("" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff") + "" + ex.Message + "" + " rnrn"); } } private void MqttNetTrace_TraceMessagePublished(object sender, MqttNetTraceMessagePublishedEventArgs e) { //Console.WriteLine($">> 线程ID：{e.ThreadId} 来源：{e.Source} 跟踪级别：{e.Level} 消息: {e.Message}"); //if (e.Exception != null) //{ // Console.WriteLine(e.Exception); //} }
界面就是以下
2.创建一个winform项目作为服务端，MqttClient
复制代码
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231private MqttClient mqttClient = null; public Client_Form1() { InitializeComponent(); Task.Run(async () => { await ConnectMqttServerAsync(); }); } /// <summary> /// 发布 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void button1_Click(object sender, EventArgs e) { string topic = txtPubTopic.Text.Trim(); if (string.IsNullOrEmpty(topic)) { MessageBox.Show("发布主题不能为空！"); return; } string inputString = txtSendMessage.Text.Trim(); var appMsg = new MqttApplicationMessage(topic, Encoding.UTF8.GetBytes(inputString), MqttQualityOfServiceLevel.AtMostOnce, false); mqttClient.PublishAsync(appMsg); } /// <summary> /// 订阅 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void button2_Click(object sender, EventArgs e) { string topic = txtSubTopic.Text.Trim(); if (string.IsNullOrEmpty(topic)) { MessageBox.Show("订阅主题不能为空！"); return; } if (!mqttClient.IsConnected) { MessageBox.Show("MQTT客户端尚未连接！"); return; } mqttClient.SubscribeAsync(new List<TopicFilter> { new TopicFilter(topic, MqttQualityOfServiceLevel.AtMostOnce) }); txtReceiveMessage.AppendText($"已订阅[{topic}]主题" + Environment.NewLine); txtSubTopic.Enabled = false; button2.Enabled = false; } #region 自定义方法 private async Task ConnectMqttServerAsync() { if (mqttClient == null) { mqttClient = new MqttClientFactory().CreateMqttClient() as MqttClient; mqttClient.ApplicationMessageReceived += MqttClient_ApplicationMessageReceived; mqttClient.Connected += MqttClient_Connected; mqttClient.Disconnected += MqttClient_Disconnected; } try { var options = new MqttClientTcpOptions { //Server = "127.0.0.1", Server = "192.168.16.207", ClientId = Guid.NewGuid().ToString().Substring(0, 5), UserName = "u0011123", Password = "p00112134", CleanSession = false, }; await mqttClient.ConnectAsync(options); } catch (Exception ex) { Invoke((new Action(() => { txtReceiveMessage.AppendText($"连接到MQTT服务器失败！" + Environment.NewLine + ex.Message + Environment.NewLine); }))); } } /// <summary> /// 连接触发事件 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void MqttClient_Connected(object sender, EventArgs e) { Invoke((new Action(() => { txtReceiveMessage.AppendText("已连接到MQTT服务器！" + Environment.NewLine); }))); } /// <summary> /// 断开连接触发事件 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void MqttClient_Disconnected(object sender, EventArgs e) { Invoke((new Action(() => { txtReceiveMessage.AppendText("已断开MQTT连接！" + Environment.NewLine); }))); } /// <summary> /// 消息事件 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void MqttClient_ApplicationMessageReceived(object sender,MqttApplicationMessageReceivedEventArgs e) { Invoke((new Action(() => { txtReceiveMessage.AppendText($">> {Encoding.UTF8.GetString(e.ApplicationMessage.Payload)}{Environment.NewLine}"); }))); }
界面
本人第一次写，有什么问题大家可以指出来，谢谢~~~~
给大家推荐一个平台：帐号已迁移
最后
以上就是疯狂戒指最近收集整理的关于.NET使用MQTT通信实例的全部内容，更多相关内容请搜索靠谱客的其他文章。
本图文内容来源于网友提供，作为学习参考使用，或来自网络收集整理，版权属于原作者所有。
发表评论 取消回复