RabbitMQ 上的 Nack 和拒绝

Posted 2023-03-10

【中文标题】RabbitMQ 上的 Nack 和拒绝

【英文标题】：Nack and reject on RabbitMQ

【发布时间】：2017-09-01 04:00:44

【问题描述】：

我想处理消费者从队列中获取的不成功消息并重新排队。

想象一下我有这样的情况：

P => | foo | bar | baz | => C

其中 foo、bar 和 baz 是消息。

如果消费者读取baz 但出现问题，我可以使用basic.reject 或basic.nack (https://www.rabbitmq.com/nack.html)。使用这两个命令之一，我将传递参数以重新排队消息。

问题是消息在之前的位置重新排队，所以下一条消息将再次是baz。

我想重新排队，但将其发送回队列的开头：

P => | baz | foo | bar | => C

我在我的应用程序上用几行代码解决了这个问题，但我想知道是否存在更好的解决方案，也许直接使用 RabbitMQ 的某些功能。

【参考方案1】：

你可以看看死信队列（DLQ）：https://www.rabbitmq.com/dlx.html

【讨论】：

是的，我昨天阅读了整个文档。这不是我要找的东西，但显然我要找的东西不存在，死信队列可能是一个很好的解决方法。

这里队列（FIFO）的行为与预期完全一样，因为您使用手动确认模式，线程将等待直到收到确认，因为它无法处理，因此它会尝试将相同的位置放在循环方式。另一方面，一次又一次地处理坏消息是没有意义的。重试 2-3 次（spring-amqp 有直接支持），如果仍然失败然后死信，以便稍后您可以分析错误消息的模式并直接联系客户团队。

也许你可以为你的失败消息添加 TTL 并放入 DLX，所以一旦过期它会自动移动到主队列。