argoproj/mqtt-gateway

镜像概述

MQTT网关镜像作为物联网系统的关键中间件，提供高效的消息转发与协议转换能力，连接不同MQTT broker、协议网络或设备集群，实现跨网络、跨协议的消息交互。以MQTT协议为核心枢纽，简化多设备、多平台间的数据通信架构，提升系统集成灵活性与可扩展性。

核心功能特性

• 协议转换：支持HTTP、CoAP、MQTT-SN等协议与标准MQTT的双向转换，适配非MQTT原生设备接入
• 智能消息路由：基于主题(Topic)、消息内容、设备标识的灵活路由规则，实现消息精准转发
• 多网络桥接：同时连接多个MQTT broker（本地与云端、多区域节点），构建分布式MQTT网络拓扑
• 高可用设计：内置断线重连、消息缓存（QoS 0/1/2支持）及负载均衡机制，保障传输可靠性
• 轻量化部署：基于精简系统构建，镜像体积小、资源占用低，适配边缘与云端部署场景
• 可配置化：通过环境变量、配置文件或API动态调整路由规则、连接参数及日志级别，支持自定义扩展

使用场景

• 物联网系统集成：在多厂商设备组成的IoT系统中统一消息接入标准，解决协议碎片化问题
• 多协议设备互联：连接HTTP/CoAP传感器与MQTT云平台，实现跨协议数据汇聚与指令下发
• 跨区域MQTT网络桥接：桥接本地边缘节点与云端中心节点，构建全局分布式MQTT消息网络
• 设备集群管理：对大量MQTT设备分组管理，通过消息过滤、聚合减轻核心broker负载
• 边缘-云端协同：作为边缘计算场景中边缘节点与云端平台的通信桥梁，实现本地预处理与云端同步

使用方法

快速启动（docker run）

bash
docker run -d \
  --name mqtt-gateway \
  -p 1883:1883 \  # 本地MQTT接入端口
  -p 8883:8883 \  # 加密MQTT接入端口（可选）
  -e LOCAL_BROKER_URL=mqtt://localhost:1883 \  # 本地MQTT broker地址
  -e REMOTE_BROKER_URL=mqtt://cloud-broker.example.com:1883 \  # 远程MQTT broker地址
  -e ROUTE_RULES='{"topic/+/local":"topic/remote","topic/cloud/#":"topic/local/cloud"}' \  # 主题路由规则（JSON格式）
  -e LOG_LEVEL=info \  # 日志级别（debug/info/warn/error）
  mqtt-gateway:latest

核心环境变量配置

Docker Compose示例

yaml
version: '3.8'
services:
  mqtt-gateway:
    image: docker.xuanyuan.run/mqtt-gateway:latest
    container_name: mqtt-gateway
    ports:
      - "1883:1883"  # 本地MQTT端口
      - "5683:5683/udp"  # CoAP协议端口（若启用CoAP适配器）
    environment:
      - LOCAL_BROKER_URL=mqtt://local-broker:1883
      - REMOTE_BROKER_URL=mqtt://cloud-broker:1883,mqtt://region-broker:1883
      - ROUTE_RULES='{
          "sensor/+/data": "cloud/sensor/data",
          "cloud/command/+/device": "command/{{device_id}}/execute"
        }'
      - PROTOCOL_ADAPTERS=mqtt,coap
      - LOG_LEVEL=debug
      - AUTH_USERNAME=gateway-user
      - AUTH_PASSWORD=secure-passwd
    depends_on:
      - local-broker
    restart: unless-stopped

  local-broker:
    image: docker.xuanyuan.run/eclipse-mosquitto:latest
    container_name: local-mqtt-broker
    ports:
      - "1884:1883"  # 避免与网关端口冲突
    volumes:
      - ./mosquitto/config:/mosquitto/config
      - ./mosquitto/data:/mosquitto/data
    restart: unless-stopped

注意事项

• 网络配置：确保网关容器与目标broker网络互通，边缘环境需配置端口映射与防火墙规则
• 安全加固：生产环境建议启用MQTT over TLS（mqtts://），并通过环境变量设置认证信息
• 性能调优：高并发场景下可调整MESSAGE_QUEUE_SIZE及broker连接参数（心跳间隔、重连策略）
• 日志与监控：通过LOG_LEVEL=debug开启详细日志排查问题，关键指标可通过Prometheus监控（需启用插件）