c#编写mqtt客户端

好的，以下是使用 C# 编写 MQTT 客户端的示例代码，需要使用 MQTTnet 库：

using System;
using System.Text;
using System.Threading;
using MQTTnet;
using MQTTnet.Client;
using MQTTnet.Client.Options;

namespace MqttClientDemo
{
    class Program
    {
        static async Task Main(string[] args)
        {
            var factory = new MqttFactory();
            var client = factory.CreateMqttClient();

            var options = new MqttClientOptionsBuilder()
                .WithTcpServer("broker.emqx.io")
                .WithClientId("MqttClientDemo")
                .WithCredentials("username", "password")
                .WithCleanSession()
                .Build();

            await client.ConnectAsync(options);

            Console.WriteLine("连接到 MQTT 服务器成功！");

            var topic = new MqttTopicFilterBuilder()
                .WithTopic("topic/test")
                .Build();

            await client.SubscribeAsync(topic);

            Console.WriteLine("订阅主题成功！");

            client.UseApplicationMessageReceivedHandler(e =>
            {
                Console.WriteLine($"接收到主题：{e.ApplicationMessage.Topic}，消息：{Encoding.UTF8.GetString(e.ApplicationMessage.Payload)}");
            });

            while (true)
            {
                Console.Write("请输入要发布的消息：");
                var message = Console.ReadLine();

                var mqttMessage = new MqttApplicationMessageBuilder()
                    .WithTopic("topic/test")
                    .WithPayload(message)
                    .WithExactlyOnceQoS()
                    .WithRetainFlag()
                    .Build();

                await client.PublishAsync(mqttMessage);

                Console.WriteLine("消息发送成功！");
            }
        }
    }
}

在上述示例代码中，我们使用 MQTTnet 库创建了一个 MQTT 客户端，并连接到了一个公共的 MQTT 服务器（broker.emqx.io）。我们订阅了一个主题（topic/test），并使用 `UseApplicationMessageReceivedHandler` 方法处理接收到的消息。同时，我们还可以使用 `MqttApplicationMessageBuilder` 创建一个 MQTT 消息，并使用 `PublishAsync` 方法将其发布到指定的主题。

需要注意的是，在实际应用中，我们需要根据实际的业务需求，选择合适的 MQTT 服务器和主题，以及正确的连接方式、QoS 等参数。