漫畫講解Kafka高效的存儲設(shè)計

作者：浪尖 2020-10-22 09:37:39

存儲

存儲軟件

Kafka 索引文件存儲大量元數(shù)據(jù)，數(shù)據(jù)文件存儲大量消息，索引文件中元數(shù)據(jù)指向?qū)?yīng)數(shù)據(jù)文件中message的物理偏移地址。

網(wǎng)站設(shè)計制作過程拒絕使用模板建站；使用PHP+MYSQL原生開發(fā)可交付網(wǎng)站源代碼;符合網(wǎng)站優(yōu)化排名的后臺管理系統(tǒng)；網(wǎng)站制作、網(wǎng)站建設(shè)收費(fèi)合理；免費(fèi)進(jìn)行網(wǎng)站備案等企業(yè)網(wǎng)站建設(shè)一條龍服務(wù).我們是一家持續(xù)穩(wěn)定運(yùn)營了10年的創(chuàng)新互聯(lián)網(wǎng)站建設(shè)公司。

在開始講解之前，先帶著大家回憶一下kafka一些名詞概念：

a. Broker：提供數(shù)據(jù)存儲和數(shù)據(jù)讀寫服務(wù)實例，一個Kafka節(jié)點就是一個broker，多個broker可以組成一個Kafka集群。

b. Topic：代表的是一類消息，例如應(yīng)用日志的topic，應(yīng)用健康監(jiān)控指標(biāo)的topic等。

c. Partition：topic物理上的分組，一個topic可以分為多個partition。

d. Segment：partition物理上由多個segment組成，每個segment是一個文件。

e. offset：每個partition都由一系列有序的、不可變的消息組成，這些消息被連續(xù)的追加到partition中。partition中的每個消息都有一個連續(xù)的序列號叫做offset,用于partition唯一標(biāo)識一條消息.

下面是兩個topic,頁面瀏覽流量日志的topic page_view，和點擊日志 click_log，在kafka數(shù)據(jù)目錄下的分區(qū)存儲情況：

  
 
 
 

   
  
  
  
|--page_view-0 
   
  
  
  
          |--page_view-1 
   
  
  
  
          |--page_view-2 
   
  
  
  
          |--page_view-3 
   
  
  
  
          |--click_log-0 
   
  
  
  
          |--click_log-1 
   
  
  
  
          |--click_log-2 
   
  
  
  
          |--click_log-3 
  
 
 
 

下圖說明了文件的存儲方式：

• 每個partion(目錄)相當(dāng)于一個巨型文件被平均分配到多個大小相等segment(段)數(shù)據(jù)文件中。但每個段segment file消息數(shù)量不一定相等，這種特性方便old segment file快速被刪除。
• 每個partiton只需要支持順序讀寫就行了，segment文件生命周期由服務(wù)端配置參數(shù)決定。

這樣做的好處就是能快速刪除無用文件，有效提高磁盤利用率。

partition中segment file組成和物理結(jié)構(gòu)，細(xì)節(jié)如下：

• segment file組成：由2大部分組成，分別為index文件和data文件，這兩個文件一一對應(yīng)，成對出現(xiàn)，后綴”.index”和“.log”分別表示為segment索引文件、數(shù)據(jù)文件.
• segment文件命名規(guī)則：partion全局的第一個segment從0開始，后續(xù)每個segment文件名為上一個segment文件最后一條消息的offset值。數(shù)值最大為64位long大小，19位數(shù)字字符長度，沒有數(shù)字用0填充。

創(chuàng)建一個topicXXX包含1 partition，設(shè)置每個segment大小為500MB,并啟動producer向Kafka broker寫入大量數(shù)據(jù)，該partition文件內(nèi)容如下：

圖1

還有一張細(xì)節(jié)的圖，說明一些index文件和log文件的對應(yīng)關(guān)系：

圖2

索引文件存儲大量元數(shù)據(jù)，數(shù)據(jù)文件存儲大量消息，索引文件中元數(shù)據(jù)指向?qū)?yīng)數(shù)據(jù)文件中message的物理偏移地址。其中以索引文件中元數(shù)據(jù)3,497為例，依次在數(shù)據(jù)文件中表示第3個message(在全局partiton表示第368772個message)、以及該消息的物理偏移地址為497。

例如讀取offset=368776的message，需要通過下面2個步驟查找。

第一步查找segment file 以前面圖1為例，其中00000000000000000000.index表示最開始的文件，起始偏移量(offset)為0.第二個文件00000000000000368769.index的消息量起始偏移量為368770 = 368769 + 1.同樣，第三個文件00000000000000737337.index的起始偏移量為737338=737337 + 1，其他后續(xù)文件依次類推，以起始偏移量命名并排序這些文件，只要根據(jù)offset **二分查找**文件列表，就可以快速定位到具體文件。當(dāng)offset=368776時定位到00000000000000368769.index|log

第二步 圖2 ，通過segment file查找message 通過第一步定位到segment file，當(dāng)offset=368776時，依次定位到00000000000000368769.index的元數(shù)據(jù)物理位置和00000000000000368769.log的物理偏移地址，然后再通過00000000000000368769.log順序查找直到offset=368776為止。

這樣做的優(yōu)點很明顯，segment index file采取稀疏索引存儲方式，它減少索引文件大小，通過mmap可以直接內(nèi)存操作，稀疏索引為數(shù)據(jù)文件的每個對應(yīng)message設(shè)置一個元數(shù)據(jù)指針,它比稠密索引節(jié)省了更多的存儲空間，但查找起來需要消耗更多的時間。

本文轉(zhuǎn)載自微信公眾號「浪尖聊大數(shù)據(jù)」，可以通過以下二維碼關(guān)注。轉(zhuǎn)載本文請聯(lián)系浪尖聊大數(shù)據(jù)公眾號。

網(wǎng)頁題目：漫畫講解Kafka高效的存儲設(shè)計
網(wǎng)站URL：http://uogjgqi.cn/article/djscosj.html