RabbitMQ PRECONDITION_FAILED - 未知的交付标签

Question

我们有一个 PHP 应用程序，它通过 WebSocket 连接（PHP AMQP pecl 扩展 v1.7.1 和 RabbitMQ 3.6.6）将消息从 RabbitMQ 转发到连接的设备。

消息从队列数组（每个 websocket 连接 1 个）中消费，当我们通过 websocket 收到消息已收到确认时由消费者确认（因此我们可以重新排队未在可接受的时间范围内交付的消息）。这是以非阻塞方式完成的。

99% 的情况下，这可以完美运行，但偶尔我们会收到错误“RabbitMQ PRECONDITION_FAILED - 未知的交付标签”。这将关闭通道。据我了解，此异常是以下条件之一的结果：

1. 消息已被确认或拒绝。
2. 尝试通过消息未通过的通道进行确认。
3. 在消息超时 (ttl) 到期后尝试确认。

我们已针对上述每种情况实施了保护，但问题仍然存在。

我意识到有许多实现细节可能会影响这一点，但在概念层面上，是否还有其他我们没有考虑过并且应该处理的失败案例？或者有没有更好的方法来实现上述功能？

Answer 1

“PRECONDITION_FAILED - 未知的交付标签”通常是由于双重确认、错误通道上的确认或不应该确认的消息而发生的。

因此，在同一情况下，您要执行basic.ack两次或basic.ack使用另一个通道

Answer 2

如果您将Consumerno-ack的选项设置为这意味着您不应该手动调用函数，则可能会发生这种情况：trueack

https://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.consume.no-ack

解决办法：将no-ackflag设置为false。

Answer 3

（下面的解决方案）

引用 Jan Grzegorowski 从他的博客：

如果您正在为这篇文章标题中包含的 406 错误消息而苦恼，您可能有兴趣阅读整个故事。

问题

我使用 amqplib 将基于 NodeJS 的消息处理器与 RabbitMQ 代理连接起来。一切似乎都运行良好，但不时会在日志中显示 406 (PRECONDINTION-FAILED) 消息：

"Error: Channel closed by server: 406 (PRECONDITION-FAILED) with message "PRECONDITION_FAILED - unknown delivery tag 1"

解决方案 <--

保持简单：

• 您必须按照到达系统的相同顺序确认消息
• 您不能在与它们到达的频道不同的频道上确认消息如果您违反这些规则中的任何一条，您将面临 406 (PRECONDITION-FAILED) 错误消息。

原答案