Spring RabbitMQ死信機制原理實例詳解
更新時間：2020年03月02日 14:53:24 作者：白眉大蝦
這篇文章主要介紹了Spring RabbitMQ死信機制原理實例詳解,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
死信隊列：沒有被及時消費的消息存放的隊列，消息沒有被及時消費有以下幾點原因：
- 1.有消息被拒絕（basic.reject/ basic.nack）并且requeue=false
- 2.隊列達到最大長度
- 3.消息TTL過期
采用死信機制的好處是可以提高系統(tǒng)的穩(wěn)定性，當消息消費失敗后，消息進入死信隊列，可以對消息進行補償，可以達到最終一致性的目標.
具體例子如下：
@Bean
public Queue deadQueue() {
return new Queue(DEAD_QUEUE_NAME, true);
}
@Bean
public DirectExchange deadExchange() {
return new DirectExchange(DEAD_EXCHANGE_NAME);
}
@Bean
public Binding bindingDeadExchange(Queue deadQueue, DirectExchange deadExchange) {
return BindingBuilder.bind(deadQueue).to(deadExchange).with(DEAD_ROUTING_KEY);
}
@Bean
Queue 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)容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。
相關文章
這篇文章主要給大家介紹了關于Mybatis中輸入輸出映射與動態(tài)Sql的相關資料,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面來一起學習學習吧2019-02-02
這篇文章主要為大家詳細介紹了java實現(xiàn)簡單計算器，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2020-12-12
本篇文章主要介紹了詳解java整合solr5.0之solrj的使用 ，具有一定的參考價值，有興趣的可以了解下2017-06-06
SSM框架中測試單元的使用 spring整合Junit過程詳解
這篇文章主要介紹了SSM框架中測試單元的使用 spring整合Junit過程詳解,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-09-09
這篇文章主要為大家詳細介紹了Java Web實現(xiàn)文件上傳和下載接口功能的相關知識，文中的示例代碼講解詳細，對我們學習有一定的借鑒價值，需要的可以參考一下2022-12-12
枚舉是 Java 中的一種特殊類型，它用于表示一組固定值，這篇文章就是來和大家講講枚舉的作用與具體使用，感興趣的小伙伴可以跟隨小編一起學習一下2023-06-06
這篇文章主要介紹了java操作elasticsearch的案例解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-10-10
HASHMAP基于哈希表的 Map 接口的實現(xiàn)。此實現(xiàn)提供所有可選的映射操作，并允許使用 null 值和 null 鍵。（除了非同步和允許使用 null 之外，HashMap 類與 Hashtable 大致相同。）下面小編來帶大家詳細了解下吧2019-06-06
這篇文章主要介紹了java中如何使用泛型方法比較大小,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-04-04
解決spring 處理request.getInputStream()輸入流只能讀取一次問題
這篇文章主要介紹了解決spring 處理request.getInputStream()輸入流只能讀取一次問題，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2020-09-09