kafka每次收到新的消息之后都會(huì)將消息存儲(chǔ)在尾部，按照順序存儲(chǔ)消息。但是消息一旦存儲(chǔ)無(wú)法刪除。

當(dāng)消費(fèi)者消費(fèi)時(shí)也是順序消費(fèi)，每個(gè)消費(fèi)者會(huì)有一個(gè)偏移量，記錄當(dāng)前消費(fèi)的消息的位置。如下圖所示：

順序消費(fèi)

MMFile

MMFile是指Memory Mapped Files，即內(nèi)存映射技術(shù)。操作系統(tǒng)為了解決內(nèi)存和硬盤讀寫速度之間的差異，采用了內(nèi)存映射技術(shù)，內(nèi)存被劃分為若干頁(yè)，每一頁(yè)被映射到一塊磁盤空間，因?yàn)閮?nèi)存是遠(yuǎn)遠(yuǎn)小于磁盤空間的，所以分頁(yè)經(jīng)常會(huì)按照一定的算法加載到內(nèi)存，例如先進(jìn)先出(FIFO)，最近最少使用(LRU)等。內(nèi)存中分頁(yè)和磁盤空間對(duì)應(yīng)，操作系統(tǒng)會(huì)在合適的時(shí)候?qū)?nèi)存分頁(yè)中的數(shù)據(jù)定時(shí)刷磁盤中去。這種方式為什么可以提高寫入效率呢?通常CPU執(zhí)行過(guò)程中為了安全分為內(nèi)核態(tài)和用戶態(tài)。只有內(nèi)核態(tài)才能操作iO設(shè)備，內(nèi)存空間分為內(nèi)核空間和用戶空間。通常內(nèi)存中的數(shù)據(jù)寫入到磁盤要以下幾步：

write操作

數(shù)據(jù)會(huì)先從用戶空間拷貝到內(nèi)核空間，然后再由內(nèi)核空間寫入IO設(shè)備。而MMFile則省去了一次用數(shù)據(jù)從戶空間到內(nèi)核空間復(fù)制的開銷。

讀取快

讀取快主要是因?yàn)榱憧截?Zero Copy)技術(shù)。上面介紹到數(shù)據(jù)從內(nèi)存空間寫入磁盤的步驟，那么從磁盤讀取數(shù)據(jù)剛好相反，具體過(guò)程如下：

read操作

數(shù)據(jù)先從磁盤讀取到內(nèi)核空間，然后再?gòu)膬?nèi)核空間復(fù)制到用戶空間，然后再到Socket，最后傳輸?shù)较M(fèi)者。

Linux提供了一種sendFile系統(tǒng)調(diào)用，可以將數(shù)據(jù)直接由磁盤拷貝到內(nèi)核空間。省去了一次數(shù)據(jù)從用戶空間到內(nèi)核空間的復(fù)制。這就是所謂的零拷貝技術(shù)。

上面從讀寫兩個(gè)角度分析了為什么kafka吞吐量高，其實(shí)還有一個(gè)重要的原因。

批量數(shù)據(jù)壓縮

kafka不會(huì)對(duì)每個(gè)消息都做壓縮，而是對(duì)一批消息壓縮，然后將數(shù)據(jù)統(tǒng)一發(fā)送。將所有的消息變?yōu)橐粋€(gè)批量文件，然后直接丟給消費(fèi)者。

綜上所述，kafka通過(guò)MMFile技術(shù)快速將數(shù)據(jù)順序?qū)懭氪疟P，在讀取時(shí)通過(guò)零拷貝技術(shù)快速讀取，然后通過(guò)批量數(shù)據(jù)壓縮將數(shù)據(jù)傳輸?shù)较M(fèi)者。這就是kafka快的秘訣。然而魚與熊掌不可兼得，速度和可靠性不可能同時(shí)滿足，需要根據(jù)實(shí)際業(yè)務(wù)情況在二者之間作出取舍。例如當(dāng)用kafka做日志聚合和網(wǎng)站用戶行為分析時(shí)速度要比可靠性重要，而在某些消息不允許丟失的場(chǎng)景，可靠性可能是首選。