1. 程式人生 > >理解HDFS的架構和原理

理解HDFS的架構和原理

這裡寫圖片描述

(一) HDFS主要是用於做什麼的? 

  1. HDFS(Hadoop Distributed File System)是Hadoop專案的核心子專案,是分散式計算中資料儲存管理的基礎,是基於流資料模式訪問和處理超大檔案的需求而開發的,可以運行於廉價的商用伺服器上。它所具有的高容錯、高可靠性、高可擴充套件性、高獲得性、高吞吐率等特徵為海量資料提供了不怕故障的儲存,為超大資料集(Large Data Set)的應用處理帶來了很多便利。

(二) HDFS的優缺點比較  HDFS 的優點:

1、高容錯性

1)資料自動儲存多個副本。它通過增加副本的形式,提高容錯性 2)某一個副本丟失以後,它可以自動恢復,這是由 HDFS 內部機制實現的,我們不必關心。

2、適合批處理

1)它是通過移動計算而不是移動資料 2)它會把資料位置暴露給計算框架。

3、適合大資料處理

1)處理資料達到 GB、TB、甚至PB級別的資料。

2)能夠處理百萬規模以上的檔案數量,數量相當之大。 3)能夠處理10K節點的規模

4、流式檔案訪問 1)一次寫入,多次讀取。檔案一旦寫入不能修改,只能追加。 2)它能保證資料的一致性。

5、可構建在廉價機器上 1)它通過多副本機制,提高可靠性。

2)它提供了容錯和恢復機制。比如某一個副本丟失,可以通過其它副本來恢復。  HDFS 缺點(不適用適用HDFS的場景):  1、低延時資料訪問  1)比如毫秒級的來儲存資料,這是不行的,它做不到。 2)它適合高吞吐率的場景,就是在某一時間內寫入大量的資料。但是它在低延時的情況下是不行的,比如毫秒級以內讀取資料,這樣它是很難做到的。

2、小檔案儲存  1)儲存大量小檔案的話,它會佔用 NameNode大量的記憶體來儲存檔案、目錄和塊資訊。這樣是不可取的,因為NameNode的記憶體總是有限的。 2)小檔案儲存的尋道時間會超過讀取時間,它違反了HDFS的設計目標。

3、併發寫入、檔案隨機修改

1)一個檔案只能有一個寫,不允許多個執行緒同時寫。  2)僅支援資料 append(追加),不支援檔案的隨機修改。

(三)HDFS 如何儲存資料?  HDFS儲存資料架構圖: 

這裡寫圖片描述

      HDFS 採用Master/Slave的架構來儲存資料,這種架構主要由四個部分組成,分別為HDFS Client、NameNode、DataNode和Secondary NameNode。下面我們分別介紹這四個組成部分。

Client:就是客戶端。

       1、檔案切分。檔案上傳 HDFS 的時候,Client 將檔案切分成 一個一個的Block,然後進行儲存。

       2、與 NameNode 互動,獲取檔案的位置資訊。

      3、與 DataNode 互動,讀取或者寫入資料。

       4、Client 提供一些命令來管理 HDFS,比如啟動或者關閉HDFS。

       5、Client 可以通過一些命令來訪問 HDFS。

NameNode:就是 master,它是一個主管、管理者。

      1、管理 HDFS 的名稱空間。

       2、管理資料塊(Block)對映資訊

       3、配置副本策略

      4、處理客戶端讀寫請求。

DataNode:就是Slave。NameNode 下達命令,DataNode 執行實際的操作。

       1、儲存實際的資料塊。

       2、執行資料塊的讀/寫操作。

Secondary NameNode:並非 NameNode 的熱備。當NameNode 掛掉的時候,它並不能馬上替換 NameNode 並提供服務。

       1、輔助 NameNode,分擔其工作量。

      2、定期合併 fsimage和fsedits,並推送給NameNode。

       3、在緊急情況下,可輔助恢復 NameNode。

(四) HDFS 如何讀取檔案?  HDFS 讀取檔案步驟圖: 

這裡寫圖片描述

HDFS的檔案讀取原理,詳細解析如下:

     1、首先呼叫FileSystem物件的open方法,其實獲取的是一個DistributedFileSystem的例項。

         2、DistributedFileSystem通過RPC(遠端過程呼叫)獲得檔案的第一批block的locations,同一block按照重複數會返回多個locations,這些locations按照Hadoop拓撲結構排序,距離客戶端近的排在前面。

     3、前兩步會返回一個FSDataInputStream物件,該物件會被封裝成 DFSInputStream物件,DFSInputStream可以方便的管理datanode和namenode資料流。客戶端呼叫read方 法,DFSInputStream就會找出離客戶端最近的datanode並連線datanode。

           4、資料從datanode源源不斷的流向客戶端。

          5、如果第一個block塊的資料讀完了,就會關閉指向第一個block塊的datanode連線,接著讀取下一個block塊。這些操作對客戶端來說是透明的,從客戶端的角度來看只是讀一個持續不斷的流。

         6、如果第一批block都讀完了,DFSInputStream就會去namenode拿下一批blocks的location,然後繼續讀,如果所有的block塊都讀完,這時就會關閉掉所有的流。  (五) HDFS 如何寫入檔案?  HDFS的檔案寫入步驟圖: 

這裡寫圖片描述

HDFS的檔案寫入原理詳細步驟解析:

      1.客戶端通過呼叫 DistributedFileSystem 的create方法,建立一個新的檔案。

      2.DistributedFileSystem 通過 RPC(遠端過程呼叫)呼叫 NameNode,去建立一個沒有blocks關聯的新檔案。建立前,NameNode 會做各種校驗,比如檔案是否存在,客戶端有無許可權去建立等。如果校驗通過,NameNode 就會記錄下新檔案,否則就會丟擲IO異常。

      3.前兩步結束後會返回 FSDataOutputStream 的物件,和讀檔案的時候相似,FSDataOutputStream 被封裝成 DFSOutputStream,DFSOutputStream 可以協調 NameNode和 DataNode。客戶端開始寫資料到DFSOutputStream,DFSOutputStream會把資料切成一個個小packet,然後排成佇列 data queue。

      4.DataStreamer 會去處理接受 data queue,它先問詢 NameNode 這個新的 block 最適合儲存的在哪幾個DataNode裡,比如重複數是3,那麼就找到3個最適合的 DataNode,把它們排成一個 pipeline。DataStreamer 把 packet 按佇列輸出到管道的第一個 DataNode 中,第一個 DataNode又把 packet 輸出到第二個 DataNode 中,以此類推。

      5.DFSOutputStream 還有一個佇列叫 ack queue,也是由 packet 組成,等待DataNode的收到響應,當pipeline中的所有DataNode都表示已經收到的時候,這時akc queue才會把對應的packet包移除掉。

      6.客戶端完成寫資料後,呼叫close方法關閉寫入流。

      7.DataStreamer 把剩餘的包都刷到 pipeline 裡,然後等待 ack 資訊,收到最後一個 ack 後,通知 DataNode 把檔案標示為已完成。