问题描述
我有一个应用程序，其中的消息由多节点侦听器使用。我遇到的问题是，一旦消费者无法处理任何消息，我就必须限制 RabbitMQ 执行的重试次数。我发现有一种方法可以将这条消息死信给 DLQ 并在对其进行死信处理时为失败的消息设置 TTL，一旦 TTL 启动，它就可以通过将消费者/工作队列作为 DLQ 取回消费者/工作队列原始死信队列。然而，问题是要保持处理事件的顺序，因为事件的顺序是一个重要方面。如果我死信一条消息并延迟重试，则事件序列将不匹配，从而导致数据损坏问题。
例如：有创建订单的消息，然后还有更新订单的消息。现在，在处理创建订单消息时，它以某种方式失败并发送到 DLQ 并处理更新订单的下一条消息，更新订单事件将失败，因为它将无法找到实际订单。
所以我们在这里需要的是，如果消息在消费者处理失败，它应该在队列的头部尝试直到rabbitmq“n”次，如果它仍然失败，那么我们打开一个断路器，这将停止将进一步的事件推送到队列，直到根据 TTL 策略处理或丢弃此失败消息。
任何帮助将不胜感激。提前致谢
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）