分布桥接(Bridge)

emqttd节点间桥接

emqttd消息服务器支持多节点桥接模式互联:

              ---------                     ---------                     ---------
Publisher --> | node1 | --Bridge Forward--> | node2 | --Bridge Forward--> | node3 | --> Subscriber
              ---------                     ---------                     ---------

节点间桥接与集群不同，不复制主题树与路由表，只按桥接规则转发MQTT消息。

emqttd节点桥接配置

假设在本机创建两个emqttd节点，并创建一条桥接转发全部传感器(sensor)主题消息:

启动emqttd1, emqttd2节点:

cd emqttd1/ && ./bin/emqttd start
cd emqttd2/ && ./bin/emqttd start

emqttd1节点上创建到emqttd2桥接:

$ ./bin/emqttd_ctl bridges start emqttd2@127.0.0.1 sensor/#
bridge is started.
$ ./bin/emqttd_ctl bridges list
bridge: emqttd1@127.0.0.1--sensor/#-->emqttd2@127.0.0.1

测试emqttd1–sensor/#–>emqttd2的桥接:

#emqttd2节点上
mosquitto_sub -t sensor/# -p 2883 -d
#emqttd1节点上
mosquitto_pub -t sensor/1/temperature -m "37.5" -d

删除桥接:

./bin/emqttd_ctl bridges stop emqttd2@127.0.0.1 sensor/#

mosquitto桥接

mosquitto可以普通MQTT连接方式，桥接到emqttd消息服务器:

             -------------             -----------------
Sensor ----> | mosquitto | --Bridge--> |               |
             -------------             |    emqttd     |
             -------------             |    Cluster    |
Sensor ----> | mosquitto | --Bridge--> |               |
             -------------             -----------------

mosquitto.conf

本机2883端口启动emqttd消息服务器，1883端口启动mosquitto并创建桥接。

mosquitto.conf配置:

connection emqttd
address 127.0.0.1:2883
topic sensor/# out 2
# Set the version of the MQTT protocol to use with for this bridge. Can be one
# of mqttv31 or mqttv311. Defaults to mqttv31.
bridge_protocol_version mqttv311

rsmb桥接

本机2883端口启动emqttd消息服务器，1883端口启动rsmb并创建桥接。

broker.cfg桥接配置:

connection emqttd
addresses 127.0.0.1:2883
topic sensor/#