1.什么是HA?

所谓HA,也就是高可用,放在理论经营中,那就是7*24小时不间断服务。
那么实现HA,最要害的中央的就是打消单点故障,那什么是单点故障,就没有可代替的节点,一旦这个节点挂了,那整个服务也跟着瘫痪,直到该节点复原。

2.Hadoop HA

Hadoop为什么须要HA呢?
因为存在单点故障,HDFS上的NameNode,这就是一个单点故障,它只存在一个,如果NameNode挂了,或者咱们须要对这个节点降级更新,那么会导致集群不可用,
2.0版本之后,还有Yarn也是,ResourceManager也只有一个,也是单点故障。

所以Hadoop须要HA,而且咱们要实现两个中央的HA,HDFS的HA和Yarn的HA。

3.利用Zookeeper的实现Hadoop的HA

3.1 搭建hadoop

参考文档hadoop部署

3.2 搭建Zookeeper集群

参考文档zookeeper部署

3.3 HDFS HA

我这有三个节点,hadoop14、hadoop15、hadoop16
节点信息如下:

==============hadoop14 jps================6096 JobHistoryServer6436 Jps5751 DataNode5929 SecondaryNameNode6205 NodeManager5599 NameNode==============hadoop15 jps================3616 ResourceManager3746 NodeManager4163 Jps3454 DataNode==============hadoop16 jps================3089 Jps2796 DataNode2894 NodeManager

咱们当初实现的是多个namenode和ResourceManager,打算如下:

server_namehadoop14hadoop15hadoop16
namenodeYYY
ResourceManagerYY

namenode咱们弄三个,ResourceManager咱们来两个。

3.2.1 HDFS HA

多个NameNode中,只有一个处于Active提供服务,其余的处于Standby状态,作为备用。如果Active的NameNode故障或者该节点须要保护,则切换到Standby节点上提供服务即可,这时提供服务的Standby的节点变为Active。
那么如何做到实时同步节点Active和Standby的元数据信息呢?那就须要一个共享存储系统,咱们这里应用Zookeeper。
Active负责向共享存储系统写入元数据,而处于Standby的的节点负责监听,当发现有新数据写入时,则读取这些数据,将其加载到内存中,保障本人内存状态与ActiveNameNode统一。

那么开始配置HDFS HA。
1)core-site.html

<!-- 把多个NameNode的地址组装成一个集群mycluster -->        <property>            <name>fs.defaultFS</name>            <value>hdfs://mycluster</value>        </property>        <!-- 指定hadoop运行时产生文件的存储目录 -->        <property>            <name>hadoop.tmp.dir</name>            <value>/opt/module/ha/data/tmp</value>        </property>   <!-- 申明journalnode服务器存储目录-->    <property>        <name>dfs.journalnode.edits.dir</name>        <value>file://${hadoop.tmp.dir}/jn</value>    </property>

2)hdfs-site.html

<!-- 齐全分布式集群名称 -->    <property>        <name>dfs.nameservices</name>        <value>mycluster</value>    </property>  <!-- NameNode数据存储目录 -->  <property>    <name>dfs.namenode.name.dir</name>    <value>file://${hadoop.tmp.dir}/name</value>  </property> <!-- DataNode数据存储目录 -->  <property>    <name>dfs.datanode.data.dir</name>    <value>file://${hadoop.tmp.dir}/data</value>  </property>    <!-- 集群中NameNode节点都有哪些 -->    <property>        <name>dfs.ha.namenodes.mycluster</name>        <value>nn1,nn2,nn3</value>    </property>    <!-- nn1的RPC通信地址 -->    <property>        <name>dfs.namenode.rpc-address.mycluster.nn1</name>        <value>hadoop14:9000</value>    </property>    <!-- nn2的RPC通信地址 -->    <property>        <name>dfs.namenode.rpc-address.mycluster.nn2</name>        <value>hadoop15:9000</value>    </property>    <!-- nn3的RPC通信地址 -->    <property>        <name>dfs.namenode.rpc-address.mycluster.nn3/name>        <value>hadoop16:9000</value>    </property>    <!-- nn1的http通信地址 -->    <property>        <name>dfs.namenode.http-address.mycluster.nn1</name>        <value>hadoop14:9870</value>    </property>    <!-- nn2的http通信地址 -->    <property>        <name>dfs.namenode.http-address.mycluster.nn2</name>        <value>hadoop15:9870</value>    </property>    <!-- nn3的http通信地址 -->    <property>        <name>dfs.namenode.http-address.mycluster.nn3/name>        <value>hadoop16:9870</value>    </property>    <!-- 指定NameNode元数据在JournalNode上的寄存地位 -->    <property>        <name>dfs.namenode.shared.edits.dir</name>    <value>qjournal://hadoop14:8485;hadoop15:8485;hadoop16:8485/mycluster</value>    </property>    <!-- 配置隔离机制,即同一时刻只能有一台服务器对外响应 -->    <property>        <name>dfs.ha.fencing.methods</name>        <value>sshfence</value>    </property>    <!-- 应用隔离机制时须要ssh无秘钥登录-->    <property>        <name>dfs.ha.fencing.ssh.private-key-files</name>        <value>/home/v2admin/.ssh/id_rsa</value>    </property>    <!-- 拜访代理类:client用于确定哪个NameNode为Active -->    <property>            <name>dfs.client.failover.proxy.provider.mycluster</name>    <value>org.apache.hadoop.hdfs.server.namenode.ha.ConfiguredFailoverProxyProvider</value>    </property>

3)别离在三个节点启动journalnode服务

$HADOOP_HOME/bin/hdfs --daemon start journalnode

4)在nn1上,对namenode进行格式化

$HADOOP_HOME/binhdfs namenode -format$HADOOP_HOME/binhdfs --daemon start namenode

而后在nn2和nn3上同步nn1的元数据信息。

$HADOOP_HOME/binbin/hdfs namenode -bootstrapStandby

看下各个节点状态

==============hadoop14 jps================8885 JournalNode9157 NameNode7190 QuorumPeerMain9544 Jps==============hadoop15 jps================4579 QuorumPeerMain5859 NameNode5940 Jps5083 JournalNode==============hadoop16 jps================3811 JournalNode4053 NameNode3305 QuorumPeerMain4124 Jps

有三个namenode启动胜利,此刻三个namenode都处于standby状态。
5)启动所有datanode

hdfs --daemon start datanode

6)将nn1设为Active

hdfs haadmin -transitionToActive nn1

4)在nn1上,对namenode进行格式化

$HADOOP_HOME/binhdfs namenode -format$HADOOP_HOME/binhdfs --daemon start namenode

而后在nn2和nn3上同步nn1的元数据信息。

$HADOOP_HOME/binbin/hdfs namenode -bootstrapStandby

看下各个节点状态

==============hadoop14 jps================8885 JournalNode9157 NameNode7190 QuorumPeerMain9544 Jps==============hadoop15 jps================4579 QuorumPeerMain5859 NameNode5940 Jps5083 JournalNode==============hadoop16 jps================3811 JournalNode4053 NameNode3305 QuorumPeerMain4124 Jps

有三个namenode启动胜利,此刻三个namenode都处于standby状态。
5)启动所有datanode

hdfs --daemon start datanode

6)将nn1设为Active

hdfs haadmin -transitionToActive nn1

这个时候还没有完结,因为当初能做的只是手动切换Active和Standby,还没有实现namenode主动切换,
实现主动切换就要借助ZooKeeper和ZKFailoverController(ZKFC)两个新组件,咱们先简略说下这两个组件的作用,再进行配置。

ZooKeeper保护大量协调数据,告诉客户端这些数据的扭转和监督客户端故障的高可用服务,Zookeeper有以下性能:
a)故障检测:ZooKeeper中为集群中的每个NameNode保护了一个长久会话,如果节点挂了,那ZooKeeper中的会话将终止,ZooKeeper告诉另一个NameNode须要触发故障转移。
b)Active NameNode抉择:ZooKeeper提供了一个简略的ActiveNameNode抉择机制,用于惟一的抉择一个节点为active状态,其实就是锁机制。

ZKFC是ZooKeeper的客户端,监督和治理NameNode的状态,它是实现HA的另一个组件。每个运行NameNode的主机上也运行了一个ZKFC过程,ZKFC负责:
a)衰弱监测:咱们须要晓得NameNode的衰弱状态,ZKFC定期地ping与之在雷同主机的NameNode,只有该NameNode及时地回复衰弱状态,ZKFC认为该节点是衰弱的,如果该节点挂了,解冻或进入不衰弱状态,衰弱监测器标识该节点为非衰弱的。
b)ZooKeeper会话治理:当本地NameNode是衰弱的,ZKFC放弃一个在ZooKeeper中关上的会话。如果本地NameNode处于active状态,ZKFC也放弃一个非凡的znode锁,该锁应用了ZooKeeper对长期节点的反对,如果会话终止,锁节点将主动删除。
c)基于ZooKeeper的抉择:如果本地NameNode是衰弱的,且ZKFC发现没有其它的节点以后持有znode锁,它将为本人获取该锁。如果胜利,则它曾经博得了抉择,并负责运行故障转移过程以使它的本地NameNode为Active。故障转移过程与后面形容的手动故障转移类似,首先如果必要爱护之前的现役NameNode,而后本地NameNode转换为Active状态。

好了,理解完这两个组件,持续进行咱们的配置

7)hdfs-site.xml中减少

<property>    <name>dfs.ha.automatic-failover.enabled</name>    <value>true</value></property>

8)core-site.xml减少

<property>    <name>ha.zookeeper.quorum</name>    <value>hadoop14:2181,hadoop15:2181,hadoop16:2181</value></property>

9)启动
9-1)敞开所有hdfs服务
9-2)在每个节点上启动Zookeeper服务,生成环境中可本人写群启服务的脚本。
9-3)在每个节点上初始化Zookeeper中HA的状态

hdfs zkfc -formatZK

9-4)启动HDFS服务

start-dfs.sh

至此配置实现了。
咱们在web登录,能够看到一个Active,两个Standby。
咱们也能够进行验证是否胜利,kill掉Active节点,看看切换是否胜利。

可能会要的问题

No Route to Host from  hadoop......

这个个别是防火墙的关系,关掉防火墙个别能够了,这个不过多赘述。

3.2.2 Yarn HA

1.yarn-site.xml

<property>        <name>yarn.nodemanager.aux-services</name>        <value>mapreduce_shuffle</value>    </property>    <!--启用resourcemanager ha-->    <property>        <name>yarn.resourcemanager.ha.enabled</name>        <value>true</value>    </property>     <!--申明两台resourcemanager的地址-->    <property>        <name>yarn.resourcemanager.cluster-id</name>        <value>cluster-yarn1</value>    </property>    <property>        <name>yarn.resourcemanager.ha.rm-ids</name>        <value>rm1,rm2</value>    </property>    <property>        <name>yarn.resourcemanager.hostname.rm1</name>        <value>hadoop15</value>    </property>    <property>        <name>yarn.resourcemanager.hostname.rm2</name>        <value>hadoop16</value>    </property>     <!--指定zookeeper集群的地址-->     <property>        <name>yarn.resourcemanager.zk-address</name>        <value>hadoop14:2181,hadoop15:2181,hadoop16:2181</value>    </property>    <!--启用主动复原-->     <property>        <name>yarn.resourcemanager.recovery.enabled</name>        <value>true</value>    </property>     <!--指定resourcemanager的状态信息存储在zookeeper集群-->     <property>        <name>yarn.resourcemanager.store.class</name>     <value>org.apache.hadoop.yarn.server.resourcemanager.recovery.ZKRMStateStore</value></property>

2.启动yarn

start-yarn.sh

3)查看服务状态

[v2admin@hadoop14 ha]$ yarn rmadmin -getServiceState rm1standby[v2admin@hadoop14 ha]$ yarn rmadmin -getServiceState rm2active

至此Hadoop的HA配置实现了。