RabbitMQ接收器
使用说明
RabbitMQ 接收器用于连接 RabbitMQ 服务,从指定队列接收消息,并将消息内容作为输出结果。
该工具适用于通过交换机、路由 key 和队列配置接入实时消息数据。获取实时流数据时,可与 RabbitMQ 监听触发器配合使用,由触发器监听队列并触发后续处理流程。
功能原理
工具根据 RabbitMQ 连接信息建立消息通道,通过交换机和路由 key 定位队列,读取队列中的消息并输出。
- direct 交换机:根据完全匹配的路由 key 将消息发送到指定队列。
- topic 交换机:根据主题匹配规则将消息发送到符合条件的队列。
SuperMap TransformX 2026 版本开始支持。
参数说明
| 参数名 | 参数释义 | 参数类型 |
|---|---|---|
| 服务器地址 | RabbitMQ 服务器地址。 | String |
| 端口(可选) | RabbitMQ 服务器端口号。默认值为 5672。 | Integer |
| 虚拟主机(可选) | RabbitMQ 服务器虚拟主机名称。 | String |
| 用户名(可选) | 连接 RabbitMQ 服务器的用户名。 | String |
| 密码(可选) | 连接 RabbitMQ 服务器的密码。 | String |
| 交换机 | 用于接收生产者发送的消息并将消息路由到队列的交换机。 | String |
| 交换机类型(可选) | 交换机类型。默认值为 DIRECT,支持 direct 和 topic。 | ExchangeType |
| 交换机持久化(可选) | 交换机是否持久化。DURABLE 表示服务器重启后交换机仍然存在,TRANSIENT 表示不持久化。 | ExchangeDurability |
| 队列名称 | 需要接收消息的队列名称。 | String |
| 路由 key | 将消息路由到指定队列的关键字。 | String |
| 消息数量(可选) | 接收的消息数量。填 0 表示获取全部消息;大于 0 时,仅获取指定数量的消息。默认值为 0。 | Integer |
输出结果
| 参数名 | 参数释义 | 参数类型 |
|---|---|---|
| 请求结果 | 接收到的 RabbitMQ 消息内容。 | String |
相关主题