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

相关主题

RabbitMQ监听触发器