如何在注解驱动的Spring RabbitMQ应用中实现单消费者单次拉取一条消息

你遇到的问题根源在于，仅设置concurrentConsumers=1只能控制消费者线程数量，但BlockingQueueConsumer默认会预取250条消息到本地队列，这就导致RabbitMQ控制台里消息显示为unack状态，而非预期的ready状态。

无需改用手动轮询，通过调整容器工厂配置就能实现「单次仅拉取一条消息，处理完成后再取下一条」的需求，具体配置如下：

1. 修改容器工厂配置 #

在SimpleRabbitListenerContainerFactory中添加两个关键配置：

• prefetchCount=1：告诉RabbitMQ仅向该消费者发送1条消息，直到这条消息被确认后才会发送下一条
• 手动确认模式：确保消息处理完成后再向RabbitMQ发送确认信号，避免预取行为

@Bean
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory);
    factory.setMessageConverter(jsonConverter());
    factory.setConcurrentConsumers(1);
    factory.setMaxConcurrentConsumers(1);
    // 核心配置：限制单次预取1条消息
    factory.setPrefetchCount(1);
    // 开启手动确认模式，保证消息处理完成后再确认
    factory.setAcknowledgeMode(AcknowledgeMode.MANUAL);
    return factory;
}

2. 配合监听器手动确认消息 #

在@RabbitListener注解的方法中，通过Channel对象手动确认消息，确保处理逻辑完成后才通知RabbitMQ：

@RabbitListener(queues = "your-target-queue", containerFactory = "rabbitListenerContainerFactory")
public void processMessage(Message message, Channel channel) throws IOException {
    try {
        // 执行你的消息处理逻辑
        String content = new String(message.getBody());
        System.out.println("正在处理消息：" + content);
        
        // 处理完成后手动确认消息
        channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
    } catch (Exception e) {
        // 处理失败时，根据业务需求选择拒绝或重新入队
        // 第三个参数为true表示将消息重新放回队列
        channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true);
    }
}

效果说明 #

配置完成后：

• RabbitMQ控制台中，未被处理的消息会处于ready状态
• 消费者仅会拉取一条消息进行处理，此时该消息在RabbitMQ中显示为unack状态
• 消息处理完成并确认后，RabbitMQ才会向消费者发送下一条消息

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