EMQX v5.0通过连接器和规则同步数据

1 概述

EMQX数据集成功能，帮助用户将所有的业务数据无需额外编写代码即可快速完成处理与分发。

数据集成能力由连接器和规则两部分组成，用户可以使用数据桥接或 MQTT 主题来接入数据，使用规则处理数据后，再通过数据桥接将数据发送到外部应用系统中。

例如，本地EMQX集群可以通过上述的连接器和规则来将数据复制一份到远程EMQX集群。

2 部署两个EMQX

通过一台机器，docker run出两个EMQX实例来模拟新数据的复制。

2.1 运行emqx-01，作为本地EMQX集群。

docker run -d --name emqx-01 -p 1883:1883 -p 8083:8083 -p 8084:8084 -p 8883:8883 -p 18083:18083 emqx/emqx:latest

1883端口emqx-01的mqtt端口。
18083端口是emqx-01的web控制台。

2.2 运行emqx-02，作为远程EMQX集群。

docker run -d --name emqx-02 -p 21883:1883 -p 28083:8083 -p 28084:8084 -p 28883:8883 -p 38083:18083 emqx/emqx:latest

21883端口emqx-02的mqtt端口。
38083端口是emqx-01的web控制台。

3 为本地EMQX配置连接器和规则

创建连接器，选择MQTT集群这个类型：


为连接器创建规则：

在规则中，先添加动作，该动作就是将输入数据进行提取，然后发送到远程集群：

在规则中，设置哪些本地数据应该复制到远程，设置t/开头的所有话题都应该被选中：

规则添加完成，如下图：

4 测试

1）步骤1：
客户端mqttx一直监听emqx-02的话题t/a。

2）步骤2：

客户端mqttx向emqx-01的t/a这个话题发布一个消息：

2）步骤3：
已经订阅emqx-02的话题t/a的客户端mqttx，马上收到一个新的消息：

5 小结

本文介绍EMQX的原生的数据复制能力，并且通过单机模拟两个EMQX服务来亲自实践，让大家更好的理解零代码纯配置就能解决EMQX集群之间的数据分发。