一、为什么 MQTT 在物联网领域如此重要？

在物联网（IoT）场景中，我们面临几个天然问题：

• 设备数量巨大（十万、百万级）
• 设备网络环境复杂（4G / 5G / 弱网 / 高延迟）
• 设备算力有限（MCU、嵌入式 Linux）
• 数据频繁但单条数据很小

MQTT（Message Queuing Telemetry Transport） 正是为这些问题而生的。

它的核心优势可以用 6 个字概括：

轻量、稳定、省流量

二、MQTT 是什么？

MQTT 是一种 基于发布/订阅（Pub/Sub）模型的应用层消息协议，运行在 TCP 之上。

1️⃣ 核心角色

设备之间不直接通信，一切通过 Broker 转发

三、MQTT 的通信模型

发布 / 订阅模型

设备A  --->  Broker  --->  设备B
         发布          订阅

• 发布者只管发消息
• 订阅者只关心自己订阅的主题
• 双方完全解耦

这是 MQTT 能支撑大规模设备的关键原因。

四、MQTT Topic（主题）设计

Topic 是 MQTT 的“路由规则”，非常重要。

1️⃣ Topic 基本规则

• 使用 / 分层
• 区分大小写
• 不支持空格

示例：

device/locker/12345/status
device/locker/12345/cmd

2️⃣ 通配符

示例：

device/+/+/status
device/locker/# 

五、QoS（服务质量）机制

QoS 是 MQTT 的核心特性之一，用来平衡 可靠性与性能。

⚠️ QoS 越高，性能越差，千万不要滥用 QoS 2

六、MQTT 会话与连接机制

1️⃣ 长连接

• MQTT 使用 长 TCP 连接
• 连接成功后长期保持

2️⃣ Keep Alive 心跳

CONNECT -> PINGREQ -> PINGRESP

• 保活时间由客户端指定
• Broker 超时会主动断开

七、遗嘱消息（Last Will Testament）

遗嘱机制用于 异常下线检测。

示例：

如果我掉线了，
请帮我往 device/locker/12345/status
发一条 "offline"

典型用途：

• 设备在线/离线状态
• 监控告警

八、Retained Message（保留消息）

Retain 的作用：

让新订阅者立即拿到最后一条有效消息

适合场景：

• 设备当前状态
• 开关状态
• 配置下发

九、MQTT 协议版本区别

⚠️ 实际工程中：设备 3.1.1，服务端可 5.0

十、MQTT 安全机制

1️⃣ 认证方式

• 用户名 / 密码
• ClientId 鉴权
• Token / JWT

2️⃣ 传输安全

• TCP → TLS（8883）
• 单向 / 双向证书认证

3️⃣ 权限控制

• Topic 级别 ACL
• 读 / 写 分离

十一、典型物联网实战模型

设备上行

device/{type}/{id}/data

设备下行

device/{type}/{id}/cmd

状态汇报

device/{type}/{id}/status

十二、MQTT Broker 选型

百万级设备：必须关注内存、FD、内核参数

十三、常见坑与经验总结

❌ 每个设备一个 Topic 但无层级设计
❌ QoS 2 滥用
❌ ClientId 重复
❌ KeepAlive 设置过小
❌ Retain 用错导致“脏数据”

十四、总结

MQTT 并不是“简单的消息协议”，而是一套 为海量设备而设计的工程级通信体系。

学 MQTT 的正确路径：

1. 理解 Pub/Sub 模型
2. 玩明白 Topic 和 QoS
3. 熟悉连接、心跳、遗嘱
4. 结合真实设备场景设计 Topic
5. 上 Broker，压测、调优