Spring Boot中RabbitMQ消费者按固定步长递增配置问询

完全可以调整为每次触发扩容条件后按5或10个的步长递增消费者数量，核心是通过自定义消费者数量调整逻辑覆盖默认的步长规则。

当前配置回顾 #

你当前的容器配置代码如下：

container.setMaxConcurrentConsumers(100);
container.setConcurrentConsumers(1);
container.setPrefetchCount(1);
container.setAutoStartup(true);
container.setConsecutiveActiveTrigger(1);

默认逻辑下，只要检测到消费者连续活跃1次（consecutiveActiveTrigger=1），容器就会将并发消费者数量+1，直到达到最大限制100。

解决方案 #

根据你使用的Spring AMQP版本，有两种实现方式：

方式一：Spring AMQP 2.3+版本（推荐）

2.3及以上版本提供了setConsumerCountAdjuster方法，可以直接自定义扩容步长：

// 设置每次扩容步长为5，如需10则改为+10
container.setConsumerCountAdjuster((currentCount, maxCount, minCount, isActive) -> {
    if (isActive && currentCount < maxCount) {
        // 计算新的消费者数量，确保不超过最大值
        int newCount = currentCount + 5;
        return Math.min(newCount, maxCount);
    }
    // 空闲场景如需缩容可在此添加逻辑，无需则返回当前数量
    return currentCount;
});

这段Lambda表达式会在容器检测到消费者活跃时触发，每次将当前消费者数量增加指定步长，同时避免超过最大限制。

方式二：旧版本Spring AMQP（2.3以下）

如果使用的是旧版本，需要继承容器类并重写调整消费者数量的方法：

public class CustomStepMessageListenerContainer extends SimpleMessageListenerContainer {

    // 自定义扩容步长，默认5
    private int expansionStep = 5;

    @Override
    protected void adjustConsumers(boolean idle) {
        if (!idle) {
            int current = getConcurrentConsumers();
            int max = getMaxConcurrentConsumers();
            if (current < max) {
                int newCount = current + expansionStep;
                // 确保不超过最大消费者数量
                setConcurrentConsumers(Math.min(newCount, max));
            }
        } else {
            // 缩容逻辑按需实现，不需要则沿用父类逻辑
            super.adjustConsumers(idle);
        }
    }

    public void setExpansionStep(int expansionStep) {
        this.expansionStep = expansionStep;
    }
}

使用自定义容器时，直接设置步长即可：

CustomStepMessageListenerContainer container = new CustomStepMessageListenerContainer(connectionFactory);
container.setMaxConcurrentConsumers(100);
container.setConcurrentConsumers(1);
container.setPrefetchCount(1);
container.setAutoStartup(true);
container.setConsecutiveActiveTrigger(1);
container.setExpansionStep(5); // 设置步长为5

注意事项 #

• 如果需要缩容逻辑（比如消费者空闲时按步长减少数量），可以在调整器或重写的方法中添加对应的判断逻辑。
• 步长设置需要结合业务实际情况，避免一次性扩容过多导致资源占用过高。

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