SpringCloud Dead-Letter隊(duì)列處理

2023-11-29 16:06 更新

因?yàn)槟鸁o法預(yù)期用戶將如何處置死信，所以該框架沒有提供任何標(biāo)準(zhǔn)機(jī)制來處理它們。如果死信的原因是暫時(shí)的，則您可能希望將消息路由回原始隊(duì)列。但是，如果問題是永久性問題，則可能導(dǎo)致無限循環(huán)。以下Spring Boot應(yīng)用程序顯示了一個(gè)示例，該示例說明了如何將這些消息路由回原始隊(duì)列，但在嘗試三次后將其移至第三個(gè)“ 停車場 ”隊(duì)列。第二個(gè)示例使用RabbitMQ延遲消息交換為重新排隊(duì)的消息引入延遲。在此示例中，每次嘗試的延遲都會增加。這些示例使用@RabbitListener從DLQ接收消息。您也可以在批處理過程中使用RabbitTemplate.receive()。

這些示例假定原始目的地為so8400in，而消費(fèi)者組為so8400。