Spring RabbitMQ死信機制原理實例詳解
死信隊列:沒有被及時消費的消息存放的隊列,消息沒有被及時消費有以下幾點原因:
1.有消息被拒絕(basic.reject/ basic.nack)并且requeue=false 2.隊列達(dá)到最大長度 3.消息TTL過期采用死信機制的好處是可以提高系統(tǒng)的穩(wěn)定性,當(dāng)消息消費失敗后,消息進入死信隊列,可以對消息進行補償,可以達(dá)到最終一致性的目標(biāo).
具體例子如下:
@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)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持好吧啦網(wǎng)。
相關(guān)文章:
1. python實現(xiàn)讀取類別頻數(shù)數(shù)據(jù)畫水平條形圖案例2. python中PyQuery庫用法分享3. python操作數(shù)據(jù)庫獲取結(jié)果之fetchone和fetchall的區(qū)別說明4. php使用正則驗證密碼字段的復(fù)雜強度原理詳細(xì)講解 原創(chuàng)5. Ajax實現(xiàn)頁面無刷新留言效果6. Python編寫nmap掃描工具7. ASP.NET MVC前臺動態(tài)添加文本框并在后臺使用FormCollection接收值8. python 爬取嗶哩嗶哩up主信息和投稿視頻9. PHP獲取時間戳等相關(guān)函數(shù)匯總10. AJAX實現(xiàn)數(shù)據(jù)的增刪改查操作詳解【java后臺】
