RabbitMQ如何控制队列消耗多少消息

Question

我使用入站通道适配器配置以下列方式使用消息。

    @Bean
    public AmqpInboundChannelAdapter itemInboundChannelAdapter(@Qualifier(value = "errorChannel") MessageChannel errorChannel,
                                                               @Qualifier(value = "itemChannel") Queue itemQueue,
                                                               Jackson2ObjectMapperBuilder objectMapperBuilder,
                                                               ConnectionFactory connectionFactory) {

        final SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory);
        container.setMaxConcurrentConsumers(1);
        container.setExclusive(true);
        container.setAcknowledgeMode(AcknowledgeMode.AUTO);
        container.setQueueNames(itemQueue.getName());

        return Amqp
                .inboundAdapter(container)
                .errorChannel(errorChannel)
                .outputChannel(itemValidateChannel())
                .messageConverter(new PackageConvertingJackson2JsonMessageConverter(objectMapperBuilder.build(), Item.class))
                .get();
    }

从屏幕截图中可以看出，我一次消耗 250 条消息。如何将其限制为 10 秒？

Answer 1

您没有消耗 250 x 250，但您正在预取。您可以使用：

container.setPrefetchCount(10);

限制预取计数。