java - 从一个队列铲到另一个队列后如何拒绝消息？

Question

使用 Spring 和 RabbitMQ，我设置了两个主题交换 x和dlx和两个队列q和dlq 。 q绑定(bind)到x和dlq至dlx 。 dlx被配置为 q 的死信交换.

当 q 中出现一条消息时被拒绝(取消队列)，它已成功发送到 dlx然后到dlq .

现在我使用 shovel-plugin 来移动 dlq 中的死信消息返回q 。只要这次消息处理成功(ack)，这就成功了。

但是如果其中一条消息被铲入 q再次被拒绝，它就被默默地丢弃了。我希望它会发送到 DLX dlx再次。是我配置错误还是我误解了 DLX 或铲子的概念？

Answer 1

我怀疑你正在尝试这种味道......

It is possible to form a cycle of message dead-lettering. For instance, this can happen when a queue dead-letters messages to the default exchange without specifiying a dead-letter routing key. Messages in such cycles (i.e. messages that reach the same queue twice) will be dropped if there was no rejections in the entire cycle.

...因为你在铲土。请参阅Dead Letter Exchanges .

相反，请使用 TTL 和死信配置来配置 DLQ，以将过期消息路由回原始队列。这样，x-death header 就会获得两个条目 - 1 表示来自原始队列的拒绝，1 表示来自 DLQ 的到期。

我猜测，通过铲子，经纪人认为存在一个循环。