Spring RabbitMQ RPC（TopicExchange）CorrelationId不匹配致返回null问题

CorrelationId不匹配的核心原因 #

• convertSendAndReceive方法默认会自动生成递增序列的CorrelationId（即你看到的1、2、3），如果手动设置CorrelationId的时机或方式错误，会被框架自动生成的值覆盖。比如直接在消息对象上设置，但RabbitTemplate在发送前会重新生成并覆盖这个值——因为该方法内置了RPC的自动关联逻辑。
• 你手动指定了固定回复队列RPC_RES_QUEUE，但未关闭RabbitTemplate的临时回复队列自动创建逻辑，导致框架依然用自身关联机制，忽略了你手动设置的CorrelationId。
• 客户端和服务端在同一Spring上下文时，RabbitTemplate的配置可能被共享或覆盖，比如服务端的监听配置修改了模板参数，导致客户端的设置不生效。

是否需要拆分客户端与服务端的Bean配置？ #

必须拆分。同一Spring上下文里共享RabbitTemplate或相关配置会导致客户端和服务端的RPC逻辑互相干扰：

• 客户端的RabbitTemplate需要配置为使用固定回复队列，并关闭自动生成临时队列和CorrelationId的逻辑，手动控制CorrelationId的传递。
• 服务端的监听容器和处理逻辑应使用独立配置，避免影响客户端模板的参数。

具体修复步骤 #

1. 客户端配置调整：
   • 配置专属的RabbitTemplate，设置setReplyQueue为RPC_RES_QUEUE，同时设置setUseTemporaryReplyQueue(false)，关闭临时队列自动创建。
   • 发送消息时，通过MessagePostProcessor手动设置CorrelationId，确保不被框架覆盖：

     rabbitTemplate.convertSendAndReceive(exchangeName, routingKey, request, message -> {
         message.getMessageProperties().setCorrelationId(UUID.randomUUID().toString());
         return message;
     });
     

2. 服务端处理调整：
   • 监听RPC_REQ_QUEUE时，从收到的消息中获取CorrelationId，回复时设置相同的CorrelationId并指定回复队列：

     @RabbitListener(queues = "RPC_REQ_QUEUE")
     public Message handleRequest(Message request) {
         String correlationId = request.getMessageProperties().getCorrelationId();
         // 业务处理逻辑
         Message response = MessageBuilder.withBody(/*响应内容字节数组*/)
                 .setCorrelationId(correlationId)
                 .setReplyTo("RPC_RES_QUEUE")
                 .build();
         return response;
     }
     

3. 拆分Bean配置：
   • 分别创建客户端和服务端的RabbitTemplate，客户端模板专注于发送RPC请求，服务端的模板（或直接使用监听注解）专注于处理请求和回复，确保两者配置参数互不干扰。

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