扇出交换上的RabbitMQ重试逻辑

Question

我们有一个队列和交换集群来支持消息。

null

我们每个队列都有一个交换，以便在重试超时期间后将重试的消息发送回特定的队列。

在这个场景中，我们有3个交换（“foo-exchange”、“foo-exchange-dead”、“baz-exchange-retry（每个队列1个fanout exchange）”和3个队列（“baz-queue”、“baz-queue-delay”、“baz-queue-error”和1个用于整个交换的死队列（“foo-queue-dead）。

此设置是为1个队列扇出，并将大大增加扇出交换机有多个消费者队列。

因此，我们需要一种解决方案，它可以将这种复杂的设置减少到一些可管理的队列和交换中

1. x-delay-exchange：这对我们来说不是一个好的解决方案，因为它不能告诉有多少消息等待再次处理。我们需要知道在外部失败的情况下要重试多少次。(https://github.com/rabbitmq/rabbitmq-delayed-message-exchange)
2. 到主队列的消息ttl：这将阻止延迟消息后面的所有消息。

Answer 1

每个队列还绑定到默认的exchange（“”），路由键等于队列名。

您可以简单地将过期的死信直接路由到原始队列。