RabbitMQ：Queue→Shovel→Stream 如何配置适配Stream消息格式

核心问题 #

你用AMQP 0.9.1配置Shovel转发时，RabbitMQ不会自动把消息转换成Stream要求的RabbitMQ私有AMQP 1.0格式，这直接导致rbfly解码失败。

解决步骤 #

• 配置Shovel用AMQP 1.0转发到Stream节点
  在第一台节点的Shovel配置里，把目标端的连接URI指向Stream节点的AMQP 1.0端点（先确保该节点已启用amqp1_0插件），同时显式指定协议参数：

  [shovels]
  queue-to-stream-shovel =
    src-uri = amqp://<用户名>:<密码>@queue-node:5672
    src-queue = <你的缓冲队列名>
    dest-uri = amqp://<用户名>:<密码>@stream-node:5672
    dest-protocol = amqp10
    dest-queue = <你的目标Stream名>
  

  注意：dest-queue必须是Stream节点上已创建好的Stream名称，且该Stream要允许AMQP 1.0连接写入。

• 确认插件启用状态
  两台节点都要执行以下命令，确保AMQP 1.0和管理插件生效：

  rabbitmq-plugins enable amqp1_0 rabbitmq_management
  

• 发送端无需修改
  你用pika（AMQP 0.9.1）发消息到缓冲队列的逻辑不用改，Shovel通过AMQP 1.0转发时会自动完成格式转换。

排查注意事项 #

• 用rabbitmqctl log_tail查看Shovel日志，排查是否有协议连接或转换的报错。
• 验证Stream节点上的Stream是否正确创建，且Shovel使用的用户有写入权限。

结论 #

这个需求完全可以实现，你之前遗漏了Shovel的目标端协议配置，只要改成AMQP 1.0转发就能解决格式不兼容问题。

内容的提问来源于stack exchange，提问作者Moe