第四章 Mosquitto集群部署：桥接模式实战
好，咱们今天聊点硬核的。Mosquitto的桥接模式，说白了就是让多个Broker手拉手连成一张网。我最早接触这个，是在一个智慧农业项目里——几百个传感器分布在几十个大棚里，单个Broker根本扛不住。嗯，那时候我就开始研究桥接了。
4.1 桥接模式的核心原理
桥接模式，你可以理解成「消息的中转站」。两个Mosquitto实例通过TCP连接，互相订阅对方的主题。A节点收到消息，如果匹配了B节点的订阅规则，就转发过去。反过来也一样。
为什么会这样设计？你想想看，物联网设备分布在天南海北，网络延迟、带宽限制都是问题。桥接模式让每个Broker只负责本区域的设备，跨区域的消息通过桥接通道传递。说白了，就是「分而治之」的思想。
核心要点：
- 桥接是双向的，也可以配置成单向
- 每个桥接连接独立维护，互不影响
- 支持主题映射，可以重写消息的主题
我在项目中遇到过一个问题：两个Broker桥接后，消息循环转发，导致风暴。后来发现是主题映射没配好，A发出去的消息又被B转发回来。嗯，这里要注意——桥接一定要避免环路。
4.2 多节点桥接配置实战
咱们直接上配置。假设有三台服务器：broker1、broker2、broker3，IP分别是192.168.1.10、192.168.1.20、192.168.1.30。
先看broker1的配置，在mosquitto.conf里加上：
# 桥接到broker2
connection bridge-to-broker2
address 192.168.1.20:1883
topic sensor/# out 2
topic actuator/# in 2
remote_username bridge_user
remote_password bridge_pass
start_type automatic
try_private true
# 桥接到broker3
connection bridge-to-broker3
address 192.168.1.30:1883
topic sensor/# out 2
topic actuator/# in 2
remote_username bridge_user
remote_password bridge_pass
start_type automatic
try_private true
broker2和broker3的配置类似，只是IP地址换一下。我个人习惯把桥接配置单独放一个文件，用include_dir引入，方便管理。
小技巧： topic sensor/# out 2 表示把本地sensor主题的消息发出去，QoS等级为2。后面的数字是QoS，别搞反了。
配置完重启服务：
sudo systemctl restart mosquitto检查桥接状态：
mosquitto_sub -t '$SYS/broker/connection/bridge-to-broker2/state' -v返回1表示连接正常，0表示断开。我曾经遇到一个坑——防火墙没开1883端口，桥接一直连不上，查了半天才发现。所以，先telnet测试一下端口通不通。
4.3 负载均衡策略
桥接模式本身不提供负载均衡，但我们可以搭配其他工具实现。常用的策略有三种：
| 策略 | 实现方式 | 适用场景 |
|---|---|---|
| DNS轮询 | 多个A记录指向不同Broker | 设备端简单分发 |
| 硬件负载均衡 | F5、A10等设备 | 企业级高并发 |
| 软件负载均衡 | HAProxy、Nginx | 中小规模集群 |
我个人推荐HAProxy，轻量、配置简单。下面是一个HAProxy的配置片段：
frontend mqtt_front
bind *:1883
mode tcp
default_backend mqtt_back
backend mqtt_back
mode tcp
balance roundrobin
server broker1 192.168.1.10:1883 check
server broker2 192.168.1.20:1883 check
server broker3 192.168.1.30:1883 check
你想想看，设备连接HAProxy，HAProxy把请求轮询分发给三个Broker。每个Broker之间通过桥接同步消息。这样既实现了负载均衡，又保证了数据一致性。
注意： 桥接模式下，消息会有一定的延迟。如果业务对实时性要求极高，比如工业控制，建议用其他方案。
4.4 集群监控方案
集群搭好了，不监控等于白搭。我常用的监控手段有三个层面：
第一层：系统指标
CPU、内存、网络IO、磁盘。用Prometheus + Node Exporter就能搞定。我习惯在每台Broker上部署Node Exporter，然后Grafana画仪表盘。
第二层：MQTT指标
Mosquitto的$SYS主题提供了丰富的内部状态：
mosquitto_sub -t '$SYS/broker/#' -v | grep -E 'clients|messages|bytes'重点关注这几个指标：
clients/connected：当前连接数messages/sent：发送消息总数bytes/received：接收字节数heap/current：当前堆内存使用
第三层：桥接状态
每个桥接连接都有对应的$SYS/broker/connection/<名称>/state主题。我写了个脚本，每分钟检查一次，如果状态为0就告警：
#!/bin/bash
# 检查桥接状态
STATE=$(mosquitto_sub -t '$SYS/broker/connection/bridge-to-broker2/state' -C 1)
if [ "$STATE" != "1" ]; then
echo "桥接连接异常！" | mail -s "MQTT告警" admin@example.com
fi嗯，这里要注意——$SYS主题默认只有本地能订阅。如果你要远程监控，记得在配置里加上allow_anonymous true或者创建专门的监控用户。
避坑指南： 我曾经在生产环境里，因为监控脚本订阅了太多$SYS主题，导致Broker性能下降。后来改成只订阅关键指标，问题就解决了。监控也要讲究「够用就好」。
最后说一句，桥接模式不是万能的。如果你的集群规模超过10个节点，或者消息量达到百万级/秒，建议考虑专业的MQTT集群方案，比如EMQX。但中小规模场景下，Mosquitto桥接完全够用，而且免费、稳定。
好，这一章就到这里。下一章咱们聊聊Mosquitto的鉴权与安全配置，这可是生产环境的必修课。