RocketMQ消息丟失怎么解決？很多新手對(duì)此不是很清楚，為了幫助大家解決這個(gè)難題，下面小編將為大家詳細(xì)講解，有這方面需求的人可以來學(xué)習(xí)下，希望你能有所收獲。

金鄉(xiāng)ssl適用于網(wǎng)站、小程序/APP、API接口等需要進(jìn)行數(shù)據(jù)傳輸應(yīng)用場(chǎng)景，ssl證書未來市場(chǎng)廣闊！成為創(chuàng)新互聯(lián)建站的ssl證書銷售渠道，可以享受市場(chǎng)價(jià)格4-6折優(yōu)惠！如果有意向歡迎電話聯(lián)系或者加微信：028-86922220（備注：SSL證書合作）期待與您的合作！

既然使用在項(xiàng)目中使用了MQ，那么就不可避免的需要考慮消息丟失問題。在一些涉及到了金錢交易的場(chǎng)景下，消息丟失還是很致命的。那么在RocketMQ中存在哪幾種消息丟失的場(chǎng)景呢？

先來一張最簡(jiǎn)單的消費(fèi)流程圖：

上圖中大致包含了這么幾種場(chǎng)景：

生產(chǎn)者產(chǎn)生消息發(fā)送給RocketMQRocketMQ接收到了消息之后，必然需要存到磁盤中，否則斷電或宕機(jī)之后會(huì)造成數(shù)據(jù)的丟失消費(fèi)者從RocketMQ中獲取消息消費(fèi)，消費(fèi)成功之后，整個(gè)流程結(jié)束

這三種場(chǎng)景都可能會(huì)產(chǎn)生消息的丟失，如下圖所示：

場(chǎng)景1中生產(chǎn)者將消息發(fā)送給Rocket MQ的時(shí)候，如果出現(xiàn)了網(wǎng)絡(luò)抖動(dòng)或者通信異常等問題，消息就有可能會(huì)丟失場(chǎng)景2中消息需要持久化到磁盤中，這時(shí)會(huì)有兩種情況導(dǎo)致消息丟失

①RocketMQ為了減少磁盤的IO，會(huì)先將消息寫入到os cache中，而不是直接寫入到磁盤中，消費(fèi)者從os cache中獲取消息類似于直接從內(nèi)存中獲取消息，速度更快，過一段時(shí)間會(huì)由os線程異步的將消息刷入磁盤中，此時(shí)才算真正完成了消息的持久化。在這個(gè)過程中，如果消息還沒有完成異步刷盤，RocketMQ中的Broker宕機(jī)的話，就會(huì)導(dǎo)致消息丟失

②如果消息已經(jīng)被刷入了磁盤中，但是數(shù)據(jù)沒有做任何備份，一旦磁盤損壞，那么消息也會(huì)丟失消費(fèi)者成功從RocketMQ中獲取到了消息，還沒有將消息完全消費(fèi)完的時(shí)候，就通知RocketMQ我已經(jīng)將消息消費(fèi)了，然后消費(fèi)者宕機(jī)，但是RocketMQ認(rèn)為消費(fèi)者已經(jīng)成功消費(fèi)了數(shù)據(jù)，所以數(shù)據(jù)依舊丟失了

那么如何保證消息的零丟失呢？

1、場(chǎng)景1中保證消息不丟失的方案是使用RocketMQ自帶的事務(wù)機(jī)制來發(fā)送消息，大致流程為

①首先生產(chǎn)者發(fā)送half消息到RocketMQ中，此時(shí)消費(fèi)者是無法消費(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í)間沒有收到生產(chǎn)者是要commit/rollback操作的響應(yīng)，回調(diào)生產(chǎn)者接口的細(xì)節(jié)，感興趣的可以參考文末的 RocketMQ分布式事務(wù)原理

在使用了RocketMQ事務(wù)將生產(chǎn)者的消息成功發(fā)送給RocketMQ，就可以保證在這個(gè)階段消息不會(huì)丟失在場(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)故障。在場(chǎng)景3中，消息到達(dá)了消費(fèi)者，RocketMQ在代碼中就能保證消息不會(huì)丟失

//注冊(cè)消息監(jiān)聽器處理消息
consumer.registerMessageListener(new MessageListenerConcurrently() {
 @Override
 public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context){ 		 						      
  //對(duì)消息進(jìn)行處理
  return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
 }
});

分享名稱：RocketMQ消息丟失怎么解決-創(chuàng)新互聯(lián)
標(biāo)題路徑：http://aaarwkj.com/article42/dohchc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供動(dòng)態(tài)網(wǎng)站、品牌網(wǎng)站制作、網(wǎng)站內(nèi)鏈、定制開發(fā)、網(wǎng)站收錄、小程序開發(fā)

廣告

聲明：本網(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)