Spring JMS message-driven-channel-adapter消费者数量无法回落至初始值

你遇到的问题是Spring Integration JMS消息驱动适配器的消费者自动扩容后无法自动缩容——默认情况下该组件仅配置了负载高时的扩容逻辑，缺少触发缩容的条件配置，导致空闲时消费者数量和RabbitMQ的空轮询速率无法回落至初始水平。

核心解决方案：配置缩容相关参数 #

在你的message-driven-channel-adapter配置中添加以下两个参数，即可实现消费者自动缩容至concurrent-consumers设定的初始值：

• idle-consumer-limit：设置允许保留的最大空闲消费者数量，超过该值的空闲消费者会被关闭
• consumer-shutdown-timeout：设置消费者持续空闲多久后触发关闭，单位为毫秒（默认60000，即1分钟）

修改后的完整配置如下：

<int-jms:message-driven-channel-adapter  id="inboundAdapter"
                                         auto-startup="true"
                                         connection-factory="jmsConnectionFactory"
                                         destination="inboundQueue"
                                         channel="requestChannel"
                                         error-channel="errorHandlerChannel"
                                         receive-timeout="-1"
                                         concurrent-consumers="2"
                                         max-concurrent-consumers="100"
                                         idle-consumer-limit="2"
                                         consumer-shutdown-timeout="30000" />

说明：idle-consumer-limit设为与concurrent-consumers一致，确保空闲时消费者数量严格回落至初始值；consumer-shutdown-timeout可根据业务场景调整，比如设为30000（30秒）加快缩容速度。

临时应急方案：手动触发缩容 #

如果不想重启应用或修改配置，可通过以下方式手动关闭空闲消费者：

1. 代码调用方式：
   获取适配器对应的消息监听容器Bean，调用shutdownIdleConsumers()方法：

   @Autowired
   @Qualifier("inboundAdapter.container")
   private AbstractMessageListenerContainer listenerContainer;
   
   public void shrinkIdleConsumers() {
       listenerContainer.shutdownIdleConsumers();
   }
   

   可通过接口暴露该方法，触发一次即可完成缩容。

2. JMX操作方式：
   若应用开启了JMX，可在JMX控制台找到名称为inboundAdapter.container的Bean，执行shutdownIdleConsumers()操作。

验证效果 #

配置完成后，压测结束等待consumer-shutdown-timeout时长，查看RabbitMQ管理控制台的消费者数量应回落至2，同时GET(Empty)速率会恢复到650次/秒左右。

内容的提问来源于stack exchange，提问作者İlkay Gunel