1.MQTT协议简介

---

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协议栈

 2.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. MQTT接入流程

---

3.1 连接流程

 3.2 发布消息流程

平台收到上报数据点后保存起来

 

3.3 订阅流程

设备发起订阅请求;

平台收到请求后更新topic列表;

平台给设备回复SubAck;

subscribe的requestqos级别可以为0、1、2。

 3.5 连接保活流程

客户端发送 PINGREQ 报文给服务端的，服务端发送 PINGRESP 报文响应客户端的 PINGREQ 报文，表示服务端还活着。

3.6 断开连接流程

DISCONNECT 报文是客户端发给服务端的最后一个控制报文，表示客户端正常断开连接。

 4.MQTT消息QOS

---

级别0：最多一次，消息发送者会想尽办法发送消息，但是遇到意外并不会重试，这一级别会发生消息丢失。

 

 MQTT发布消息QoS保证不是端到端的，是客户端与服务器之间的。订阅者收到MQTT消息的QoS级别，最终取决于发布消息的QoS和主题订阅的QoS。

最后

以上就是和谐睫毛膏为你收集整理的MQTT协议介绍1.MQTT协议简介  2.MQTT通信报文 3. MQTT接入流程 4.MQTT消息QOS的全部内容，希望文章能够帮你解决MQTT协议介绍1.MQTT协议简介  2.MQTT通信报文 3. MQTT接入流程 4.MQTT消息QOS所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。