Docs

# 使用 EMQX Cloud 数据集成桥接数据到 MQTT Broker

为了方便多个 MQTT Broker 进行消息桥接，你可以使用数据集成进行操作。

这篇指南会创建一个 MQTT Broker 桥接的数据集成，实现下面的功能：

  • 将所有发送到 greet 主题的消息，转发到另一个 MQTT Broker 上

为了实现这个功能，我们会完成以下 5 个任务：

  1. 开启 Mosquitto 服务
  2. 创建 Broker Bridge 资源
  3. 创建规则
  4. 新建动作
  5. 完成数据集成创建，并进行测试

注意:

在使用数据集成前，请先创建部署。

对于专业版部署用户：请先完成对等连接，并确保以下涉及到的资源都建立在对等连接下的 VPC 中，下文提到的 IP 均指资源的内网 IP（专业版部署若开通 NAT 网关也可使用公网 IP 进行连接）

对于基础版用户：无需完成对等连接，下文提到的 IP 均指资源的公网 IP

# 1. 创建 Mosquitto 服务

在你的云服务器中，创建一个 Mosquitto 服务。为了方便演示，这里使用 Docker 快速搭建。(请勿在生产环境中使用)

docker run -it -p 1883:1883 --name mosquitto eclipse-mosquitto:1.6
1

之后，开放服务器的 1883 端口

# 2. 创建 MQTT Bridge 资源

进入 EMQX Cloud 控制台 (opens new window)，并点击进入要使用 MQTT Bridge 的部署。

在部署页面，选择数据集成，点击数据转发下的 MQTT Bridge 资源进行创建。

数据集成页

在创建资源页面里，按照如下设置：

  • 远程 broker 地址：填写服务器的 IP 地址以及端口
  • 桥接挂载点（非必填）：本示例中填写 emqx/，即在转发主题前面加了挂载点 emqx/

桥接挂载点：指桥接主题的挂载点，通常适用于需要在转发主题前加挂载点的场景中。例如将桥接主题的挂载点设置为emqx/, 当本地节点向 topic1 发消息时，远程桥接节点的主题会变换为 emqx/topic1

资源创建页

完成配置后点击测试连接，提示资源可用后便可点击新建来创建资源。

# 3. 创建规则

成功创建资源后可直接点击对话框中的创建规则或者回到数据集成界面，找到刚创建的资源点击操作下的新建规则。

规则创建1

我们的目标是：当有消息发送到 greet 主题时，就会触发规则。这里需要对 SQL 进行一定的处理：

  • 仅针对 'greet/#'

根据上面的原则，我们最后得到的 SQL 应该如下：

SELECT
   payload.msg as msg
FROM
    "greet/#"
1
2
3
4

规则创建2

# 4. 新建动作

完成规则配置后点击下一步，便可配置和新建动作。使用资源会默认选择到该资源，填写一个需要转发消息到主题，在消息内容模版里填写 "${msg} FROM EMQX CLOUD"，点击确定。

转发主题 (非必填)：指转发消息时使用的主题。如果未提供，则默认为桥接消息的主题。

规则创建3

完成动作创建后可继续添加一个动作或者完成创建回到数据集成界面。

# 5. 测试

如果您是第一次使用 EMQX Cloud 可以前往部署连接指南，查看 MQTT 客户端连接和测试指南

由于在创建资源时，我们将桥接挂载点设为 emqx/，新建动作时，我们将转发消息主题设置为 test-mqtt，这里用客户端订阅 Mosquitto 的 emqx/# 主题，实际接收到消息的主题为 emqx/test-mqtt

同时我们发送 "hello" 到 EMQX Cloud 的 greet 主题，数据集成就会触发。可以看到 Mosquitto 已经收到消息 "hello FROM EMQX CLOUD"

收到转发的消息

← 桥接数据到 Kafka →

本页导航