MQTT 桥接

EMQ X 桥接转发 MQTT 消息到 MQTT Broker:

image

mqtt bridge 桥接插件配置文件: etc/plugins/emqx_bridge_mqtt.conf。

配置 MQTT 桥接的 Broker 地址

  1. ## 桥接地址： 使用节点名则用于 rpc 桥接，使用 host:port 用于 mqtt 连接
  2. bridge.mqtt.aws.address = 127.0.0.1:1883
  4. ## 桥接的协议版本
  5. ## 枚举值: mqttv3 | mqttv4 | mqttv5
  6. bridge.mqtt.aws.proto_ver = mqttv4
  8. ## mqtt 连接是否启用桥接模式
  9. bridge.mqtt.aws.bridge_mode = true
  11. ## mqtt 客户端的 client_id
  12. bridge.mqtt.aws.client_id = bridge_aws
  14. ## mqtt 客户端的 clean_start 字段
  15. ## 注: 有些 MQTT Broker 需要将 clean_start 值设成 `true`
  16. bridge.mqtt.aws.clean_start = true
  18. ## mqtt 客户端的 username 字段
  19. bridge.mqtt.aws.username = user
  21. ## mqtt 客户端的 password 字段
  22. bridge.mqtt.aws.password = passwd
  24. ## mqtt 客户端是否使用 ssl 来连接远程服务器
  25. bridge.mqtt.aws.ssl = off
  27. ## 客户端 SSL 连接的 CA 证书 (PEM格式)
  28. bridge.mqtt.aws.cacertfile = etc/certs/cacert.pem
  30. ## 客户端 SSL 连接的 SSL 证书
  31. bridge.mqtt.aws.certfile = etc/certs/client-cert.pem
  33. ## 客户端 SSL 连接的密钥文件
  34. bridge.mqtt.aws.keyfile = etc/certs/client-key.pem
  36. ## SSL 加密算法
  37. bridge.mqtt.aws.ciphers = ECDHE-ECDSA-AES256-GCM-SHA384,ECDHE-RSA-AES256-GCM-SHA384
  39. ## TLS PSK 的加密算法
  40. ## 注意 'listener.ssl.external.ciphers' 和 'listener.ssl.external.psk_ciphers' 不能同时配置
  41. ##
  42. ## See 'https://tools.ietf.org/html/rfc4279#section-2'.
  43. bridge.mqtt.aws.psk_ciphers = PSK-AES128-CBC-SHA,PSK-AES256-CBC-SHA,PSK-3DES-EDE-CBC-SHA,PSK-RC4-SHA
  45. ## 客户端的心跳间隔
  46. bridge.mqtt.aws.keepalive = 60s
  48. ## 支持的 TLS 版本
  49. bridge.mqtt.aws.tls_versions = tlsv1.2,tlsv1.1,tlsv1

配置 MQTT 桥接转发和订阅主题

  1. ## 桥接的 mountpoint(挂载点)
  2. bridge.mqtt.aws.mountpoint = bridge/aws/${node}/
  4. ## 转发消息的主题
  5. bridge.mqtt.aws.forwards = topic1/#,topic2/#
  7. ## 用于桥接的订阅主题
  8. bridge.mqtt.aws.subscription.1.topic = cmd/topic1
  10. ## 用于桥接的订阅 qos
  11. bridge.mqtt.aws.subscription.1.qos = 1
  13. ## 用于桥接的订阅主题
  14. bridge.mqtt.aws.subscription.2.topic = cmd/topic2
  16. ## 用于桥接的订阅 qos
  17. bridge.mqtt.aws.subscription.2.qos = 1

MQTT 桥接转发和订阅主题说明

挂载点 Mountpoint: mountpoint 用于在转发消息时加上主题前缀，该配置选项须配合 forwards 使用，转发主题为 sensor1/hello 的消息, 到达远程节点时主题为 bridge/aws/emqx1@192.168.1.1/sensor1/hello 。

转发主题 Forwards: 转发到本地 EMQX 指定 forwards 主题上的消息都会被转发到远程 MQTT Broker 上。

订阅主题 Subscription: 本地 EMQX 通过订阅远程 MQTT Broker 的主题来将远程 MQTT Broker 上的消息同步到本地。

启用 bridge_mqtt 桥接插件

  1. ./bin/emqx_ctl plugins load emqx_bridge_mqtt

桥接 CLI 命令

  1. $ cd emqx1/ && ./bin/emqx_ctl bridges
  2. bridges list                                    # List bridges
  3. bridges start \<Name>                            # Start a bridge
  4. bridges stop \<Name>                             # Stop a bridge
  5. bridges forwards \<Name>                         # Show a bridge forward topic
  6. bridges add-forward \<Name> \<Topic>              # Add bridge forward topic
  7. bridges del-forward \<Name> \<Topic>              # Delete bridge forward topic
  8. bridges subscriptions \<Name>                    # Show a bridge subscriptions topic
  9. bridges add-subscription \<Name> \<Topic> \<Qos>   # Add bridge subscriptions topic

列出全部 bridge 状态

  1. $ ./bin/emqx_ctl bridges list
  2. name: emqx     status: Stopped

启动指定 bridge

  1. $ ./bin/emqx_ctl bridges start emqx
  2. Start bridge successfully.

停止指定 bridge

  1. $ ./bin/emqx_ctl bridges stop emqx
  2. Stop bridge successfully.

列出指定 bridge 的转发主题

  1. $ ./bin/emqx_ctl bridges forwards emqx
  2. topic:   topic1/#
  3. topic:   topic2/#

添加指定 bridge 的转发主题

  1. $ ./bin/emqx_ctl bridges add-forwards emqx topic3/#
  2. Add-forward topic successfully.

删除指定 bridge 的转发主题

  1. $ ./bin/emqx_ctl bridges del-forwards emqx topic3/#
  2. Del-forward topic successfully.

列出指定 bridge 的订阅

  1. $ ./bin/emqx_ctl bridges subscriptions emqx
  2. topic: cmd/topic1, qos: 1
  3. topic: cmd/topic2, qos: 1

添加指定 bridge 的订阅主题

  1. $ ./bin/emqx_ctl bridges add-subscription emqx cmd/topic3 1
  2. Add-subscription topic successfully.

删除指定 bridge 的订阅主题

  1. $ ./bin/emqx_ctl bridges del-subscription emqx cmd/topic3
  2. Del-subscription topic successfully.