MQTT 服务端搭建以及详解

服务端配置

链接方法

创建MQTT服务器类似于创建MQTT客户机。下面的代码显示了创建一个新的MQTT服务器的最简单方法，该服务器的TCP端点正在默认端口1883上侦听。

// Configure MQTT server.
var optionsBuilder = new MqttServerOptionsBuilder().WithConnectionBacklog(100)//最大链接数.WithDefaultEndpointPort(1883);//监听端口号var mqttServer = new MqttFactory().CreateMqttServer();
mqttServer.StartAsync(optionsBuilder.Build());//服务启动

配置参数如下所示

函数名	功能说明
Build	构建配置参数
WithApplicationMessageInterceptor	允许处理来自客户端的所有已发布消息
WithClientId	服务端发布消息时使用的ClientId
WithConnectionBacklog	设置要保留的连接数
WithConnectionValidator	验证连接
WithDefaultCommunicationTimeout	设置默认的通信超时
WithDefaultEndpoint	使用默认端点
WithDefaultEndpointBoundIPAddress	使用默认端点IPv4地址
WithDefaultEndpointBoundIPV6Address	使用默认端点IPv6地址
WithDefaultEndpointPort	使用默认端点端口
WithEncryptedEndpoint	使用加密的端点
WithEncryptedEndpointBoundIPAddress	使用加密的端点IPv4地址
WithEncryptedEndpointBoundIPV6Address	使用加密的端点IPv6地址
WithEncryptedEndpointPort	使用加密的端点端口
WithEncryptionCertificate	使用证书进行SSL连接
WithEncryptionSslProtocol	使用SSL协议级别
WithMaxPendingMessagesPerClient	每个客户端允许最多未决消息
WithPersistentSessions	保持会话
WithStorage	使用存储
WithSubscriptionInterceptor	允许处理来自客户端的所有订阅
WithoutDefaultEndpoint	禁用默认端点
WithoutEncryptedEndpoint	禁用默认(SSL)端点

账户验证

var optionsBuilder = new MqttServerOptionsBuilder().WithConnectionValidator(c =>
{if (c.ClientId.Length < 10){c.ReasonCode = MqttConnectReasonCode.ClientIdentifierNotValid;return;}if (c.Username != "mySecretUser"){c.ReasonCode = MqttConnectReasonCode.BadUserNameOrPassword;return;}if (c.Password != "mySecretPassword"){c.ReasonCode = MqttConnectReasonCode.BadUserNameOrPassword;return;}c.ReasonCode = MqttConnectReasonCode.Success;
});

另一种验证账户方式

        mqttServer.ClientConnectedHandler = new MqttServerClientConnectedHandlerDelegate(MqttClientConnectedEvent);/// <summary>/// 可以增加对客户端的校验规则/// </summary>/// <param name="e"></param>static void MqttClientConnectedEvent(MqttServerClientConnectedEventArgs e){if (e.ClientId.Length < 10){Console.WriteLine(MqttConnectReturnCode.ConnectionRefusedIdentifierRejected);}if (e.UserName != "gaodong"){Console.WriteLine(MqttConnectReturnCode.ConnectionRefusedBadUsernameOrPassword);}}

可以在服务器选项中设置自定义拦截器。对于服务器接收到的每个应用程序消息，都会调用该拦截器。这允许在应用程序消息被持久化（对于保留的消息）之前以及在被分派给订阅者之前扩展它们。这允许在硬件设备不知道时间或时区等情况下向每个应用程序消息添加时间戳。以下代码显示了如何使用拦截器：

var optionsBuilder = new MqttServerOptionsBuilder().WithApplicationMessageInterceptor(context =>{if (context.ApplicationMessage.Topic == "my/custom/topic"){context.ApplicationMessage.Payload = Encoding.UTF8.GetBytes("The server injected payload.");}// 可以像这样禁止发送特定客户端id的消息:if (context.ClientId != "Someone"){context.AcceptPublish = false;return;}// 还可以读取有效负载并扩展它。例如，在JSON文档中添加时间戳.// 当物联网设备没有自己的时钟且消息的创建时间可能很重要时，这很有用.}).Build();

拦截订阅

可以设置自定义拦截器来控制MQTT客户机可以订阅哪些主题。这允许将私有API主题移动到仅对某些客户端可用的受保护区域。下面的代码显示了如何使用订阅拦截器。

// 防止每个客户端订阅多个主题.
var optionsBuilder = new MqttServerOptionsBuilder().WithSubscriptionInterceptor(context =>{if (context.TopicFilter.Topic.StartsWith("admin/foo/bar") && context.ClientId != "theAdmin"){context.AcceptSubscription = false;}if (context.TopicFilter.Topic.StartsWith("the/secret/stuff") && context.ClientId != "Imperator"){context.AcceptSubscription = false;context.CloseConnection = true;}}).Build();

MQTT 服务端搭建以及详解相关推荐

七、Oracle11g R2服务端卸载图文详解过程
Oracle11g R2服务端卸载图文详解过程注:由于Oracle 11g R2服务端安装的时候已经包含了客户端,所以服务端的卸载方案跟客户端的一样,也就是说,客户端卸载按照以下步骤同样适用. 一. ...
android mqtt服务器搭建,Mqtt从服务端到Android客户端搭建（mqtt服务端搭建）
一.简介 MQTT(消息队列遥测传输)是ISO 标准(ISO/IEC PRF 20922)下基于发布/订阅范式的消息协议. 此处不再引入官方文字描述,以个人开发认识浅谈一下本文分为两部分: 1. M ...
https客户端与服务端认证过程详解
Go和HTTPS 四月 30, 2015 27 条评论近期在构思一个产品,考虑到安全性的原因,可能需要使用到HTTPS协议以及双向数字证书校验.之前只是粗浅接触过HTTP(使用Golang开发微信 ...
java 服务端渲染_基于vue-ssr服务端渲染入门详解
第一部分基本介绍 1.前言服务端渲染实现原理机制:在服务端拿数据进行解析渲染,直接生成html片段返回给前端.然后前端可以通过解析后端返回的html片段到前端页面,大致有以下两种形式: 1.服务器 ...
win10安装oracle11g 服务端及配置详解
第一部分:Oracle 11g 的安装一.准备工作修改文件cvu_prereq,使之能够通过Oracle的环境检查文件位置:Database\stage\cvu 文件名称:cvu_prereq. ...
Windows 网络服务架构系列课程详解（一） ----DHCP服务器的搭建与配置
Windows 网络服务架构系列课程详解(一) ---------DHCP服务器的搭建与配置实验背景: 企业网络环境中在没有配置DHCP服务器时,经常会遇到这样的情况,用户不懂怎么去配置IP地址 ...
mqtt服务器搭建php,MQTT 服务端
MQTT 服务端 MQTT是一个基于客户端-服务器的消息发布/订阅传输协议.MQTT协议是轻量.简单.开放和易于实现的,这些特点使它适用范围非常广泛.在很多情况下,包括受限的环境中,如:机器与机器(M ...
【夯实Spring Cloud】Spring Cloud中的Eureka服务注册与发现详解
本文属于[夯实Spring Cloud]系列文章,该系列旨在用通俗易懂的语言,带大家了解和学习Spring Cloud技术,希望能给读者带来一些干货.系列目录如下: [夯实Spring Cloud]D ...
Windows 网络服务架构系列课程详解（六） ---利用NLB群集实现WEB服务器的可靠性...
Windows 网络服务架构系列课程详解(六) -----利用NLB群集实现WEB服务器的可靠性实验背景: 在大型网络环境中存在这样一种情景,公司内部的FTP服务器出现故障或脱机了,而且不能快速 ...

MQTT 服务端搭建以及详解

配置参数如下所示

MQTT 服务端搭建以及详解相关推荐

最新文章

热门文章