Spring RabbitMQ死信機(jī)制原理實(shí)例詳解

更新時(shí)間：2020年03月02日 14:53:24 作者：白眉大蝦

這篇文章主要介紹了Spring RabbitMQ死信機(jī)制原理實(shí)例詳解,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下

死信隊(duì)列：沒有被及時(shí)消費(fèi)的消息存放的隊(duì)列，消息沒有被及時(shí)消費(fèi)有以下幾點(diǎn)原因：

1.有消息被拒絕（basic.reject/ basic.nack）并且requeue=false
2.隊(duì)列達(dá)到最大長(zhǎng)度
3.消息TTL過期

采用死信機(jī)制的好處是可以提高系統(tǒng)的穩(wěn)定性，當(dāng)消息消費(fèi)失敗后，消息進(jìn)入死信隊(duì)列，可以對(duì)消息進(jìn)行補(bǔ)償，可以達(dá)到最終一致性的目標(biāo).

具體例子如下：

@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);
}

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

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

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章:

相關(guān)文章

Mybatis中輸入輸出映射與動(dòng)態(tài)Sql圖文詳解
這篇文章主要給大家介紹了關(guān)于Mybatis中輸入輸出映射與動(dòng)態(tài)Sql的相關(guān)資料,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面來一起學(xué)習(xí)學(xué)習(xí)吧
2019-02-02
java實(shí)現(xiàn)簡(jiǎn)單計(jì)算器
這篇文章主要為大家詳細(xì)介紹了java實(shí)現(xiàn)簡(jiǎn)單計(jì)算器，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
2020-12-12
詳解java整合solr5.0之solrj的使用
本篇文章主要介紹了詳解java整合solr5.0之solrj的使用，具有一定的參考價(jià)值，有興趣的可以了解下
2017-06-06
SSM框架中測(cè)試單元的使用 spring整合Junit過程詳解
這篇文章主要介紹了SSM框架中測(cè)試單元的使用 spring整合Junit過程詳解,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
2019-09-09
Java Web實(shí)現(xiàn)文件上傳和下載接口功能詳解
這篇文章主要為大家詳細(xì)介紹了Java Web實(shí)現(xiàn)文件上傳和下載接口功能的相關(guān)知識(shí)，文中的示例代碼講解詳細(xì)，對(duì)我們學(xué)習(xí)有一定的借鑒價(jià)值，需要的可以參考一下
2022-12-12
一文教會(huì)你使用Java中的枚舉Enmu
枚舉是 Java 中的一種特殊類型，它用于表示一組固定值，這篇文章就是來和大家講講枚舉的作用與具體使用，感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下
2023-06-06
java操作elasticsearch的案例解析
這篇文章主要介紹了java操作elasticsearch的案例解析,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
2019-10-10
深入了解JAVA HASHMAP的死循環(huán)
HASHMAP基于哈希表的 Map 接口的實(shí)現(xiàn)。此實(shí)現(xiàn)提供所有可選的映射操作，并允許使用 null 值和 null 鍵。（除了非同步和允許使用 null 之外，HashMap 類與 Hashtable 大致相同。）下面小編來帶大家詳細(xì)了解下吧
2019-06-06
java中如何使用泛型方法比較大小
這篇文章主要介紹了java中如何使用泛型方法比較大小,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
2024-04-04
解決spring 處理request.getInputStream()輸入流只能讀取一次問題
這篇文章主要介紹了解決spring 處理request.getInputStream()輸入流只能讀取一次問題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過來看看吧
2020-09-09