kafka中的消費者在讀取服務(wù)端的數(shù)據(jù)時，需要將服務(wù)端的磁盤文件通過網(wǎng)絡(luò)發(fā)送到消費者進程，網(wǎng)絡(luò)發(fā)送需要經(jīng)過幾種網(wǎng)絡(luò)節(jié)點。如下圖所示： 傳統(tǒng)的讀取...
投稿
收錄了22篇文章 · 8人關(guān)注
-
Kafka的零拷貝技術(shù)
-
深入分析Kafka高可用性本文主要內(nèi)容：①kafka復(fù)制機制②分區(qū)leader副本宕掉怎么選新的leader③高水位與leader epoch的詳細(xì)分析。④一些相關(guān)配置 ...
-
RocketMQ MappedFile 預(yù)熱原理解析
創(chuàng)建 MappedFile 文件 創(chuàng)建 MappedFile 文件實現(xiàn)如下： 從代碼中可以看出，只有 MappedFile 的大小等于或大于 C...
-
聊聊Java消息消息在開發(fā)過程中多次用到，在分布式系統(tǒng)中也是高頻使用的一項技術(shù)，特寫該片文章以作總結(jié)。 一、消息使用場景 1.1 常見的使用場景 系統(tǒng)解耦 異步...
-
消息中間件面試題：消息中間件的高可用接著上一篇面試題的擴展。 面試題 如何保證消息隊列的高可用？ 消息中間件各種面試題：消息中間件面試題：消息丟失怎么辦？消息中間件面試題：消息隊列...
-
RocketMQ 底層通信機制 源碼分析概述 RocketMQ 底層通訊是使用Netty來實現(xiàn)的。下面我們通過源碼分析下RocketMQ是怎么利用Netty進行通訊的。 本文分析的是R...
-
怎樣保證消息處理的順序？
1. 流水消息：沒有順序要求。 2. 狀態(tài)消息：有順序要求。消息增加版本號作為樂觀鎖控制，接收方只處理版本號大于當(dāng)前的消息。 3. 連鎖消息：有...
-
高并發(fā)架構(gòu)系列：如何從0到1設(shè)計一個MQ消息隊列
消息隊列作為系統(tǒng)解耦，流量控制的利器，成為分布式系統(tǒng)核心組件之一。 如果你對消息隊列背后的實現(xiàn)原理關(guān)注不多，其實了解消息隊列背后的實現(xiàn)非常重要。...
-
RocketMQ源碼閱讀(四)-消息存儲三
前文已經(jīng)介紹了消息存儲中使用到的充要對象, 本文分析一下消息介紹的主流程. 另外, 此篇主要分析消息存儲主流程的代碼, 不影響主流程的代碼先不看...
-
RocketMQ源碼閱讀(四)-消息存儲二
RocketMQ的消息存儲過程非常復(fù)雜, 本文先介紹存儲模塊中幾個重要對象. 1. MappedFile 對MappedByteBuffer的封...
{var%20f='http://v.t.sina.com.cn/share/share.php?appkey=1881139527',u=z||d.location,p=['&url=',e(u),'&title=',e(t||d.title),'&source=',e(r),'&sourceUrl=',e(l),'&content=',c||'gb2312','&pic=',e(p||'')].join('');function%20a(){if(!window.open([f,p].join(''),'mb',['toolbar=0,status=0,resizable=1,width=440,height=430,left=',(s.width-440)/2,',top=',(s.height-430)/2].join('')))u.href=[f,p].join('');};if(/Firefox/.test(navigator.userAgent))setTimeout(a,0);else%20a();})(screen,document,encodeURIComponent,'','','https://upload.jianshu.io/collections/images/1697894/crop1545149745774.jpg', '推薦專題《MQ消息系列》（ 分享自 @簡書 ）','http://m.itdecent.cn/c/dee942d70e37?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','頁面編碼gb2312|utf-8默認(rèn)gb2312'));){kind=link}