适配无TLS受限设备的MQTT转Google Cloud PubSub重发布方案咨询

核心逻辑 #

Google Cloud PubSub 相关的官方MQTT接入端点强制要求TLS加密和证书认证，无法直接对接仅支持明文MQTT over TCP的受限设备，因此你需要部署一层中间MQTT broker做中转，broker侧负责和设备走明文MQTT通信，再由broker将消息转发到Google PubSub。 #

方案1：开源自建方案（成本最低，灵活性最高） #

选用开源MQTT broker（推荐EMQX或Eclipse Mosquitto）完成部署：

• 第一步：部署MQTT broker到和受限设备网络可达的区域，开放默认1883明文MQTT端口，配置基础接入认证规则（支持Client ID白名单、用户名密码校验），避免未授权设备接入。
• 第二步：配置消息转发规则：
  • 若使用EMQX：直接调用内置的GCP PubSub桥接插件，把有权限写入PubSub的GCP服务账号密钥填入插件配置，设置匹配指定MQTT Topic的消息自动转发到目标PubSub Topic即可。
  • 若使用Eclipse Mosquitto：可开发轻量消费脚本，用MQTT客户端消费broker上的目标Topic消息，调用Google Cloud PubSub SDK完成消息上报即可，核心逻辑不超过百行代码。
• 第三步：安全加固：
  若设备和broker跨公网通信，需配置IP白名单限制仅已知设备可访问broker的1883端口；若传输包含敏感数据，可要求设备在应用层对payload做加密，broker仅做透传即可。

方案2：托管式方案（无需运维，稳定性更高） #

选用支持明文MQTT over TCP接入的托管物联网平台，无需自行运维broker，直接在平台侧配置规则引擎，将设备上报的消息自动转发到Google PubSub即可，后续的扩容、故障恢复、监控都由平台侧负责。 #

可选优化项 #

• 可在broker侧先做数据预处理：包含格式校验、去重、脱敏、聚合后再转发到PubSub，降低云端处理成本。
• 配置broker侧离线缓存：当broker到Google Cloud的网络临时中断时，先缓存消息，网络恢复后自动补发，避免数据丢失。
• 配置监控告警：监控设备连接数、消息转发成功率、转发延迟等核心指标，故障时及时触发告警。

内容的提问来源于stack exchange，提问作者Soumitri Pattnaik