第6章 HDFS HA配置

目录

• ​​6.1 hdfs-site.xml文件配置​​
• ​​6.2 core-site.xml文件配置​​
• ​​6.3 启动与测试​​
• ​​6.4 结合ZooKeeper进行自动故障转移​​

在Hadoop 2.0.0之前，一个HDFS集群中只有一个单一的NameNode，如果NameNode所在的节点宕机了或者因服务器软件升级导致NameNode进程不可用，则将导致整个集群无法访问，直到NameNode被重新启动。

HDFS高可用性（HDFS High Availability）解决了上述问题，它提供了一个选项，可以在同一个集群中运行两个NameNode，其中一个处于活动状态，另一个处于备用状态。当活动状态的NameNode崩溃时，HDFS集群可以快速切换到备用的NameNode，这样也就实现了故障转移功能。

为了使备用节点保持与活动节点同步的状态，两个节点都与一组称为“日志节点”(JournalNodes)的独立守护进程通信。当活动状态的NameNode的命名空间有任何修改时，会告知大部分的JournalNodes进程。备份状态的NameNode有能力读取JournalNodes中的变更信息，并且一直监控edit log的变化，把变化应用于自己的命名空间。
本例中，各节点的角色分配如下表所示：

节点	角色
centos01	NameNode DataNode JournalNode
centos02	NameNode DataNode JournalNode
centos03	DataNode JournalNode

配置之前最好将三个节点的$HADOOP_HOME/etc/hadoop文件夹与$HADOOP_HOME/tmp文件夹备份一下。备份命令如下：

[hadoop@centos01 etc]$ cp -r hadoop/ backup-hadoop
[hadoop@centos01 hadoop-2.7.1]$ cp -r tmp/ backup-tmp

注意：本例配置的总体思路是，先在centos01节点上配置完毕之后，再将改动的配置文件发送到centos02、centos03节点上。

6.1 hdfs-site.xml文件配置

要配置HA NameNodes，必须向hdfs-site.xml文件添加一些配置选项，设置这些配置的顺序并不重要，但是需要为选项dfs.nameservice和dfs. namenodes (nameservice ID)设置一个值，这个值将被后面的选项所引用。因此，在设置其他配置选项之前，应该先设置这些值。
向hdfs-site.xml文件加入以下内容（在之前配置的基础上追加）：

<property>
  <name>dfs.nameservices</name>
  <value>mycluster</value><!--mycluster为自定义的值，下方配置要使用该值-->
</property>
<property>
  <name>dfs.ha.namenodes.mycluster</name>
  <value>nn1,nn2</value>
</property>
<property>
  <name>dfs.namenode.rpc-address.mycluster.nn1</name>
  <value>centos01:8020</value>
</property>
<property>
  <name>dfs.namenode.rpc-address.mycluster.nn2</name>
  <value>centos02:8020</value>
</property>
<property>
  <name>dfs.namenode.http-address.mycluster.nn1</name>
  <value>centos01:50070</value>
</property>
<property>
  <name>dfs.namenode.http-address.mycluster.nn2</name>
  <value>centos02:50070</value>
</property>
<property>
  <name>dfs.namenode.shared.edits.dir</name>
<value>qjournal://centos01:8485;centos02:8485;centos03:8485/mycluster</value>
</property>
<property>
  <name>dfs.journalnode.edits.dir</name>
  <value>/opt/modules/hadoop-2.7.1/tmp/dfs/jn</value>
</property>
<property>
  <name>dfs.client.failover.proxy.provider.mycluster</name>
 <value>org.apache.hadoop.hdfs.server.namenode.ha.ConfiguredFailoverProxyProvider</value>
</property>
 <property>
      <name>dfs.ha.fencing.methods</name>
      <value>sshfence</value>
    </property>
    <property>
      <name>dfs.ha.fencing.ssh.private-key-files</name>
      <value>/home/hadoop/.ssh/id_rsa</value><!--hadoop为当前用户名-->
</property>

上述参数解析如下：
dfs.nameservices：为nameservice设置一个逻辑名称ID（nameservice ID），名称ID可以自定义，例如mycluster。并使用这个逻辑名称ID作为配置选项的值。后续配置选项将引用该ID。
dfs.ha.namenodes.mycluster：nameservice中每个NameNode的唯一标识符。选项值是一个以逗号分隔的NameNode id列表。这将被DataNodes用于确定集群中的所有NameNodes。例如，本例中使用“mycluster”作为nameservice ID，并且使用“nn1”和“nn2”作为NameNodes的单个ID。需要注意的是，当前每个nameservice只能配置最多两个NameNodes。
dfs.namenode.rpc-address.mycluster.nn1：设置NameNode的RPC监听地址，需要设置NameNode进程的完整地址和RPC端口。
dfs.namenode.rpc-address.mycluster.nn2：设置另一个NameNode的RPC监听地址，需要设置NameNode进程的完整地址和RPC端口。
dfs.namenode.http-address.mycluster.nn1：设置NameNode的HTTP Web端监听地址，类似于上面的RPC地址，可以通过浏览器端访问NameNode。
dfs.namenode.http-address.mycluster.nn2：设置另一个NameNode的HTTP Web端监听地址，类似于上面的RPC地址，可以通过浏览器端访问NameNode。
dfs.namenode.shared.edits.dir：设置一组 JournalNode 的 URI 地址，活动状态的NameNode将 edit log 写入这些JournalNode，而备份状态的 NameNode 则读取这些 edit log，并作用在内存的目录树中。如果JournalNode有多个节点则使用分号分割。该属性值应符合以下格式：qjournal://host1:port1;host2:port2;host3:port3/nameservice ID。
dfs.journalnode.edits.dir: JournalNode所在节点上的一个目录，用于存放 edit log和其他状态信息。
dfs.client.failover.proxy.provider.mycluster：客户端与活动状态的NameNode 进行交互的 Java 实现类，DFS 客户端通过该类寻找当前的活动NameNode。目前Hadoop的唯一实现是ConfiguredFailoverProxyProvider类，除非我们自己对其定制，否则应该使用这个类。
dfs.ha.fencing.methods：解决HA集群脑裂问题（即出现两个 master 同时对外提供服务，导致系统处于不一致状态）。在 HDFS HA中，JournalNode只允许一个 NameNode 写数据，不会出现两个活动NameNode 的问题，但是，当主备切换时，之前的 活动 NameNode 可能仍在处理客户端的 RPC 请求，为此，需要增加隔离机制（fencing）将之前的活动NameNode 杀死。常用的fence方法是sshfence，使用ssh需要指定ssh通讯使用的密钥文件。
dfs.ha.fencing.ssh.private-key-files：指定上述选项ssh通讯使用的密钥文件在系统中的位置。

6.2 core-site.xml文件配置

修改core-site.xml文件中的fs.defaultFS属性值，为Hadoop客户端配置默认的访问路径，以使用新的支持HA的逻辑URI。将之前配置的hdfs://centos01:9000改为hdfs://mycluster，其中的mycluster为hdfs-site.xml中定义的nameservice ID值。内容如下：

<property>
  <name>fs.defaultFS</name>
  <value>hdfs://mycluster</value>
</property>

文件hdfs-site.xml与core-site.xml都配置完成后，需要将这两个文件重新发送到集群其它的节点中，并覆盖原来的文件。
进入Hadoop安装目录，执行以下命令：

scp etc/hadoop/hdfs-site.xml hadoop@centos02:/opt/modules/hadoop-2.7.1/etc/hadoop/
scp etc/hadoop/hdfs-site.xml hadoop@centos03:/opt/modules/hadoop-2.7.1/etc/hadoop/
scp etc/hadoop/core-site.xml hadoop@centos02:/opt/modules/hadoop-2.7.1/etc/hadoop/  
scp etc/hadoop/core-site.xml hadoop@centos03:/opt/modules/hadoop-2.7.1/etc/hadoop/

6.3 启动与测试

HDFS HA配置完成后，下面我们将集群启动，进行测试：
（1）删除各个节点的$HADOOP_HOME/tmp目录下的所有文件。在各个节点分别执行下面命令，启动三台JournalNode ：

sbin/hadoop-daemon.sh start journalnode

（2）在centos01节点上执行namenode格式化，如果没有启动JournalNode，格式化将失败。

bin/hdfs namenode -format

出现如下输出代表格式化成功：

18/03/15 14:14:45 INFO common.Storage: Storage directory /opt/modules/hadoop-2.7.1/tmp/dfs/name has been successfully formatted.

（3）在centos01节点上执行如下命令，启动namenode：

sbin/hadoop-daemon.sh start namenode

启动namenode后会生成images元数据。
（4）在centos02上执行以下命令，将centos01上的NameNode元数据拷贝到centos02上（也可以直接将centos01上的$HADOOP_HOME/tmp目录拷贝到centos02上）：

bin/hdfs namenode -bootstrapStandby

输出以下信息代表拷贝成功：

18/03/15 14:28:01 INFO common.Storage: Storage directory /opt/modules/hadoop-2.7.1/tmp/dfs/name has been successfully formatted.

（5）在centos02上执行以下命令，启动namenode2（备份的NameNode）：

sbin/hadoop-daemon.sh start namenode

启动后，在浏览器中输入网址http://centos01:50070 查看namenode1（活动的NameNode）的状态。namenode1的状态显示，如下图所示。

在浏览器中输入网址http://centos02:50070 查看namenode2的状态。Namenode2的状态显示，如下图所示。

可以看到，此时两个namenode的状态都为standby。接下来我们需要将namenode1的状态设置为active。

（6）在centos01上执行如下命令，将namenode1的状态置为active：

bin/hdfs haadmin -transitionToActive nn1

上述代码中，nn1为hdfs-site.xml中设置的节点centos01上的namenode的ID标识符。

上述代码执行完毕后，刷新浏览器，可以看到namenode1的状态已经变为了active，如下图所示：

（7）重新启动HDFS

停止HDFS：

sbin/stop-dfs.sh

启动HDFS：

sbin/start-dfs.sh

（8）重启以后，NameNode、DataNode等进程都已经启动了，但两个NameNode的状态仍然都为standby，需要再次执行步骤（6）的命令，将namenode1的状态置为active。
（9）在各节点中执行jps命令，查看各节点启动的Java进程：
centos01节点上的Java进程：

[hadoop@centos01 hadoop-2.7.1]$ jps
8996 DataNode
9221 JournalNode
9959 Jps
8877 NameNode

centos02节点上的Java进程：

[hadoop@centos02 hadoop-2.7.1]$ jps
8162 NameNode
8355 JournalNode
8565 Jps
8247 DataNode

centos03节点上的Java进程：

[hadoop@centos03 hadoop-2.7.1]$ jps
7144 DataNode
7256 JournalNode
7371 Jps

（10）上传一个文件到HDFS，测试HDFS是否正常运行。若一切正常，接下来测试NameNode故障转移功能，首先将namenode1进程杀掉：

[hadoop@centos01 hadoop-2.7.1]$ jps
8996 DataNode
10452 Jps
9221 JournalNode
8877 NameNode
[hadoop@centos01 hadoop-2.7.1]$ kill -9 8877

然后查看namenode2的状态，发现仍然是standby，没有自动切换到active，此时需要手动执行步骤（6）的命令，将namenode2的状态切换为active。再次进行HDFS文件系统的测试，发现一切正常。

以上描述了如何配置手动故障转移。在该模式下，即使活动节点失败，系统也不会自动触发从active到备用NameNode的故障转移。这样手动切换NameNode虽然能解决故障问题，但是还是比较麻烦，可不可以自动切换呢？答案是肯定的。下一节讲解HDFS结合ZooKeeper进行自动故障转移。

6.4 结合ZooKeeper进行自动故障转移

自动故障转移为HDFS部署添加了两个新组件：一个ZooKeeper quorum和ZKFailoverController流程(缩写为ZKFC)。
Apache ZooKeeper是一种高度可用的服务，用于维护少量的协调数据，通知客户数据的变化，并监控客户的失败。自动HDFS故障转移的实现主要依赖于ZooKeeper的如下功能：

* 故障检测——集群中的每个NameNode机器都在ZooKeeper中维护一个持久会话。如果机器崩溃，ZooKeeper会话将过期，通知另一个NameNode，它将触发故障转移。
* 活动的NameNode选举——ZooKeeper提供了一个简单的机制来专门选择一个活动的节点。如果当前活动的NameNode崩溃，另一个节点可能会在ZooKeeper中使用一个特殊的独占锁，这表明它应该成为下一个活            动。
* ZKFailoverController (ZKFC)是一个新的组件，它是一个ZooKeeper客户端，它也监视和管理NameNode的状态。每个运行NameNode的机器都运行一个ZKFC。
* 健康监测——ZKFC以健康检查命令定期对本地的NameNode进行检测。只要NameNode能及时地以健康的状态做出反应，ZKFC就认为该节点是健康的。如果该节点崩溃、冻结或进入不健康状态，健康监控器将标记为不健康状态。

有关自动故障转移设计的更多细节，请参考Apache HDFS JIRA上的HDFS-2185的设计文档。
本例中，各节点的角色分配如下表：

节点	角色
centos01	NameNode DataNode JournalNode ZKFC QuorumPeerMain
centos02	NameNode DataNode JournalNode ZKFC QuorumPeerMain
centos03	DataNode JournalNode QuorumPeerMain

HDFS集成ZooKeeper来实现NameNode的自动故障转移，操作步骤如下：
（1）修改hdfs-site.xml文件，加入以下内容：

<!--开启自动故障转移,mycluster为自定义配置的nameservice ID值-->
  <property>
     <name>dfs.ha.automatic-failover.enabled.mycluster</name>
     <value>true</value>
   </property>

（2）修改core-site.xml文件，加入以下内容，指定ZooKeeper集群：

<property>
     <name>ha.zookeeper.quorum</name>
     <value>centos01:2181,centos02:2181,centos03:2181</value>
   </property>

（3）发送修改好的hdfs-site.xml、core-site.xml文件到集群其它节点，覆盖原来的文件（这一步容易被忽略）。
（4）停止HDFS集群：

sbin/stop-dfs.sh

（5）启动ZooKeeper集群：
分别进入每个节点的安装目录，执行如下命令：

bin/zkServer.sh start

（6）初始化HA在ZooKeeper中的状态：
在centos01节点上执行如下命令，将在ZooKeeper中创建一个znode，存储自动故障转移系统的数据：

bin/hdfs zkfc -formatZK

（7）启动HDFS集群：

sbin/start-dfs.sh

（8）由于我们是手动管理集群上的服务，所以需要手动启动运行NameNode的每个机器上的zkfc守护进程。分别在centos01和centos02上执行以下命令，启动zkfc进程（先在哪个节点上启动，哪个节点的namenode状态就是active）：

sbin/hadoop-daemon.sh start zkfc

(或者执行bin/hdfs start zkfc也可以，两种启动方式。)
（9）上传文件到HDFS进行测试。
在centos01中上传一个文件，然后停止namenode1，读取刚才上传的文件内容。相关命令及输出如下：

[hadoop@centos01 hadoop-2.7.1]$ jps
13105 QuorumPeerMain
13523 DataNode
13396 NameNode
13753 JournalNode
13882 DFSZKFailoverController
14045 Jps
[hadoop@centos01 hadoop-2.7.1]$ kill -9 13396
[hadoop@centos01 hadoop-2.7.1]$ jps
13105 QuorumPeerMain
14066 Jps
13523 DataNode
13753 JournalNode
13882 DFSZKFailoverController
[hadoop@centos01 hadoop-2.7.1]$ hdfs dfs -cat /input/*

如果仍能成功读取文件内容，说明自动故障转移配置成功。此时我们在浏览器中访问namenode2，可以看到namenode2的状态变为了active。

查看各节点的Java进程，命令及输出结果如下：

[hadoop@centos01 hadoop-2.7.1]$ jps
3360 QuorumPeerMain
4080 DFSZKFailoverController
3908 JournalNode
3702 DataNode
4155 Jps
3582 NameNode

[hadoop@centos02 hadoop-2.7.1]$ jps
3815 DFSZKFailoverController
3863 Jps
3480 NameNode
3353 QuorumPeerMain
3657 JournalNode
3563 DataNode

[hadoop@centos03 zookeeper-3.4.9]$ jps
3496 JournalNode
3293 QuorumPeerMain
3390 DataNode
3583 Jps

原创文章，转载请注明出处！！

更多内容及Java+大数据个人原创视频，可关注公众号观看：

原创文章，转载请注明出处！！