随着物联网生态系统的持续扩张，专为受限网络环境打造的 MQTT 协议已成为设备间通信的事实标准。该协议采用轻量级的发布/订阅架构，具备低功耗、高可靠、易部署等特性，在智能制造、智慧交通、远程监控等场景中发挥着关键作用。

本文将通过实操演示，带领开发者快速掌握 MQTT 的核心机制，完成从理论到实践的跨越。

建立 MQTT 连接

客户端实现

MQTT 客户端泛指任何集成协议库的应用程序或嵌入式设备——从手机上的消息应用到工业现场的传感器节点，再到调试用的桌面工具均属此类。主流编程语言均提供成熟的客户端实现，开发者可根据技术栈灵活选择。

本教程采用浏览器端的在线调试工具进行演示，访问地址：http://www.emqx.io/online-mqtt-client。该工具由开源社区维护，同时提供跨平台的桌面版本与命令行工具，便于不同场景下的开发测试。

服务端部署

MQTT 服务端（Broker）承担连接管理与消息转发的核心职责，高可用架构可支撑千万级并发连接。部署形态分为三种：

• 私有化部署：适合有运维团队的企业，通过容器快速启动：

docker run -d --name mqtt-broker \
  -p 1883:1883 \
  -p 8083:8083 \
  -p 8883:8883 \
  -p 18083:18083 \
  emqx/emqx:latest

• 托管云服务：免运维的 Serverless 方案，按需扩缩容
• 公共测试节点：用于快速验证协议行为

本次演示使用公开测试环境：

配置项	数值
接入地址	broker.emqx.io
TCP 端口	1883
WebSocket 端口	8083

连接参数详解

打开在线工具后点击新建连接，需配置以下关键参数：

参数	说明
Client ID	全局唯一标识，服务端据此识别客户端身份
传输协议	Web 环境选择 ws/wss，原生应用可选 tcp/ssl
保活间隔	心跳周期，无数据传输时维持连接活性
会话清除	false 启用持久会话，保存订阅关系与离线消息
协议版本	推荐 5.0，支持主题别名、流量控制、用户属性等增强特性

输入连接名称后点击连接，状态指示灯变绿即表示握手成功。

消息收发机制

主题层级与通配符

MQTT 通过主题（Topic）实现消息路由，采用层级结构组织：

factory/line-A/robot-01/status
home/bedroom/humidity

通配符支持批量订阅：

• +：匹配单一层级，如 device/+/telemetry 匹配 device/sensor01/telemetry
• #：匹配多层后缀，如 factory/# 匹配该层级下任意子主题

服务质量等级

等级	语义	适用场景
QoS 0	最多送达一次	高频 telemetry，允许偶发丢失
QoS 1	至少送达一次	关键状态通知，容忍重复
QoS 2	恰好送达一次	支付指令等高可靠场景

实操演示：多传感器数据汇聚

步骤一：创建订阅端

在已建立的连接中新增订阅，主题填写 sensor/+/temperature，QoS 设为 0。该模式可自动接收所有温度传感器的数据上报。

步骤二：模拟传感器设备

新建两个独立连接分别命名为 TempSensor-A 和 TempSensor-B，模拟分布式传感器节点。

步骤三：数据发布

在 TempSensor-A 连接中，向主题 sensor/A/temperature 发送载荷：

{
  "value": 23.5,
  "unit": "C",
  "ts": 1699123456
}

同理，TempSensor-B 向 sensor/B/temperature 发送数据。观察订阅端界面，可见两条消息按到达顺序呈现，实现多对一的数据汇聚。

高级特性验证

保留消息（Retained Message）

发布时启用 Retain 标志，消息将被服务端持久化。后续订阅者建立订阅时立即收到该主题下最新的保留消息——适用于设备状态、配置参数等场景。

验证方法：向 config/system 发布保留消息，然后新建订阅，观察是否即时收到历史数据。

持久会话（Persistent Session）

设置 Clean Session = false 并固定 Client ID，服务端将维护：

• 会话状态（订阅列表）
• 未确认的 QoS 1/2 消息
• 离线期间收到的 QoS 1/2 消息（受限于服务端配置）

验证流程：

1. 创建 MQTT 3.1.1 连接，Clean Session 置 false
2. 订阅 cmd/execute 主题，QoS 设为 1
3. 主动断开网络连接
4. 通过另一客户端向该主题发布三条 QoS 1 消息
5. 恢复网络并重新连接，观察离线消息是否补发

遗嘱消息（Last Will）

连接建立时预设遗嘱，当客户端异常断连（未发送 DISCONNECT）时，服务端自动代发遗嘱内容，用于上游系统感知设备离线。

配置示例：

遗嘱参数	设定值
主题	lwt/alert
QoS	1
保留标志	true
载荷	{"device":"node-01","event":"disconnected"}

验证时强制关闭浏览器标签或断网超保活周期，观察监控端是否收到遗嘱通知。

下一步

掌握上述基础后，可深入探索 MQTT 5.0 的共享订阅、消息过期、流量配额等企业级特性，或结合具体语言 SDK 构建生产级应用。

标签: MQTT