当 RabbitMQ 消费者崩溃时，获取的消息会发生什么？

Question

如果我有一个 RabbitMQ 消费者批量检索 100 条消息，但它在将这些消息标记为已处理之前就崩溃了，这些消息会丢失吗？我希望队列中的每条消息至少处理一次。处理在确认消息之前崩溃的消费者的推荐方法是什么？

RabbitMQ 是否以某种方式将它们放回队列中，或者我需要做些什么才能让它发生？

Answer 1

对于在确认消息之前就崩溃的消费者，推荐的处理方法是什么？

让 rabbitmq 为你做所有的事情 - 不是的消息 确认被重新排队并将再次交付给另一个（或 甚至相同）消费者。

RabbitMQ 是否以某种方式将它们放回队列中，或者我需要做什么才能让它发生？

查看第一个问题的答案。根本不承认消息 在他们被处理之前。这也意味着确保 auto_ack 标志未设置！

如果我有一个 RabbitMQ 消费者批量检索 100 条消息，但它在将这些消息标记为已处理之前就崩溃了，这些消息会丢失吗？

请参阅上面的答案 - 如果它们是自动的，它们就会丢失 承认。
只是一点参考，从第二个引用 tutorial:

如果消费者在没有发送 ack 的情况下死亡（其通道关闭、连接关闭或 TCP 连接丢失），RabbitMQ 将理解消息未完全处理并将重新排队。如果同时有其他消费者在线，它会迅速将其重新发送给另一个消费者。这样，即使工人偶尔死亡，您也可以确保不会丢失任何消息 .

Answer 2

如果消费者必须确认收到的消息，并且在它这样做之前就死了，则会发生以下事情：

1. RabbitMQ 代理会知道消费者不会确认，因为通道已关闭。
2. 它将邮件标记为未送达。
3. 保留队列中消息的顺序。
4. 队列中的消息将在下次连接时发送给消费者。

如果同一队列有多个消费者，或者您的 RabbitMQ 代理版本低于 2.7.0，第 3 点将无效。

希望对你有帮助。