# NanoMQ桥接到EMQX

桥接是一种连接多个 MQTT 消息中间件的方式。不同于集群，工作在桥接模式下的节点之间不会复制主题树和路由表。桥接模式所做的是：

按照规则把消息转发至桥接节点；
从桥接节点订阅主题，并在收到消息后在本节点/集群中转发该消息。

# 配置

需在配置nanomq.conf文件中进行配置

具体配置参数请参考桥接配置, 以下配置示例为Hocon格式配置:

重点配置项：

桥接功能启用: bridges.mqtt.nodes[].enable
远端broker地址: bridges.mqtt.nodes[].connector.server
转发远端Topic数组(支持MQTT 通配符): bridges.mqtt.nodes[].forwards
订阅远端Topic数组(支持MQTT 通配符): bridges.mqtt.nodes[].subscription

nanomq.conf桥接配置部分

bridges.mqtt {
	nodes = [ 
		{
			## 桥接节点名
			name = emqx
			## 启用桥接功能
			enable = true
			connector {
				## TCP URL格式:  mqtt-tcp://host:port
				## TLS URL格式:  tls+mqtt-tcp://host:port
				## QUIC URL格式: mqtt-quic://host:port
				server = "mqtt-tcp://broker.emqx.io:1883"
				## MQTT协议版本 （4 ｜ 5）
				proto_ver = 4
				# username = admin
				# password = public
				clean_start = true
				keepalive = 60s
				ssl {
					enable = false
					keyfile = "/etc/certs/key.pem"
					certfile = "/etc/certs/cert.pem"
					cacertfile = "/etc/certs/cacert.pem"
				}
			}
			forwards = ["forward1/#","forward2/#"]
			subscription = [
				{
					topic = "recv/topic1"
					qos = 1
				},
				{
					topic = "recv/topic2"
					qos = 2
				}
			]
			congestion_control = cubic
			parallel = 2
			max_send_queue_len = 1024
			max_recv_queue_len = 1024
		}
	]
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43

如需查看运行过程中更多日志数据，可以在配置文件中设置日志等级 log.level

# 运行

启动 NanoMQ 时使用--conf 指定配置文件路径（若配置文件已放置于系统路径/etc/nanomq.conf 则无需在命令行指定）

$ nanomq start --conf nanomq.conf

# 验证桥接

验证桥接是否成功，只需往桥接的上下行主题发送数据即可，也可以使用 NanoMQ 自带的 nanomq_cli 工具中的 QUIC 客户端来与 EMQX 5.0 测试验证。

# 测试消息转发

使用nanomq自带客户端工具测试桥接消息的收发。

订阅远端EMQX Broker的主题：
从EMQX订阅转发的主题 “forward1/#”, 该主题将接收到从NanoMQ上转发的数据：
在第1个终端上执行订阅:
```
$ nanomq_cli sub --url "mqtt-tcp://broker.emqx.io:1883" -t  "forward1/#"
forward1/msg: forward_msg
```
1
2
发布消息到本地NanoMQ Broker主题:
发布消息到NanoMQ Broker，主题为 “forward1/msg”：
在第2个终端上执行消息发布:
```
$ nanomq_cli pub -t  "forward1/msg"  -m "forward_msg"
```
1

# 测试消息接收

订阅本地NanoMQ Broker的主题：
从NanoMQ订阅主题 “cmd/topic1”, 该主题将接收到EMQX上发布的数据：
在第3个终端上执行订阅:
```
$ nanomq_cli sub -t "recv/topic1"
recv/topic1: cmd_msg
```
1
2
发布消息到远端EMQX Broker主题“cmd/topic1”：
在第4个终端上执行消息发布:
```
$ nanomq_cli pub --url "mqtt-tcp://broker.emqx.io:1883" -t  "recv/topic1" -m "cmd_msg"
```
1

← Docker MQTT over QUIC桥接 →