www.久久久久|狼友网站av天堂|精品国产无码a片|一级av色欲av|91在线播放视频|亚洲无码主播在线|国产精品草久在线|明星AV网站在线|污污内射久久一区|婷婷综合视频网站

當(dāng)前位置:首頁(yè) > 公眾號(hào)精選 > 架構(gòu)師社區(qū)
[導(dǎo)讀]?https://blog.csdn.net/LO_YUN/article/details/103949317既然在項(xiàng)目中使用了MQ,那么就不可避免的需要考慮消息丟失問(wèn)題。在一些涉及到了金錢交易的場(chǎng)景下,消息丟失還是很致命的。那么在RocketMQ中存在哪幾種消息丟失的場(chǎng)景呢?先...

?本文來(lái)源:https://blog.csdn.net/LO_YUN/article/details/103949317

ckground-color: rgb(255, 255, 255);font-family: 等線;text-align: center;line-height: 2em;">

既然在項(xiàng)目中使用了MQ,那么就不可避免的需要考慮消息丟失問(wèn)題。在一些涉及到了金錢交易的場(chǎng)景下,消息丟失還是很致命的。那么在RocketMQ中存在哪幾種消息丟失的場(chǎng)景呢?先來(lái)一張最簡(jiǎn)單的消費(fèi)流程圖:RocketMQ?消息丟失場(chǎng)景分析及如何解決!

上圖中大致包含了這么幾種場(chǎng)景:
  • 生產(chǎn)者產(chǎn)生消息發(fā)送給RocketMQ
  • RocketMQ接收到了消息之后,必然需要存到磁盤中,否則斷電或宕機(jī)之后會(huì)造成數(shù)據(jù)的丟失
  • 消費(fèi)者從RocketMQ中獲取消息消費(fèi),消費(fèi)成功之后,整個(gè)流程結(jié)束
這三種場(chǎng)景都可能會(huì)產(chǎn)生消息的丟失,如下圖所示:RocketMQ?消息丟失場(chǎng)景分析及如何解決!

1、場(chǎng)景1中生產(chǎn)者將消息發(fā)送給Rocket MQ的時(shí)候,如果出現(xiàn)了網(wǎng)絡(luò)抖動(dòng)或者通信異常等問(wèn)題,消息就有可能會(huì)丟失2、場(chǎng)景2中消息需要持久化到磁盤中,這時(shí)會(huì)有兩種情況導(dǎo)致消息丟失
  • RocketMQ為了減少磁盤的IO,會(huì)先將消息寫入到os cache中,而不是直接寫入到磁盤中,消費(fèi)者從os cache中獲取消息類似于直接從內(nèi)存中獲取消息,速度更快,過(guò)一段時(shí)間會(huì)由os線程異步的將消息刷入磁盤中,此時(shí)才算真正完成了消息的持久化。在這個(gè)過(guò)程中,如果消息還沒(méi)有完成異步刷盤,RocketMQ中的Broker宕機(jī)的話,就會(huì)導(dǎo)致消息丟失
  • 如果消息已經(jīng)被刷入了磁盤中,但是數(shù)據(jù)沒(méi)有做任何備份,一旦磁盤損壞,那么消息也會(huì)丟失
3、消費(fèi)者成功從RocketMQ中獲取到了消息,還沒(méi)有將消息完全消費(fèi)完的時(shí)候,就通知RocketMQ我已經(jīng)將消息消費(fèi)了,然后消費(fèi)者宕機(jī),但是RocketMQ認(rèn)為消費(fèi)者已經(jīng)成功消費(fèi)了數(shù)據(jù),所以數(shù)據(jù)依舊丟失了。那么如何保證消息的零丟失呢?RocketMQ?消息丟失場(chǎng)景分析及如何解決!

1、場(chǎng)景1中保證消息不丟失的方案是使用RocketMQ自帶的事務(wù)機(jī)制來(lái)發(fā)送消息,大致流程為:
  • 首先生產(chǎn)者發(fā)送half消息到RocketMQ中,此時(shí)消費(fèi)者是無(wú)法消費(fèi)half消息的,若half消息就發(fā)送失敗了,則執(zhí)行相應(yīng)的回滾邏輯
  • half消息發(fā)送成功之后,且RocketMQ返回成功響應(yīng),則執(zhí)行生產(chǎn)者的核心鏈路
  • 如果生產(chǎn)者自己的核心鏈路執(zhí)行失敗,則回滾,并通知RocketMQ刪除half消息
  • 如果生產(chǎn)者的核心鏈路執(zhí)行成功,則通知RocketMQ commit half消息,讓消費(fèi)者可以消費(fèi)這條數(shù)據(jù)
其中還有一些RocketMQ長(zhǎng)時(shí)間沒(méi)有收到生產(chǎn)者是要commit/rollback操作的響應(yīng),回調(diào)生產(chǎn)者接口的細(xì)節(jié),感興趣的可以參考:
https://blog.csdn.net/LO_YUN/article/details/101673893

在使用了RocketMQ事務(wù)將生產(chǎn)者的消息成功發(fā)送給RocketMQ,就可以保證在這個(gè)階段消息不會(huì)丟失2、在場(chǎng)景2中要保證消息不丟失,首先需要將os cache的異步刷盤策略改為同步刷盤,這一步需要修改Broker的配置文件,將flushDiskType改為SYNC_FLUSH同步刷盤策略,默認(rèn)的是ASYNC_FLUSH異步刷盤。一旦同步刷盤返回成功,那么就一定保證消息已經(jīng)持久化到磁盤中了;為了保證磁盤損壞不會(huì)丟失數(shù)據(jù),我們需要對(duì)RocketMQ采用主從機(jī)構(gòu),集群部署,Leader中的數(shù)據(jù)在多個(gè)Follower中都存有備份,防止單點(diǎn)故障。3、在場(chǎng)景3中,消息到達(dá)了消費(fèi)者,RocketMQ在代碼中就能保證消息不會(huì)丟失
//注冊(cè)消息監(jiān)聽(tīng)器處理消息
consumer.registerMessageListener(new?MessageListenerConcurrently()?{
???@Override
????public?ConsumeConcurrentlyStatus?consumeMessage(List?msgs,?ConsumeConcurrentlyContext?context){??????????????????????????????????
????????//對(duì)消息進(jìn)行處理
????????return?ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
????}
});
上面這段代碼中,RocketMQ在消費(fèi)者中注冊(cè)了一個(gè)監(jiān)聽(tīng)器,當(dāng)消費(fèi)者獲取到了消息,就會(huì)去回調(diào)這個(gè)監(jiān)聽(tīng)器函數(shù),去處理里面的消息當(dāng)你的消息處理完畢之后,才會(huì)返回ConsumeConcurrentlyStatus.CONSUME_SUCCESS 只有返回了CONSUME_SUCCESS,消費(fèi)者才會(huì)告訴RocketMQ我已經(jīng)消費(fèi)完了,此時(shí)如果消費(fèi)者宕機(jī),消息已經(jīng)處理完了,也就不會(huì)丟失消息了如果消費(fèi)者還沒(méi)有返回CONSUME_SUCCESS時(shí)就宕機(jī)了,那么RocketMQ就會(huì)認(rèn)為你這個(gè)消費(fèi)者節(jié)點(diǎn)掛掉了,會(huì)自動(dòng)故障轉(zhuǎn)移,將消息交給消費(fèi)者組的其他消費(fèi)者去消費(fèi)這個(gè)消息,保證消息不會(huì)丟失為了保證消息不會(huì)丟失,在consumeMessage方法中就直接寫消息消費(fèi)的業(yè)務(wù)邏輯就可以了,如果非要搞一些騷操作,比如下面的代碼//注冊(cè)消息監(jiān)聽(tīng)器處理消息
consumer.registerMessageListener(new?MessageListenerConcurrently()?{
???@Override
????public?ConsumeConcurrentlyStatus?consumeMessage(List?msgs,?ConsumeConcurrentlyContext?context){?
?????//開(kāi)啟子線程異步處理消息
?????new?Thread()?{
???public?void?run()?{
????//對(duì)消息進(jìn)行處理
???}
??}.start();?????????????????????????????????
????????return?ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
????}
});
如果新開(kāi)子線程異步處理消息的話,就有可能出現(xiàn)消息還沒(méi)有被消費(fèi)完,消費(fèi)者告訴RocketMQ消息已經(jīng)被消費(fèi)了,結(jié)果宕機(jī)丟失消息的情況。使用上面一整套的方案就可以在使用RocketMQ時(shí)保證消息零丟失,但是性能和吞吐量也將大幅下降
  • 使用事務(wù)機(jī)制傳輸消息,會(huì)比普通的消息傳輸多出很多步驟,耗費(fèi)性能
  • 同步刷盤相比異步刷盤,一個(gè)是存儲(chǔ)在磁盤中,一個(gè)存儲(chǔ)在內(nèi)存中,速度完全不是一個(gè)數(shù)量級(jí)
  • 主從機(jī)構(gòu)的話,需要Leader將數(shù)據(jù)同步給Follower
  • 消費(fèi)時(shí)無(wú)法異步消費(fèi),只能等待消費(fèi)完成再通知RocketMQ消費(fèi)完成
消息零丟失是一把雙刃劍,要想用好,還是要視具體的業(yè)務(wù)場(chǎng)景而定,選擇合適的方案才是最好的

本站聲明: 本文章由作者或相關(guān)機(jī)構(gòu)授權(quán)發(fā)布,目的在于傳遞更多信息,并不代表本站贊同其觀點(diǎn),本站亦不保證或承諾內(nèi)容真實(shí)性等。需要轉(zhuǎn)載請(qǐng)聯(lián)系該專欄作者,如若文章內(nèi)容侵犯您的權(quán)益,請(qǐng)及時(shí)聯(lián)系本站刪除。
換一批
延伸閱讀

9月2日消息,不造車的華為或?qū)⒋呱龈蟮莫?dú)角獸公司,隨著阿維塔和賽力斯的入局,華為引望愈發(fā)顯得引人矚目。

關(guān)鍵字: 阿維塔 塞力斯 華為

倫敦2024年8月29日 /美通社/ -- 英國(guó)汽車技術(shù)公司SODA.Auto推出其旗艦產(chǎn)品SODA V,這是全球首款涵蓋汽車工程師從創(chuàng)意到認(rèn)證的所有需求的工具,可用于創(chuàng)建軟件定義汽車。 SODA V工具的開(kāi)發(fā)耗時(shí)1.5...

關(guān)鍵字: 汽車 人工智能 智能驅(qū)動(dòng) BSP

北京2024年8月28日 /美通社/ -- 越來(lái)越多用戶希望企業(yè)業(yè)務(wù)能7×24不間斷運(yùn)行,同時(shí)企業(yè)卻面臨越來(lái)越多業(yè)務(wù)中斷的風(fēng)險(xiǎn),如企業(yè)系統(tǒng)復(fù)雜性的增加,頻繁的功能更新和發(fā)布等。如何確保業(yè)務(wù)連續(xù)性,提升韌性,成...

關(guān)鍵字: 亞馬遜 解密 控制平面 BSP

8月30日消息,據(jù)媒體報(bào)道,騰訊和網(wǎng)易近期正在縮減他們對(duì)日本游戲市場(chǎng)的投資。

關(guān)鍵字: 騰訊 編碼器 CPU

8月28日消息,今天上午,2024中國(guó)國(guó)際大數(shù)據(jù)產(chǎn)業(yè)博覽會(huì)開(kāi)幕式在貴陽(yáng)舉行,華為董事、質(zhì)量流程IT總裁陶景文發(fā)表了演講。

關(guān)鍵字: 華為 12nm EDA 半導(dǎo)體

8月28日消息,在2024中國(guó)國(guó)際大數(shù)據(jù)產(chǎn)業(yè)博覽會(huì)上,華為常務(wù)董事、華為云CEO張平安發(fā)表演講稱,數(shù)字世界的話語(yǔ)權(quán)最終是由生態(tài)的繁榮決定的。

關(guān)鍵字: 華為 12nm 手機(jī) 衛(wèi)星通信

要點(diǎn): 有效應(yīng)對(duì)環(huán)境變化,經(jīng)營(yíng)業(yè)績(jī)穩(wěn)中有升 落實(shí)提質(zhì)增效舉措,毛利潤(rùn)率延續(xù)升勢(shì) 戰(zhàn)略布局成效顯著,戰(zhàn)新業(yè)務(wù)引領(lǐng)增長(zhǎng) 以科技創(chuàng)新為引領(lǐng),提升企業(yè)核心競(jìng)爭(zhēng)力 堅(jiān)持高質(zhì)量發(fā)展策略,塑強(qiáng)核心競(jìng)爭(zhēng)優(yōu)勢(shì)...

關(guān)鍵字: 通信 BSP 電信運(yùn)營(yíng)商 數(shù)字經(jīng)濟(jì)

北京2024年8月27日 /美通社/ -- 8月21日,由中央廣播電視總臺(tái)與中國(guó)電影電視技術(shù)學(xué)會(huì)聯(lián)合牽頭組建的NVI技術(shù)創(chuàng)新聯(lián)盟在BIRTV2024超高清全產(chǎn)業(yè)鏈發(fā)展研討會(huì)上宣布正式成立。 活動(dòng)現(xiàn)場(chǎng) NVI技術(shù)創(chuàng)新聯(lián)...

關(guān)鍵字: VI 傳輸協(xié)議 音頻 BSP

北京2024年8月27日 /美通社/ -- 在8月23日舉辦的2024年長(zhǎng)三角生態(tài)綠色一體化發(fā)展示范區(qū)聯(lián)合招商會(huì)上,軟通動(dòng)力信息技術(shù)(集團(tuán))股份有限公司(以下簡(jiǎn)稱"軟通動(dòng)力")與長(zhǎng)三角投資(上海)有限...

關(guān)鍵字: BSP 信息技術(shù)
關(guān)閉
關(guān)閉