在RabbitMQ中需要单独交换死信吗？

如何解决在RabbitMQ中需要单独交换死信吗？

我在队列中设置了一个死信路由，以延迟几秒钟的时间重新排队被拒绝的消息，以防止临时的使用者错误阻塞队列。我已经设置好了，因此工作队列和死信队列都绑定到相同的交换上：

外部产生的传入消息被路由到交换机，将其放入工作队列中。在处理消息的过程中，使用者可能由于某些临时错误而失败（例如，某个搜寻器从网站上收到了500错误）。
而不是拒绝邮件并拥有它 再次放置在队列的最前面（导致无限循环），我们将拒绝的消息（使用requeue=0）路由到交换机，并添加死信队列作为路由键。在这里，每条消息都会收到X秒的TTL，在此之后它将被拒绝，并因此使用路由密钥se路由回交换到原始工作队列。

但是，在网上查看文献和示例时，每个人似乎都建议您路由到单独的死信交换处：

外部产生的传入消息被路由到工作交换，工作交换将它们放置在工作队列中。如果使用者失败，则消息将被拒绝（使用requeue=0），并将被路由到死信交换。死信交换将消息路由到死信队列，死消息队列中的消息TTL将过期，再次拒绝的消息将被路由回工作交换。

---

与第一种设计相比，第二种设计是否有一些关键优势？我什么也找不到，但是我对RabbitMQ不太自信。

解决方法

这取决于您使用的交换类型以及需要执行的其他路由。如果您对原始邮件和重新排队的邮件使用相同的交换，则需要区分以下内容：

• 新邮件，可能会被路由到多个队列，或者根本没有路由
• 失败的消息，应仅路由到延迟队列
• 延迟的邮件，应仅将其路由到失败的单个队列

在my implementation of this pattern中，我使用了两次 个额外的交换（均按需动态声明），以使其与原始路由配置尽可能独立：

• 原始消息已由消费者确认，并手动重新发布到“开始”交换。这样可以提供一些额外的灵活性，例如在消息上设置自定义标头，以及将具有不同TTL的多个延迟队列附加到同一工作队列。
• “开始”交换是一个扇出交换，绑定到特定的“正在等待”队列，如第二张图中所示。
• 当消息TTL在“等待”队列中到期时，它将被路由到一个单独的“完成”交换器，该交换器设置为“死信交换”。
• 该交换也是一个扇出交换，仅绑定到原始工作队列。这样可以确保不会将邮件的多余副本创建到其他队列，这些副本会在第一次成功处理该邮件。
• 因此，邮件将使用其原始路由密钥返回原始队列。