Spring Boot中JMS Listener线程数随时间缓慢下降问题排查

1. 手动中断线程未触发容器的线程补充机制 #

你通过切面中断超时线程，但DefaultJmsListenerContainer默认依赖SimpleAsyncTaskExecutor管理线程。如果直接调用Thread.interrupt()终止线程，却没有让容器感知到线程的异常终止，容器会误以为该线程仍在运行，不会主动创建新线程填补空缺，最终导致可用线程数持续下降。

2. AutoAcknowledge模式下的异常未被正确捕获 #

在AutoAcknowledge模式中，JMS提供者会在消息交付后自动确认，但如果监听器线程处理时出现未捕获的Error（如OOM）或RuntimeException，且未被容器捕获，线程会直接退出。若容器未感知到线程终止，就不会补充新线程。另外，如果消息处理逻辑存在隐性阻塞（比如死锁、资源耗尽导致线程挂起），切面统计的“运行中线程数”会存在误判，实际可用线程会逐渐减少。

3. 默认线程执行器的缺陷 #

DefaultJmsListenerContainer默认使用的SimpleAsyncTaskExecutor每次创建新线程，但不具备线程池的自动恢复能力。当线程因异常或中断退出后，容器的maxConcurrentConsumers配置无法触发线程补充，无法维持设定的最大并发数。

4. 消息处理逻辑存在资源泄漏 #

如果监听器处理逻辑有资源泄漏（如数据库连接未关闭、Socket连接挂起、锁未释放），会导致线程被阻塞或无法回收。随着时间推移，越来越多线程陷入无效状态，无法处理新消息，最终只剩少数正常工作的线程。

排查与修复建议 #

• 替换为具备池化能力的线程执行器：用ThreadPoolTaskExecutor替代默认执行器，配置核心线程数、最大线程数和存活时间，让线程池自动补充异常退出的线程：

  @Bean
  public DefaultJmsListenerContainerFactory jmsListenerContainerFactory(ConnectionFactory connectionFactory) {
      DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
      factory.setConnectionFactory(connectionFactory);
      factory.setConcurrency("10-300");
      factory.setSessionAcknowledgeMode(Session.AUTO_ACKNOWLEDGE);
      
      ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
      executor.setCorePoolSize(100);
      executor.setMaxPoolSize(300);
      executor.setKeepAliveSeconds(60);
      executor.setQueueCapacity(0); // 无队列，直接扩容至最大线程数
      executor.initialize();
      
      factory.setTaskExecutor(executor);
      return factory;
  }
  

• 添加全局JMS异常处理器：捕获所有未处理的异常，确保线程异常退出时被容器感知：

  @Bean
  public JmsListenerErrorHandler jmsListenerErrorHandler() {
      return (message, exception) -> {
          log.error("JMS消息处理失败", exception);
          // 抛出异常让容器感知线程终止，触发线程补充
          throw new RuntimeException("消息处理异常", exception);
      };
  }
  

• 排查线程阻塞点：定期导出线程dump，分析线程状态，查看是否有大量线程处于WAITING或BLOCKED状态，定位资源泄漏或死锁问题。
• 用容器自带超时替代手动中断：通过receiveTimeout参数控制消息接收超时，让容器自动管理线程生命周期：

  factory.setReceiveTimeout(5000); // 5秒接收超时，超时后线程自动重试
  

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