久久r热视频,国产午夜精品一区二区三区视频,亚洲精品自拍偷拍,欧美日韩精品二区

您的位置:首頁技術(shù)文章
文章詳情頁

Spring RabbitMQ死信機制原理實例詳解

瀏覽:99日期:2023-09-19 09:38:49

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

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)。

標(biāo)簽: Spring
相關(guān)文章:
主站蜘蛛池模板: 广南县| 盐山县| 新晃| 开江县| 营山县| 田林县| 登封市| 仙桃市| 琼结县| 渝中区| 佛学| 沾化县| 临桂县| 迭部县| 肇东市| 镇雄县| 萨嘎县| 唐海县| 金乡县| 潮安县| 扶沟县| 扎兰屯市| 肃宁县| 炉霍县| 滨海县| 漳州市| 遵化市| 嘉鱼县| 专栏| 葵青区| 历史| 蓬莱市| 巴马| 永年县| 沭阳县| 鹰潭市| 额济纳旗| 乌拉特中旗| 墨竹工卡县| 金秀| 涡阳县|