Hadoop到目前為止發(fā)展已經有10余年，版本經過無數(shù)次的更新迭代，目前業(yè)內大家把Hadoop大的版本分為Hadoop1.0、Hadoop2.0、Hadoop3.0 三個版本。

一、Hadoop 簡介

Hadoop版本剛出來的時候是為了解決兩個問題：一是海量數(shù)據(jù)如何存儲的問題，一個是海量數(shù)據(jù)如何計算的問題。Hadoop的核心設計就是HDFS和 Mapreduce.HDFS解決了海量數(shù)據(jù)如何存儲的問題， Mapreduce解決了海量數(shù)據(jù)如何計算的問題。HDFS的全稱：Hadoop Distributed File System。

二、分布式文件系統(tǒng)

圖片 HDFS其實就可以理解為一個分布式文件系統(tǒng)，可以看如圖1所示有4個服務器是不是都有他自己的文件系統(tǒng)都可以進行存儲數(shù)據(jù)，假設每個服務器的存儲空間存儲10G的數(shù)據(jù)。假設數(shù)據(jù)量很小的時候存儲10G的數(shù)據(jù)還是ok的當數(shù)據(jù)量大于服務器的存儲空間時是不是單個服務器就沒法存儲了。 我們是不是可以在服務器中部署一個Hadoop這樣就能構建出一個集群（超級大電腦）。這樣就存儲 4*10=40G的數(shù)據(jù)量，這樣我們面向用戶時是不是只有一臺超級大的電腦相當于一個分布式文件系統(tǒng)。

HDFS是一個主從的架構、主節(jié)點只有一個NemeNode。從節(jié)點有多個DataNode。

三、HDFS 架構

圖片 假設我們這里有5臺服務器每臺服務器都部署上Hadoop，我們隨便選擇一臺服務器部署上NameNode剩下服務器部署上DataNode。

客戶端上傳文件時假設文件大小為129MHDFS默認切分的大小為128M這時就會產生出2個blkNameNode去通知DataNode上傳文件（這里有一定的策略），我們就假設就將這幾個文件分別存儲在4個服務器上。為什們要進行分別存儲在，假設DataNode服務器有一天突然掛掉了我們是不是還可通過DataNode4或2和3進行讀取數(shù)據(jù)，這樣是不是就防止數(shù)據(jù)丟失。

NameNode

管理元數(shù)據(jù)信息（文件目錄樹）：文件與Block塊，Block塊與DataNode主機關系 NameNode為快速響應用戶操作，所以把元數(shù)據(jù)信息加載到內存里

DataNode

存儲數(shù)據(jù)，把上傳的數(shù)據(jù)劃分固定大小文件塊（Block）在Hadoop2.73之前是64M之后改為了128M 為了保證數(shù)據(jù)安全，每個文件默認都是三個副本

SecondaryNamenode

周期性的到NameNode節(jié)點拉取Edtis和fsimage文件，將這兩個文件加入到內存進行 然后將這兩個文件加入到內存中進行合并產生新的fsimage發(fā)送給NameNode。

四、HDFS寫入數(shù)據(jù)流程

客戶端會帶著文件路徑向NameNode發(fā)送寫入請求通過 RPC 與 NameNode 建立通訊， NameNode 檢查目標文件，返回是否可以上傳; Client 請求第一個 block 該傳輸?shù)侥男?DataNode 服務器上; NameNode 根據(jù)副本數(shù)量和副本放置策略進行節(jié)點分配，返回DataNode節(jié)點，如：A，B，C Client 請求A節(jié)點建立pipeline管道，A收到請求會繼續(xù)調用B，然后B調用C，將整個pipeline管道建立完成后，逐級返回消息到Client; Client收到A返回的消息之后開始往A上傳第一個block塊，block塊被切分成64K的packet包不斷的在pepiline管道里傳遞，從A到B，B到C進行復制存儲 當一個 block塊 傳輸完成之后，Client 再次請求 NameNode 上傳第二個block塊的存儲節(jié)點，不斷往復存儲 當所有block塊傳輸完成之后，Client調用FSDataOutputSteam的close方法關閉輸出流，最后調用FileSystem的complete方法告知NameNode數(shù)據(jù)寫入成功

五、HDFS讀取數(shù)據(jù)流程

客戶端會先帶著讀取路徑向NameNode發(fā)送讀取請求，通過 RPC 與 NameNode 建立通訊，NameNode檢查目標文件，來確定請求文件 block塊的位置信息 NameNode會視情況返回文件的部分或者全部block塊列表，對于每個block塊，NameNode 都會返回含有該 block副本的 DataNode 地址 這些返回的 DataNode 地址，會按照集群拓撲結構得出 DataNode 與客戶端的距離，然后進行排序，排序兩個規(guī)則：網絡拓撲結構中距離 Client 近的排靠前;心跳機制中超時匯報的 DN 狀態(tài)為 STALE，這樣的排靠后; Client 選取排序靠前的 DataNode 調用FSDataInputSteam的read方法來讀取 block塊數(shù)據(jù)，如果客戶端本身就是DataNode，那么將從本地直接獲取block塊數(shù)據(jù) 當讀完一批的 block塊后，若文件讀取還沒有結束，客戶端會繼續(xù)向NameNode 獲取下一批的 block 列表，繼續(xù)讀取 所有block塊讀取完成后，Client調用FSDataInputStream.close（）方法，關閉輸入流，并將讀取來所有的 block塊合并成一個完整的最終文件

六、HDFS缺陷

注意：早期版本

單點問題 內存受限

總結

上述給大家講解了簡單的HDFS架構，我在最后面留了一個小問題，我會在下期通過畫圖的方式給大家講解，我在這里為大家提供大數(shù)據(jù)的資料需要的朋友可以去下面GitHub去下載，信自己，努力和汗水總會能得到回報的。
責任編輯：YYX