C#使用MQTTnet快速实现MQTT通信Demo

共83个文件

dll：24个

cs：11个

cache：11个

5星 · 超过95%的资源需积分: 31 7 浏览量 2019-03-14 10:15:44 上传评论 45 收藏 2.19MB RAR 举报

在本文中，我们将深入探讨如何使用C#编程语言和MQTTnet库快速实现MQTT通信。MQTT（Message Queuing Telemetry Transport）是一种轻量级的发布/订阅式消息协议，广泛应用于物联网（IoT）场景，因为它具有低开销、高可靠性以及适用于受限网络的特点。在Windows 7环境下，使用Visual Studio 2017，我们可以轻松创建一个简单的MQTT客户端示例。确保已经安装了Visual Studio 2017，并创建一个新的C#控制台应用程序项目。接下来，我们需要引入MQTTnet库。可以通过NuGet包管理器安装，搜索“MQTTnet”并添加到项目中。 ```csharp Install-Package MQTTnet Install-Package MQTTnet.Extensions.ManagedClient ``` 一旦安装成功，我们就可以开始编写代码了。引入必要的命名空间： ```csharp using MQTTnet; using MQTTnet.Client; using MQTTnet.Client.Options; using MQTTnet.Extensions.ManagedClient; ``` 接下来，定义一个类，例如`MqttTest`，并设置MQTT客户端选项。这些选项包括服务器地址、端口、保持连接的时间间隔等： ```csharp public class MqttTest { public static async Task Main(string[] args) { var options = new ManagedMqttClientOptionsBuilder() .WithTcpServer("tcp://localhost:1883") // MQTT服务器地址和端口 .WithAutoReconnectDelay(TimeSpan.FromSeconds(5)) // 自动重连延迟 .Build(); } } ``` 在`Main`方法中，初始化MQTT客户端并连接到服务器： ```csharp var mqttFactory = new MqttFactory(); var managedMqttClient = mqttFactory.CreateManagedMqttClient(); await managedMqttClient.StartAsync(options); ``` 为了实现消息发布和订阅，我们需要定义两个方法：`PublishMessage`和`SubscribeToTopic`。发布消息时，提供主题和消息内容： ```csharp private static async Task PublishMessage(string topic, string message) { var publishPacket = new MqttApplicationMessageBuilder() .WithTopic(topic) .WithPayload(message) .WithExactlyOnceQoS() // 可选择QoS级别 .Build(); await managedMqttClient.PublishAsync(publishPacket); } ``` 订阅主题时，指定主题并提供一个处理接收到的消息的回调函数： ```csharp private static void SubscribeToTopic(string topic) { managedMqttClient.UseApplicationMessageReceivedHandler(e => { Console.WriteLine($"Received message on topic {e.ApplicationMessage.Topic}: {Encoding.UTF8.GetString(e.ApplicationMessage.Payload)}"); }); managedMqttClient.SubscribeAsync(new TopicFilterBuilder().WithTopic(topic).Build()); } ``` 现在，你可以调用这些方法来测试你的MQTT客户端。例如，订阅一个主题并发布一条消息： ```csharp await SubscribeToTopic("test/topic"); await PublishMessage("test/topic", "Hello, MQTT!"); ``` 在实际应用中，你可能需要根据具体需求调整代码，例如添加错误处理、配置不同的QoS级别或使用真实的MQTT服务器地址。这个简单的C# MQTT客户端示例展示了如何使用MQTTnet库快速地进行发布和订阅操作，从而在物联网项目中实现数据通信。总结一下，本篇文章介绍了如何在C#环境中利用MQTTnet库快速创建一个MQTT客户端，涉及的主要知识点有： 1. MQTT协议的基本概念及其在物联网中的应用。 2. 使用Visual Studio 2017创建C#控制台应用程序。 3. 安装和使用MQTTnet库进行MQTT通信。 4. 配置和初始化MQTT客户端选项，包括服务器连接信息和自动重连策略。 5. 实现消息的发布和订阅功能，包括定义主题、设置QoS级别和处理接收的消息。 6. 示例代码展示了在控制台上订阅和发布消息的基本流程。通过以上步骤，开发者可以快速入门MQTT通信，为物联网应用开发打下基础。

资源推荐

资源详情

资源评论

收起资源包目录

doNetMqttTest.rar （83个子文件）

MqttTest

MqttClientWin

packages.config 4KB

Program.cs 532B

FmMqttClient.Designer.cs 6KB

MqttClientWin.csproj 10KB

Properties

Settings.settings 249B

Resources.Designer.cs 3KB

AssemblyInfo.cs 1KB

Settings.Designer.cs 1KB

Resources.resx 5KB

App.config 562B

FmMqttClient.cs 5KB

FmMqttClient.resx 6KB

obj

Debug

MqttClientWin.csprojResolveAssemblyReference.cache 106KB

MqttClientWin.exe 15KB

MqttClientWin.Properties.Resources.resources 180B

MqttClientWin.FmMqttClient.resources 180B

TempPE

MqttClientWin.csprojAssemblyReference.cache 313KB

DesignTimeResolveAssemblyReferencesInput.cache 16KB

MqttClientWin.csproj.CoreCompileInputs.cache 42B

MqttClientWin.csproj.FileListAbsolute.txt 12KB

MqttClientWin.csproj.GenerateResource.cache 1019B

MqttClientWin.csproj.CopyComplete 0B

TemporaryGeneratedFile_036C0B5B-1481-4323-8D20-8F5ADCB23D92.cs 0B

DesignTimeResolveAssemblyReferences.cache 1KB

TemporaryGeneratedFile_E7A71F73-0F8D-4B9B-B56E-8E70B10BC5D3.cs 0B

TemporaryGeneratedFile_5937a670-0e60-4077-877b-f7221da3dda1.cs 0B

MqttClientWin.pdb 28KB

bin

Debug

System.Security.Cryptography.X509Certificates.dll 38KB

Apache.NMS.pdb 192KB

System.Security.Cryptography.Primitives.dll 22KB

MqttClientWin.exe.config 562B

System.Net.Sockets.dll 45KB

Microsoft.Win32.Primitives.dll 22KB

MqttClientWin.exe 15KB

System.Security.Cryptography.Algorithms.dll 39KB

Apache.NMS.ActiveMQ.dll 712KB

Apache.NMS.ActiveMQ.pdb 3.39MB

System.Net.Security.dll 22KB

System.Xml.ReaderWriter.dll 23KB

System.IO.Compression.ZipFile.dll 24KB

System.Security.Cryptography.Encoding.dll 23KB

Apache.NMS.dll 64KB

System.IO.Compression.dll 109KB

System.Diagnostics.DiagnosticSource.dll 35KB

System.IO.FileSystem.dll 22KB

System.Runtime.InteropServices.RuntimeInformation.dll 32KB

System.Net.Http.dll 259KB

System.Console.dll 34KB

System.Diagnostics.DiagnosticSource.xml 29KB

System.Globalization.Calendars.dll 23KB

MqttClientWin.pdb 28KB

System.IO.FileSystem.Primitives.dll 22KB

System.AppContext.dll 20KB

MQTTnet.Core.dll 88KB

Apache.NMS.ActiveMQ.xml 577KB

Apache.NMS.xml 142KB

MQTTnet.dll 20KB

Release

MqttTest.sln 2KB

.vs

MqttTest

DesignTimeBuild

.dtbcache 419KB

v15

.suo 128KB

Server

sqlite3

storage.ide-wal 3.04MB

storage.ide-shm 32KB

storage.ide 3.26MB

db.lock 0B

MqttServerTest

Program.cs 4KB

obj

Debug

netcoreapp2.0

MqttServerTest.csprojResolveAssemblyReference.cache 496KB

MqttServerTest.dll 8KB

MqttServerTest.pdb 1KB

MqttServerTest.csproj.FileListAbsolute.txt 5KB

MqttServerTest.AssemblyInfo.cs 1008B

MqttServerTest.AssemblyInfoInputs.cache 42B

MqttServerTest.csprojAssemblyReference.cache 484KB

MqttServerTest.csproj.CoreCompileInputs.cache 42B

MqttServerTest.csproj.nuget.g.targets 865B

MqttServerTest.csproj.nuget.cache 149B

project.assets.json 169KB

MqttServerTest.csproj.nuget.g.props 1KB

bin

Debug

netcoreapp2.0

MqttServerTest.runtimeconfig.dev.json 190B

MqttServerTest.dll 8KB

MqttServerTest.pdb 1KB

MqttServerTest.runtimeconfig.json 154B

MqttServerTest.deps.json 40KB

MqttServerTest.csproj 271B

DATA

D:\project\MqttTest\MqttClientWin\bin\Debug\MqttClientWin.exe.config D:\project\MqttTest\MqttClientWin\bin\Debug\MqttClientWin.exe D:\project\MqttTest\MqttClientWin\bin\Debug\MqttClientWin.pdb D:\project\MqttTest\MqttClientWin\bin\Debug\Apache.NMS.ActiveMQ.dll D:\project\MqttTest\MqttClientWin\bin\Debug\Apache.NMS.dll D:\project\MqttTest\MqttClientWin\bin\Debug\Microsoft.Win32.Primitives.dll D:\project\MqttTest\MqttClientWin\bin\Debug\MQTTnet.Core.dll D:\project\MqttTest\MqttClientWin\bin\Debug\MQTTnet.dll D:\project\MqttTest\MqttClientWin\bin\Debug\SQLServerDAL.dll D:\project\MqttTest\MqttClientWin\bin\Debug\System.AppContext.dll D:\project\MqttTest\MqttClientWin\bin\Debug\System.Console.dll D:\project\MqttTest\MqttClientWin\bin\Debug\System.Diagnostics.DiagnosticSource.dll D:\project\MqttTest\MqttClientWin\bin\Debug\System.Globalization.Calendars.dll D:\project\MqttTest\MqttClientWin\bin\Debug\System.IO.Compression.dll D:\project\MqttTest\MqttClientWin\bin\Debug\System.IO.Compression.ZipFile.dll D:\project\MqttTest\MqttClientWin\bin\Debug\System.IO.FileSystem.dll D:\project\MqttTest\MqttClientWin\bin\Debug\System.IO.FileSystem.Primitives.dll D:\project\MqttTest\MqttClientWin\bin\Debug\System.Net.Http.dll D:\project\MqttTest\MqttClientWin\bin\Debug\System.Net.Security.dll D:\project\MqttTest\MqttClientWin\bin\Debug\System.Net.Sockets.dll D:\project\MqttTest\MqttClientWin\bin\Debug\System.Runtime.InteropServices.RuntimeInformation.dll D:\project\MqttTest\MqttClientWin\bin\Debug\System.Security.Cryptography.Algorithms.dll D:\project\MqttTest\MqttClientWin\bin\Debug\System.Security.Cryptography.Encoding.dll D:\project\MqttTest\MqttClientWin\bin\Debug\System.Security.Cryptography.Primitives.dll D:\project\MqttTest\MqttClientWin\bin\Debug\System.Security.Cryptography.X509Certificates.dll D:\project\MqttTest\MqttClientWin\bin\Debug\System.Xml.ReaderWriter.dll D:\project\MqttTest\MqttClientWin\bin\Debug\SQLServerDAL.pdb D:\project\MqttTest\MqttClientWin\bin\Debug\Apache.NMS.pdb D:\project\MqttTest\MqttClientWin\bin\Debug\Apache.NMS.xml D:\project\MqttTest\MqttClientWin\bin\Debug\Apache.NMS.ActiveMQ.pdb D:\project\MqttTest\MqttClientWin\bin\Debug\Apache.NMS.ActiveMQ.xml D:\project\MqttTest\MqttClientWin\bin\Debug\System.Diagnostics.DiagnosticSource.xml D:\project\MqttTest\MqttClientWin\obj\Debug\MqttClientWin.csprojResolveAssemblyReference.cache D:\project\MqttTest\MqttClientWin\obj\Debug\MqttClientWin.FmMqttClient.resources D:\project\MqttTest\MqttClientWin\obj\Debug\MqttClientWin.Properties.Resources.resources D:\project\MqttTest\MqttClientWin\obj\Debug\MqttClientWin.csproj.GenerateResource.Cache D:\project\MqttTest\MqttClientWin\obj\Debug\MqttClientWin.csproj.CoreCompileInputs.cache D:\project\MqttTest\MqttClientWin\obj\Debug\MqttClientWin.exe D:\project\MqttTest\MqttClientWin\obj\Debug\MqttClientWin.pdb E:\project\MqttTest\MqttClientWin\bin\Debug\MqttClientWin.exe.config E:\project\MqttTest\MqttClientWin\bin\Debug\MqttClientWin.exe E:\project\MqttTest\MqttClientWin\bin\Debug\MqttClientWin.pdb E:\project\MqttTest\MqttClientWin\bin\Debug\Apache.NMS.ActiveMQ.dll E:\project\MqttTest\MqttClientWin\bin\Debug\Apache.NMS.dll E:\project\MqttTest\MqttClientWin\bin\Debug\Microsoft.Win32.Primitives.dll E:\project\MqttTest\MqttClientWin\bin\Debug\MQTTnet.Core.dll E:\project\MqttTest\MqttClientWin\bin\Debug\MQTTnet.dll E:\project\MqttTest\MqttClientWin\bin\Debug\SQLServerDAL.dll E:\project\MqttTest\MqttClientWin\bin\Debug\System.AppContext.dll E:\project\MqttTest\MqttClientWin\bin\Debug\System.Console.dll E:\project\MqttTest\MqttClientWin\bin\Debug\System.Diagnostics.DiagnosticSource.dll E:\project\MqttTest\MqttClientWin\bin\Debug\System.Globalization.Calendars.dll E:\project\MqttTest\MqttClientWin\bin\Debug\System.IO.Compression.dll E:\project\MqttTest\MqttClientWin\bin\Debug\System.IO.Compression.ZipFile.dll E:\project\MqttTest\MqttClientWin\bin\Debug\System.IO.FileSystem.dll E:\project\MqttTest\MqttClientWin\bin\Debug\System.IO.FileSystem.Primitives.dll E:\project\MqttTest\MqttClientWin\bin\Debug\System.Net.Http.dll E:\project\MqttTest\MqttClientWin\bin\Debug\System.Net.Security.dll E:\project\MqttTest\MqttClientWin\bin\Debug\System.Net.Sockets.dll E:\project\MqttTest\MqttClientWin\bin\Debug\System.Runtime.InteropServices.RuntimeInformation.dll E:\project\MqttTest\MqttClientWin\bin\Debug\System.Security.Cryptography.Algorithms.dll E:\project\MqttTest\MqttClientWin\bin\Debug\System.Security.Cryptography.Encoding.dll E:\project\MqttTest\MqttClientWin\bin\Debug\System.Security.Cryptography.Primitives.dll E:\project\MqttTest\MqttClientWin\bin\Debug\System.Security.Cryptography.X509Certificates.dll E:\project\MqttTest\MqttClientWin\bin\Debug\System.Xml.ReaderWriter.dll E:\project\MqttTest\MqttClientWin\bin\Debug\SQLServerDAL.pdb E:\project\MqttTest\MqttClientWin\bin\Debug\Apache.NMS.pdb E:\project\MqttTest\MqttClientWin\bin\Debug\Apache.NMS.xml E:\project\MqttTest\MqttClientWin\bin\Debug\Apache.NMS.ActiveMQ.pdb E:\project\MqttTest\MqttClientWin\bin\Debug\Apache.NMS.ActiveMQ.xml E:\project\MqttTest\MqttClientWin\bin\Debug\System.Diagnostics.DiagnosticSource.xml E:\project\MqttTest\MqttClientWin\obj\Debug\MqttClientWin.csprojAssemblyReference.cache E:\project\MqttTest\MqttClientWin\obj\Debug\MqttClientWin.FmMqttClient.resources E:\project\MqttTest\MqttClientWin\obj\Debug\MqttClientWin.Properties.Resources.resources E:\project\MqttTest\MqttClientWin\obj\Debug\MqttClientWin.csproj.GenerateResource.cache E:\project\MqttTest\MqttClientWin\obj\Debug\MqttClientWin.csproj.CoreCompileInputs.cache E:\project\MqttTest\MqttClientWin\obj\Debug\MqttClientWin.csproj.CopyComplete E:\project\MqttTest\MqttClientWin\obj\Debug\MqttClientWin.exe E:\project\MqttTest\MqttClientWin\obj\Debug\MqttClientWin.pdb E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\MqttClientWin.exe.config E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\MqttClientWin.exe E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\MqttClientWin.pdb E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\Apache.NMS.ActiveMQ.dll E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\Apache.NMS.dll E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\Microsoft.Win32.Primitives.dll E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\MQTTnet.Core.dll E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\MQTTnet.dll E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\System.AppContext.dll E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\System.Console.dll E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\System.Diagnostics.DiagnosticSource.dll E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\System.Globalization.Calendars.dll E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\System.IO.Compression.dll E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\System.IO.Compression.ZipFile.dll E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\System.IO.FileSystem.dll E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\System.IO.FileSystem.Primitives.dll E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\System.Net.Http.dll E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\System.Net.Security.dll E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\System.Net.Sockets.dll E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\System.Runtime.InteropServices.RuntimeInformation.dll E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\System.Security.Cryptography.Algorithms.dll E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\System.Security.Cryptography.Encoding.dll E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\System.Security.Cryptography.Primitives.dll E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\System.Security.Cryptography.X509Certificates.dll E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\System.Xml.ReaderWriter.dll E:\project\MqttTest - 副本\MqttClientWin\bin\Debug\Apache.NMS.pdb E:

评论收藏

内容反馈