在.NET7中使用MQTTnet简单实现MQTT通信

一、MQTT简介

MQTT(Message Queuing Telemetry Transport)是一种轻量级的消息传输协议,主要用于物联网设备间的通信。MQTT协议采用客户端/服务器架构,支持发布/订阅模式和点对点模式,具有高效、可靠、灵活等优点。

MQTT协议主要由三个要素构成:发布者(publisher)、代理服务器(broker)和订阅者(subscriber)。发布者将消息发布到代理服务器上,订阅者从代理服务器中订阅消息,代理服务器将消息发送给订阅者。MQTT协议中还有一个重要的概念是主题(topic),主题用于定义消息的类型和内容,发布者可以将消息发布到一个或多个主题上,订阅者可以订阅一个或多个主题的消息。

MQTT协议可以在不可靠的网络上以低带宽传输大量消息,适用于各种类型的物联网应用,例如智能家居、车联网、工业物联网等。由于其轻量级、可靠性高、快速响应等优点,MQTT协议在物联网领域得到了广泛的应用。

二、MQTTnet简介

MQTTnet 是一个跨平台、高性能和开源的 MQTT 客户端库和服务端实现,是 .NET 平台上主流的 MQTT 实现之一。基于 MQTTnet,用户可以方便地在 .NET 平台上集成 MQTT 功能,实现 MQTT 协议的消息传输等功能。

源码地址:https://github.com/dotnet/MQTTnet

三、在.NET7中使用MQTTnet****

1、项目准备

首先创建两个.NET7控制台项目,用来简单实现发布消息订阅功能。一个项目为服务端,一个客户端。

然后安装MQTTnet 包,我们这里选择安装3.12版本,MQTTnet跨版本差距比较大。大家可以在Nuget包管理器里安装,也可以用命令安装。

dotnet add package MQTTnet --3.12

2、服务端代码编写

编写服务端代码,片段代码如下:

 public static async Task MQTTP()
        {
            var factory = new MqttFactory();
            var client = factory.CreateMqttClient();

            var options = new MqttClientOptionsBuilder()
                .WithTcpServer("localhost", 1883)
                .Build();

            await client.ConnectAsync(options);
            while (true)
            {
                Console.WriteLine("输入要发布的信息: ");
                var message = Console.ReadLine();

                var mqttMessage = new MqttApplicationMessageBuilder()
                    .WithTopic("testTopic")
                    .WithPayload(Encoding.UTF8.GetBytes(message))
                    .WithExactlyOnceQoS()
                    .Build();

                await client.PublishAsync(mqttMessage);
            }
        }
    //调用
    static async Task Main(string[] args)
    {
        #region 测试
        await  MQTTP();
        #endregion
    }

3、客户端代码编写

在客户端编写如下代码:

  public static async Task MQTTClientTest()
        {
            var factory = new MqttFactory();
            var client = factory.CreateMqttClient();
            var options = new MqttClientOptionsBuilder()
                .WithTcpServer("localhost", 1883)
                .Build();
            client.UseApplicationMessageReceivedHandler(e =>
            {
                Console.WriteLine($"接收的消息: {Encoding.UTF8.GetString(e.ApplicationMessage.Payload)}");
            });
            await client.ConnectAsync(options);
            await client.SubscribeAsync(new MqttTopicFilterBuilder().WithTopic("testTopic").Build());
        }
     //调用
    static async Task Main(string[] args)
    {
        #region 测试
        await MQTTClientTest();
        #endregion
    }

这样就简单完成了发布订阅的功能,在这个示例中,发布者将消息发布到"testTopic"主题,订阅者订阅了相同的主题,一旦有新消息到达,就会打印出来。这只是一个简单的示例,实际的MQTT使用根据具体的项目场景来使用,比如异常处理等。

4、使用条件和方法:

首先在官网下载安装MQTT,官网为:https://mqtt.org/。

然后把项目的端口号改成mqtt配置的端口。同时运行两个项目就可以尝试了。大家可以拿上面代码尝试一下。

结语

本文介绍了MQTT在.NET7的简单使用,MQTT还有很多功能,大家可以根据MQTTnet 的API来使用其它功能。希望本文能对你带来收获,欢迎留言和吐槽。

来源公众号:DotNet开发跳槽

原文链接:https://www.cnblogs.com/xbhp/p/17302548.html

本站文章如无特殊说明,均为本站原创,如若转载,请注明出处:在.NET7中使用MQTTnet简单实现MQTT通信 - Python技术站

(0)
上一篇 2023年4月18日
下一篇 2023年4月18日

相关文章

  • C#创建Excel多级分组的方法

    C#创建Excel多级分组的方法 概述 在使用C#操作Excel表格时,有时需要将数据按多个字段进行分组展示,这就需要使用Excel中的多级分组功能。本文将介绍如何使用C#创建Excel多级分组,并提供两个示例说明。 示例说明 示例1:使用C#创建Excel多级分组 下面是一个示例代码,演示如何使用C#创建Excel多级分组。 using System; u…

    C# 2023年6月7日
    00
  • C#实现截图工具小项目

    下面是详细的C#实现截图工具小项目攻略。 一、项目背景 截图工具是一款在电脑操作中十分常用的小工具,通过对电脑屏幕进行截图来方便用户进行操作、记录等。而使用C#进行开发,同样可以实现一个简单易用的截图工具,因此本篇攻略主要讲解如何使用C#实现截图工具。 二、开发准备 开发工具:Visual Studio或Visual Studio Code(推荐使用Visu…

    C# 2023年6月1日
    00
  • C#调用Python模块的方法

    下面我来详细讲解C#调用Python模块的方法。步骤如下: 步骤一:安装Python环境以及Python的第三方库 在C#中调用Python模块之前,需要先安装Python环境以及需要用到的第三方库。推荐使用Anaconda安装Python环境,因为其中包含了很多常用的第三方库。 需安装的第三方库:- numpy:提供了丰富的数组操作方法;- pandas:…

    C# 2023年6月7日
    00
  • .NET IoC模式依赖反转(DIP)、控制反转(Ioc)、依赖注入(DI)

    .NET IoC模式依赖反转(DIP)、控制反转(Ioc)、依赖注入(DI)攻略 在 .NET 中,IoC(Inversion of Control)模式是一种设计模式,它包括依赖反转(DIP)、控制反转(IoC)和依赖注入(DI)三个概念。这些概念都是为了解决应用程序中的依赖关系问题而提出的。下面将详细介绍这三个概念。 依赖反转(DIP) 依赖反转(DIP…

    C# 2023年5月17日
    00
  • abp(net core)+easyui+efcore实现仓储管理系统——供应商管理升级之下(六十四)

    abp(net core)+easyui+efcore实现仓储管理系统目录 abp(net core)+easyui+efcore实现仓储管理系统——ABP总体介绍(一) abp(net core)+easyui+efcore实现仓储管理系统——解决方案介绍(二) abp(net core)+easyui+efcore实现仓储管理系统——领域层创建实体(三)…

    C# 2023年5月7日
    00
  • C# 使用 OleDbConnection 连接读取Excel的方法

    C# 使用 OleDbConnection 连接读取Excel的方法 要使用 C# 语言连接读取 Excel 文件,可以使用 OleDbConnection 类进行操作。下面将介绍 C# 使用 OleDbConnection 连接读取 Excel 的方法及示例。 步骤一:引用命名空间 使用 OleDbConnection 类需要引用以下命名空间: using…

    C# 2023年6月2日
    00
  • C# File.OpenRead(string path):以只读模式打开指定文件,并返回FileStream对象

    C#的File类是一个非常常用的类,提供了很多关于文件和文件夹操作的方法,其中之一就是OpenRead(string path)方法。 OpenRead(string path)方法的作用 OpenRead(string path)方法用于以只读方式打开指定路径下的文件,并返回该文件的FileStream对象,该对象用于读取文件内容。 OpenRead(st…

    C# 2023年4月19日
    00
  • c# 使用Entity Framework操作Access数据库的示例

    下面是详细讲解“c#使用EntityFramework操作Access数据库的示例”的完整攻略: 一、概述 在使用C#编程时,我们常常需要对数据库进行操作。其中较为常见的数据库有MySQL、SQL Server等。而今天我们要介绍的是如何使用EntityFramework操作Access数据库。 EntityFramework是.NET Framework中…

    C# 2023年5月15日
    00
合作推广
合作推广
分享本页
返回顶部