死信隊列：沒有被及時消費的消息存放的隊列，消息沒有被及時消費有以下幾點原因：

采用死信機制的好處是可以提高系統(tǒng)的穩(wěn)定性，當消息消費失敗后，消息進入死信隊列，可以對消息進行補償，可以達到最終一致性的目標.

具體例子如下：

@Beanpublic Queue deadQueue() { return new Queue(DEAD_QUEUE_NAME, true);}@Beanpublic DirectExchange deadExchange() { return new DirectExchange(DEAD_EXCHANGE_NAME);}@Beanpublic Binding bindingDeadExchange(Queue deadQueue, DirectExchange deadExchange) { return BindingBuilder.bind(deadQueue).to(deadExchange).with(DEAD_ROUTING_KEY);}@BeanQueue directQueue() { Map<String, Object> args = new HashMap<>(2); args.put('x-dead-letter-exchange', DEAD_EXCHANGE_NAME); args.put('x-dead-letter-routing-key', DEAD_ROUTING_KEY); return new Queue(DIRECT_QUEUE_NAME, true, false, false, args);}

只要簡易的配置，這樣消費失敗的消息就能被收集起來，后續(xù)我們可以實現(xiàn)一個死信消費者，將死信消息進行補償。

如果是想手動補償，可以將死信消息存入數(shù)據(jù)庫，做一個管理頁面去做補償.

以上就是本文的全部內(nèi)容，希望對大家的學習有所幫助，也希望大家多多支持好吧啦網(wǎng)。