Hadoop集群的搭建

搭建6个节点的Hadoop集群

节点

在实验室192.168.100.20:8006，用户名：root，密码：**，申请了6个节点，分别是：

192.168.101.44  #主节点
192.168.101.45  #节点1
192.168.101.46  #节点2
192.168.101.47  #节点3
192.168.101.48  #节点4
192.168.101.49  #节点4

1
2
3
4
5
6
1
2
3
4
5
6

网络基本配置

255.255.254.0    #子网掩码
192.168.100.1    #网关
233.6.6.6        #使用阿里的DNS或者233.8.8.8

1
2
3
1
2
3

各个节点的初始用户名均是：zhujunpeng，密码均是：***，在配置Hadoop集群时，新创建了Hadoop用户，下面会讲这个过程。

安装操作系统

安装操作系统（centos 7）中注意三点：
请安装Development版本的操作系统，我安装的是Centos 7的Development版本。
请使用固定ip地址，因为整个集群将使用网络进行通讯，ip地址是他们进行通讯的关键。
在配置网络的过程中采用的是 muanul（手动设置），不要使用动态分配，这样不利用集群节点之间的通信

工具介绍

在整个操作的过程中未了方便，我将使用两种工具：
SecureCRT，该工具能够方便的与Linux系统进行交互，不用每次都在不同的虚拟机界面下切换，方便管理，如果没有呀用过该工具，请自行谷歌安装并学会使用，该工具需要破解，网上有很多破解的教程。
WinSCP，这是一个FTP工具，用于不通操作系统时间的文件传输，当然在我的应用中只涉及到了Windows向Centos系统传输已经下载好的hadoop安装包和JDK，传输速度快。

创建hadoop用户

如果你安装hadoop时不是采用“hadoop”用户，那么需要增加一个名为hadoop的用户（安装集群时形成习惯，每个集群都是用自己的用户名和密码，方便管理），密码也为hadoop，首先打开终端，在终端中输入：

su  #切换成root用户登录

1
1

输入密码之后，进入root权限，接着在终端中输入：

useradd -m hadoop -G root -s /bin/bash  #创建用户hadoop，使用/bin/bash作为shell

1
1

接着使用下面的命令修改密码，提示输入两次密码，可简单的设为“hadoop”(密码随意指定，若提示“无效的密码，过于简单”，不用理会，再次输入确认即可)。

passwd hadoop #该条命令设置hadoop用户的密码,输入此命令后会出现一个输入密码的提示，输入即可，但是不会在终端中显示你的密码，会让你再次确认你的密码

1
1

可以为hadoop用户增加管理员权限，方便部署，避免一些对新手来说比较棘手的权限问题，在终端中输入：

visudo  #该命令会打开一个编辑文件，在其中的98行进行操作

1
1

打开这个文件之后，在文件的98行会看见如下的一条命令：

root   ALL=(ALL)   ALL
hadoop ALL=(ALL)   ALL  #在上面一条命令的后面增加这条命令，意思是为hadoop用户增加管理员权限

1
2
1
2

另外一种比较常用的设置管理员权限的方法是：

vim /etc/sudoers  #依然是在第98行之后添加上面的命令

1
1

准备工作

使用hadoop用户登陆后，还需要安装几个软件才能安装hadoop，Centos采用的是yum来安装软件，需要联网环境，请检查你的操作系统是否已经连接网络，连接网络之后，需要安装ssh和Java环境。

安装SSH、配置SSH无密码登陆

首先检查是否已经安装ssh，在终端中输入：

rpm -qa | grep ssh

1
1

在返回的结果中如果有clients和server说明已经安装成功，如果安装没有成功，在终端中输入：

sudo yum install openssh-clients
sudo yum install openssh-server

1
2
1
2

接着用下面的命令测试ssh是否可用，在终端中输入:

ssh localhost

1
1

但是仅仅这样登陆的话，每次都是需要密码的，我们需要配置ssh无密码登陆方式才比较方便，在终端中输入下面的命令：

cd ~/.ssh/  #若没有该目录，请先执行一次ssh localhost
ssh-keygen -t rsa #会有提示，都按回车就可以
cat id_rsa.pub >> authorized_keys #加入授权
chmod 600 ./authorized_keys  #修改文件的权限

1
2
3
4
1
2
3
4

增加了上述的操作之后，再次使用

ssh localhost

命令，无需密码就能直接登录了。

安装Java环境

首先下载相应版本的JDK，我推荐sun公司发行的JDK，并且在当前生态环境下使用JDK 1.7就够了，我的计算机中使用的是：jdk-7u79-Linux-x64.tar.gz（实验室一直使用这哥版本的JDK）。并且放在”/home/hadoop(即~)”中。注意hadoop用户必须有管理员权限，因为下面的操作全部都包含sudo操作，前面已经设置过，在传输文件时用WinSCP前面已经介绍过这种工具。

#解压JDK压缩包
$ sudo tar -zxvf jdk-7u79-linux-x64.tar.gz  #在解压的过程中并没有给出应该讲解压的文件放在哪里，原因是本身这个压缩包里面就有一个名为jdk-7u79-linux的文件夹

#复制JDK文件夹到/usr/lib/jvm目录中
$ sudo cp -r ~/jdk1.7.0_79/ /usr/lib/jvm   #Centos 7的java安装包都放在这里

#配置环境变量
$ sudo vim /etc/profile
#在末尾加上：
export JAVA_HOME=/usr/lib/jvm/jdk1.7.0_79  #只加这个环境变量远远不够，在本文结束部分，会给出配置hadoop必须加的所有环境变量

#然后保存关闭，使用source命令更新下
$ source /etc/profile
#使用env命令查看JAVA_HOME环境变量的值
$ env
#如果JAVA_HOME=/usr/lib/jvm/jdk1.7.0_79，说明配置成功。

#修改系统默认的JDK
$ sudo update-alternatives --install /usr/bin/java java /usr/lib/jvm/jdk1.7.0_79/bin/java 300

$ sudo update-alternatives --install /usr/bin/javac javac /usr/lib/jvm/jdk1.7.0_79/bin/javac 300

$ sudo update-alternatives --config java #输入/usr/lib/jvm/jdk1.7.0_79/bin/java前面的数字就可以了

$ sudo update-alternatives --config javac #输入/usr/lib/jvm/jdk1.7.0_79/bin/javac前的数字就好了

#查看是否安装成功
$ java
$ javac
$ java -version

#删除冗余文件，该操作在“/home/hadoop”下进行
$ sudo rm -rf jdk1.7.0_79/
$ sudo rm -rf jdk-7u79-linux-x64.tar.gz

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

在各个节点上安装hadoop 2.7.2稳定版

可用从apache官网下载最新版本的hadoop，但是请下载稳定版。下载时请下载hadoop-2.x.x.tar.gz这个格式的文件，这是编译好的文件，另一个包含src的文件时是hadoop源代码，需要进行编译才能使用。在Windows上下载好hadoop的安装包，使用WinSCP将其传入”/home/hadoop”中，接着进行下面的过程。

$ sudo tar -zxf /home/hadoop/hadoop-2.7.2.tar.gz -C /usr/local #解压到/usr/local中
$ cd /usr/local/
$ sudo mv ./hadoop-2.7.2/ ./hadoop #将文件夹命名改为hadoop
$ sudo chown -R hadoop:hadoop ./hadoop #修改文件权限

#hadoop解压后即可使用，输入如下命令来检查hadoop是否可用，成功则会显示hadoop版本信息。
$ cd /usr/local/hadoop
$ ./bin/hadoop version

1
2
3
4
5
6
7
8
1
2
3
4
5
6
7
8

测试实例看单节点是否成功配置

hadoop默认模式为非分布式，无需进行其他的配置即可运行，非分布式即单Java进程，方便进行调试。现在我们可以执行例子来感受一下hadoop的运行。hadoop附带了丰富的例子（运行./bin/hadoop
jar ./share/hadoop/mapreduce/hadoop-mapreduce-example-2.7.2.jar可以看到所有的例子），包括wordcount、terasort、join、grep等。在此我们选择运行grep的例子，我们将input文件夹中的所有文件作为输入，筛选当中符合正则表达式

dfs[a-z.]+

的单词并统计出现的次数，最后输出结果到output文件夹中。

$ cd /usr/local/hadoop
$ mkdir ./input
$ cp ./etc/hadoop/*.xml ./input  #将配置文件作为输入文件
$ ./bin/hadoop jar ./share/hadoop/mapreduce/hadoop-mapreduce-examples-*.jar grep ./input  ./output  'dfs[a-z.]+'
cat ./output/*  #查看运行结果

1
2
3
4
5
1
2
3
4
5

上述代码的运行结果为：

1 dfsadmin #注意hadoop不会覆盖结果文件，因此再次运行上面实例会提示出错，需要先将`./output`删除

1
1

输入下面的命令：

rm -rf ./output

1
1

集群生态系统之间互相通信-网络配置

首先应该保证集群在同一个局域网，如果使用的是虚拟机安装的系统，需要更改网络连接方式为桥接（Bridge）模式，才能实现多个节点之间的互联。
修改主机名：hostname

$ sudo vim /etc/hostname #修改节点的名字，我的节点一次为：Master、Slave1、Slave2、Slave3、Slave4
$ 在打开的文件中依次写入Master、Slave1、Slave2、Slave3、Slave4，如果有其他的内容全部删除hostname只出现Master、Slave1、Slave2、Slave3、Slave4，该名字用来标识你所使用的计算机

1
2
1
2
修改/etc/hosts文件

$ sudo vim /etc/hosts #修改IP映射关系

1
1

打开后出现下面的内容,如果有其他的内容，删除它，那些信息并没有什么用：

127.0.0.1 localhost localhost.localdomain localhost4 localhost4.localdomain4 #ipv4地址，不能删除
::1 localhost localhost.localdomain localhost6 localhost6.localdomain6  #ipv6地址，不能删除

1
2
1
2

在打开的/etc/hosts文件后面追加下面的内容：

#在打开的文件中写入下面的内容
192.168.101.44 Master
192.168.101.45 Slave1
192.168.101.46 Slave2
192.168.101.47 Slave3
192.168.101.48 Slave4
192.168.101.49 Slave5

1
2
3
4
5
6
7
1
2
3
4
5
6
7

完成上述操作之后，ping一下看是否能联通

ping Master -c 3 #只ping3次
ping Slave1 -c 3
ping Slave2 -c 3
ping Slave3 -c 3
ping Slave4 -c 3
ping Slave5 -c 3

1
2
3
4
5
6
1
2
3
4
5
6

修改完成后，需要重新启动一下(exit即可，只是重启终端，并不需要重启操作系统)，重启后在终端中才能看到机器名的变化。后面的操作请注意区分Master和Slave节点的操作。

ssh无密码登陆节点

这个操作是让Master节点可以无密码ssh登陆到各个Slave节点上，首先生成Master节点的公钥，在Master节点的终端执行（因为改过主机名，所以还需要删掉原来有的重新生成一次，凡是修改了Master节点的内容，都要执行此步进行更新公钥，当然会对后续的过程有影响，请更改有影响的步骤，也就是进行redo操作）。

# 在Master节点上执行下面所有的命令
$ cd ~/.ssh      #如果没有该目录，先执行一次ssh localhost
$ rm ./id_rsa*    #删除之前生成的公钥
$ ssh-keygen -t rsa   #一直按回车就可以
$ cat ./id_rsa.pub >> ./authorized_keys #让Master节点能首先无密码ssh登陆本机，在Master执行该命令
$ ssh Master  #验证是否能成功的登陆本机
$ scp ~/.ssh/id_rsa.pub hadoop@Slave1:/home/hadoop #scp是Secure Copy的简写，用于在Linux下进行远程拷贝文件，类似于cp命令，不过cp只能在本机中拷贝，执行scp时会要求输入Slave1节点上hadoop用户的密码（hadoop），输入完成后会提示传输完毕。
$ scp ~/.ssh/id_rsa.pub hadoop@Slave2:/home/hadoop #传入2号节点
$ scp ~/.ssh/id_rsa.pub hadoop@Slave3:/home/hadoop #传入3号节点
$ scp ~/.ssh/id_rsa.pub hadoop@Slave4:/home/hadoop #传入4号节点
$ scp ~/.ssh/id_rsa.pub hadoop@Slave5:/home/hadoop #传入5号节点

#在各个子节点上将ssh公钥介入授权
$ cat ~/id_rsa.pub  >> ~/.ssh/authorized_keys
$ rm ~/id_rsa.pub  #用完就可以删掉了

#接着在Slave1节点上将ssh公钥添加到授权中
$ cat ~/id_rsa.pub >> ~/.ssh/authorized_keys #在Slave1节点上执行
$ rm ./id_rsa.pub #用完删掉

#接着在Slave2节点上将ssh公钥添加到授权中
$ cat ~/id_rsa.pub >> ~/.ssh/authorized_keys #在Slave2节点上执行
$ rm ./id_rsa.pub #用完删掉

#接着在Slave3节点上将ssh公钥添加到授权中
$ cat ~/id_rsa.pub >> ~/.ssh/authorized_keys #在Slave3节点上执行
$ rm ./id_rsa.pub #用完删掉

#接着在Slave4节点上将ssh公钥添加到授权中
$ cat ~/id_rsa.pub >> ~/.ssh/authorized_keys #在Slave4节点上执行
$ rm ./id_rsa.pub #用完删掉

#接着在Slave5节点上将ssh公钥添加到授权中
$ cat ~/id_rsa.pub >> ~/.ssh/authorized_keys #在Slave5节点上执行
$ rm ./id_rsa.pub #用完删掉

#最后我们在Master节点上测试是否能成功登陆各个子节点
$ ssh Slave1  #登陆子节点1
$ exit        #退出Slave1节点
$ ssh Slave2  #登陆子节点2
$ exit
$ ssh Slave3  #登陆子节点3
$ exit
$ ssh Slave4  #登陆子节点4
$ exit
$ ssh Slave5  #登陆子节点5
$ exit

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

配置PATH环境变量

可以将hadoop安装目录加入到PATH变量中，这样就有可以在任意目录中使用hadoop、hdfs等命令，需要在Master节点上进行配置，注意下面命令只须在Master节点上执行，其他的Slave节点不需要。

$ vim ~/.bashrc
#加入下面的命令
$
export JAVA_HOME=/usr/lib/jvm/jdk1.7.0_79 #加入Java环境变量
export PATH=$PATH:/usr/local/hadoop/bin:/usr/local/hadoop/sbin
$ source ~/.bashrc  #刷新一下

1
2
3
4
5
6
1
2
3
4
5
6

配置集群/分布式环境

集群/分布式环境需要修改/usr/local/hadoop/etc/hadoop中的5个配置文件，更多设置项可查看官方说明，这里仅仅设置了正常启动所必须的设置项：slaves、core-site.xml、hdfs-site.xml、mapred-site.xml、yarn-site.xml。
文件slaves，将作为DataNode的主机名写入该文件，每行一个，默认为localhost，所谓在伪分布式节点配置时，节点即作为NameNode也可以作为DataNode。分布式配置可以保留localhost，也可以删掉，让Master节点近作为NameNode节点。本教程让Master节点仅仅作为NameNode节点使用，因此将文件中原来的localhost删除，在slaves中添加：

Slave1  #作为DataNode节点
Slave2  #作为DataNode节点
Slave3  #作为DataNode节点
SLave4  #作为DataNode节点
Slave5  #作为DataNode节点

1
2
3
4
5
1
2
3
4
5
将core-site.xml文件改为下面的配置：

<configuration>
<property>
<name>fs.defaultFS</name>
<value>hdfs://Master:9000</value>
</property>
<property>
<name>hadoop.tmp.dir</name>
<value>file:/usr/local/hadoop/tmp</value>
<description>Abase for other temporary directories.</description>
</property>
</configuration>

1
2
3
4
5
6
7
8
9
10
11
1
2
3
4
5
6
7
8
9
10
11
文件hdfs-site.xml，dfs.replication一般设置为3，但是我们现在有5个Slave节点，所以dfs.replication的值设置为5。

<configuration>
<property>
<name>dfs.namenode.secondary.http-address</name>
<value>Master:50090</value>
</property>
<property>
<name>dfs.replication</name>
<value>5</value>
</property>
<property>
<name>dfs.namenode.name.dir</name>
<value>file:/usr/local/hadoop/tmp/dfs/name</value>
</property>
<property>
<name>dfs.datanode.data.dir</name>
<value>file:/usr/local/hadoop/tmp/dfs/data</value>
</property>
</configuration>

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
文件mapred-site.xml（可能需要先重命名，默认文件名为madred-site.xml.template），然后配置修改如下： 

首先重命名，在终端中输入：

mv madred-site.xml.template madred-site.xml  #将前一个文件的名字修改为后者

1
1

<configuration>
<property>
<name>mapreduce.framework.name</name>
<value>yarn</value>
</property>
<property>
<name>mapreduce.jobhistory.address</name>
<value>Master:10020</value>
</property>
<property>
<name>mapreduce.jobhistory.webapp.address</name>
<value>Master:19888</value>
</property>
</configuration>

1
2
3
4
5
6
7
8
9
10
11
12
13
14
1
2
3
4
5
6
7
8
9
10
11
12
13
14
修改文件yarn-site.xml如下：

<configuration>
<property>
<name>yarn.resourcemanager.hostname</name>
<value>Master</value>
</property>
<property>
<name>yarn.nodemanager.aux-services</name>
<value>mapreduce_shuffle</value>
</property>
</configuration>

1
2
3
4
5
6
7
8
9
10
1
2
3
4
5
6
7
8
9
10
最基本的配置完成，我们需要将Master节点上的/usr/local/hadoop文件夹复制到各个节点上，因为之前在节点上跑过单节点的例子，所以在切换到集群模式之前应先删除之前临时的文件，在Master节点上执行：

$ cd /usr/local
$ sudo rm -r ./hadoop/tmp #删除hadoop临时文件
$ `sudo rm -r ./hadoop/logs/*`  #删除日志文件
$ tar -zcf ~/hadoop.master.tar.gz ./hadoop #先压缩再执行复制
$ cd ~
$ scp ./hadoop.master.tar.gz Slave1:/home/hadoop #传输到Shave1节点上
$ scp ./hadoop.master.tar.gz Slave2:/home/hadoop #传输到Shave2节点上
$ scp ./hadoop.master.tar.gz Slave3:/home/hadoop #传输到Shave3节点上
$ scp ./hadoop.master.tar.gz Slave4:/home/hadoop #传输到Shave4节点上
$ scp ./hadoop.master.tar.gz Slave5:/home/hadoop #传输到Shave5节点上

1
2
3
4
5
6
7
8
9
10
1
2
3
4
5
6
7
8
9
10
在各个slave节点上执行下面的命令,我有5个slave节点，所有在5个节点下都应该执行下面的命令：

$ sudo rm -r /usr/local/hadoop  #删掉旧的
$ sudo tar -zxf ~/hadoop.master.tar.gz -C /usr/local  #解压缩到/usr/local文件夹中
$ sudo chown -R hadoop:hadoop /usr/local/hadoop  #修改/usr/local/hadoop文件夹权限

1
2
3
1
2
3

首次启动hadoop

首次启动需要先在Master节点上执行NameNode的格式化，如果要重新格式化，要删除所有节点上tmp文件，否则是不能格式化成功的，即使成功也不会刷新状态。

$ hdfs namenode -format  #首次运行需要执行格式化操作，之后不需要

1
1

关闭防火墙，Centos中默认开启了防火墙，在开启hadoop集群之前，需要关闭集群中每个节点的防火墙，有防火墙会导致ping得通但是telnet端口不通，从而导致DataNode启动了，但是Live datanodes为0的情况。

在Centos 6.x中关闭防火墙命令

$ sudo service iptables stop #关闭防火墙服务
$ sudo chkconfig iptables off #禁止防火墙开机自启动，这样就不用手动去关闭了

1
2
1
2

在Centos 7中需要通过如下命令（防火墙改成了firewall）

$ systemctl stop firewalld.service #关闭firewall
$ systemctl disable firewalld.service #禁止firewall开机自启动

1
2
1
2

启动hadoop，需要在Master上进行：

$ start-dfs.sh
$ start-yarn.sh
$ start-all.sh
$ mr-jobhistory-daemon.sh start historyserver

1
2
3
4
1
2
3
4

启动的过程如果报错，可能是环境变量设置有问题，将下面我已经设置好的环境变量放到指定的部分就可以。

最终环境变量设置

最终在~/.bashrc和~/.bash_profile文件中应该有下面的环境变量，请直接复制下面的环境变量，这种设置可以方便你izai任意路径下打开相应的可执行文件。

export JAVA_HOME=/usr/lib/jvm/jdk1.7.0_79
export PATH=$PATH:/usr/local/hadoop/bin:/usr/local/hadoop/sbin:$JAVA_HOME/bin
export HADOOP_PREFIX=/usr/local/hadoop
export HADOOP_HOME=/usr/local/hadoop
export HADOOP_INSTALL=$HADOOP_HOME
export HADOOP_MAPRED_HOME=$HADOOP_HOME
export HADOOP_COMMON_HOME=$HADOOP_HOME
export HADOOP_HDFS_HOME=$HADOOP_HOME
export YARN_HOME=$HADOOP_HOME
export HADOOP_COMMON_LIB_NATIVE_DIR=$HADOOP_HOME/lib/native
export PATH=$PATH:$HADOOP_HOME/sbin:$HADOOP_HOME/bin
export HADOOP_CONF_DIR=$HADOOP_HOME/etc/hadoop

1
2
3
4
5
6
7
8
9
10
11
12
1
2
3
4
5
6
7
8
9
10
11
12

查看运行结果

是否启动成功呢？这可能是我们最为关心的问题，下面一些方式去查看你的集群是否已经成功的启动。

jps，在各个节点上输入jps命令
在Master必须包含的信息，必须至少包含下面的4个进行，否则就可以判定你的集群没有成功的启动。

ResourceManager   #资源管理
Jps
NameNode
SecondaryNameNode

1
2
3
4
1
2
3
4
在Slave节点上应该包含3个进程，三个进行却一不可。

Jps
NodeManager
DataNode

1
2
3
1
2
3

Master:50070 

将上面的Master换成你的Master节点的IP地址，在启动的界面中，查看，如下图,其中的LiveNode应该为你的Slave节点数： 

在终端中输入：hdfs dfsadmin -report，其中的LiveNode应该为你的LiveNode数目，否则说明集群没有成功的启动。

停止hadoop集群

停止过程十分简单，只需要在Master节点上执行命令：

stop-all.sh   #停止所有的进程

1
1

可能出现的问题

在你输入一些命令比如jps时，会提示“can not found“，这个命令本身不属于hadoop，这是Java的JDK自带的一条命令，出现这种情况的原因有二： 
你的JDK安装不正确，但是如果你跟我的教程做，不会出现这种情况
环境变量的导入不正确，在本文中最后给出了你应该导入的环境变量，请自己仔细检查是否正确

第一次启动hadoop时不成功，之后一会报错该怎么办？
出现这种情况的原因可能是你第一次开启hadoop的姿势不正确，请删除/usr/local/hadoop路径下的tmp文件夹，重新进行格式化操作，看是否能够成功。

在启动的过程中可能会伴随一个警告，还警告直接忽略，它不会影响你的正常启动，这个警告的解决需要编译源代码，还是比较复杂的，一般不建议修改。