Spring RabbitMQ监听器问题求助，附我的配置类代码

首先，我先帮你完善并格式化你提供的配置类代码（补充了常见的必要Bean，方便后续排查）：

@Configuration
@EnableRabbit
public class NeuwMessagingConfig implements RabbitListenerConfigurer {
    private Logger logger = Logger.getLogger(this.getClass());

    @Bean
    public ConnectionFactory connectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory("localhost");
        connectionFactory.setUsername("guest");
        connectionFactory.setPassword("guest");
        connectionFactory.setPort(5672);
        return connectionFactory;
    }

    @Bean
    public AmqpAdmin amqpAdmin() {
        return new RabbitAdmin(connectionFactory());
    }

    @Bean
    public RabbitTemplate rabbitTemplate() {
        RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory());
        // 配置JSON消息转换器，适配对象消息的收发
        rabbitTemplate.setMessageConverter(jsonMessageConverter());
        return rabbitTemplate;
    }

    @Bean
    public MessageConverter jsonMessageConverter() {
        return new Jackson2JsonMessageConverter();
    }

    @Override
    public void configureRabbitListeners(RabbitListenerEndpointRegistrar registrar) {
        // 绑定自定义的监听器容器工厂
        registrar.setContainerFactory(rabbitListenerContainerFactory());
    }

    @Bean
    public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory() {
        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory());
        factory.setMessageConverter(jsonMessageConverter());
        // 配置消费者并发数，按需调整
        factory.setConcurrentConsumers(1);
        factory.setMaxConcurrentConsumers(5);
        return factory;
    }

    // 可选：声明监听的队列，确保队列存在
    @Bean
    public Queue targetQueue() {
        // 参数：队列名、是否持久化、是否排他、是否自动删除
        return new Queue("your-target-queue", true, false, false);
    }
}

接下来，针对Spring RabbitMQ监听器常见的问题，给你列出排查和解决要点：

• 确保监听器类被Spring管理：你的监听方法所在的类必须添加@Component/@Service等注解，让Spring能够扫描到并创建实例。示例监听类：

  @Component
  public class MessageListener {
  
      @RabbitListener(queues = "your-target-queue")
      public void handleMessage(YourMessageDto message) {
          // 消息处理逻辑
          logger.info("Received message: {}", message);
      }
  }
  

• 验证队列存在性：@RabbitListener指定的队列必须已经在RabbitMQ中存在。你可以通过配置类的@Bean声明队列（如上面代码中的targetQueue），或者在RabbitMQ管理控制台手动创建。

• 检查连接配置有效性：

  • 确认RabbitMQ服务正在本地运行，可通过rabbitmqctl status命令验证
  • 端口、用户名、密码是否与RabbitMQ服务端配置一致（默认5672端口，guest/guest仅允许本地访问）
  • 如果是远程RabbitMQ服务器，需确保防火墙开放5672端口，且服务端配置允许对应用户访问

• 消息转换器一致性：如果生产者发送的是Java对象转JSON的消息，监听器端必须配置相同的MessageConverter（如Jackson2JsonMessageConverter），否则会出现消息转换失败的异常。

• 开启日志定位问题：在application.properties中添加RabbitMQ相关的DEBUG日志，便于排查连接、消息接收、转换等环节的问题：

  logging.level.org.springframework.amqp=DEBUG
  logging.level.org.springframework.rabbit=DEBUG
  

• 配置重试机制（可选）：如果消息处理过程中可能出现临时异常，可给监听器容器工厂添加重试配置，避免消息直接进入死信队列：

  @Bean
  public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory() {
      SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
      factory.setConnectionFactory(connectionFactory());
      factory.setMessageConverter(jsonMessageConverter());
      // 开启重试
      factory.setRetryTemplate(retryTemplate());
      return factory;
  }
  
  @Bean
  public RetryTemplate retryTemplate() {
      RetryTemplate retryTemplate = new RetryTemplate();
      // 最多重试3次
      SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy(3, Collections.singletonMap(Throwable.class, true));
      retryTemplate.setRetryPolicy(retryPolicy);
      // 每次重试间隔1秒
      FixedBackOffPolicy backOffPolicy = new FixedBackOffPolicy();
      backOffPolicy.setBackOffPeriod(1000);
      retryTemplate.setBackOffPolicy(backOffPolicy);
      return retryTemplate;
  }
  

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