RabbitMQ -设计重试机制

Question

每当我无法处理RabbitMQ中的事件/消息时，我都会存储到MongoDB中，以便进行自动和/或手动重试。问题是如何从MongoDB启用自动重试机制。我如何才能有效地收听MongoDB？在MongoDB中预先存储失败的事件/消息好吗？或者我应该创建错误队列，以便在自动重试失败时将失败的事件/消息推送到MongoDB进行手动重试？还有其他建议吗？

我的目的是为失败的RabbitMQ事件/消息设计有效的重试机制

Answer 1

这是dead-letter exchanges的典型用例。

任何队列都可以与死信交换关联。由于任何原因而无法处理消息的消费者可以拒绝给定的消息。该消息将被路由到死信交换，其工作方式与常规交换相同。因此，您可以对死信邮件应用任何路由策略。