RabbitMQ发送器
使用说明
RabbitMQ发送器用于将文本消息发送到 RabbitMQ 消息队列,供其他消费者订阅和处理。
该工具适用于流数据处理结果需要推送到消息队列的流程。发送器可与 RabbitMQ 监听触发器配合使用,由监听触发器接收队列消息并触发后续处理逻辑。
功能原理
工具根据服务器地址、端口、虚拟主机和账号信息建立 RabbitMQ 连接,并按照交换机、路由 key 和队列绑定配置发送消息。
- 直连交换机:按路由 key 精确匹配队列,适用于明确路由的消息发送。
- 主题交换机:按主题规则匹配路由,适用于多类型消息分发。
- 直接队列:交换机和路由 key 均为空时,消息直接发送到指定队列。
SuperMap TransformX 2026 版本开始支持。
参数说明
| 参数名 | 参数释义 | 参数类型 |
|---|---|---|
| 消息 | 需要发送到 RabbitMQ 的消息内容。 | String |
| 服务器地址 | RabbitMQ 服务器地址。 | String |
| 端口 (可选) |
RabbitMQ 服务器端口。默认值为 5672。 | Integer |
| 虚拟主机 (可选) |
RabbitMQ 虚拟主机名称。 | String |
| 用户名 (可选) |
连接 RabbitMQ 的用户名。 | String |
| 密码 (可选) |
连接 RabbitMQ 的密码。 | String |
| 交换机 (可选) |
接收生产者消息并将消息路由到队列的交换机名称。 | String |
| 交换机类型 (可选) |
交换机类型。DIRECT 表示直连交换机,topic 表示主题交换机。默认值为 DIRECT。 | RabbitMQExchangeType |
| 交换机持久化 (可选) |
交换机是否持久化。DURABLE 表示服务器重启后仍保留交换机,TRANSIENT 表示不保留。默认值为 DURABLE。 | ExchangeDurability |
| 路由key (可选) |
发布消息时使用的路由 key。交换机为空时,该参数表示队列名称。 | String |
| 队列 (可选) |
消息发送目标队列。绑定路由不为空时,通过路由绑定交换机与队列,并按路由 key 匹配发送队列;交换机和路由 key 均为空时,直接发送到指定队列。 | RabbitMQQueueBinder |
输出结果
| 参数名 | 参数释义 | 参数类型 |
|---|---|---|
| 结果 | 消息发送结果。true 表示发送成功,false 表示发送失败。 | Boolean |