如何在Spring Boot项目中实现RabbitMQ队列Peek功能及关闭ack机制

要实现 RabbitMQ 队列的 Peek 需求，关闭 ACK 机制后消息投递到消费者就会被 RabbitMQ 标记为已处理，以下是两种可落地的配置方式：

1. 全局配置（所有监听队列生效） #

直接在项目配置文件中添加如下配置即可：

application.yml 示例 #

spring:
  rabbitmq:
    listener:
      simple:
        acknowledge-mode: none

application.properties 示例 #

spring.rabbitmq.listener.simple.acknowledge-mode=none

2. 局部配置（仅指定队列生效） #

如果只需要对实现 Peek 功能的特定队列关闭 ACK，其他队列保持原有确认规则，可以自定义监听容器工厂：

第一步：自定义容器工厂配置 #

import org.springframework.amqp.core.AcknowledgeMode;
import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitMqCustomConfig {
    @Bean
    public SimpleRabbitListenerContainerFactory noAckListenerFactory(ConnectionFactory connectionFactory) {
        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        // 关闭ACK机制
        factory.setAcknowledgeMode(AcknowledgeMode.NONE);
        return factory;
    }
}

第二步：指定监听使用自定义工厂 #

在对应队列的监听方法上绑定自定义的工厂即可：

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class QueueMessageConsumer {
    @RabbitListener(queues = "你的目标队列名称", containerFactory = "noAckListenerFactory")
    public void handlePeekMessage(String message) {
        // 此处直接获取到消息内容，无需手动执行ACK操作
        System.out.println("Peek到消息：" + message);
    }
}

注意：如果你的 Peek 需求是读取消息后仍保留消息在队列中，不建议关闭 ACK，可将确认模式改为manual手动确认，读取消息后不调用ACK接口，待消息超时后会自动重回队列。

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