RabbitMQ通过Shovel转发至ActiveMQ Classic的消息格式异常问题

核心结论 #

可以只保留纯JSON内容，这不是AMQP协议本身的特性，而是RabbitMQ Shovel的默认行为导致的——它会把RabbitMQ原生的消息属性（比如exchange、routing_key等）封装到转发的消息payload里，才出现了你看到的带乱码元数据的内容。

解决配置方案 #

要去除额外元数据，只需在RabbitMQ的Shovel配置里调整参数，让它仅转发原始消息体：

1. 通过rabbitmq.conf配置 #

shovels.my-shovel {
  source = {
    protocol = amqp10
    uri = "amqp://user:pass@rabbitmq-host:5672/"
    queue = "src-queue"
  }
  destination = {
    protocol = amqp10
    uri = "tcp://activemq-host:5672/"
    address = "queue:/dest-queue"
  }
  # 仅保留必要的消息属性，可根据需求调整
  publish_properties = [content_type, content_encoding]
  # 关键配置：直接转发原始消息体，不封装元数据
  payload_encoding = raw
}

2. 通过RabbitMQ管理UI配置 #

• 创建或编辑Shovel时，切换到Advanced选项卡
• 将Payload encoding设置为raw
• 在Publish properties中仅保留业务需要的属性（如content_type），避免包含RabbitMQ内部属性

原理说明 #

RabbitMQ Shovel默认会把自身的消息元数据序列化成Java对象（你看到的乱码部分就是序列化后的对象头），再拼接原始JSON payload。通过payload_encoding = raw配置，Shovel会跳过元数据封装步骤，直接将原始的JSON字节流发送到ActiveMQ，这样ActiveMQ队列中收到的就只有纯JSON内容了。

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