MQTT协议
MQTT（Message Queuing Telemetry Transport）是一种轻量级发布/订阅（Publish/Subscribe）消息协议，主要用于物联网（IoT）、机器人、移动设备、传感器网络等带宽有限、网络不稳定、设备资源受限的环境。
在机器人云平台、ROS 云通信、设备远程控制等场景中，MQTT 是非常常见的通信协议。
一、MQTT整体架构
MQTT采用Broker中心架构。
Publisher
|
v
+--------+
| Broker |
+--------+
^ ^
/ \
Subscriber Subscriber
核心角色：
1 Publisher（发布者）
发布消息的客户端，例如：
机器人
传感器
IoT设备
服务器
例如：
机器人发布位置信息
topic: robot/pose
2 Subscriber（订阅者）
订阅某个Topic（主题）的客户端。
例如：
云服务器订阅：
robot/pose
收到机器人位置。
3 Broker（代理服务器）
MQTT系统核心。
作用：
- 接收消息
- 根据Topic匹配订阅
- 转发给订阅者
常见Broker：
- Mosquitto
- EMQX
- HiveMQ
- RabbitMQ MQTT插件
二、MQTT通信模型
MQTT核心思想：
发布 / 订阅模型
而不是传统：
客户端 → 服务器
MQTT是：
客户端 → Broker → 客户端
例如：
机器人发布数据
Topic:
robot/battery
服务器订阅：
robot/battery
数据流程：
Robot
|
publish
v
Broker
|
v
Cloud Server
发布者和订阅者完全解耦。
三、Topic（主题）
MQTT使用Topic字符串来进行消息路由。
例如：
robot/pose
robot/battery
robot/map
robot/cmd
类似：
文件路径
层级结构：
robot/1/pose
robot/1/battery
robot/2/pose
MQTT通配符
1 单层通配符
+
例如：
robot/+/pose
匹配：
robot/1/pose
robot/2/pose
2 多层通配符
#
例如：
robot/#
匹配：
robot/1/pose
robot/2/battery
robot/3/map
四、MQTT连接流程
MQTT通信流程：
客户端
|
| CONNECT
v
Broker
|
| CONNACK
v
客户端
然后开始：
SUBSCRIBE
PUBLISH
完整流程：
Client → CONNECT → Broker
Broker → CONNACK → Client
Client → SUBSCRIBE → Broker
Broker → SUBACK → Client
Client → PUBLISH → Broker
Broker → PUBLISH → Subscriber
五、MQTT报文结构
MQTT所有消息都是固定结构报文。
MQTT报文结构：
+----------------------+
| Fixed Header |
+-----------------------+
| Variable Header |
+-----------------------+
| Payload |
+-----------------------+
1 Fixed Header（固定头）
每个MQTT报文都有。
结构：
1 byte Message Type
1-4 byte Remaining Length
2 Variable Header（可变头）
根据不同报文类型不同。
例如：
CONNECT包含：
协议版本
clientID
keepalive
用户名
密码
3 Payload（消息体）
真正的数据。
例如：
机器人坐标
JSON数据
控制命令
六、MQTT消息类型
MQTT定义14种控制报文。
最重要几个：
| 类型 | 作用 |
|---|---|
| CONNECT | 客户端连接Broker |
| CONNACK | Broker确认连接 |
| PUBLISH | 发布消息 |
| SUBSCRIBE | 订阅Topic |
| SUBACK | 订阅确认 |
| UNSUBSCRIBE | 取消订阅 |
| PINGREQ | 心跳 |
| PINGRESP | 心跳响应 |
| DISCONNECT | 断开连接 |
七、QoS（服务质量）
MQTT最重要的机制。
QoS解决：
消息可靠传输
MQTT有3个等级。
QoS 0
最多一次
At most once
特点：
- 不保证消息到达
- 不重发
流程：
PUBLISH
类似：
UDP
适合：
传感器实时数据
QoS 1
至少一次
At least once
流程：
PUBLISH
|
v
PUBACK
可能：
重复消息
适合：
状态信息
QoS 2
只一次
Exactly once
流程：
PUBLISH
|
PUBREC
|
PUBREL
|
PUBCOMP
四次握手。
特点：
绝对不重复
但开销最大。
八、Retained Message（保留消息）
Broker可以保存最后一条消息。
新订阅者会立即收到这条消息。
例如：
Topic:
robot/status
消息：
online
新客户端订阅：
立即收到online
九、Last Will（遗嘱消息）
MQTT支持：
客户端异常断开时自动发布消息
例如：
机器人设置：
Will Topic:
robot/status
Will Message:
offline
如果机器人断网：
Broker自动发布：
robot/status = offline
云端立刻知道机器人掉线。
十、MQTT vs HTTP
| 特性 | MQTT | HTTP |
|---|---|---|
| 通信方式 | 发布订阅 | 请求响应 |
| 连接 | 长连接 | 短连接 |
| 开销 | 非常小 | 较大 |
| 实时性 | 高 | 低 |
| 适合 | IoT | Web |
MQTT头部：
2字节
HTTP头：
几百字节
所以MQTT适合：
弱网络
移动设备
机器人
十一、MQTT优缺点
优点：
1 轻量
2 实时性高
3 低带宽
4 支持离线消息
5 发布订阅解耦
缺点：
1 需要Broker
2 不适合大文件传输