自动确认模式

自动确认模式是 RabbitMQ 最基础的消息确认方式，消息投递后服务端立即将其从队列中移除。

定义

自动确认（autoAck=true）指消费者收到消息时，RabbitMQ 自动将该消息标记为已确认并从队列中删除，无需消费者显式发送确认回执。

Maven 依赖

<dependency>
    <groupId>com.rabbitmq</groupId>
    <artifactId>amqp-client</artifactId>
    <version>5.20.0</version>
</dependency>

配置示例

自动确认消费者

import com.rabbitmq.client.*;

import java.io.IOException;

public class AutoAckConsumer {
    private static final String QUEUE_NAME = "auto_ack_queue";

    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        factory.setPort(5672);

        try (Connection connection = factory.newConnection();
             Channel channel = connection.createChannel()) {
            channel.queueDeclare(QUEUE_NAME, true, false, false, null);

            // autoAck=true 开启自动确认
            boolean autoAck = true;
            channel.basicConsume(QUEUE_NAME, autoAck, new DefaultConsumer(channel) {
                @Override
                public void handleDelivery(String consumerTag,
                                          Envelope envelope,
                                          AMQP.BasicProperties properties,
                                          byte[] body) throws IOException {
                    String message = new String(body, "UTF-8");
                    System.out.println("收到消息: " + message);
                    // 无需手动调用 basicAck，RabbitMQ 已自动确认
                }
            });

            System.out.println("自动确认消费者已启动，等待消息...");
            Thread.sleep(Long.MAX_VALUE);
        }
    }
}

配合自动确认的生产者

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

public class AutoAckProducer {
    private static final String QUEUE_NAME = "auto_ack_queue";

    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");

        try (Connection connection = factory.newConnection();
             Channel channel = connection.createChannel()) {
            channel.queueDeclare(QUEUE_NAME, true, false, false, null);

            String message = "Hello AutoAck Consumer";
            channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8"));

            System.out.println("消息已发送: " + message);
        }
    }
}

注意事项

自动确认模式下，消息一旦投递即被删除，若消费者处理过程中崩溃，该消息将永久丢失。

仅适用于幂等操作或对消息丢失不敏感的场景，如日志记录、非关键通知。

若业务处理失败且无法重试，自动确认模式无法提供重新消费能力。

高吞吐场景下，自动确认可减少网络往返，提升消费速率。

要点总结

• 自动确认：channel.basicConsume(queue, true, callback) 中第二个参数设为 true
• 消息投递后立即从队列删除，无需消费者手动确认
• 适合幂等、非关键业务场景，性能优于手动确认
• 存在消息丢失风险，关键业务应使用手动确认模式