第10章 Mosquitto桥接模式

第10章 Mosquitto桥接模式10.1 桥接模式概述桥接本地本地本地本地Broker ABroker B客户端A1客户端A2客户端B1客户端B2消息转发10.2 桥接类型本地桥接桥接桥接Broker主监听器1: 1883监听器2: 1884客户端组1客户端组2主题转发本地桥接同一Broker远程桥接网络桥接边缘Broker云端Broker本地设备云端服务主题同步数据聚合10.3 配置本地桥接# /etc/mosquitto/mosquitto.conf# 主监听器listener1883# 桥接连接connection bridge-to-remote address remote.broker.com:1883# 远程桥接的客户端IDremote_clientid bridge_local remote_username bridge_user remote_password bridge_pass# 要桥接的主题topic sensor/# out 1topic cmd/# in 1# 尝试重连try_privatetruestart_type automatic notificationstruecleansessionfalse10.4 配置远程桥接# /etc/mosquitto/mosquitto.conf# 桥接到云端connection cloud-bridge address cloud.mqtt.io:8883# TLS配置bridge_cafile /etc/mosquitto/ca.crt bridge_certfile /etc/mosquitto/bridge.crt bridge_keyfile /etc/mosquitto/bridge.key# 认证remote_username edge_bridge remote_password secure_password# 主题映射topic local/data/# out 1topic cloud/cmd/# in 1# 桥接配置try_privatetruecleansessionfalsekeepalive_interval6010.5 桥接主题方向outinbothboth本地主题远程主题本地Broker远程Brokerlocal/#remote/#主题方向示例# out: 从本地发布到远程topic sensor/# out 1# in: 从远程订阅到本地topic cmd/# in 1# both: 双向转发topic status/# both 110.6 桥接连接流程远程Broker本地Broker远程Broker本地Broker启动桥接订阅远程主题本地客户端发布本地客户端发布CONNECTClientIDbridge_localCONNACK连接成功SUBSCRIBE cmd/SUBACKPUBLISH cmd/device1 on转发到本地订阅者PUBLISH sensor/temp 25转发到远程订阅者10.7 多桥接配置# /etc/mosquitto/mosquitto.conf# 桥接1: 到数据中心connection datacenter-bridge address dc1.mqtt.io:1883 topic aggregate/# out 1remote_clientid bridge_to_dc1 remote_username bridge remote_password pass# 桥接2: 到备份中心connection backup-bridge address dc2.mqtt.io:1883 topic aggregate/# out 1remote_clientid bridge_to_dc2 remote_username bridge remote_password pass# 桥接3: 到云端connection cloud-bridge address cloud.mqtt.io:8883 bridge_cafile /etc/mosquitto/ca.crt topic sensor/# out 1topic cloud/cmdin1多桥接架构边缘Broker数据中心1数据中心2云端服务本地设备本地设备数据存储数据备份数据分析10.8 桥接监控# 桥接状态mosquitto_sub-v-t$SYS/broker/connection/## 桥接消息统计$SYS/broker/connection/bridge-local/state$SYS/broker/connection/bridge-local/messages/received$SYS/broker/connection/bridge-local/messages/sent10.9 桥接应用场景场景1: 边缘云计算桥接边缘设备边缘Mosquitto本地处理云端Mosquitto大数据分析长期存储场景2: 多地域部署# 区域Aconnection to-region-b address region-b.mqtt.io:1883 topic region-a/# both 1# 区域Bconnection to-region-a address region-a.mqtt.io:1883 topic region-b/# both 110.10 本章小结掌握了桥接模式配置,实现了多Broker之间的消息转发。