spring framework 6 移除了已废弃的 amqp remoting 模块，推荐使用 rabbittemplate 的 sendandreceive 方法配合 @rabbitlistener 实现轻量、可控的 rpc 调用，本文提供完整实现示例与关键注意事项。
spring framework 6 移除了已废弃的 amqp remoting 模块，推荐使用 rabbittemplate 的 sendandreceive 方法配合 @rabbitlistener 实现轻量、可控的 rpc 调用，本文提供完整实现示例与关键注意事项。
在 Spring AMQP 6.x 及更高版本中，原生的 AMQP Remoting（如 AmqpInvokerServiceExporter 和 AmqpInvokerProxyFactoryBean）已被彻底移除，因其耦合度高、灵活性差且维护成本上升。官方明确建议转向更底层、更透明的通信模式：基于请求-响应语义的手动消息交互。
核心替代方案由两部分组成：
- 客户端：使用 RabbitTemplate.sendAndReceive() 发送带 replyTo 属性的请求消息，并同步等待响应（支持超时控制）；
- 服务端：通过 @RabbitListener 监听请求队列，处理业务逻辑后，利用 MessageProperties.getReplyTo() 获取响应目标，并通过 RabbitTemplate.send() 或自动响应机制返回结果。
✅ 示例：实现一个简单的用户查询 RPC
// 客户端调用（例如 Service 层）
@Service
public class UserServiceClient {
private final RabbitTemplate rabbitTemplate;
public UserServiceClient(RabbitTemplate rabbitTemplate) {
this.rabbitTemplate = rabbitTemplate;
// 必须启用 reply-to 自动配置（默认已启用）
rabbitTemplate.setReplyTimeout(5000); // 建议显式设置超时
}
public User getUserById(Long id) {
String requestJson = "{\"id\":" + id + "}";
Message request = MessageBuilder.withBody(requestJson.getBytes(StandardCharsets.UTF_8))
.setContentType(MessageProperties.CONTENT_TYPE_JSON)
.build();
Message response = rabbitTemplate.sendAndReceive("user.rpc.exchange", "user.rpc.route", request);
if (response == null) {
throw new RuntimeException("RPC timeout or no response from server");
}
return new ObjectMapper().readValue(response.getBody(), User.class);
}
}// 服务端监听与响应（例如 RPC Endpoint）
@Component
public class UserRpcEndpoint {
private final RabbitTemplate rabbitTemplate;
private final ObjectMapper objectMapper;
public UserRpcEndpoint(RabbitTemplate rabbitTemplate, ObjectMapper objectMapper) {
this.rabbitTemplate = rabbitTemplate;
this.objectMapper = objectMapper;
}
@RabbitListener(queues = "user.rpc.queue")
public void handleUserRequest(Message message, Channel channel,
@Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag) throws Exception {
try {
String json = new String(message.getBody(), StandardCharsets.UTF_8);
UserQuery query = objectMapper.readValue(json, UserQuery.class);
User result = lookupUser(query.getId()); // 业务逻辑
String responseJson = objectMapper.writeValueAsString(result);
MessageProperties props = message.getMessageProperties();
String replyTo = props.getReplyTo(); // 获取原始 reply-to 地址（如 amq.rabbitmq.reply-to）
if (replyTo != null) {
Message response = MessageBuilder.withBody(responseJson.getBytes(StandardCharsets.UTF_8))
.setContentType(MessageProperties.CONTENT_TYPE_JSON)
.setCorrelationId(props.getCorrelationId())
.build();
rabbitTemplate.send("", replyTo, response); // 注意：replyTo 是临时队列名，routingKey 为空
}
channel.basicAck(deliveryTag, false);
} catch (Exception e) {
channel.basicNack(deliveryTag, false, true);
throw e;
}
}
private User lookupUser(Long id) {
return new User(id, "Alice", "alice@example.com");
}
}⚠️ 关键注意事项：
- sendAndReceive 默认依赖 RabbitMQ 的 amq.rabbitmq.reply-to 临时队列机制，无需预声明 reply 队列，但需确保 Broker 支持（RabbitMQ 3.7+ 默认启用）；
- 必须正确传递并回传 correlationId，以保障请求-响应匹配（RabbitTemplate 默认自动处理）；
- 生产环境建议配置 replyTimeout 和重试策略（如 RetryTemplate），避免线程阻塞；
- 若需异步 RPC 或流式响应，可进一步结合 Mono<Message>（Reactive RabbitMQ）或自定义回调机制；
- 不再推荐使用 SimpleMessageListenerContainer 手动管理连接——@RabbitListener 已提供完善的生命周期与并发控制。
总结而言，放弃高层 Remoting 抽象后，开发者获得更强的可控性与可观测性。虽然代码量略有增加，但换来了清晰的消息流向、灵活的错误处理和与 Spring Boot Actuator 等生态更好的集成能力。这是 Spring 向“约定优于配置、透明优于黑盒”演进的重要一步。
