MQTT消息传输机制(协议解读与调用实例).pdf

MQTT 消息传输机制（协议解读与调用实例） MQTT 消息传输机制（协议解读与调用实例） 前言 最近在研究 MQTT 时，我发现我身边的同事都在看类似 android 中实现 mqtt 通信、java 如何调用 mqtt 实现消息推送等，这种方式在现实编程中见怪不怪，也是常规的解决思 路，但也有诸多疑惑是常规思路中不能轻易达成的，原因有以下几点 ： 1. 代码调用简单 ，仅实现基本的功能； 2. 现成的类库文档较少 ，影响对类库的理解 ； 3. 开发者自身知其然，不知其所以然，等等 由此产生了很多令人困惑的问题，诸如： 1. 用户 （非 ）正常断开连接，代码能对断开的用户进行后续的逻辑处理吗 （断开后的业务回调）？ 2. 消息发布后，接收者未在线 ，上线能接收到之前发布的消息吗 ？ 3. 如何进行用户的登录验证 ？ 4. 消息发送失败及接收端下线，如何确保接收端再次登录后有正常接收到消息 ？ 5. …… 本篇会把连接(CONNECT)、心跳(PINGREQ/PINGRESP)、确认(CONNACK)、断开连接(DISCONNECT)和在一起 ，通过对协议的解读，结合类库的调用来对以上问题进行逐一解 答。 CONNECT 像前面所说，MQTT 有关字符串部分采用的修改版的 UTF-8 编码，CONNECT 可变头部中协议名称、消息体都是采用修改版的 UTF-8 编码。前面基本上可变头部内容不多，下面 是一个较为完整的 CONNECT 消息结构： Description 7 6 5 4 3 2 1 0 Fixed header/固定头部 Message Type(1) DUP QoS level RETAIN MQTT 消息传输机制（协议解读与调用实例） 李阳 MQTT 消息传输机制（协议解读与调用实例） Description 7 6 5 4 3 2 1 0 flag byte 1 0 0 0 1 x x x x byte 2 Remaining Length Variable header/可变头部 Protocol Name byte 1 Length MSB (0) 0 0 0 0 0 0 0 0 byte 2 Length LSB (6) 0 0 0 0 0 1 1 0 byte 3 M 0 1