4、MQTT协议基础：MQTT原理、QoS等级、Topic与Payload设计、Keep Alive机制

好，咱们进入第四讲。这一章可以说是整个设备接入的「地基」。你想想看，不管你是用ESP32、树莓派，还是工业PLC，最终它们跟ThingsBoard说话，靠的就是MQTT协议。

我刚开始接触物联网那会儿，觉得MQTT不就是个发布/订阅嘛，有啥好学的？结果第一次做项目，设备频繁掉线，消息丢得莫名其妙。后来才明白——嗯，MQTT里的门道，比想象中多得多。

4.1 MQTT原理：轻量级的「信使」

MQTT全称是Message Queuing Telemetry Transport。名字挺长，说白了就是「消息队列遥测传输」。它专门为低带宽、高延迟、不可靠的网络环境设计。

它的核心模型是发布/订阅。跟传统的客户端/服务器不一样，这里有个中间人——Broker（代理服务器）。

• 发布者：只管把消息扔给Broker，不关心谁收。
• 订阅者：只管跟Broker说「我对这个Topic感兴趣」，有消息来了Broker会推给你。
• Broker：就是ThingsBoard的MQTT服务器，负责转发。

我在项目中遇到过一种情况：现场有200多个传感器，如果每个传感器都直接跟服务器建立长连接，服务器压力巨大。用了MQTT之后，所有传感器只跟Broker通信，Broker再统一转发给后端。架构瞬间清爽了。

4.2 QoS等级：消息到底靠不靠谱？

MQTT定义了三个服务质量等级。说白了就是：你愿意花多少代价，确保消息到达。

QoS等级	名称	含义	可靠性
0	至多一次	发出去就不管了，不确认	最低
1	至少一次	确保收到，但可能重复	中等
2	恰好一次	确保收到且不重复	最高

QoS 0：我习惯叫它「发完就跑」。适合那些丢了也无所谓的场景，比如温度传感器每秒上报一次，丢一两个数据不影响大局。

QoS 1：这是最常用的等级。Broker收到消息后会回复一个PUBACK。如果发布者没收到确认，就会重发。但问题来了——重发可能导致Broker收到两条相同的消息。所以你的业务逻辑里要做好去重。

QoS 2：最安全，也最慢。它用了两轮四次握手。我曾经在一个金融级物联网项目里用过QoS 2，因为每一笔交易数据都不能丢、不能重复。但代价是网络开销翻倍。

4.3 Topic与Payload设计：命名是门艺术

Topic是MQTT里的「地址」。发布者往Topic上发消息，订阅者从Topic上收消息。Topic用斜杠分隔，形成层级结构。

举个例子：

sensor/temperature/room1
sensor/humidity/room1
actuator/light/room1/switch

我个人习惯用设备类型/数据类型/位置/操作这样的结构。为什么？因为ThingsBoard的规则引擎里，你可以用通配符订阅。

MQTT支持两个通配符：

• +：匹配单层。比如 sensor/+/room1 能匹配所有room1的传感器。
• #：匹配多层。比如 sensor/# 能匹配所有sensor开头的Topic。

Payload就是消息体。我强烈建议你用JSON格式。为什么？因为ThingsBoard原生解析JSON，可以直接提取字段。

{
  "temperature": 25.6,
  "humidity": 68.2,
  "timestamp": 1695000000
}

4.4 Keep Alive机制：心跳不能停

MQTT是长连接协议。但网络随时可能断开，怎么知道对方还活着？靠的就是Keep Alive。

客户端在连接时，会告诉Broker一个时间间隔，比如60秒。如果60秒内Broker没收到任何数据包（包括PINGREQ），Broker就认为客户端挂了，主动断开连接。

反过来，客户端也要检测Broker是否还活着。如果客户端在1.5倍Keep Alive时间内没收到任何响应，它也会主动断开重连。

我习惯把Keep Alive设成60秒。太短了，网络波动容易误判；太长了，断线了要等很久才能发现。

4.5 实战：用MQTT连接ThingsBoard

咱们来点实际的。假设你有一个温度传感器，要接入ThingsBoard。

第一步，获取设备的访问令牌。在ThingsBoard的设备详情页里，找到「复制访问令牌」。这个令牌就是设备的「身份证」。

第二步，构造MQTT连接。客户端ID可以随便起，但用户名和密码有讲究：

• 用户名：空（或者不填）
• 密码：就是刚才复制的访问令牌

第三步，发布数据。ThingsBoard要求设备往 v1/devices/me/telemetry 这个Topic上发数据。

mosquitto_pub -d -h your-thingsboard-server.com \
  -p 1883 \
  -u "" \
  -P "YOUR_ACCESS_TOKEN" \
  -t "v1/devices/me/telemetry" \
  -m '{"temperature": 25.6, "humidity": 68.2}' \
  -q 1

看到没？-q 1 就是QoS 1。如果你用MQTT客户端库（比如Python的paho-mqtt），代码也很简单：

import paho.mqtt.client as mqtt

client = mqtt.Client()
client.username_pw_set("", "YOUR_ACCESS_TOKEN")
client.connect("your-thingsboard-server.com", 1883, 60)

payload = '{"temperature": 25.6, "humidity": 68.2}'
client.publish("v1/devices/me/telemetry", payload, qos=1)
client.loop_forever()

这里connect的第三个参数60，就是Keep Alive时间。我习惯设成60秒，够用。

下一章，咱们会深入ThingsBoard的设备配置，看看怎么在平台上管理这些设备。到时候你会发现，MQTT的知识全都能用上。