摘要：协议简介，消息队列遥测传输是一个轻量的发布订阅模式消息传输协议，是专门针对低带宽和不稳定网络环境的物联网应用设计的。它是等级协议交换的第二个报文。
MQTT（Message Queuing Telemetry Transport，消息队列遥测传输）是一个轻量的发布/订阅模式消息传输协议，是专门针对低带宽和不稳定网络环境的物联网应用设计的。
特点：
1.开放消息协议，易实现
2.发布订阅模式，一对多消息发布
3.基于TCP/IP网络连接
4.报文结构紧凑
5.消息QoS支持，保证可靠传输
MQTT协议原理
（2）payload可以理解为消息的内容，是指订阅者具体要使用的内容。
MQTT协议服务器 ：
MQTT服务器以称为“消息代理”（Broker），它是位于消息发布者和订阅者之间，服务器可以：
（1）接受来自客户端的网络连接；
（2）接受客户端发布的信息；
（3）处理来自客户端的订阅和退订请求；
（4）向订阅的客户转发消息。
MQTT协议客户端：
一个使用MQTT协议设备，它总是建立到服务器的网络连接，客户端可以：
（1）发布其他客户端可能会订阅的信息；
（2）订阅其它客户端发布的消息；
（3）退订或删除消息；
（4）断开与服务器连接。
MQTT协议栈
MQTT协议数据包结构：
在MQTT协议中，一个MQTT数据包由：固定头（Fixed header）、可变头（Variable header）、消息体（Payload）三部分构成。MQTT数据包结构如下：
Fixed Header（固定报文头）
Variable Header &Payload
2.1 CONNECT报文解读
Clean Session：清理会话，用于控制会话状态的生存时间，标志被设置为 1，客户端和服务端 必须丢弃之前的任何会话并开始一个新的会话。标志被设置为 0，服务端 必须基于当前会话（使用客户端标识符识别）的状态恢复与客户端的通信；
Will Flag：遗嘱标志设置为 1，表示如果连接请求被接受了，遗嘱（Will Message）消息 必须被存储在服务端；
QoS：遗嘱消息服务质量等级，遗嘱标志被设置为 0，遗嘱 QoS 也设置为 0；遗嘱标志被设置为 1，遗嘱 QoS 的值可以等于 0，1，2；
User Name Flag：用户名标志，标志被设置为 0，有效载荷中 不能包含用户名字段，标志被设置为 1，有效载荷中 必须包含用户名字段；
Password Flag：密码标志，标志被设置为 0，有效载荷中 不能包含密码字段，标志被设置为 1，有效载荷中必须包含密码字段；
2.2 CONNACK 报文解读
返回码说明：
服务端发送给客户端的第一个报文 是 CONNACK，服务端发送 CONNACK 报文响应从客户端收到的 CONNECT 报文。
Sp: Session Present Flag
当前会话标志
session信息在服务器已保持，置1；
未保存，置0。
2.3 PUBLISH（C<>S）发布消息报文解读
DUP:重发标志
QoS2、Qos1：如果为0，则表示是第一次发送该包，如果为1，则表示为重复发送的包。
Qos0：DUP必须为0
QOS: 指定了该Publish包的Qos等级如下
RETAIN: 保留标志位，如果为1，服务器存储最新一条RETAIN消息，以便分发给新的订阅者；
2.4. PUBACK 收到发布消息确认报文解读
PUBACK 报文是对 QoS 1 等级的 PUBLISH 报文的响应。
2.5 PUBREC 发布消息收到
PUBREC 报文是对 QoS 等级 2 的 PUBLISH 报文的响应。它是 QoS 2 等级协议交换的第二个报文。
2.6 PUBRECL 发布消息释放报文解读
PUBREL 报文是对 PUBREC 报文的响应。它是 QoS 2 等级协议交换的第三个报文。
2.7 PUBCOMP 发布完成报文解读
PUBCOMP 报文是对 PUBREL 报文的响应。它是 QoS 2 等级协议交换的第四个也是最后一个报文。
2.8 SUBSCRIBE 订阅主题报文解读
SUBSCRIBE 报文的有效载荷包含了一个主题，它们表示客户端想要订阅的主题，后面跟着一个字节，这个字节被叫做 服务质量要求（Requested QoS）。它给出了服务端向客户端发送应用消息所允许的QoS 等级。
2.9 SUBACK 订阅确认报文解读
返回码说明：
2.10 UNSUBSCRIBE 取消订阅报文解读
UNSUBSCRIBE 报文提供的主题与服务端持有的这个客户端的当前主题集合逐个字符比较。如果主题完全匹配，那么它（服务端）自己的订阅将被删除，否则不会有进一步的处理。
2.11 UNSUBACK 取消订阅确认
可变报头包含等待确认的 UNSUBSCRIBE 报文的报文标识符。
2.12 PINGREQ 心跳请求报文解读
2.13 PINGRESP 心跳响应报文解读
客户端发送 PINGREQ 报文给服务端的。用于：
1. 在没有任何其它控制报文从客户端发给服务的时，告知服务端客户端还活着。
2. 请求服务端发送 响应确认它还活着。
3. 使用网络以确认网络连接没有断开。
14. DISCONNECT 断开连接
客户端发送 DISCONNECT 报文之后：
服务端在收到 DISCONNECT 报文时：
3.1 连接流程
3.2 发布消息流程
平台收到上报数据点后保存起来
3.3 订阅流程
设备发起订阅请求;
平台收到请求后更新topic列表;
平台给设备回复SubAck;
subscribe的requestqos级别可以为0、1、2。
3.5 连接保活流程
客户端发送 PINGREQ 报文给服务端的，服务端发送 PINGRESP 报文响应客户端的 PINGREQ 报文，表示服务端还活着。
3.6 断开连接流程
DISCONNECT 报文是客户端发给服务端的最后一个控制报文，表示客户端正常断开连接。
级别0：最多一次，消息发送者会想尽办法发送消息，但是遇到意外并不会重试，这一级别会发生消息丢失。
MQTT发布消息QoS保证不是端到端的，是客户端与服务器之间的。订阅者收到MQTT消息的QoS级别，最终取决于发布消息的QoS和主题订阅的QoS。
文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。
转载请注明本文地址：https://www.ucloud.cn/yun/120928.html
摘要：协议版本介绍互联网的基础网络协议是协议消息队列遥测传输是基于协议栈而构建的已成为通信的标准为什么选择有多好多好多么牛逼我就不说了说的再多不如一个一个试试完了做比对剩下的那个就是要选择的实在不想这样搞技术就跟着一线走发布和订阅模型协议在网络中 mqtt 协议版本: 3.1.1 MQTT 介绍 互联网的基础网络协议是 TCP/IP协议. MQTT(消息队列遥测传输)是基于 TCP/IP 协...
摘要：现在很多网站都通过服务来实现消息推送及数据即时同步功能，即时通讯组件逐渐成为产品的标配。目前国内有很多成熟稳定的第三方即时通讯服务厂家，比如融云。 现在很多网站、APP都通过IM服务来实现消息推送及数据即时同步功能，即时通讯组件逐渐成为产品的标配。目前国内有很多成熟稳定的第三方即时通讯服务厂家，比如：融云。使用这些专业的服务可以提高开发效率而且服务稳定有保障。 如果自己DIY或者需要在...
摘要：前言作为一个消息代理客户端与服务端的通信时基于协议的而现在的主流应用时呈现在浏览器中这意味着用户与服务端只能通过或者这类浏览器能理解的协议传输所以后端还要建立一个代理层将协议传输的内容解析一下以协议发送到最后再由发送到硬件端在浏览器支持的协 前言 mosquitto 作为一个消息代理, 客户端与 mosquitto 服务端的通信时基于 MQTT 协议的, 而现在的主流 web 应用时呈...
摘要：前言作为一个消息代理客户端与服务端的通信时基于协议的而现在的主流应用时呈现在浏览器中这意味着用户与服务端只能通过或者这类浏览器能理解的协议传输所以后端还要建立一个代理层将协议传输的内容解析一下以协议发送到最后再由发送到硬件端在浏览器支持的协 前言 mosquitto 作为一个消息代理, 客户端与 mosquitto 服务端的通信时基于 MQTT 协议的, 而现在的主流 web 应用时呈...
摘要：前言前些日子了解到这样一个协议，可以在上达到即时通讯的效果，但网上并不能很方便地找到一篇目前版本的在下正确实现这个协议的博客。 前言 前些日子了解到mqtt这样一个协议，可以在web上达到即时通讯的效果，但网上并不能很方便地找到一篇目前版本的在node下正确实现这个协议的博客。 自己捣鼓了一段时间，理解不深刻，但也算是基本能够达到使用目的。 本文目的为对MQTT有需求的学习者提供一定程...
阅读 2082·2023-04-26 02:41
阅读 2145·2021-09-24 09:47
阅读 1545·2019-08-30 15:53
阅读 1204·2019-08-30 13:01
阅读 1884·2019-08-29 11:27
阅读 2856·2019-08-28 17:55
阅读 1739·2019-08-26 14:00
阅读 3375·2019-08-26 10:18
