成人午夜视频全免费观看高清-秋霞福利视频一区二区三区-国产精品久久久久电影小说-亚洲不卡区三一区三区一区

mq消息丟失問題如何解決

這篇“mq消息丟失問題如何解決”文章的知識(shí)點(diǎn)大部分人都不太理解,所以小編給大家總結(jié)了以下內(nèi)容,內(nèi)容詳細(xì),步驟清晰,具有一定的借鑒價(jià)值,希望大家閱讀完這篇文章能有所收獲,下面我們一起來看看這篇“mq消息丟失問題如何解決”文章吧。

創(chuàng)新互聯(lián)建站專注于涿鹿網(wǎng)站建設(shè)服務(wù)及定制,我們擁有豐富的企業(yè)做網(wǎng)站經(jīng)驗(yàn)。 熱誠為您提供涿鹿?fàn)I銷型網(wǎng)站建設(shè),涿鹿網(wǎng)站制作、涿鹿網(wǎng)頁設(shè)計(jì)、涿鹿網(wǎng)站官網(wǎng)定制、成都微信小程序服務(wù),打造涿鹿網(wǎng)絡(luò)公司原創(chuàng)品牌,更為您提供涿鹿網(wǎng)站排名全網(wǎng)營銷落地服務(wù)。

1.生產(chǎn)者存放消息的過程中丟失消息

mq消息丟失問題如何解決

解決辦法:

(1)事務(wù)機(jī)制:(同步方式,不推薦)

對(duì)于RabbitMQ消息隊(duì)列來說,生產(chǎn)者發(fā)送數(shù)據(jù)之前開啟RabbitMQ的事務(wù)機(jī)制 channel.txselect,如果消息沒有進(jìn)隊(duì)列,則生產(chǎn)者受到異常報(bào)錯(cuò),并進(jìn)行回滾channel.txRollback,然后重試發(fā)送消息。如果收到了消息,則可以提交事務(wù)channel.txCommit。這是同步操作,會(huì)影響性能。

(2)異步機(jī)制:

confirm模式來解決同步機(jī)制的性能問題。每次生產(chǎn)者發(fā)送的消息都會(huì)分配一個(gè)唯一的id,如果寫入到了RabbitMQ隊(duì)列中,則RabbitMQ會(huì)回傳一個(gè)ack消息,說明這個(gè)消息接收成功。如果RabbitMQ沒能處理這個(gè)消息,則回調(diào)nack接口。說明需要重試發(fā)送消息。

也可以自定義超時(shí)時(shí)間 + 消息 id 來實(shí)現(xiàn)超時(shí)等待后重試機(jī)制。但可能出現(xiàn)的問題是調(diào)用ack接口時(shí)失敗了,所以會(huì)出現(xiàn)消息被發(fā)送兩次的問題,這個(gè)時(shí)候就需要保證消費(fèi)者消費(fèi)消息的冪等性。

事務(wù)模式和confirm模式的區(qū)別:

事務(wù)機(jī)制是同步的,提交事務(wù)后悔被阻塞直到提交事務(wù)完成后。

confirm 模式異步接收通知,但可能接收不到通知。需要考慮接收不到通知的場(chǎng)景。

2.消息隊(duì)列消息丟失

mq消息丟失問題如何解決

解決辦法:

(1)創(chuàng)建Queue時(shí),將其設(shè)置為持久化

(2)發(fā)送消息的時(shí)候?qū)⑾⒌膁eliveryMode設(shè)置為2(將消息持久化 1:非持久化,2:持久化)

(3)開啟生產(chǎn)者 confirm`模式,可以重試發(fā)送消息。

3.消費(fèi)者丟失消息

mq消息丟失問題如何解決

解決辦法:

關(guān)閉RabbitMQ的自動(dòng)ack,每次生產(chǎn)者將消息寫入消息隊(duì)列后,就自動(dòng)回傳一個(gè)ack給生產(chǎn)者。

消費(fèi)者處理完消息再主動(dòng)ack,告訴消息隊(duì)列我處理完了。

4.總結(jié)

(1)開啟生產(chǎn)者消息手動(dòng)確認(rèn)機(jī)制

(2)開啟消息持久化,隊(duì)列持久化,交換機(jī)持久化(默認(rèn)開啟)

(3)開啟消費(fèi)者消息手動(dòng)確認(rèn)機(jī)制

以上就是關(guān)于“mq消息丟失問題如何解決”這篇文章的內(nèi)容,相信大家都有了一定的了解,希望小編分享的內(nèi)容對(duì)大家有幫助,若想了解更多相關(guān)的知識(shí)內(nèi)容,請(qǐng)關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

網(wǎng)站題目:mq消息丟失問題如何解決
分享鏈接:http://jinyejixie.com/article28/pggscp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供ChatGPT定制網(wǎng)站、網(wǎng)站策劃、企業(yè)網(wǎng)站制作App設(shè)計(jì)、商城網(wǎng)站

廣告

聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)

營銷型網(wǎng)站建設(shè)
勐海县| 达拉特旗| 吴忠市| 玛曲县| 长寿区| 衡阳市| 松滋市| 安阳市| 鹿泉市| 修文县| 安义县| 巢湖市| 将乐县| 峨眉山市| 彭泽县| 南充市| 辉南县| 兴宁市| 北京市| 云梦县| 通海县| 尼勒克县| 靖安县| 双桥区| 比如县| 山东| 肇源县| 全椒县| 分宜县| 张家港市| 周口市| 宜阳县| 重庆市| 白水县| 德阳市| 新丰县| 启东市| 永年县| 张掖市| 武穴市| 延边|