使用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企服之家，中国第一个企服评测及商务社交产业平台。