C#MQTTNET服务端使用说明

C#MQTTNET服务端使用说明C#MQTTNET服务端使用说明1.安装MQTTNet两种方式Shell可视化安装2.当前我的项目安装的依赖如下3.如何使用1.我想启动MQTT服务器,我该怎么做?2.我想知道MQTT服务器是否启动成功,我该怎么做?3.我想知道MQTT服务器是否停止允许,我该怎么做?4.我想知道有那些设备连接上了服务器,我该怎么做?5.我想知道有那些设备断开连接,我该怎么做?6.我想监听消息,我该怎么做?7.我想连接的客户端校验身份信息后才允许收发消息,我该怎么做?8.我想知道客户端订阅主题与取消订阅主题,我该怎么做?1.

大家好,又见面了,我是你们的朋友全栈君。


代码github地址

  1. 本次演示使用到的库为:MQTTNET
  2. 开发环境:.NET Framework 4.5以上 或 .Net Core 3.1以上
  3. MQTTNET 其实不太吃.Net版本,这里为了演示用的**.Net Core 3.1**
  4. 因为MQTTNET 是一个标准库,这就意味着你.Net Core版本会使用了,.NET Framework 4.5

1.安装MQTTNet

两种方式

Shell

Install-Package MQTTNET

代码地址

代码github地址

可视化安装

  1. 鼠标右击你的项目——>
  2. 管理NuGet程序包
  3. 再NuGet包页面切换到浏览
  4. 搜索MQTTNet

2.当前我的项目安装的依赖如下

  1. MQTTnet 3.0.16 必要
  2. Microsoft.Extensions.Configuration 3.1.16
  3. Microsoft.Extensions.Configuration.Abstractions 3.1.16
  4. Microsoft.Extensions.Configuration.FileExtensions 3.1.16
  5. Microsoft.Extensions.Configuration.Json 3.1.16
  6. Newtonsoft.Json 13.0.1
  7. Microsoft.Extensions.Options.ConfigurationExtensions 3.1.16

3.如何使用

1.我想启动MQTT服务器,我该怎么做?

 IMqttServer server = new MqttFactory().CreateMqttServer();
 MqttServerOptionsBuilder serverOptions = new MqttServerOptionsBuilder();
 serverOptions.WithDefaultEndpointPort(8080);
 await server.StartAsync(serverOptions.Build());

2.我想知道MQTT服务器是否启动成功,我该怎么做?

server.StartedHandler = new MqttServerStartedHandlerDelegate(StartedHandler);
/// <summary>
/// MQTT启动服务器事件
/// </summary>
/// <param name="obj"></param>
private void StartedHandler(EventArgs obj)
{
  Console.WriteLine($"程序已经启动!监听端口为:{model.Port}");
}

3.我想知道MQTT服务器是否停止允许,我该怎么做?

 server.StoppedHandler = new MqttServerStoppedHandlerDelegate(StoppedHandler);
  /// <summary>
  /// MQTT服务器停止事件
  /// </summary>
  /// <param name="obj"></param>
  private void StoppedHandler(EventArgs obj)
  {
    Console.WriteLine("程序已经关闭");
  }

4.我想知道有那些设备连接上了服务器,我该怎么做?

//客户端连接事件
server.ClientConnectedHandler = new MqttServerClientConnectedHandlerDelegate(ClientConnectedHandler);
/// <summary>
/// 客户端连接到服务器事件
/// </summary>
/// <param name="obj"></param>
private void ClientConnectedHandler(MqttServerClientConnectedEventArgs obj)
{
  throw new NotImplementedException();
}
   server.UseClientConnectedHandler(args =>
   {
   		Console.WriteLine($"{args.ClientId}此客户端已经连接到服务器");
   });

5.我想知道有那些设备断开连接,我该怎么做?

   //客户端断开连接事件
  server.ClientDisconnectedHandler = new MqttServerClientDisconnectedHandlerDelegate(ClientDisconnectedHandler);
  private void ClientDisconnectedHandler(MqttServerClientDisconnectedEventArgs obj)
  {
     Console.WriteLine($"断开连接的客户端:{obj.ClientId}");
     Console.WriteLine($"断开连接类型:{obj.DisconnectType.ToString()}"); 
  }
 server.UseClientDisconnectedHandler(args => {
    Console.WriteLine($"断开连接的客户端:{args.ClientId}");
    Console.WriteLine($"断开连接类型:{args.DisconnectType.ToString()}");
 });

6.我想监听消息,我该怎么做?

 server.ApplicationMessageReceivedHandler = new MqttApplicationMessageReceivedHandlerDelegate(MessageReceivedHandler);
 /// <summary>
 /// 收到各个客户端发送的消息
 /// </summary>
 /// <param name="obj"></param>
 private void MessageReceivedHandler(MqttApplicationMessageReceivedEventArgs obj)
 {
  Console.WriteLine("===================================================");
  Console.WriteLine("收到消息:");
  Console.WriteLine($"客户端:{obj.ClientId}");
  Console.WriteLine($"主题:{obj.ApplicationMessage.Topic}");
  Console.WriteLine($"消息:{Encoding.UTF8.GetString(obj.ApplicationMessage.Payload)}");
  Console.WriteLine("+++++++++++++++++++++++++++++++++++++++++++++++++++");
  Console.WriteLine();
 }
  server.UseApplicationMessageReceivedHandler(args=>{
       Console.WriteLine("===================================================");
       Console.WriteLine("收到消息:");
       Console.WriteLine($"客户端:{args.ClientId}");
       Console.WriteLine($"主题:{args.ApplicationMessage.Topic}");
       Console.WriteLine($"消息:{Encoding.UTF8.GetString(args.ApplicationMessage.Payload)}");
       Console.WriteLine("+++++++++++++++++++++++++++++++++++++++++++++++++++");
       Console.WriteLine();
  });

7.我想连接的客户端校验身份信息后才允许收发消息,我该怎么做?

  IMqttServer server = new MqttFactory().CreateMqttServer();
  MqttServerOptionsBuilder serverOptions = new MqttServerOptionsBuilder();
  serverOptions.WithConnectionValidator(client => {
  	string Account = client.Username;
 	string PassWord = client.Password;
    string clientid = client.ClientId;
    if (Account == "test" && PassWord == "1234")
     {
         client.ReasonCode = MqttConnectReasonCode.Success;
         Console.WriteLine("校验成功");
     }
     else
     {
      client.ReasonCode = MqttConnectReasonCode.BadUserNameOrPassword;
      Console.WriteLine("校验失败");
     }
 });
 await server.StartAsync(serverOptions.Build());

8.我想知道客户端订阅主题与取消订阅主题,我该怎么做?

1.订阅

  //客户端订阅主题事件
server.ClientSubscribedTopicHandler = new MqttServerClientSubscribedHandlerDelegate(ClientSubscribedTopicHandler);
 /// <summary>
 /// 客户端订阅的主题
 /// </summary>
 /// <param name="obj"></param>
 private void ClientSubscribedTopicHandler(MqttServerClientSubscribedTopicEventArgs obj)
 {
   Console.WriteLine($"客户端:{obj.ClientId}");
   Console.WriteLine($"订阅主题:{obj.TopicFilter.Topic}");
 }

2.取消订阅

  //客户端取消订阅主题事件
 server.ClientUnsubscribedTopicHandler = new MqttServerClientUnsubscribedTopicHandlerDelegate(ClientUnsubscribedTopicHandler);
 /// <summary>
 /// 客户端取消订阅主题
 /// </summary>
 /// <param name="obj"></param>
 private void ClientUnsubscribedTopicHandler(MqttServerClientUnsubscribedTopicEventArgs obj)
 {
   Console.WriteLine($"客户端:{obj.ClientId}");
   Console.WriteLine($"取消订阅主题:{obj.TopicFilter}");
 }

9.我想关闭MQTT服务器,我该怎么做?

 public async Task StopAsync()
 {
   if (server != null)
   {
      if (server.IsStarted)
      {
        await server.StopAsync();
        server.Dispose();
      }
   }
 }
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/152895.html原文链接:https://javaforall.net

(0)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

  • Netty权威指南V2.0版_javascript权威指南第七版

    Netty权威指南V2.0版_javascript权威指南第七版作者:李林锋著作出版发行:北京:电子工业出版社,2015.04ISBN号:978-7-121-25801-5页数:554开本:16开主题词:JAVA语言-程序设计-指南中图法分类号:TP312-62(工业技术->自动化技术、计算机技术->计算技术、计算机技术->计算机软件)内容提要:《Netty权威指南(第2版)…

    2022年10月2日
    0
  • php设计模式之工厂模式

    php设计模式之工厂模式工厂模式的学习

    2022年7月25日
    7
  • Latex 希腊字母大写[通俗易懂]

    Latex 希腊字母大写[通俗易懂]大写小写LaTeX大写大写LaTeX$A\quad\alpha$A\alphaNνN\quad\nuNνN\nuBβB\quad\betaBβB\betaΞξ\Xi\quad\xiΞξ\Xi\xiΓγ\Gamma\quad\gammaΓγ\Gamma\gammaOoO\quadoOoOoΔδ\Delta\quad\deltaΔδ\Delta\deltaΠπ\Pi\quad\piΠπ\Pi\p…

    2022年10月13日
    0
  • VS配置管理器

    VS配置管理器可以在VS的配置管理器中,配置当前活动解决方案采用debug和release模式,还可以设置活动解决方案平台,即win32或x64。还可以配置整个解决方案哪些项目需要生成,哪些不用,在多项目编译时间较长的情况下还是挺有作用的。

    2022年7月20日
    16
  • transactionscope mysql,如何将TransactionScope与MySql和多个数据库服务器一起使用[通俗易懂]

    transactionscope mysql,如何将TransactionScope与MySql和多个数据库服务器一起使用[通俗易懂]TransactionOptionsTransOpt=newTransactionOptions();TransOpt.IsolationLevel=System.Transactions.IsolationLevel.ReadCommitted;TransOpt.Timeout=newTimeSpan(0,2,0);using(TransactionScopescope…

    2022年7月19日
    11
  • IIC通信协议详解

    IIC通信协议详解IIC通信协议详解IIC的概述IIC分为软件IIC和硬件IICIIC通信协议空闲状态开始信号与停止信号开始信号程序:IIC的概述IIC:两线式串行总线,它是由数据线SDA和时钟线SCL构成的串行总线,可发送和接收数据。在CPU与被控IC之间、IC与IC之间进行双向传送,高速IIC总线一般可达400kbs以上。时钟线SCL:在通信过程起到控制作用。数据线SDA:用来一位一位的传送数据。IIC分为软件IIC和硬件IIC软件IIC:软件IIC通信指的是用单片机的两个I/O端口模拟出来的IIC,用

    2022年6月10日
    153

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号