ActiveMQ Artemis特定队列消息阻塞、消费者异常退出问题咨询

• JMS会话池与底层会话状态不同步：从异常栈可判断，Spring事务管理器提交后清理资源时，尝试将池化会话放回缓存时，底层Artemis会话已经被提前关闭，该问题是ActiveMQ Artemis 2.17.0版本的已知bug：毫秒级网络闪断、服务端静默断开空闲连接时，底层会话被销毁但不会通知上层pooled-jms会话池，池化资源全部失效后无法创建新的消费者，最终对应队列消费者计数降为0。其余队列不受影响是因为会话失效是逐个发生的，只有该队列的消费者会话全部耗尽后才会出现故障。
• 资源配置不合理触发会话泄漏：故障队列的消息量、消息大小可能远高于其余队列，配合不合理的预拉取（consumerWindowSize）参数，消费者一次性拉取过多消息未处理完成时会话被关闭，消息被标记为投递中无法重新分发，同时会话池的无效会话得不到清理，最终无可用会话创建新消费者。
• HA参数不匹配导致静默断连：当前连接URL仅配置ha=true，未配置重连、连接TTL相关参数，客户端默认参数与服务端不匹配时，服务端会主动断开超时的空闲连接，客户端无感知导致会话批量失效，又因为未配置自动重连逻辑，无法自行恢复。

• 依赖版本升级：将Artemis客户端版本升级至2.17.1及以上，该版本修复了底层会话关闭未通知上层池的问题；同时将pooled-jms依赖升级至1.2.3及以上，优化了会话放回池时的状态校验逻辑，避免无效会话留在池中。
• 连接参数优化：在现有连接URL后补充配置：

  &reconnectAttempts=-1&connectionTTL=30000&useTopologyForLoadBalancing=false
  

  其中reconnectAttempts=-1表示连接断开后无限重试，connectionTTL设置为30秒和服务端配置保持一致，关闭拓扑负载均衡避免客户端拉取到无效节点地址导致意外断连。
• 消费者配置调整：
  • 关闭Spring侧的会话缓存，配置spring.jms.session.cache.size=0，所有会话生命周期统一交给pooled-jms管理，避免两层缓存出现状态不一致
  • 开启会话池取用校验，配置pooled.jms.session.test-on-borrow=true，每次从池中取会话时先校验可用性，无效直接销毁重建
  • 调小故障队列的预拉取窗口，配置consumerWindowSize=1048576（可根据单条消息大小调整为更小值），避免一次性拉取过多消息卡住会话
• 临时快速恢复方案：无需重启Artemis或服务器，在消费者端增加健康检查逻辑，监控到目标队列消费者计数为0时，主动销毁重建JMS连接池即可恢复消费。

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