在做一個關于資料庫的PPT時,畫了一個圖,群裡的哥們提出HBase不應該畫在key-value這一類中,搜尋了相關資料,将它分到列式存儲中。下面是搜到的一篇不錯的文章,和大家分享下。
一、Hbase簡介
started by chad walters and jim
2006.11 G release paper on BigTable
2007.2 inital Hbase prototype created as Hadoop contrib
2007.10 First useable Hbase
2008.1 Hadoop become Apache top-level project and Hbase becomes subproject
2008.10 Hbase 0.18,0.19 released
Hbase是bigtable的開源山寨版本。是建立的hdfs之上,提供高可靠性、高性能、列存儲、可伸縮、實時讀寫的資料庫系統。
它介于nosql和RDBMS之間,僅能通過主鍵(row key)和主鍵的range來檢索資料,僅支援單行事務(可通過hive支援來實作多表join等複雜操作)。主要用來存儲非結構化和半結構化的松散資料。
與hadoop一樣,Hbase目标主要依靠橫向擴充,通過不斷增加廉價的商用伺服器,來增加計算和存儲能力。
Hbase中的表一般有這樣的特點:
1 大:一個表可以有上億行,上百萬列
2 面向列:面向列(族)的存儲和權限控制,列(族)獨立檢索。
3 稀疏:對于為空(null)的列,并不占用存儲空間,是以,表可以設計的非常稀疏。
下面一幅圖是Hbase在Hadoop Ecosystem中的位置。
二、邏輯視圖
Hbase以表的形式存儲資料。表有行和列組成。列劃分為若幹個列族(row family)
Row Key
與nosql資料庫們一樣,row key是用來檢索記錄的主鍵。通路Hbase table中的行,隻有三種方式:
1 通過單個row key通路
2 通過row key的range
3 全表掃描
Row key行鍵 (Row key)可以是任意字元串(最大長度是 64KB,實際應用中長度一般為 10-100bytes),在Hbase内部,row key儲存為位元組數組。
存儲時,資料按照Row key的字典序(byte order)排序存儲。設計key時,要充分排序存儲這個特性,将經常一起讀取的行存儲放到一起。(位置相關性)
注意:
字典序對int排序的結果是1,10,100,11,12,13,14,15,16,17,18,19,2,20,21,…,9,91,92,93,94,95,96,97,98,99。要保持×××的自然序,行鍵必須用0作左填充。
行的一次讀寫是原子操作 (不論一次讀寫多少列)。這個設計決策能夠使使用者很容易的了解程式在對同一個行進行并發更新操作時的行為。
列族
Hbase表中的每個列,都歸屬與某個列族。列族是表的chema的一部分(而列不是),必須在使用表之前定義。列名都以列族作為字首。例如courses:history,courses:math
都屬于courses 這個列族。
通路控制、磁盤和記憶體的使用統計都是在列族層面進行的。實際應用中,列族上的控制權限能幫助我們管理不同類型的應用:我們允許一些應用可以添加新的基本資料、一些應用可以讀取基本資料并建立繼承的列族、一些應用則隻允許浏覽資料(甚至可能因為隐私的原因不能浏覽所有資料)。
時間戳
Hbase中通過row和columns确定的為一個存貯單元稱為cell。每個 cell都儲存着同一份資料的多個版本。版本通過時間戳來索引。時間戳的類型是 64位整型。時間戳可以由Hbase(在資料寫入時自動 )指派,此時時間戳是精确到毫秒的目前系統時間。時間戳也可以由客戶顯式指派。如果應用程式要避免資料版本沖突,就必須自己生成具有唯一性的時間戳。每個 cell中,不同版本的資料按照時間倒序排序,即最新的資料排在最前面。
為了避免資料存在過多版本造成的的管理 (包括存貯和索引)負擔,Hbase提供了兩種資料版本回收方式。一是儲存資料的最後n個版本,二是儲存最近一段時間内的版本(比如最近七天)。使用者可以針對每個列族進行設定。
Cell
由{row key, column(= + ), version} 唯一确定的單元。cell中的資料是沒有類型的,全部是位元組碼形式存貯。
三、實體存儲
1 已經提到過,Table中的所有行都按照row key的字典序排列。
2 Table 在行的方向上分割為多個Hregion。
3 region按大小分割的,每個表一開始隻有一個region,随着資料不斷插入表,region不斷增大,當增大到一個閥值的時候,Hregion就會等分會兩個新的Hregion。當table中的行不斷增多,就會有越來越多的Hregion。
4 HRegion是Hbase中分布式存儲和負載均衡的最小單元。最小單元就表示不同的Hregion可以分布在不同的HRegion server上。但一個Hregion是不會拆分到多個server上的。
5 HRegion雖然是分布式存儲的最小單元,但并不是存儲的最小單元。
事實上,HRegion由一個或者多個Store組成,每個store儲存一個columns family。
每個Strore又由一個memStore和0至多個StoreFile組成。如圖:
StoreFile以HFile格式儲存在HDFS上。
HFile的格式為:
HFile分為六個部分:
Data Block 段–儲存表中的資料,這部分可以被壓縮
Meta Block 段 (可選的)–儲存使用者自定義的kv對,可以被壓縮。
File Info 段–Hfile的元資訊,不被壓縮,使用者也可以在這一部分添加自己的元資訊。
Data Block Index 段–Data Block的索引。每條索引的key是被索引的block的第一條記錄的key。
Meta Block Index段 (可選的)–Meta Block的索引。
Trailer–這一段是定長的。儲存了每一段的偏移量,讀取一個HFile時,會首先讀取Trailer,Trailer儲存了每個段的起始位置(段的Magic Number用來做安全check),然後,DataBlock Index會被讀取到記憶體中,這樣,當檢索某個key時,不需要掃描整個HFile,而隻需從記憶體中找到key所在的block,通過一次磁盤io将整個block讀取到記憶體中,再找到需要的key。DataBlock Index采用LRU機制淘汰。
HFile的Data Block,Meta Block通常采用壓縮方式存儲,壓縮之後可以大大減少網絡IO和磁盤IO,随之而來的開銷當然是需要花費cpu進行壓縮和解壓縮。
目标Hfile的壓縮支援兩種方式:Gzip,Lzo。
HLog(WAL log)
WAL 意為Write ahead log(http://en.wikipedia.org/wiki/Write-ahead_logging),類似mysql中的binlog,用來做災難恢複隻用,Hlog記錄資料的所有變更,一旦資料修改,就可以從log中進行恢複。
每個Region Server維護一個Hlog,而不是每個Region一個。這樣不同region(來自不同table)的日志會混在一起,這樣做的目的是不斷追加單個檔案相對于同時寫多個檔案而言,可以減少磁盤尋址次數,是以可以提高對table的寫性能。帶來的麻煩是,如果一台region server下線,為了恢複其上的region,需要将region server上的log進行拆分,然後分發到其它region server上進行恢複。
HLog檔案就是一個普通的Hadoop Sequence File,Sequence File 的Key是HLogKey對象,HLogKey中記錄了寫入資料的歸屬資訊,除了table和region名字外,同時還包括 sequence number和timestamp,timestamp是”寫入時間”,sequence number的起始值為0,或者是最近一次存入檔案系統中sequence number。HLog Sequece File的Value是Hbase的KeyValue對象,即對應HFile中的KeyValue,可參見上文描述。
四、系統架構
Client
1 包含通路Hbase的接口,client維護着一些cache來加快對Hbase的通路,比如regione的位置資訊。
Zookeeper
1 保證任何時候,叢集中隻有一個master
2 存貯所有Region的尋址入口。
3 實時監控Region Server的狀态,将Region server的上線和下線資訊實時通知給Master
4 存儲Hbase的schema,包括有哪些table,每個table有哪些column family
Master
1 為Region server配置設定region
2 負責region server的負載均衡
3 發現失效的region server并重新配置設定其上的region
4 GFS上的垃圾檔案回收
5 處理schema更新請求
Region Server
1 Region server維護Master配置設定給它的region,處理對這些region的IO請求
2 Region server負責切分在運作過程中變得過大的region
可以看到,client通路Hbase上資料的過程并不需要master參與(尋址通路zookeeper和region server,資料讀寫通路regione server),master僅僅維護者table和region的中繼資料資訊,負載很低。
五、關鍵算法/流程
region定位
系統如何找到某個row key (或者某個 row key range)所在的region
bigtable 使用三層類似B+樹的結構來儲存region位置。
第一層是儲存zookeeper裡面的檔案,它持有root region的位置。
第二層root region是.META.表的第一個region其中儲存了.META.z表其它region的位置。通過root region,我們就可以通路.META.表的資料。
.META.是第三層,它是一個特殊的表,儲存了Hbase中所有資料表的region 位置資訊。
說明:
1 root region永遠不會被split,保證了最需要三次跳轉,就能定位到任意region 。
2.META.表每行儲存一個region的位置資訊,row key 采用表名+表的最後一樣編碼而成。
3 為了加快通路,.META.表的全部region都儲存在記憶體中。
假設,.META.表的一行在記憶體中大約占用1KB。并且每個region限制為128MB。
那麼上面的三層結構可以儲存的region數目為:
(128MB/1KB) * (128MB/1KB) = = 2(34)個region
4 client會将查詢過的位置資訊儲存緩存起來,緩存不會主動失效,是以如果client上的緩存全部失效,則需要進行6次網絡來回,才能定位到正确的region(其中三次用來發現緩存失效,另外三次用來擷取位置資訊)。
讀寫過程
上文提到,Hbase使用MemStore和StoreFile存儲對表的更新。
資料在更新時首先寫入Log(WAL log)和記憶體(MemStore)中,MemStore中的資料是排序的,當MemStore累計到一定門檻值時,就會建立一個新的MemStore,并且将老的MemStore添加到flush隊列,由單獨的線程flush到磁盤上,成為一個StoreFile。于此同時,系統會在zookeeper中記錄一個redo point,表示這個時刻之前的變更已經持久化了。(minor compact)
當系統出現意外時,可能導緻記憶體(MemStore)中的資料丢失,此時使用Log(WAL log)來恢複checkpoint之後的資料。
前面提到過StoreFile是隻讀的,一旦建立後就不可以再修改。是以Hbase的更新其實是不斷追加的操作。當一個Store中的StoreFile達到一定的門檻值後,就會進行一次合并(major compact),将對同一個key的修改合并到一起,形成一個大的StoreFile,當StoreFile的大小達到一定門檻值後,又會對StoreFile進行split,等分為兩個StoreFile。
由于對表的更新是不斷追加的,處理讀請求時,需要通路Store中全部的StoreFile和MemStore,将他們的按照row key進行合并,由于StoreFile和MemStore都是經過排序的,并且StoreFile帶有記憶體中索引,合并的過程還是比較快。
寫請求處理過程
1 client向region server送出寫請求
2 region server找到目标region
3 region檢查資料是否與schema一緻
4 如果用戶端沒有指定版本,則擷取目前系統時間作為資料版本
5 将更新寫入WAL log
6 将更新寫入Memstore
7 判斷Memstore的是否需要flush為Store檔案。
region配置設定
任何時刻,一個region隻能配置設定給一個region server。master記錄了目前有哪些可用的region server。以及目前哪些region配置設定給了哪些region server,哪些region還沒有配置設定。當存在未配置設定的region,并且有一個region server上有可用空間時,master就給這個region server發送一個裝載請求,把region配置設定給這個region server。region server得到請求後,就開始對此region提供服務。
region server上線
master使用zookeeper來跟蹤region server狀态。當某個region server啟動時,會首先在zookeeper上的server目錄下建立代表自己的檔案,并獲得該檔案的獨占鎖。由于master訂閱了server目錄上的變更消息,當server目錄下的檔案出現新增或删除操作時,master可以得到來自zookeeper的實時通知。是以一旦region server上線,master能馬上得到消息。
region server下線
當region server下線時,它和zookeeper的會話斷開,zookeeper而自動釋放代表這台server的檔案上的獨占鎖。而master不斷輪詢server目錄下檔案的鎖狀态。如果master發現某個region server丢失了它自己的獨占鎖,(或者master連續幾次和region server通信都無法成功),master就是嘗試去擷取代表這個region server的讀寫鎖,一旦擷取成功,就可以确定:
1 region server和zookeeper之間的網絡斷開了。
2 region server挂了。
的其中一種情況發生了,無論哪種情況,region server都無法繼續為它的region提供服務了,此時master會删除server目錄下代表這台region server的檔案,并将這台region server的region配置設定給其它還活着的同志。
如果網絡短暫出現問題導緻region server丢失了它的鎖,那麼region server重新連接配接到zookeeper之後,隻要代表它的檔案還在,它就會不斷嘗試擷取這個檔案上的鎖,一旦擷取到了,就可以繼續提供服務。
master上線
master啟動進行以下步驟:
1 從zookeeper上擷取唯一一個代碼master的鎖,用來阻止其它master成為master。
2 掃描zookeeper上的server目錄,獲得目前可用的region server清單。
3 和2中的每個region server通信,獲得目前已配置設定的region和region server的對應關系。
4 掃描.META.region的集合,計算得到目前還未配置設定的region,将他們放入待配置設定region清單。
master下線
由于master隻維護表和region的中繼資料,而不參與表資料IO的過程,master下線僅導緻所有中繼資料的修改被當機(無法建立删除表,無法修改表的schema,無法進行region的負載均衡,無法處理region上下線,無法進行region的合并,唯一例外的是region的split可以正常進行,因為隻有region server參與),表的資料讀寫還可以正常進行。是以master下線短時間内對整個Hbase叢集沒有影響。從上線過程可以看到,master儲存的資訊全是可以備援資訊(都可以從系統其它地方收集到或者計算出來),是以,一般Hbase叢集中總是有一個master在提供服務,還有一個以上的"master"在等待時機搶占它的位置。
六、通路接口
Hbase Shell
Java clietn API
Hbase non-java access
languages talking to the JVM
Jython interface to Hbase
Groovy DSL for Hbase
Scala interface to Hbase
languages with a custom protocol
REST gateway specification for Hbase
充分利用HTTP協定:GET POST PUT DELET
text/plain
text/xml
application/json
application/x-protobuf
Thrift gateway specification for Hbase
java
cpp
rb
py
perl
php
Hbase Map Reduce
Hive/Pig
七、結語:
全文對Hbase做了簡單的介紹,有錯誤之處,敬請指正。未來将結合Hbase在淘寶資料平台的應用場景,在更多細節上進行深入。
參考文檔
Bigtable: A Distributed Storage System for Structured Data
HFile: A Block-Indexed File Format to Store Sorted Key-Value Pairs for a thorough introduction Hbase Architecture 101
Hbase source code
轉自--http://tech.hexun.com/2011-10-17/134285153.html