Spring应用消费ActiveMQ时消息滞留Dispatched Queue的原因排查

问题场景 #

基于Spring的ActiveMQ消费应用初始运行正常，数天后停止消费消息。ActiveMQ控制台显示：入队1条、出队0条、已分发1条，1条消息滞留于Dispatched Queue。重启应用后滞留消息可正常消费，新消息处理正常；若不操作，1-2天后滞留消息虽会被消费，但新消息仍会进入Dispatched Queue无法及时处理。

相关配置：

<bean id="baseConnectionFactory" class="org.apache.activemq.ActiveMQSslConnectionFactory"></bean>

<bean id="singleConnectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
    <property name="targetConnectionFactory" ref="baseConnectionFactory"/>
    <property name="reconnectOnException" value="true"/>
</bean>

<bean id="requestListenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
  <property name="concurrentConsumers" value="5"/>
  <property name="maxConcurrentConsumers" value="10"/>
  <property name="idleTaskExecutionLimit" value="5"/>
  <property name="maxMessagesPerTask" value="1000"/>
  <property name="receiveTimeout" value="${mq.i94dataentry.receivetimeout}"/>
  <property name="connectionFactory" ref="singleConnectionFactory" />
  ...
</bean>

可能的原因 #

1. 动态消费者扩容-收缩机制异常 #

DefaultMessageListenerContainer会根据消息量动态调整消费者线程数：消息堆积时扩容至maxConcurrentConsumers，闲置时依据idleTaskExecutionLimit收缩线程。如果收缩过程中出现异常（如线程未正确销毁、连接隐性失效），会导致部分线程处于"假存活"状态：ActiveMQ认为这些消费者仍在线，将新消息分发到对应的Dispatched Queue，但这些线程已无法处理消息，最终造成消息滞留。

2. maxMessagesPerTask预取与线程回收问题 #

原配置maxMessagesPerTask=1000表示每个消费者线程处理完1000条消息后会被销毁，由容器创建新线程接替。如果线程处理消息时遇到未捕获异常、业务逻辑阻塞（如数据库连接耗尽、死锁），会导致线程无法正常完成任务并被回收，这些线程持有的预取消息会滞留在Dispatched Queue。同时，若容器未检测到线程异常，会认为消费者数量足够，不再创建新线程处理新消息。

3. 消费者线程假死与ActiveMQ消息分发不匹配 #

若业务逻辑导致消费者线程阻塞或假死（如无限等待外部资源），线程未抛出异常触发reconnectOnException，容器会认为线程仍在运行。ActiveMQ会持续将新消息分发给这些假死线程，消息进入Dispatched Queue后无法被处理，直到ActiveMQ的消息超时重发机制触发（通常1-2天），滞留消息才会被重新放回队列处理，但新消息仍会被分发到假死线程，形成恶性循环。

对调整方案的验证 #

你将concurrentConsumers与maxConcurrentConsumers设为相同值，关闭了动态扩容机制，避免了扩容收缩过程中的线程异常风险；将maxMessagesPerTask设为0，让线程持续处理消息，减少了线程创建销毁带来的泄漏可能。这个调整直接规避了前两类核心问题，大概率能解决消息滞留的问题。

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