Spring RabbitMQ死信機(jī)制原理實(shí)例詳解
死信隊(duì)列:沒有被及時(shí)消費(fèi)的消息存放的隊(duì)列,消息沒有被及時(shí)消費(fèi)有以下幾點(diǎn)原因:
1.有消息被拒絕(basic.reject/ basic.nack)并且requeue=false 2.隊(duì)列達(dá)到最大長度 3.消息TTL過期采用死信機(jī)制的好處是可以提高系統(tǒng)的穩(wěn)定性,當(dāng)消息消費(fèi)失敗后,消息進(jìn)入死信隊(duì)列,可以對消息進(jìn)行補(bǔ)償,可以達(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);}
只要簡易的配置,這樣消費(fèi)失敗的消息就能被收集起來,后續(xù)我們可以實(shí)現(xiàn)一個(gè)死信消費(fèi)者,將死信消息進(jìn)行補(bǔ)償。
如果是想手動(dòng)補(bǔ)償,可以將死信消息存入數(shù)據(jù)庫,做一個(gè)管理頁面去做補(bǔ)償.
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持好吧啦網(wǎng)。
相關(guān)文章:
1. 使用Python webdriver圖書館搶座自動(dòng)預(yù)約的正確方法2. Linux刪除系統(tǒng)自帶版本Python過程詳解3. ASP基礎(chǔ)知識VBScript基本元素講解4. Python 合并拼接字符串的方法5. Python 利用Entrez庫篩選下載PubMed文獻(xiàn)摘要的示例6. Python3 json模塊之編碼解碼方法講解7. Python 制作查詢商品歷史價(jià)格的小工具8. ASP.NET MVC使用jQuery ui的progressbar實(shí)現(xiàn)進(jìn)度條9. Python sublime安裝及配置過程詳解10. python 使用事件對象asyncio.Event來同步協(xié)程的操作

網(wǎng)公網(wǎng)安備