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

?

我們可以給simple.queue添加一個(gè)死信交換機(jī)，給死信交換機(jī)綁定一個(gè)

?我們?cè)赾onsumer服務(wù)中，定義一組死信交換機(jī)、死信隊(duì)列：

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

總結(jié)

什么樣的消息會(huì)成為死信？

• 消息被消費(fèi)者reject或者返回nack

• 消息超時(shí)未消費(fèi)

• 隊(duì)列滿了

死信交換機(jī)的使用場(chǎng)景是什么？

• 如果隊(duì)列綁定了死信交換機(jī)，死信會(huì)投遞到死信交換機(jī)；

• 可以利用死信交換機(jī)收集所有消費(fèi)者處理失敗的消息（死信），交由人工處理，進(jìn)一步提高消息隊(duì)列的可靠性。

總結(jié)

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

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