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