RabbitMQ监听触发器
使用说明
RabbitMQ 监听触发器用于订阅指定 RabbitMQ 队列。当队列中产生新消息时,触发器主动接收消息,并触发计划任务中的模型执行。
该触发器适用于实时消息驱动的数据处理流程,例如接收传感器消息、业务事件消息或外部系统推送数据,并将消息传递给模型中的解析工具。
功能原理
触发器根据 RabbitMQ 连接信息监听指定队列。接收到新消息后,将消息绑定到模型参数,并启动模型执行。
- 队列监听:持续监听指定队列中的新增消息。
- 参数绑定:将接收到的消息传递给模型中指定工具的参数。
SuperMap TransformX 2026 版本开始支持。
操作说明
构建模型时,添加“解析JSON要素”和“写出数据集”工具,设置模型参数。模型中不需要添加“简单RabbitMQ接收器”或“RabbitMQ接收器”。

发布模型后,在模型列表中选中模型,选择右键菜单“计划任务”。在计划任务窗口中设置计划任务名称,单击“添加”按钮配置触发器。

在触发器类型下拉列表中选择“RabbitMQ监听”,并填写 RabbitMQ 监听触发器参数。
参数说明
| 参数名 | 参数释义 | 参数类型 |
|---|---|---|
| 主机 | RabbitMQ 服务器地址。 | String |
| 端口(可选) | RabbitMQ 服务器端口号。默认值为 5672。 | Integer |
| 虚拟主机(可选) | RabbitMQ 服务器虚拟主机名称。 | String |
| 用户名(可选) | 连接 RabbitMQ 服务器的用户名。 | String |
| 密码(可选) | 连接 RabbitMQ 服务器的密码。 | String |
| 交换机(可选) | 用于接收生产者发送的消息并将消息路由到队列的交换机。 | String |
| 交换机类型(可选) | 交换机类型。默认值为 DIRECT,支持 direct 和 topic。 | ExchangeType |
| 交换机持久化(可选) | 交换机是否持久化。DURABLE 表示服务器重启后交换机仍然存在,TRANSIENT 表示不持久化。 | ExchangeDurability |
| 队列名称 | 需要监听并接收消息的队列名称。 | String |
| 路由 key(可选) | 将消息路由到指定队列的关键字。 | String |
展开高级设置,单击“添加”,绑定模型中“解析JSON要素”工具的 json 参数,将接收的消息传递至模型进行解析和写出。

输出结果
| 参数名 | 参数释义 | 参数类型 |
|---|---|---|
| 触发消息 | 监听到的 RabbitMQ 消息内容,可绑定到模型中的工具参数。 | String |