Spring集成RabbitMQ实现RPC模式：如何将临时响应队列替换为自定义固定队列？

要实现用自定义固定队列接收RPC响应，同时将响应转发到日志队列，你需要调整RabbitTemplate的配置并显式控制消息的回复地址，而不是依赖Spring自动生成的临时队列。下面是具体步骤和代码示例：

1. 定义所需的队列、Exchange和绑定关系 #

首先，在配置类中声明自定义的响应队列、用于转发响应的Exchange，以及和日志队列的绑定，确保持久化和路由关系正确：

@Configuration
public class RabbitRpcConfig {

    // 自定义响应队列
    @Bean
    public Queue replyQueue() {
        return QueueBuilder.durable("rpc-reply-queue").build();
    }

    // 响应转发Exchange
    @Bean
    public DirectExchange replyExchange() {
        return ExchangeBuilder.directExchange("rpc-reply-exchange").durable(true).build();
    }

    // 日志队列（用于记录所有响应）
    @Bean
    public Queue replyLogQueue() {
        return QueueBuilder.durable("rpc-reply-log-queue").build();
    }

    // 绑定响应队列到Exchange（指定路由键）
    @Bean
    public Binding replyQueueBinding(Queue replyQueue, DirectExchange replyExchange) {
        return BindingBuilder.bind(replyQueue).to(replyExchange).with("rpc-reply-routing-key");
    }

    // 绑定日志队列到Exchange（复用相同路由键实现响应转发）
    @Bean
    public Binding replyLogQueueBinding(Queue replyLogQueue, DirectExchange replyExchange) {
        return BindingBuilder.bind(replyLogQueue).to(replyExchange).with("rpc-reply-routing-key");
    }
}

2. 配置RabbitTemplate以使用自定义回复地址 #

默认情况下，RabbitTemplate的convertSendAndReceive会强制使用临时队列，所以你需要通过两种方式之一覆盖这个行为：

方式一：全局配置RabbitTemplate #

在配置类中统一设置模板的默认回复地址，关闭临时队列的自动使用：

@Bean
public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory, DirectExchange replyExchange) {
    RabbitTemplate template = new RabbitTemplate(connectionFactory);
    // 设置回复消息的Exchange和路由键
    template.setReplyAddress(replyExchange.getName() + "/" + "rpc-reply-routing-key");
    // 禁用自动临时队列
    template.setUseTemporaryReplyQueue(false);
    return template;
}

配置完成后，你原来的convertSendAndReceive代码就会自动使用自定义队列接收响应：

public void send() { 
    // ...
    Integer response = (Integer) template.convertSendAndReceive(exchange.getName(), "rpc", "message"); 
    // ...
}

方式二：发送消息时手动指定回复地址 #

如果你不想全局修改模板，也可以在发送时手动构建消息，显式指定回复地址：

public void sendCustomRpc() {
    // 构建请求消息，指定回复的Exchange和路由键
    Message requestMessage = MessageBuilder
            .withBody("message".getBytes(StandardCharsets.UTF_8))
            .setReplyToAddress(new Address("rpc-reply-exchange", "rpc-reply-routing-key"))
            .build();

    // 使用底层sendAndReceive方法发送消息
    Message responseMessage = rabbitTemplate.sendAndReceive(
            exchange.getName(), 
            "rpc", 
            requestMessage);

    if (responseMessage != null) {
        Integer response = (Integer) rabbitTemplate.getMessageConverter().fromMessage(responseMessage);
        // 处理响应逻辑
    }
}

3. 确保服务端正确转发响应 #

服务端处理RPC请求时，无需额外修改代码，Spring AMQP会自动将响应发送到请求消息中指定的replyToAddress：

@RabbitListener(queues = "rpc-request-queue")
public Integer handleRpcRequest(String request) {
    // 处理业务逻辑，返回响应结果
    return processRequestContent(request);
}

为什么之前setReplyTo没生效？ #

默认情况下，convertSendAndReceive方法会忽略你手动设置的replyTo属性——因为它内部会强制创建并使用临时队列来接收响应。只有当你关闭临时队列的自动使用（setUseTemporaryReplyQueue(false)），或者使用更底层的sendAndReceive方法显式指定回复地址时，手动设置的replyTo才会生效。

内容的提问来源于stack exchange，提问作者José Ignacio Durand