如何正确使用RabbitListenerEndpointRegistry？为何无法获取监听容器？

问题根源 #

你手动定义了RabbitListenerEndpointRegistry Bean，这会覆盖Spring Boot自动配置的默认实例。而你手动new的这个实例并没有和@RabbitListener注解标注的监听器完成绑定，因此调用getListenerContainers()时返回空集合。

解决步骤 #

• 删除自定义的RabbitListenerEndpointRegistry Bean
  删掉你在RabbitMqConfiguration中定义的以下代码：

  @Bean
  @Qualifier("RabbitListenerEndpointRegistry")
  public RabbitListenerEndpointRegistry rabbitListenerEndpointRegistry(){
          return new RabbitListenerEndpointRegistry();
      }
  

  Spring Boot会自动创建一个默认的RabbitListenerEndpointRegistry实例，所有通过@RabbitListener注册的监听器容器都会自动关联到这个实例上。

• 确保@RabbitListener指定了正确的id
  在你的监听器方法上必须明确设置id属性，这样才能通过ID定位到对应的容器：

  @RabbitListener(id = "listener_id", queues = "your_target_queue")
  public void handleMessage(String message) {
      // 消息处理逻辑
  }
  

• 正确注入默认的Registry实例
  直接通过@Autowired注入即可，无需额外的@Qualifier：

  @Autowired
  private RabbitListenerEndpointRegistry endpointRegistry;
  

• 调用容器控制方法
  确认容器存在后，即可调用stop()方法暂停监听器：

  // 先检查容器是否存在，避免空指针
  MessageListenerContainer container = endpointRegistry.getListenerContainer("listener_id");
  if (container != null) {
      container.stop();
      // 如果需要彻底销毁，可调用 container.destroy();
  }
  

额外注意事项 #

• 确保操作时机在Spring容器完全启动之后，否则可能无法获取到容器实例。
• 如果需要在非Spring管理的类中操作，需先通过Spring上下文获取RabbitListenerEndpointRegistry实例。

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