x/rabbitmqClient组件：v0.24.0+ RabbitMQ客户端组件。用于将消息发布到RabbitMQ消息服务器的指定交换机和路由键。

配置

该组件支持通过server字段复用共享的连接客户端，避免重复创建连接。详见组件连接复用。

字段	类型	必填	说明	默认值
server	string	是	RabbitMQ服务器地址，格式为amqp://username:password@host:port/	无
exchange	string	是	交换机名称	无
exchangeType	string	是	交换机类型，可选值：direct(直连)、fanout(扇出)、topic(主题)、headers(头)	无
key	string	是	路由键，支持使用组件配置变量进行动态配置	无
durable	bool	否	交换机持久化标志。true表示交换机会在服务器重启后保留	false
autoDelete	bool	否	自动删除标志。true表示当所有队列都不再使用该交换机时，会自动删除交换机	false

工作原理

1. 组件初始化时会根据配置连接到RabbitMQ服务器
2. 接收到消息后，将消息内容发布到指定的exchange和routing key
3. 发布成功后通过Success链路由，失败则通过Failure链路由
4. 组件会自动管理连接的生命周期，包括重连、心跳等

Relation Type

• Success: 消息成功发布到RabbitMQ服务器时，原始消息发送到Success链路
• Failure: 以下情况消息发送到Failure链路:
  • 连接RabbitMQ服务器失败
  • 交换机声明失败
  • 消息发布失败
  • 配置参数错误

执行结果

组件仅负责消息发布，不会修改原始消息的任何内容：

• msg保持不变
• metadata保持不变
• msgType保持不变

配置示例