如何使用RabbitTemplate.convertSendAndReceive发送org.springframework.messaging.Message？

我知道你已经成功用org.springframework.amqp.core.Message实现了消息发送和byte[]接收的逻辑，现在想换成更通用的org.springframework.messaging.Message来调用RabbitTemplate.convertSendAndReceive对吧？其实这个转换非常顺畅，下面给你详细说明怎么操作：

核心逻辑 #

org.springframework.messaging.Message是Spring生态里通用的消息抽象，RabbitTemplate原生支持它作为入参。你只需要构建这个通用消息实例，直接传入方法即可，Spring会自动完成它和AMQP专属消息的转换工作，包括消息头和消息体的映射。

基础实现代码 #

首先导入对应的类：

import org.springframework.messaging.Message;
import org.springframework.messaging.support.MessageBuilder;
import org.springframework.amqp.rabbit.core.RabbitTemplate;

然后构建通用消息并调用方法：

// 构建通用Message实例，设置消息体和correlationId头
Message<byte[]> message = MessageBuilder.withPayload(payload)
        .setHeader("correlationId", id)
        .build();

// 直接传入convertSendAndReceive，接收返回的byte[]结果
byte[] response = (byte[]) rabbitTemplate.convertSendAndReceive(message);

进阶：自定义AMQP专属属性 #

如果需要设置更多AMQP特定的消息属性（比如优先级、过期时间等），可以借助AmqpHeaders和MessageHeaderAccessor来精准控制：

import org.springframework.amqp.support.AmqpHeaders;
import org.springframework.messaging.support.MessageHeaderAccessor;

// 创建消息头访问器，设置AMQP专属属性
MessageHeaderAccessor headerAccessor = MessageHeaderAccessor.create();
headerAccessor.setHeader(AmqpHeaders.CORRELATION_ID, id);
headerAccessor.setHeader(AmqpHeaders.PRIORITY, 5); // 设置消息优先级
headerAccessor.setHeader(AmqpHeaders.EXPIRATION, "30000"); // 设置消息过期时间30秒

// 用访问器构建通用Message
Message<byte[]> message = MessageBuilder.createMessage(payload, headerAccessor.getMessageHeaders());

// 调用方法并接收结果
byte[] response = (byte[]) rabbitTemplate.convertSendAndReceive(message);

关键注意点 #

• 不需要手动处理MessageProperties：Spring会自动把messaging.Message的头信息映射到AMQP的MessageProperties中，比如correlationId头会直接对应AMQP消息的correlationId属性。
• 返回值处理和之前一致：如果没有配置额外的消息转换器，返回结果依然可以直接强转为byte[]，和你之前用AMQP专属Message的逻辑完全兼容。

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