RabbitMQ监听触发器

使用说明

RabbitMQ 监听触发器用于订阅指定 RabbitMQ 队列。当队列中产生新消息时,触发器主动接收消息,并触发计划任务中的模型执行。

该触发器适用于实时消息驱动的数据处理流程,例如接收传感器消息、业务事件消息或外部系统推送数据,并将消息传递给模型中的解析工具。

功能原理

触发器根据 RabbitMQ 连接信息监听指定队列。接收到新消息后,将消息绑定到模型参数,并启动模型执行。

  • 队列监听:持续监听指定队列中的新增消息。
  • 参数绑定:将接收到的消息传递给模型中指定工具的参数。

SuperMap TransformX 2026 版本开始支持。

操作说明

构建模型时,添加“解析JSON要素”和“写出数据集”工具,设置模型参数。模型中不需要添加“简单RabbitMQ接收器”或“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 监听触发器参数绑定

输出结果

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