问题描述
我在队列中设置了一个死信路由,以延迟几秒钟的时间重新排队被拒绝的消息,以防止临时的使用者错误阻塞队列。我已经设置好了,因此工作队列和死信队列都绑定到相同的交换上:
外部产生的传入消息被路由到交换机,将其放入工作队列中。在处理消息的过程中,使用者可能由于某些临时错误而失败(例如,某个搜寻器从网站上收到了500错误)。
而不是拒绝邮件并拥有它 再次放置在队列的最前面(导致无限循环),我们将拒绝的消息(使用requeue=0
)路由到交换机,并添加死信队列作为路由键。在这里,每条消息都会收到X秒的TTL,在此之后它将被拒绝,并因此使用路由密钥se路由回交换到原始工作队列。
但是,在网上查看文献和示例时,每个人似乎都建议您路由到单独的死信交换处:
外部产生的传入消息被路由到工作交换,工作交换将它们放置在工作队列中。如果使用者失败,则消息将被拒绝(使用
requeue=0
),并将被路由到死信交换。死信交换将消息路由到死信队列,死消息队列中的消息TTL将过期,再次拒绝的消息将被路由回工作交换。
与第一种设计相比,第二种设计是否有一些关键优势?我什么也找不到,但是我对RabbitMQ不太自信。
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)