使用C#连接MQTT 进行数据接收和数据处理，QoS1 持久会话模式 解决服务掉选 ...

1、准备工作
在开始写代码之前，我们先要准备下写程序的
　　基础信息：MQTT地址、OrgID(机构ID)、API访问密钥
　　连接模式：QoS1, 持久会话 ，防止服务掉选数据丢失问题，具体模式根据实际情况而定
2、我们先创建个C#的控制台应用程序，然后写入以下代码：
 

1. // 创建MQTT客户端工厂
2.         var mqttFactory = new MqttFactory();
3.         var mqttClient = mqttFactory.CreateMqttClient();
5.         // 配置MQTT客户端选项
6.         var options = new MqttClientOptionsBuilder()
7.             .WithClientId("org-机构id-quickstart")  // 修改客户端ID
8.             .WithTcpServer("服务器地址", 1883) // 修改服务器地址，使用默认端口
9.             .WithCredentials("org-机构id", "秘钥") // 修改用户名
10.             .WithCleanSession(false)  // 添加这行，不清除会话
11.             .Build(); // 移除 TLS 配置，因为使用的是普通连接
13.         try
14.         {
15.             // 添加连接状态处理
16.             mqttClient.UseDisconnectedHandler(async e =>
17.             {
18.                 Console.WriteLine("已断开连接！正在尝试重新连接...");
19.                 await Task.Delay(TimeSpan.FromSeconds(5));
20.                 try
21.                 {
22.                     await mqttClient.ConnectAsync(options);
23.                 }
24.                 catch
25.                 {
26.                     Console.WriteLine("重新连接失败");
27.                 }
28.             });
30.             // 修改订阅主题以匹配您的格式
31.             string topic = "/device_sensor_data/机构id/+/+/+/+";
32.             
33.             // 添加订阅处理
34.             mqttClient.UseApplicationMessageReceivedHandler(e =>
35.             {
36.                 string payload = Encoding.UTF8.GetString(e.ApplicationMessage.Payload);
37.                 string topic = e.ApplicationMessage.Topic ?? "";
38.                
39.                 // 解析主题数据
40.                 string[] topicParts = topic.Split('/');
41.                 //将解析后的出具进行处理<br>
42.             });
44.             // 修改订阅配置
45.             var subscribeOptions = new MqttClientSubscribeOptionsBuilder()
46.                 .WithTopicFilter(topic, MqttQualityOfServiceLevel.AtLeastOnce)
47.                 .Build();
49.             // 连接后进行订阅
50.             await mqttClient.ConnectAsync(options);
51.             await mqttClient.SubscribeAsync(subscribeOptions);
52.             Console.WriteLine("已成功连接并订阅主题 (QoS1, 持久会话)");
55.             // 保持程序运行
56.             Console.WriteLine("按任意键退出...");
57.             Console.ReadKey();
59.             // 断开连接
60.             await mqttClient.DisconnectAsync();
61.         }
62.         catch (Exception ex)
63.         {
64.             Console.WriteLine($"发生错误: {ex.Message}");
65.         }

复制代码

　　
4、以下是程序接收到数据后的截图

 

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。