在Net8.0中使用 MQTTnet 开源库实现 MQTT 应用程序开发（实践） ...

1. 先容

MQTTnet 是一个强大的开源 MQTT 客户端库，适用于 C# 平台。它提供了丰富的功能和灵活的 API，可以轻松地构建基于 MQTT 协议的应用程序。本文将逐步学习如何使用 MQTTnet 库创建 MQTT 客户端，并实现根本的发布、订阅功能。
简介

什么是MQTT?

MQTT的发布和订阅架构

2. 搭建MQTT Broker

在Windows 系统上搭建 MQTT Broker，前一篇文章 Docker部署Eclipse Mosquitto开源MQTT的消息署理情况步调（实践），我们使用docker搭建了Mosquitto情况。如果你以为比较麻烦，也可以使用软件包来搭建情况。

详细的搭建步调，可以查看官网。
3. 安装MQTTnet库

通过 NuGet 包管理器将 MQTTnet 库添加到我们的项目中。

4. 项目编码开发

1. MqttSubscriber项目

• 新建MqttSubscriber项目。
  
  
  
  
• 配置引用MQTTnet库
  

1. <Project Sdk="Microsoft.NET.Sdk">
2.   <PropertyGroup>
3.     <OutputType>Exe</OutputType>
4.     <TargetFramework>net8.0</TargetFramework>
5.     <ImplicitUsings>enable</ImplicitUsings>
6.     <Nullable>enable</Nullable>
7.   </PropertyGroup>
8.         <ItemGroup>
9.                 <PackageReference Include="MQTTnet" Version="4.3.3.952" />
10.                 <PackageReference Include="MQTTnet.Extensions.ManagedClient" Version="4.3.3.952" />
11.         </ItemGroup>
13. </Project>

复制代码

• 编写订阅代码
  

1. using System.Text;
2. using MQTTnet;
3. using MQTTnet.Client;
5. class Program
6. {
7.     static async Task Main(string[] args)
8.     {
9.         var options = new MqttClientOptionsBuilder()
10.             .WithTcpServer("localhost", 1883)
11.             .WithCredentials("root","root")
12.             .Build();
14.         var factory = new MqttFactory();
15.         var mqttClient = factory.CreateMqttClient();
17.         mqttClient.ApplicationMessageReceivedAsync += MqttClient_ApplicationMessageReceivedAsync;
19.         await mqttClient.ConnectAsync(options);
20.         await mqttClient.SubscribeAsync("testtopic");
22.         Console.WriteLine("Press any key to exit.");
23.         Console.ReadKey();
25.         await mqttClient.DisconnectAsync();
26.     }
28.     private static Task MqttClient_ApplicationMessageReceivedAsync(MqttApplicationMessageReceivedEventArgs arg)
29.     {
30.         Console.WriteLine($"Received message: {Encoding.UTF8.GetString(arg.ApplicationMessage.PayloadSegment)}");
31.         return Task.CompletedTask;
32.     }
33. }

复制代码

2. MqttPublisher项目

• 新建MqttPublisher项目。
  
  
  
  
• 配置引用MQTTnet库
  

1. <Project Sdk="Microsoft.NET.Sdk">
2.   <PropertyGroup>
3.     <OutputType>Exe</OutputType>
4.     <TargetFramework>net8.0</TargetFramework>
5.     <ImplicitUsings>enable</ImplicitUsings>
6.     <Nullable>enable</Nullable>
7.   </PropertyGroup>
8.         <ItemGroup>
9.                 <PackageReference Include="MQTTnet" Version="4.3.3.952" />
10.                 <PackageReference Include="MQTTnet.Extensions.ManagedClient" Version="4.3.3.952" />
11.         </ItemGroup>
13. </Project>

复制代码

• 编写发布代码
  

1. using System;
2. using System.Text;
3. using System.Threading.Tasks;
4. using MQTTnet;
5. using MQTTnet.Client;
6. using MQTTnet.Extensions.ManagedClient;
8. class Program
9. {
10.     static async Task Main(string[] args)
11.     {
12.         var options = new MqttClientOptionsBuilder()
13.             .WithTcpServer("localhost", 1883)
14.             .WithCredentials("root", "root")
15.             .Build();
17.         var factory = new MqttFactory();
18.         var mqttClient = factory.CreateMqttClient();
20.         var managedMqttClient = new MqttFactory().CreateManagedMqttClient();
21.         await managedMqttClient.SubscribeAsync("testtopic");
23.         await mqttClient.ConnectAsync(options);
24.         bool bcontinue = true;
25.         while (bcontinue)
26.         {
27.             string input = $"{DateTime.Now.ToString("HH:mm:ss fff")}:{Guid.NewGuid().ToString()}";           
28.             Console.WriteLine(input);
29.             var message = new MqttApplicationMessageBuilder()
30.                 .WithTopic("testtopic")
31.                 .WithPayload(Encoding.UTF8.GetBytes(input))
32.                 .WithQualityOfServiceLevel(MQTTnet.Protocol.MqttQualityOfServiceLevel.ExactlyOnce)
33.                 .WithRetainFlag()
34.                 .Build();
36.             await mqttClient.PublishAsync(message);
37.         }
39.         await managedMqttClient.StopAsync();
40.     }
41. }

复制代码

• 调试运行
  
  
  
  

5. 参考文档

• MQTT - The Standard for IoT Messaging
  
• Getting started
  
• 在.NET7中使用MQTTnet简单实现MQTT通讯 - 翔星 - 博客园
  

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。