在失敗重試策略中，默認的RejectAndDontRequeueRecoverer會在本地重試次數(shù)耗盡后，發(fā)送reject給RabbitMQ，消息變成死信，被丟棄。

?

我們可以給simple.queue添加一個死信交換機，給死信交換機綁定一個

?我們在consumer服務中，定義一組死信交換機、死信隊列：

// 聲明普通的 simple.queue隊列，并且為其指定死信交換機：dl.direct @Bean public Queue simpleQueue2(){return QueueBuilder.durable("simple.queue") // 指定隊列名稱，并持久化.deadLetterExchange("dl.direct") // 指定死信交換機.build(); } // 聲明死信交換機 dl.direct @Bean public DirectExchange dlExchange(){return new DirectExchange("dl.direct", true, false); } // 聲明存儲死信的隊列 dl.queue @Bean public Queue dlQueue(){return new Queue("dl.queue", true); } // 將死信隊列 與 死信交換機綁定 @Bean public Binding dlBinding(){return BindingBuilder.bind(dlQueue()).to(dlExchange()).with("simple");

總結

什么樣的消息會成為死信？

• 消息被消費者reject或者返回nack

• 消息超時未消費

• 隊列滿了

死信交換機的使用場景是什么？

• 如果隊列綁定了死信交換機，死信會投遞到死信交換機；

• 可以利用死信交換機收集所有消費者處理失敗的消息（死信），交由人工處理，進一步提高消息隊列的可靠性。

總結

以上是生活随笔為你收集整理的利用死信交换机接收死信的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。