net core 如何使用mqtt

在 .NET Core 中使用 MQTT，需要使用一个 MQTT 客户端库。常用的 MQTT 客户端库包括：

MQTTnet：一个跨平台、高性能的 MQTT 客户端库，支持 .NET Core、.NET Framework 和 Xamarin。
Eclipse Paho MQTT：一个流行的跨平台 MQTT 客户端库，支持多种编程语言。
HiveMQ MQTT Client：一个基于 Java 实现的 MQTT 客户端库，提供了 .NET Core 的支持。

下面以 MQTTnet 为例，介绍如何在 .NET Core 中使用 MQTT。

安装 MQTTnet

可以通过 NuGet 安装 MQTTnet：

Install-Package MQTTnet

连接 MQTT 服务器

使用 MQTTnet 连接 MQTT 服务器需要创建一个 MqttClient 对象，然后调用 ConnectAsync 方法连接到服务器。下面是一个简单的例子：

using MQTTnet;
using MQTTnet.Client;
using MQTTnet.Client.Options;

var options = new MqttClientOptionsBuilder()
    .WithTcpServer("broker.hivemq.com", 1883) // 设置 MQTT 服务器地址和端口
    .WithClientId("mqtt-client") // 设置客户端 ID
    .Build();

var factory = new MqttFactory();
var client = factory.CreateMqttClient();

await client.ConnectAsync(options); // 连接到 MQTT 服务器

上面的代码创建了一个 MqttClient 对象，连接到了 broker.hivemq.com 的 1883 端口，并设置了一个客户端 ID。

发布消息

使用 MQTTnet 发布消息需要调用 PublishAsync 方法。下面是一个简单的例子：

var message = new MqttApplicationMessageBuilder()
    .WithTopic("my/topic")
    .WithPayload("Hello, MQTT!")
    .WithExactlyOnceQoS()
    .WithRetainFlag()
    .Build();

await client.PublishAsync(message); // 发布消息

上面的代码创建了一个 MQTT 消息，设置了主题、负载、QoS 和 retain 标志，并调用 PublishAsync 方法发布了消息。

订阅主题

使用 MQTTnet 订阅主题需要调用 SubscribeAsync 方法。下面是一个简单的例子：

var topicFilter = new TopicFilterBuilder()
    .WithTopic("my/topic")
    .WithExactlyOnceQoS()
    .Build();

await client.SubscribeAsync(topicFilter); // 订阅主题

上面的代码创建了一个主题过滤器，并调用 SubscribeAsync 方法订阅了主题。

接收消息

使用 MQTTnet 接收消息需要实现 IMqttApplicationMessageReceivedHandler 接口，然后调用 UseApplicationMessageReceivedHandler 方法注册消息处理程序。下面是一个简单的例子：

class MyMessageHandler : IMqttApplicationMessageReceivedHandler
{
    public Task HandleApplicationMessageReceivedAsync(MqttApplicationMessageReceivedEventArgs eventArgs)
    {
        Console.WriteLine($"Received message: {eventArgs.ApplicationMessage.Payload}");
        return Task.CompletedTask;
    }
}

var handler = new MyMessageHandler();
client.UseApplicationMessageReceivedHandler(handler); // 注册消息处理程序

上面的代码创建了一个消息处理程序，并调用 UseApplicationMessageReceivedHandler 方法注册了该处理程序。当接收到消息时，HandleApplicationMessageReceivedAsync 方法会被调用。这个例子中，只是简单地输出了消息的负载。

断开连接

使用 MQTTnet 断开连接需要调用 DisconnectAsync 方法。下面是一个简单的例子：

await client.DisconnectAsync(); // 断开连接

总结

以上就是在 .NET Core 中使用 MQTT 的基本步骤。当然，还有很多其他的高级功能，可以根据实际需求进行调整