c# mqttnet

using System;
using System.Text;
using System.Threading.Tasks;
using MQTTnet;
using MQTTnet.Client;
using MQTTnet.Client.Connecting;
using MQTTnet.Client.Disconnecting;
using MQTTnet.Client.Options;
using MQTTnet.Client.Receiving;

class Program
{
    static async Task Main(string[] args)
    {
        // 创建MQTT客户端工厂
        var factory = new MqttFactory();
        var mqttClient = factory.CreateMqttClient();

        // 配置客户端连接选项
        var options = new MqttClientOptionsBuilder()
            .WithTcpServer("broker.hivemq.com", 1883) // MQTT代理服务器地址和端口
            .Build();

        // 处理连接成功事件
        mqttClient.UseConnectedHandler(async e =>
        {
            Console.WriteLine("客户端已连接");

            // 订阅主题
            var subscribeOptions = new TopicFilterBuilder().WithTopic("test/topic").Build();
            await mqttClient.SubscribeAsync(subscribeOptions);
            Console.WriteLine("已订阅主题: test/topic");
        });

        // 处理接收到消息事件
        mqttClient.UseApplicationMessageReceivedHandler(e =>
        {
            Console.WriteLine($"收到消息: {Encoding.UTF8.GetString(e.ApplicationMessage.Payload)}");
        });

        // 连接到MQTT代理
        await mqttClient.ConnectAsync(options);

        // 发布消息到指定主题
        var message = new MqttApplicationMessageBuilder()
            .WithTopic("test/topic")
            .WithPayload("Hello MQTTNet!")
            .Build();

        await mqttClient.PublishAsync(message);
        Console.WriteLine("消息已发布");

        // 等待一段时间以确保消息被处理
        await Task.Delay(TimeSpan.FromSeconds(10));

        // 断开连接
        await mqttClient.DisconnectAsync();
        Console.WriteLine("客户端已断开连接");
    }
}

解释说明：

1. 创建MQTT客户端工厂：使用MqttFactory创建一个MQTT客户端实例。
2. 配置客户端连接选项：通过MqttClientOptionsBuilder设置连接的MQTT代理服务器地址和端口。
3. 处理连接成功事件：当客户端成功连接到MQTT代理时，会触发UseConnectedHandler事件处理器，在这里可以执行订阅操作。
4. 处理接收到消息事件：当客户端接收到消息时，会触发UseApplicationMessageReceivedHandler事件处理器，并输出接收到的消息内容。
5. 连接到MQTT代理：使用ConnectAsync方法连接到指定的MQTT代理。
6. 发布消息：通过PublishAsync方法向指定的主题发布消息。
7. 等待一段时间：为了确保消息被处理，使用Task.Delay等待一段时间。
8. 断开连接：使用DisconnectAsync方法断开与MQTT代理的连接。

以上代码展示了如何使用C#和MQTTnet库来创建一个简单的MQTT客户端，连接到MQTT代理，订阅主题，接收消息以及发布消息。