弹性兔amqp @RabbitListener设置最小和最大消费数量

Question

我使用的是spring amqp rabbit @RabbitListener注解，来自: annotation spring-rabbit 1.7.1.RELEASE我想知道是否有一种方法可以为每个队列配置消费者数量？我一直在挖掘文档，但还没有找到任何东西，有没有办法在相关的容器中为每个队列配置消费者的数量？提前谢谢。

Answer 1

通过container factory bean as shown in the documentation配置并发性。

@Bean
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory() {
    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory());
    factory.setConcurrentConsumers(3);
    factory.setMaxConcurrentConsumers(10);
    return factory;
}

如果您使用的是Spring Boot，它会为您创建工厂bean，您可以使用属性对它们进行配置。

如果您想要固定数量的消费者，只需省略max即可。

如果要为每个侦听器设置不同的设置，则需要为每组设置设置不同的工厂。然后，您将在其containerFactory属性中引用@RabbitListener的特定容器工厂。