spring - Spring boot 中的 Rabbitmq 并发消费者

Question

我使用@RabbitListener注释和SimpleRabbitListenerContainerFactory bean来并行执行rabbitmq消息，并按以下方式设置最小和最大并发消费者:

@Bean
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory() {
    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory());
    factory.setConcurrentConsumers(MIN_RABBIT_CONCURRENT_CONSUMERS);
    factory.setMaxConcurrentConsumers(MAX_RABBIT_CONCURRENT_CONSUMERS);
    factory.setConsecutiveActiveTrigger(1);
    factory.setAcknowledgeMode(AcknowledgeMode.MANUAL);
    return factory;
}

最小限制为 3，最大限制为 10。使用此配置，即使队列中有 12 条消息，也只能并行执行 3 条消息。

请告诉我配置有什么问题？

Answer 1

您可以使用rabbitMQ注释创建最大并发消费者

@RabbitListener(queues = "your-queue-name", concurrency = "4")
public void customCheck(Object requestObject) {
    // process
}