我们有一个 PHP 应用程序,它通过 WebSocket 连接(PHP AMQP pecl 扩展 v1.7.1 和 RabbitMQ 3.6.6)将消息从 RabbitMQ 转发到连接的设备。
消息从队列数组(每个 websocket 连接 1 个)中消费,当我们通过 websocket 收到消息已收到确认时由消费者确认(因此我们可以重新排队未在可接受的时间范围内交付的消息)。这是以非阻塞方式完成的。
99% 的情况下,这可以完美运行,但偶尔我们会收到错误“RabbitMQ PRECONDITION_FAILED - 未知的交付标签”。这将关闭通道。据我了解,此异常是以下条件之一的结果:
我们已针对上述每种情况实施了保护,但问题仍然存在。
我意识到有许多实现细节可能会影响这一点,但在概念层面上,是否还有其他我们没有考虑过并且应该处理的失败案例?或者有没有更好的方法来实现上述功能?