Spring 6 中 AMQP 远程调用（Remoting）的替代方案-java教程-PHP中文网

spring 6 移除了对 amqp remoting 的原生支持，推荐使用 rabbittemplate 的 sendandreceive 方法配合 @rabbitlistener 实现轻量级 rpc 调用，兼顾灵活性与可控性。

spring 6 移除了对 amqp remoting 的原生支持，推荐使用 rabbittemplate 的 sendandreceive 方法配合 @rabbitlistener 实现轻量级 rpc 调用，兼顾灵活性与可控性。

在 Spring 6 及更高版本中，原有的 AmqpInvokerServiceExporter 和 AmqpInvokerProxyFactoryBean 等基于 Spring Remoting 的 AMQP 远程服务抽象已被正式移除。官方明确指出：该功能因设计耦合度高、维护成本大且与现代消息驱动架构理念不符，已从 Spring Framework 中剥离。

取而代之的是更显式、更可控的基于消息的请求-响应模式（Request-Reply Pattern），其核心组件为：

客户端：使用 RabbitTemplate.sendAndReceive() 发送带 reply-to 地址的消息，并同步等待响应；
服务端：通过 @RabbitListener 监听请求队列，处理业务逻辑后，将结果返回至 reply-to 指定的临时或专用响应队列。

以下是一个典型实现示例：

// 客户端：发起 RPC 调用
@Service
public class OrderServiceClient {

    private final RabbitTemplate rabbitTemplate;

    public OrderServiceClient(RabbitTemplate rabbitTemplate) {
        this.rabbitTemplate = rabbitTemplate;
        // 启用 reply-to 自动配置（默认已启用）
        rabbitTemplate.setReplyTimeout(10000);
        rabbitTemplate.setReplyAddress("amq.rabbitmq.reply-to"); // 使用 broker 内置 reply-to 机制
    }

    public OrderResult placeOrder(OrderCommand command) {
        Message request = MessageBuilder.withBody(JsonUtils.toJson(command).getBytes())
                .setContentType(MessageProperties.CONTENT_TYPE_JSON)
                .build();
        Message response = rabbitTemplate.sendAndReceive("order.request.queue", request);
        if (response == null) {
            throw new RuntimeException("RPC timeout or no response received");
        }
        return JsonUtils.fromJson(new String(response.getBody()), OrderResult.class);
    }
}

// 服务端：处理 RPC 请求
@Component
public class OrderService {

    @RabbitListener(queues = "order.request.queue")
    public Message handleOrderRequest(Message request) {
        try {
            OrderCommand command = JsonUtils.fromJson(
                new String(request.getBody()), OrderCommand.class);

            OrderResult result = processOrder(command); // 业务逻辑

            return MessageBuilder.withBody(JsonUtils.toJson(result).getBytes())
                    .setContentType(MessageProperties.CONTENT_TYPE_JSON)
                    .build();
        } catch (Exception e) {
            return MessageBuilder.withBody(("ERROR: " + e.getMessage()).getBytes())
                    .setContentType(MessageProperties.CONTENT_TYPE_TEXT_PLAIN)
                    .build();
        }
    }

    private OrderResult processOrder(OrderCommand cmd) {
        // 实际订单处理逻辑...
        return new OrderResult("SUCCESS", UUID.randomUUID().toString());
    }
}

✅ 关键注意事项：

sendAndReceive 默认依赖 RabbitMQ 的 amq.rabbitmq.reply-to 机制（无需显式声明 reply queue），性能更优、资源更省；
若需自定义响应队列（如调试或审计场景），可手动设置 MessageProperties.setReplyTo(...) 并配合 RabbitAdmin 声明队列；
建议为 RPC 场景配置独立的 RabbitTemplate 实例（非共享默认实例），便于单独设置超时、重试和序列化策略；
避免在高并发 RPC 场景中滥用 sendAndReceive —— 它本质是同步阻塞调用，若需异步解耦，应转向事件驱动（Event Sourcing / CQRS）架构。

综上，Spring 6 并未取消 AMQP 上的 RPC 能力，而是将控制权交还开发者：通过组合基础 API 实现更健壮、可观测、可演进的服务交互方式。这既是简化，更是面向云原生消息架构的一次必要进化。