我们有一个 PHP 应用程序,它通过 WebSocket 连接将消息从 RabbitMQ 转发到连接的设备(PHP AMQP pecl 扩展 v1.7.1 和 RabbitMQ 3.6.6)。
消息从一组队列中使用(每个 websocket 连接一个),并在我们通过 websocket 收到消息已收到的确认时由消费者确认(因此我们可以重新排队未在可接受的时间范围内传递的消息)。这是以非阻塞方式完成的。
在 99% 的情况下,这工作得很好,但偶尔我们会收到错误“RabbitMQ PRECONDITION_FAILED - 未知的交付标签”。这将关闭通道。据我了解,此异常是以下情况之一的结果:
- 该消息 已 被确认或拒绝。
- 尝试通过未传递消息的通道进行确认。
- 在消息超时 (ttl) 到期后尝试确认。
我们已针对上述每种情况实施了保护措施,但问题仍然存在。
我意识到有许多实施细节可能会影响这一点,但在概念层面上,是否还有我们没有考虑但应该处理的其他失败案例?还是有更好的方法来实现上述功能?
原文由 Matt Renner 发布,翻译遵循 CC BY-SA 4.0 许可协议
“PRECONDITION_FAILED - unknown delivery tag”通常是由于双重确认、在错误的频道上确认或确认不应确认的消息而发生。
所以在同样的情况下你要执行
basic.ack
两次或basic.ack
使用另一个通道