MQTT协议c#代码使用实列

MQTT（Message Queuing Telemetry Transport）是一种轻量级的消息传输协议，常用于物联网设备之间的通信。在C#中使用MQTT协议，可以通过引入第三方库来实现。

一个常用的MQTT库是M2Mqtt，下面是一个使用M2Mqtt库的C#代码示例：

首先，你需要在项目中引入M2Mqtt库。你可以通过NuGet包管理器来安装M2Mqtt库。

然后，你可以使用以下代码来连接到MQTT服务器、发布消息和订阅主题：

using System;
using System.Text;
using uPLibrary.Networking.M2Mqtt;
using uPLibrary.Networking.M2Mqtt.Messages;

class Program
{
    static void Main(string[] args)
    {
        // 创建一个MQTT客户端实例
        MqttClient client = new MqttClient("broker.mqtt-dashboard.com");

        // 注册连接成功的回调函数
        client.MqttMsgConnected += Client_MqttMsgConnected;

        // 注册接收消息的回调函数
        client.MqttMsgPublishReceived += Client_MqttMsgPublishReceived;

        // 连接到MQTT服务器
        client.Connect(Guid.NewGuid().ToString());

        // 订阅主题
        client.Subscribe(new string[] { "topic1" }, new byte[] { MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE });

        // 发布消息
        string message = "Hello, MQTT!";
        client.Publish("topic1", Encoding.UTF8.GetBytes(message), MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE, false);

        // 等待用户输入，保持程序运行
        Console.ReadLine();

        // 断开与MQTT服务器的连接
        client.Disconnect();
    }

    private static void Client_MqttMsgConnected(object sender, MqttMsgConnectEventArgs e)
    {
        Console.WriteLine("Connected to MQTT broker.");
    }

    private static void Client_MqttMsgPublishReceived(object sender, MqttMsgPublishEventArgs e)
    {
        string message = Encoding.UTF8.GetString(e.Message);
        Console.WriteLine("Received message: " + message);
    }
}

上述代码中，我们首先创建了一个MqttClient实例，然后注册了连接成功和接收消息的回调函数。接着，我们使用client.Connect方法连接到MQTT服务器，并使用client.Subscribe方法订阅了一个主题。最后，我们使用client.Publish方法发布了一条消息，并通过Console.ReadLine方法等待用户输入，以保持程序运行。当接收到消息时，会触发Client_MqttMsgPublishReceived回调函数。