Spring AMQP @RabbitListener懒队列及direct reply配置问题

原因 #

你将@RabbitListener注解写在了@SpringBootTest修饰的测试类中，测试上下文的Bean处理逻辑和标准Spring容器不同，无法正确识别autoStartup属性，导致监听容器仍然自动启动，在队列未创建时发起被动声明触发404错误。

解决方案 #

1. 将@RabbitListener修饰的消费方法迁移到被@Component/@Service修饰的普通业务类中，同时添加id属性和关闭本地自动声明配置：

@Service
@Slf4j
public class BroadcastMessageHandler {
    @RabbitListener(
        id = "broadcastQueueListener",
        queues = "broadcastQueue.MYUSER_123",
        autoStartup = "false",
        autoDeclare = "false"
    )
    public void handleMessage(Object obj) {
        log.info("{}",obj);
    }
}

autoDeclare=false的作用是关闭本地主动声明队列逻辑，因为该队列由远端服务创建，本地不需要做声明校验。
如果调整后仍然有自动启动的问题，可在配置文件中添加全局配置关闭所有监听容器默认自动启动：

spring:
  rabbitmq:
    listener:
      simple:
        auto-startup: false

2. 在异步登录请求执行成功、确认远端已创建队列后，注入RabbitListenerEndpointRegistry手动启动监听容器：

@Autowired
private RabbitListenerEndpointRegistry endpointRegistry;

// 登录成功确认队列已创建后执行
MessageListenerContainer listenerContainer = endpointRegistry.getListenerContainer("broadcastQueueListener");
if (!listenerContainer.isRunning()) {
    listenerContainer.start();
}

默认Spring AMQP的direct reply-to机制仅在未显式指定replyAddress时启用，使用RabbitMQ内置的amq.rabbitmq.reply-to队列。如果需要指定自定义回复地址，不需要自行实现监听容器，可按如下配置：

1. 删除你自定义的replyListenerContainer Bean，无需手动声明回复监听容器。
2. 在配置RabbitTemplate时添加useDirectReplyToContainer=true配置即可：

private void configureReply(RabbitTemplate rabbitTemplate, @NonNull Queue inquiryResponseQueue) {
    // 启用自定义地址的direct reply容器
    rabbitTemplate.setUseDirectReplyToContainer(true);
    rabbitTemplate.setReplyAddress(inquiryResponseQueue.getName());
    rabbitTemplate.setDefaultReceiveQueue(inquiryResponseQueue.getName());
    // 按需配置回复超时时间
    rabbitTemplate.setReplyTimeout(10000);
}

该特性从Spring AMQP 2.0版本开始支持，配置后Spring会自动管理回复队列的监听容器，你可以直接使用convertSendAndReceive等方法完成同步请求回复，或者配置回调处理异步回复。

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