Skip to main content

RabbitMQ有哪几种ACK机制？

作者：程序员马丁

在线博客：https://open8gu.com

note

大话面试，技术同学面试必备的八股文小册，以精彩回答应对深度问题，助力你在面试中拿个offer。

回答话术​

RabbitMQ 提供了多种消息确认机制，以确保消息能够可靠地传递到消费者。RabbitMQ 中常用的消息确认机制有以下几种形式。

1. 自动确认 Automatic Acknowledgment​

当消费者接收到消息并成功处理后，RabbitMQ 会立即将消息从队列中删除，不需要额外的确认操作。

这种方式适用于那些不需要严格的消息可靠性保证的场景，因为一旦消息交付给消费者，就无法再恢复它们，但是这种模式性能最强且资源占用最低。

@RabbitListener(queues = "yourQueue")
public class AutoAckReceiver {

    @RabbitHandler
    public void handleMessage(String message) {
        // 处理消息
        System.out.println("Received message: " + message);
    }
}

2. 显式确认 Explicit Acknowledgment​

在这种模式下，消费者需要显式地发送确认（ACK）给 RabbitMQ，以告知它消息已经被成功处理。

消费者可以发送确认，也可以发送拒绝（NACK）来表示消息处理失败，消息将被重新排队或进入死信队列。

@RabbitListener(queues = "yourQueue")
public class ExplicitAckReceiver {

    @RabbitHandler
    public void handleMessage(String message, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) throws IOException {
        try {
            // 处理消息
            System.out.println("Received message: " + message);
        } finally {
            // 手动确认消息
            channel.basicAck(tag, false);
        }
    }
}

3. 手动确认模式 Manual Acknowledgment​

手动确认模式提供了更大的灵活性，消费者可以在处理消息后手动发送确认或拒绝。

这种方式适用于需要更高消息可靠性的应用，因为只有在消费者明确确认消息后，RabbitMQ 才会将消息从队列中删除。

@RabbitListener(queues = "yourQueue")
public class ManualAckReceiver {

    @RabbitHandler
    public void handleMessage(String message, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) throws IOException {
        try {
            // 处理消息
            System.out.println("Received message: " + message);

            // 手动确认消息，如果处理成功
            channel.basicAck(tag, false);
        } catch (Exception e) {
            // 如果发生异常，可以选择拒绝消息
            channel.basicReject(tag, false);
        }
    }
}

4. 使用推荐​

对于需要快速处理和高吞吐量的场景，可以选择使用自动确认，以实现最佳的性能和资源利用率。

对于需要监控和管理消息处理状态的场景，推荐使用显式确认，因为它提供了对消息处理结果的明确反馈。

对于消息有可靠性有严格要求的高级应用，建议使用手动确认模式，因为它提供了最高级别的消息处理控制和灵活性。

问题详解​

1. 显式确认和手动确认有什么区别？​

显式确认和手动确认在 RabbitMQ 中是相关但不同的概念。

显式确认是手动确认的一种特例，是手动确认中的一种方式。手动确认涵盖了更广泛的可能性，允许对消息处理进行更细粒度的控制。选择使用哪种方式取决于业务需求和对消息处理过程的精细度要求。

Table of Contents