RabbitMQ 中消息确认是如何工作的？

Question

Accepted Answer

**确认（acks）** 告诉 RabbitMQ 消息已成功处理，以便可以从队列中删除。它们对于 **可靠交付** 至关重要——确保如果消费者失败消息不会丢失。

## 确认如何工作

```text
When a consumer receives and processes a message, it ACKNOWLEDGES it:
  → ACK → "I've processed this message" → RabbitMQ removes it from the queue
  → if a consumer DIES before acking (crash, disconnect) → RabbitMQ REQUEUES the message
    → redelivered to another consumer (NOT lost)
→ acks ensure messages are processed reliably (not lost if a consumer fails)
```

## 手动与自动确认

```text
MANUAL ack → the consumer explicitly acks AFTER processing → reliable (message redelivered
  if processing fails) — the safe choice for important messages
AUTOMATIC ack → the message is considered acked as soon as it's DELIVERED (before processing)
  → faster but UNSAFE → if the consumer crashes during processing, the message is LOST
→ use MANUAL acks for reliability (ack only after successful processing)
```

## 否定确认和拒绝

```text
✓ NACK / REJECT → the consumer can negatively acknowledge a message it can't process:
  → REQUEUE it (try again / another consumer) OR send it to a DEAD LETTER queue
  → handle messages that fail processing (don't lose them, don't block forever)
→ acks (positive and negative) give control over message handling and reliability
```

## 为什么这很重要

理解消息确认是基础性的，因为它们是 **RabbitMQ 中可靠交付所必需的**，因此这是构建可靠消息传递的重要知识。

确认是 RabbitMQ 确保消息被可靠处理的方式。

理解 **确认如何工作** ——消费者在处理后确认消息（告诉 RabbitMQ 完成以便删除消息），具有 **如果消费者在确认前失败消息会被重新排队和重新发送**（这样消息不会在消费者失败时丢失）——这阐明了防止消息丢失的可靠机制。

理解 **手动与自动确认** 至关重要：**手动确认**（消费者在处理后显式确认，因此如果处理失败消息会被重新发送——安全、可靠的选择）与 **自动确认**（消息一旦交付就被视为已确认，在处理前，更快但 **不安全**，因为处理期间崩溃会导致消息丢失）。

关键的实际指导是 **为了可靠性使用手动确认**（仅在成功处理后确认），因为自动确认有消息丢失的风险——这是一个常见且重要的考虑。

理解 **否定确认和拒绝** ——消费者否定确认（nack/reject）它无法处理的消息，要么重新排队，要么将其发送到 **死信队列** ——提供了处理失败消息的控制（不丢失它们或永久阻塞）。

这些确认机制（用于可靠交付的正确确认、用于安全的手动确认、用于故障处理的否定确认）对于构建不丢失消息的可靠 RabbitMQ 消息传递至关重要。

由于确认对于 RabbitMQ 中的可靠交付至关重要（防止消费者失败时的消息丢失，使用手动确认作为安全选择），并且由于理解它们对于构建可靠消息传递很重要，理解消息确认是基础性的、必要的 RabbitMQ 知识——对可靠交付至关重要（确保如果消费者失败消息不会丢失），使用手动与自动确认的区别是重要的可靠性考虑，并且对于构建可靠的 RabbitMQ 系统是必要的。