一、 環境介紹
模擬環境使用三臺rhel5.8 32bit,各自IP和主機名如下:
- IP 主機名
- 192.168.88.253 none.mos.com
- 192.168.88.129 lab1.mos.com
- 192.168.88.130 lab2.mos.com
其中
- none.mos.com負責任務管理和數據名稱節點,在生產環境中,建議將此兩項分開;
- lab1.mos.com為第二名稱節點,其并不提供名稱節點的功能,但默認情況下,負責周期性的將編輯日志合并至名稱節點,并自己也保存一份,其提供了名稱節點的冗余,但其數據依然落后于名稱節點;
- lab3.mos.com為實際數據存儲節點和任務執行節點。
使用的軟件版本及下載地址:
- JDK: jdk-7u5-linux-i586.rpm
- 下載地址: http://www.oracle.com/technetwork/java/javase/downloads/java-archive-downloads-javase7-521261.html
- Hadoop: hadoop-0.20.2-cdh3u5.tar.gz
- 下載地址: http://hadoop.apache.org/releases.html
二、 準備工作
2.1 修改每個主機的/etc/hosts文件如下:
- 192.168.88.253 none.mos.com none
- 192.168.88.129 lab1.mos.com lab1
- 192.168.88.130 lab2.mos.com lab2
2.2 在集群的每個節點建立用于運行hadoop的用戶及設定密碼
- # useradd hduser && echo "redhat" | passwd --stdin hduser
2.3 為master節點的hduser用戶能夠管理并監控其他節點,在none節點做如下操作。
- # su – hduser
- $ ssh-keygen -t rsa -P ''
- $ ssh-copy-id -i .ssh/id_rsa.pub hduser@lab1
- $ ssh-copy-id -i .ssh/id_rsa.pub hduser@lab2
2.4 確保每個節點時間的一致性,并清空iptables和關閉selinux,此處操作略
三、 配置hadoop運行所需的java環境,此操作需在每個節點執行一遍。
3.1 安裝jdk
- # rpm -ivh ~/root/Download/jdk-7u5-linux-i586.rpm
3.2 配置java環境變量
- # vim /etc/profile.d/java.sh
- JAVA_HOME=/usr/java/latest
- PATH=$JAVA_HOME/bin:$PATH
- export JAVA_HOME PATH
3.3 使剛才配置的環境其生效(或重新登陸控制臺亦可)
- # source /etc/profile.d/java.sh
3.4 測試java環境是否OK
- # su – hduser
- $ java –version
- java version "1.7.0_05"
- Java(TM) SE Runtime Environment (build 1.7.0_05-b05)
- Java HotSpot(TM) Server VM (build 23.1-b03, mixed mode)
四、 安裝Hadoop,此步驟操作略長,但也需在每個節點執行。
4.1 解壓至/usr/local目錄,并做軟件鏈接使其易于訪問
- # tar xf ~/Download/hadoop-0.20.2-cdh3u5.tar.gz –C /usr/local/
- # ln -sv /usr/local/hadoop-0.20.2-cdh3u5 /usr/local/hadoop
4.2 修改hadoop目錄的屬主屬組,并配置hadoop環境變量
- # chown -R hduser. /usr/local/hadoop-0.20.2-cdh3u5
- # vim /etc/profile.d/hadoop.sh
- HADOOP_HOME=/usr/local/hadoop
- PATH=$HADOOP_HOME/bin:$PATH
- export HADOOP_HOME PATH
4.3 使hadoop環境變量生效并使用hduser測試其是否就緒
- # source /etc/profile.d/hadoop.sh
- # su – hduser
- $ hadoop version
- Subversion git://ubuntu-slave02/var/lib/jenkins/workspace/CDH3u5-Full-RC/build/cdh3/hadoop20/0.20.2-cdh3u5/source -r 30233064aaf5f2492bc687d61d72956876102109
- Compiled by jenkins on Fri Oct 5 17:21:34 PDT 2012
- From source with checksum de1770d69aa93107a133657faa8ef467
五、 配置Hadoop,集群中每個節點只能通過配置文件來得知自身的角色,因此,以下配置需在每個節點都做同樣修改。
5.1 定義第二名稱節點的主機名或IP地址
- # echo ‘lab1.mos.com’ > /usr/local/hadoop/conf/masters
5.2 定義數據節點和任務執行節點,筆者這里只有一個,而生成環境中,數據節點一般最少3個以上。
- # echo ‘lab2.mos.com’ > /usr/local/hadoop/conf/slaves
5.3 定義系統級別的參數如下:
- # vim /usr/local/hadoop/conf/core-site.xml
- <?xml version="1.0"?>
- <?xml-stylesheet type="text/xsl" href="configuration.xsl"?>
- <!-- Put site-specific property overrides in this file. -->
- <configuration>
- <!-- 定義hadoop的分布式文件系統hdfs的名稱節點。-->
- <property>
- <name>fs.default.name</name>
- <value>hdfs://none.mos.com:8020</value>
- </property>
- <!--定義臨時文件的位置,需確保此目錄存在,且hadoop的執行用戶hduser對其有足夠的權限. -->
- <property>
- <name>hadoop.tmp.dir</name>
- <value>/hadoop/temp</value>
- </property>
- <!--定義回收站,可不定義,設置在hdfs中刪除的文件先放在回收站內,超時才會被刪除,時間單位為分鐘,筆者此處定義為100小時。-->
- <property>
- <name>fs.trash.interval</name>
- <value>6000</value>
- </property>
- </configuration>
5.4 定義任務管理管理節點
- # vim /usr/local/hadoop/conf/mapred-site.xml
- <?xml version="1.0"?>
- <?xml-stylesheet type="text/xsl" href="configuration.xsl"?>
- <!-- Put site-specific property overrides in this file. -->
- <configuration>
- <property>
- <name>mapred.job.tracker</name>
- <value>none.mos.com:8021</value>
- </property>
- </configuration>
5.5 定義hadoop的分布式文件系統相關屬性
- # vim /usr/local/hadoop/conf/hdfs-site.xml
- <?xml version="1.0"?>
- <?xml-stylesheet type="text/xsl" href="configuration.xsl"?>
- <!-- Put site-specific property overrides in this file. -->
- <configuration>
- <!-- 為了保證數據的冗余,定義切割后的數據塊在幾個節點上存儲,生產環境中,建議最少3份以上,筆者這里就一個數據節點,因此,此處為1即可-->
- <property>
- <name>dfs.replication</name>
- <value>1</value>
- </property>
- <!-- 數據名稱節點用于存儲HDFS文件數據塊的本地目錄,存儲多份時,可寫多個路徑,以逗號隔開即可-->
- <property>
- <name>dfs.data.dir</name>
- <value>/hadoop/data</value>
- <final>ture</final>
- </property>
- <!-- 數據節點用于存儲名稱空間和事務日志的本地文件系統路徑,存儲多份時,可寫多個路徑,以逗號隔開即可 -->
- <property>
- <name>dfs.name.dir</name>
- <value>/hadoop/name</value>
- <final>ture</final>
- </property>
- <!-- 用于定義HDFS元數據冗余的復制到這個目錄 -->
- <property>
- <name>fs.checkpoint.dir</name>
- <value>/hadoop/namesecondary</value>
- <final>ture</final>
- </property>
- </configuration>
5.6 創建hadoop配置中定義的目錄,且給予相應的權限
- # mkdir -pv /hadoop/temp && chown -R hduser. /hadoop
六、 格式化hadoop的分布式文件系統(HDFS),并檢測hadoop是否就緒。
6.1 以hduser的身份格式,切記一定要將第五步的操作在三個節點全部完成
- # su - hduser
- $ hadoop namenode –format
- 出現“Storage directory /hadoop/temp/dfs/name has been successfully formatted”此行,才表示格式化成功,否則需檢查是否配置出錯。
6.2 以hduser的身份啟動hadoop
- $ start-all.sh
6.3 使用jps在每個節點,檢查是否啟動正常.
七、 使用hadoop提供的字符統計應用程序算法樣例做簡單的計算實現
7.1 在hadoop的分布式文件系統(hdfs)中創建目錄,并上傳要計算的文件
- $ hadoop fs -mkdir mos-test
- $ hadoop fs -put /etc/services mos-test
7.2 調用hadoop提供的字符統計程序,計算上傳的services文件的每個字符個數,并輸出到hdfs的test-out目錄中,此目錄hadoop會自行創建。
- $ hadoop jar /usr/local/hadoop/hadoop-examples-0.20.2-cdh3u5.jar wordcount mos-test test-out
7.3 等命令執行完成后,下載執行結果到本地當前目錄,并查看相關內容
- $ hadoop fs -get ./test-out/part-r-00000 ./
- $ head part-r-00000
7.4 也可不用下載直接查看HDFS的文件或目錄
- $ hadoop fs –ls / #查看hdfs的根位置
- $ hadoop fs –cat /user/hduser/test-out/part-r-00000 #不下載直接查看計算結果
- Ps: hadoop fs命令的相關用法,可通過:hadoop fs --help獲得
到此為止,一個簡單的分布式hadoop并行運算集群已經已然完成,哈哈,是不是很簡單,但是需要說明的是,各位其實也看到了,并且想必各位也充滿了各種 疑惑:這些命名神馬的怎么這么奇怪?hdfs是怎么工作的?數據怎么分開存儲的?數據怎么在被切開存儲后還能計算?各個節點的高可用怎么實現?如果需要更 為復雜的運算怎么處理等等?相關內容,筆者也在慢慢的整理和學習,敬請關注哈。
補充一點相關知識:
當hadoop正常啟動后,不同的節點,會開放不同的幾個端口,可以直接通過web頁面查看其相關信息的端口,實際上,開放的端口 遠不止這些,(詳情可以通過 netstat -tnlp|grep java)查看, 但是只有這些可以通過web直接打開查看。具體如下:
- 端口 工作節點 本此實驗的web查方式
- 0.0.0.0:50030 任務管理節點(JobTracker) 192.168.88.253:5030
- 0.0.0.0:50070 HDFS的數據名稱節點(NameNode) 192.168.88.253:5070
- 0.0.0.0:50090 第二數據名稱節點(SecondaryNameNode) 192.168.88.129:50090
- 0.0.0.0:50060 任務執行節點(TaskTracker) 192.168.88.130:5060
- 0.0.0.0:50075 數據節點(DataNode) 192.168.88.130:5075
下圖是之前執行計算時筆者的截圖: