介绍

MQTT（消息队列遥测传输）是一种轻量级消息传递协议，专为资源受限的环境而设计。MQTT 广泛应用于物联网 (IoT) 和机器对机器 (M2M) 通信。

本文将讨论如何在 .NET 7 中实现 MQTT 消费者。我们将使用 MQTTnet 库，这是 C# 中的高性能 MQTT 客户端库。

设置环境

要开始使用 .NET 7，您必须在系统上安装它。您可以从 .NET 官方网站下载并安装 .NET 7。

要使用 MQTTnet，您需要将 MQTTnet NuGet 包添加到您的项目中。您可以使用 Visual Studio 中的 NuGet 包管理器或 dotnet CLI 来完成此操作。

dotnet add package MQTTnet

实现 MQTT 消费者

您需要创建一个新的控制台应用程序来在 .NET 7 中实现 MQTT 消费者。在此示例中，我们将订阅一个主题并从 MQTT 代理接收消息。

using System;
using System.Threading;
using System.Threading.Tasks;
using MQTTnet;
using MQTTnet.Client;
using MQTTnet.Client.Options;
using MQTTnet.Client.Subscribing;
using MQTTnet.Protocol;
class Program {
static async Task Main(string[] args) {
var factory = new MqttFactory();
var client = factory.CreateMqttClient();
var options = new MqttClientOptionsBuilder().WithTcpServer("localhost", 1883).WithClientId("mqtt_consumer").Build();
client.UseConnectedHandler(async e => {
Console.WriteLine("Connected to MQTT broker.");
var topicFilter = new MqttTopicFilterBuilder().WithTopic("test/topic").Build();
await client.SubscribeAsync(new MqttClientSubscribeOptionsBuilder().WithTopicFilter(topicFilter).Build());
});
client.UseDisconnectedHandler(async e => {
Console.WriteLine("Disconnected from MQTT broker.");
await Task.Delay(TimeSpan.FromSeconds(5));
try {
await client.ConnectAsync(options, CancellationToken.None);
} catch {
Console.WriteLine("Reconnecting to MQTT broker failed.");
}
});
client.UseApplicationMessageReceivedHandler(e => {
Console.WriteLine($ "Received message on topic '{e.ApplicationMessage.Topic}': {Encoding.UTF8.GetString(e.ApplicationMessage.Payload)}");
});
try {
await client.ConnectAsync(options, CancellationToken.None);
} catch {
Console.WriteLine("Connecting to MQTT broker failed.");
}
Console.ReadLine();
}
}

上述代码创建了一个新的 MQTT 客户端，并订阅了“test/topic”主题。当收到该主题的消息时，会调用 UseApplicationMessageReceivedHandler 方法，并在控制台上显示该消息。

UseConnectedHandler 和 UseDisconnectedHandler 方法处理连接和断开连接事件。当客户端连接到 MQTT 代理时会调用 UseConnectedHandler 方法，当客户端与 MQTT 代理断开连接时会调用 UseDisconnectedHandler 方法。