📚 课程目录第4章 MQTT Broker搭建

4. MQTT Broker搭建：使用公共Broker与本地搭建

MQTT协议采用发布/订阅模式，Broker是消息流转的中枢。设备端（Publisher/Subscriber）不直接通信，而是统一连接到Broker，由Broker根据主题（Topic）路由消息。因此，选择一个合适的Broker并正确搭建，是物联网项目从原型走向稳定运行的关键一步。本章将围绕“公共Broker”与“本地Broker”两条路线展开，帮助你在不同阶段做出合理选择。

4.1 核心原理：Broker在MQTT架构中的角色

在MQTT架构中，Broker承担三个核心职责：连接管理（维护所有客户端的TCP/TLS会话）、主题路由（根据通配符匹配规则将消息从发布者转发给订阅者）、服务质量保障（处理QoS 0/1/2的确认与重发逻辑）。理解Broker的工作机制，有助于后续排查消息丢失或重复的问题。

关键点：Broker不存储业务数据（除非启用Retain或持久化会话），它只做“即时转发”。如果订阅者不在线，QoS 1消息默认会被丢弃（除非订阅者使用持久化会话）。因此，Broker的稳定性直接决定整个物联网链路的可靠性。

上图展示了Broker的核心路由逻辑：左侧多个发布者将消息推送到Broker，Broker内部通过主题匹配引擎（支持通配符 + 和 #）确定转发目标，最终将消息推送给所有匹配的订阅者。整个过程对客户端透明，客户端无需知道对方IP地址。

4.2 方法流程：公共Broker与本地Broker的选择

搭建Broker前，需要根据项目阶段和需求权衡。下表对比了两种方式的适用场景与优缺点：

对比维度	公共Broker（如EMQX、Mosquitto测试服务器）	本地Broker（自建）
上手难度	零配置，注册即可用	需要安装、配置、维护
网络延迟	依赖公网，延迟较高	局域网内毫秒级响应
数据安全	数据经过第三方服务器	数据完全自主可控
稳定性	取决于服务商SLA	取决于自身服务器资源
典型场景	开发调试、跨地域演示	生产环境、隐私敏感项目

4.2.1 使用公共Broker快速验证

对于课程实验或原型验证，推荐使用公共Broker。以EMQX提供的公共服务器为例：

# EMQX 公共Broker 连接参数
Broker地址: broker.emqx.io
TCP端口: 1883
WebSocket端口: 8083
SSL端口: 8883
用户名/密码: 无需认证（匿名访问）

在NodeMCU中，使用PubSubClient库连接公共Broker的代码片段：

#include <PubSubClient.h>
const char* mqtt_server = "broker.emqx.io";

WiFiClient espClient;
PubSubClient client(espClient);

void setup() {
  client.setServer(mqtt_server, 1883);
  client.setCallback(callback);
}

void reconnect() {
  while (!client.connected()) {
    if (client.connect("NodeMCU_Client_01")) {
      client.subscribe("esp8266/control");
    }
  }
}

注意：公共Broker通常不保证数据持久性，且所有消息对公网可见。切勿在公共Broker上传输敏感数据（如设备密钥、用户隐私）。建议使用随机客户端ID，避免与其他用户冲突。

4.2.2 本地搭建Mosquitto Broker

当项目需要离线运行或数据保密时，本地搭建是更优选择。Mosquitto是轻量级开源Broker，适合树莓派、NAS或云主机。以下是在Ubuntu/Debian系统上的安装步骤：

# 1. 安装Mosquitto及客户端工具
sudo apt update
sudo apt install -y mosquitto mosquitto-clients

# 2. 启动服务并设置开机自启
sudo systemctl enable mosquitto
sudo systemctl start mosquitto

# 3. 查看运行状态
sudo systemctl status mosquitto

默认配置下，Mosquitto监听1883端口且允许匿名访问。为了安全，建议修改配置文件 /etc/mosquitto/mosquitto.conf：

# 禁止匿名访问
allow_anonymous false

# 设置密码文件
password_file /etc/mosquitto/passwd

# 监听端口（默认1883）
listener 1883 0.0.0.0

创建用户密码：

sudo mosquitto_passwd -c /etc/mosquitto/passwd iot_user
# 输入两次密码后，用户iot_user创建成功

重启服务使配置生效：

sudo systemctl restart mosquitto

4.2.3 本地搭建EMQX Broker（进阶）

EMQX支持集群、规则引擎和可视化Dashboard，适合更复杂的生产环境。安装EMQX（以Ubuntu为例）：

# 添加EMQX官方源
curl -s https://assets.emqx.com/scripts/install-emqx-deb.sh | sudo bash

# 安装EMQX
sudo apt install -y emqx

# 启动服务
sudo systemctl start emqx

# 访问Dashboard（默认端口18083）
# 浏览器打开 http://localhost:18083 ，默认账号 admin / public

EMQX Dashboard提供了直观的连接监控、主题订阅统计和消息流量图表，便于调试。

4.3 案例/场景：从公共Broker迁移到本地Broker

假设你已完成课程实验，现在需要将一套温湿度监测系统部署到实验室内部网络。迁移步骤如下：

在本地服务器安装Mosquitto（参考4.2.2节），并创建专用账号 lab_sensor。
修改NodeMCU代码中的Broker地址和端口：

const char* mqtt_server = "192.168.1.100";  // 本地服务器IP
const char* mqtt_user = "lab_sensor";
const char* mqtt_pass = "your_password";
int mqtt_port = 1883;

测试连接：使用mosquitto_sub命令行工具验证消息是否正常路由：

# 在服务器终端订阅所有主题
mosquitto_sub -h 192.168.1.100 -u lab_sensor -P your_password -t '#' -v

验证数据流：NodeMCU上电后，应能在终端看到类似输出：

sensor/temp {"value": 25.3, "unit": "C"}
sensor/humidity {"value": 60.1, "unit": "%"}

常见坑：迁移后NodeMCU无法连接Broker，首先检查本地服务器防火墙是否放行1883端口：sudo ufw allow 1883。其次确认NodeMCU与服务器在同一网段，且服务器IP未被路由器隔离。

4.4 误区/复盘：Broker搭建中的典型错误

根据教学经验，初学者在搭建Broker时容易陷入以下误区：

误区一：盲目使用公共Broker做生产环境。公共Broker的带宽和存储有限，且无法定制安全策略。如果设备量超过100台，建议立即迁移到自建Broker。
误区二：忽略QoS与Broker的配合。在弱网环境下，如果发布端使用QoS 0，Broker不会重发消息，导致数据丢失。正确做法是：传感器上报使用QoS 1，控制指令使用QoS 1或2。
误区三：不设置心跳与重连机制。NodeMCU断电重启后，如果Broker未及时清理旧会话，可能导致连接被拒绝。代码中应设置 client.setKeepAlive(30) 并实现自动重连逻辑。
误区四：混淆Broker与数据库。Broker不负责数据存储。如果需要在断线后补发数据，应使用持久化会话（Clean Session = false），但这也增加了Broker内存负担。更合理的方案是让订阅端（如Node-RED）将数据写入数据库。

复盘建议：每次搭建Broker后，务必使用 mosquitto_pub 和 mosquitto_sub 做一次完整的回环测试，确认Broker本身工作正常，再排查设备端代码。这能帮你快速定位问题是出在网络层、Broker配置还是设备固件。

通过本章学习，你应能根据项目阶段选择合适的Broker方案，并独立完成从公共Broker调试到本地Broker部署的完整流程。在实际项目中，建议先在公共Broker上验证设备端代码逻辑，再平滑迁移到本地Broker，以降低调试复杂度。