MQTT 基本认知 (mqtt 服务器源码)
物联网 (internet of thing)
,表示的是可以把一些带某些传感器的设备(终端),接入到互联网的行为。
通过互联网连接这些设备,这些设备就能够互相协作。
而
MQTT
就是这些设备之间数据通信的一个基于 TCP/IP 的协议。
每个终端都和实现了
MQTT
协议的代理/服务器相连。
通过
published
MQTT 代理服务器的某个
主题
发送数据。
通过
subscription
从 MQTT 代理服务器获取自己订阅的
主题
数据。
MQTT 协议是一种轻量级的、灵活的网络协议。并且非常适合 IOT 的场景。
大多数开发人员已经熟悉了 HTTP WEB 协议。那么为什么不让 IOT 设置链接到 WEB 服务?
设备可以采用 HTTP 请求的形式发送数据,并采用 HTTP 响应的形式从服务器获取数据,接受更新。
因为对于 IOT 的设备来说,这种
主动请求–> 被动等待应答的
数据传输模型存在严重的局限性:
那么,MQTT 为什么如此轻便且灵活?MQTT 协议的一个关键的特性是
发布/订阅模型
。它将数据的发布者和接受者分离。
一个设备终端既可以是数据的发布者
(published)
也可以是数据的订阅者
(subscription)
。
一个设备如果要发布数据,只需要往代理服务器中
相应的主题发布数据内容即可。
一个设备如果需要接受到数据,只需要在代理服务器中,
提前订阅自己需要关注的主题即可。
MQTT 最基本的体验,就是使用 mosquitto 。
Mosquitto是一款实现了 MQTT v3.1 协议的开源消息代理软件,提供轻量级的,支持发布/订阅的的消息推送模式,使设备对设备之间的短消息通信简单易用。
它可以理解成一个 MQTT 的代理服务器。
基本步骤如下:
安装成功截图
使用 brew services start mosquitto 启动 MQTT 服务
运行截图
然后再打开另外两个终端窗口,模拟两个IOT设备。A 订阅 MQTT 服务。B 向 MQTT 的服务枝闷唯发送数据。
A订阅当前MQTT的某个服务。
B向 MQTT 服务器发布(published) 数据。
然后,我们就可以在A控制台里看到由 B 通过 MQTT 服务发送的数据了。
基本流程图
控制台 A 向 MQTT 服务器订阅
dw/demo
服务,并被动的等待 MQTT 服务器返回数据。
控制台 B 主动的向 MQTT 服务器的
dw/demo
服务发送
published
数据,之后。服务器会主动向事先订阅了
dw/demo
的终端分发此消息。
MQTT 是一种链接协议,它指定了如何组织数据字节并通过 TCP/IP 网络传输它们。但实际上,开发人员并不需要链接这个链接协议的具体细节。我们只需要知道,每条消息都有一个命令和数据有效负载猛培。该命令定义消息类型(比如 CONNECT 消息或者 SUB SCRIBE 消息)。所有的 MQTT 库和工具都提供了直接处理这些消息的基本方法,并且能自动填充一些必要的字段(在数据包的对应字节填充),比如消息和客户端 ID。
首先客户端发送一罩举条
CONNECT消息
来链接代理。CONNECT 消息要求建立从客户端到代理服务器的链接。
CONNECT 命令的基本参数
当客户端向代理服务器发送一条
CONNECT
命令之后,服务器会调用
CONNACK
命令,告知服务链接的状态。
CONNACK 命令的基本参数
当客户端和服务器建立连接之后,客户端就可以向服务器订阅某些主题的。(发送一条或多条
SUBSCRIBE消息
)。
表明当服务器接受到其他终端推送的此主题数据时,服务器会默认发送给它。
SUBSCRIBE 参数列表
当客户端成功的向服务器订阅某个主题之后,服务器会返回一条
SUBACK
的消息,其中包含一个或者多个 returnCode 参数。
SUBACK消息参数
returnCode : 值,表示成功订阅,并返回这个订阅消息的 QOS。值 128 : 订阅失败。
既然客户端可以向服务器订阅某个主题,当然也可以取消订阅。
与
SUBSCRIBE
订阅命令相反的命令是
UNSUBSCRIBE
取消订阅命令。
此命令非常简单。只有一个topic(主题)参数。
上面讲的是订阅,订阅是需要有消息从服务器发送过来的。但是服务器本身基本不产生数据,那数据从何而来呢?
通过另外一个客户端执行
PUBLISH
命令,往代理服务器发送数据。并最终通过代理服务器将数据传递给订阅了此服务的客户端。
PUBLISH 消息参数
对于 MQTT 的一张基本理解图
基本流程图:
最后总结
参考资料: 初识 MQTT
相关问题拓展阅读:
MQTT 5.0 介绍
MQTT 协议 因为其轻量、灵活等特点成为了当今世界上更受欢迎的物联网协议,它已经广泛应用于车联网、智能家居、物流、即时聊天应用和移动消息推送等领域,连接了数以亿计的设备,并且每时每刻都有无数设备开始使用和接入 MQTT 协议。MQTT 协议为这些设备提供了稳定、可靠的通信基础,这些设备庞大的接入数量也向 MQTT 协议规范提出了挑战, MQTT 5.0 的诞生便是为了更好地满足这一需求。
MQTT(消息队列遥测传输)最初由 IBM 于上世纪 90 年代晚期发明。它最初的用途是将石油管道上的传感器与卫星相链接,所以 MQTT 从则搏局诞生之初就是专为受限设备和低带宽、高延迟或不可靠的网络而设计,它使用了发布订阅模型,在空间和时间上解耦了消息的发送者与接收者,并且基于 TCP/IP 提供稳定可靠的网络连接,拥有非常轻量的报头以减少传输开销,支持可靠消息传输,可以说天生就满足了物联网场景的各种需求。在 MQTT 3.1.1 发布并成为 OASIS 标准的四年后,MQTT 5.0 正式发布,银雹这是一次重大的改进和升级,它的目的不仅仅是满足现阶段的行业需求,更是为行业未来的发展变化做了充足的准备。2023 年 3 月,MQTT 5.0 成为了新的 OASIS 标准。
面对迅速增长的设备数量和层出不穷的需求,OASIS MQTT 技术委员会需要从繁杂的需求中提取出通用部分,将其纳入标准规范,并且尽可能不增加开销或降低易用性,在不增加不必要的复杂性的前提下提高性能和易用性。
最终,OASIS MQTT 技术委员会为 MQTT 5.0 添加了大量的全新功能与特性,5.0 成为 MQTT 有史以来变化更大的一个孙让版本。在这里,我们将列举一些比较重要的特性:
完整的新属性列表包含在协议标准的附录C,您可以访问以下网址了解详情:
。
随着各 MQTT 服务器 厂商不断加入 MQTT 5.0 的支持阵营(例如 EMQ 在 2023 年 9 月就已经完整支持了 MQTT 5.0 协议),整个行业生态逐步迁移至 MQTT 5.0 已经成为大的趋势,MQTT 5.0 也将是未来绝大多数物联网企业的首选。我们也希望用户能够尽早拥抱 MQTT 5.0 并且享受到它带来的便利,这也是这篇文章的目的。如果您已经对 MQTT 5.0 产生了一些兴趣,但还想了解更多,您可以尝试阅读以下文章,我们将以通俗易懂的方式为您介绍 MQTT 5.0 的重要特性:
mqtt 服务器源码的介绍就聊到这里吧,感谢你花时间阅读本站内容,更多关于mqtt 服务器源码,MQTT 基本认知,MQTT 5.0 介绍的信息别忘了在本站进行查找喔。