资讯

精准传达 • 有效沟通

从品牌网站建设到网络营销策划,从策略到执行的一站式服务

hadoop的HA-创新互联

1. 为什么要搭建HA?

在hadoop2.x之前,在HDFS 集群中NameNode 存在单点故障 (SPOF:A Single Point of Failure)。对于只有一个 NameNode 的集群,如果 NameNode 机器出现故障(比如宕机或是软件、硬件升级),那么整个集群将无法使用,必须等到 NameNode 重新启动,之后才能对外提供服务,这个方式在生成环境中是绝对不允许出现的。
HDFS 的 HA:通过配置 Active/Standby 两个 NameNodes 实现在集群中对 NameNode 的热备来解决上述问题。如果出现故障,如机器崩溃或机器需要升级维护,这时可通过此种方式将 NameNode 很快的切换到另外一台机器。

浚县网站制作公司哪家好,找创新互联!从网页设计、网站建设、微信开发、APP开发、响应式网站设计等网站项目制作,到程序开发,运营维护。创新互联于2013年开始到现在10年的时间,我们拥有了丰富的建站经验和运维经验,来保证我们的工作的顺利进行。专注于网站建设就选创新互联

2. HA的工作原理?

hadoop的HA
解释(数据一致以及持久化问题):

  • 当hdfs客户端连接namenode时,namenode启动时,会向JN集群提交edtis log(操作记录日志)。
  • 此时在JN集群中,当有一半的集群服务成功的接收到了消息,然后返回给namenode,这就表示edits log上传成功。
  • 此时NameNode(standBy),需要从JN集群取回元数据信息,然后整合新的fsimage,然后推送回NameNode(active)
  • 在NameNode(standBy)向JN索要数据的时候,首先在JN中会查看是否有宕机的机器,采用过半机制(当集群中有部分服务器宕机时,此时集群会将大部分可以使用的机器作为主,其他的机器全部停止服务),去向备机(standBy)提供对外的数据传输。
  • 在解决block 块信息时,此时datanode会向两台namenode都发送block 块信息。
    解释(解决主备切换问题):
  • 此时需要使用到另外一个集群zookeeper,zookeeper集群是一个高可用的集群,它的实现机制是,首先是一个服务器提供对外的服务,其他的机器是备机,当主机坏了的时候,此时zookeeper集群中采取投票机制(逻辑时钟,ID号,以及数据的更新程度),选出新的主。
  • 此时ZKFC务控制线程一直手抓住了zookeeper集群,另一只手抓住了NameNode。
    • 抓住NameNode(active)的服务控制,监控NameNode(active)的状态,实时的向zookeeper集群汇报。
    • 住NameNode(standBy)的服务控制,接收zookeeper集群发送的信息,如果发送过来的信息,表示主NameNode已停止服务,立刻调用服务控制中的回调函数,让NameNode(standBy)变成主机继续提供服务。
  •  以上的作用是一个和keeplive相同的作用,使用zookeeper不同之处在于,如果服务控制处出现进程的异常退出时,此时通过zookeeper集群会将备机改为active状态,此时主机可能还是active,就造成了两台active的NameNode。在zookeeper中是这样解决的:当有一个服务控制进程异常退出后,他会有一只无形的手去连接另外一台NameNode,并且在可控的范围内,将其变成主(active),而将自己无法控制的那台NameNode,变成备机。

    3. HA的集群搭建?

    搭建集群前的准备:https://blog.51cto.com/14048416/2341450
    zookeeper集群的搭建:https://blog.51cto.com/14048416/2336178

    1)集群的规划

    hadoop的HA

    2)具体安装步骤:

    1)上传安装包 hadoop-2.6.5-centos-6.7.tar.gz
    2)解压到对应的安装目录

    [hadoop@hadoop01 ~]$tar -zxvf hadoop-2.6.5-centos-6.7.tar.gz -C /home/hadoop/apps/

    3)修改配置文件

    hadoo-env.sh:
    加入:export JAVA_HOME= /usr/local/jdk1.8.0_73

core-site.xml




fs.defaultFS
hdfs://myha01/



hadoop.tmp.dir
/home/hadoop/data/hadoopdata/



ha.zookeeper.quorum
hadoop01:2181,hadoop02:2181,hadoop03:2181

hdfs-site.xml




 dfs.replication
 3



 dfs.nameservices
 myha01



 dfs.ha.namenodes.myha01
 nn1,nn2



 dfs.namenode.rpc-address.myha01.nn1
 hadoop01:9000



 dfs.namenode.http-address.myha01.nn1
 hadoop01:50070



 dfs.namenode.rpc-address.myha01.nn2
 hadoop02:9000



 dfs.namenode.http-address.myha01.nn2
 hadoop02:50070



 dfs.namenode.shared.edits.dir
qjournal://hadoop01:8485;hadoop02:8485;hadoop03:8485/myha01



 dfs.journalnode.edits.dir
 /home/hadoop/data/journaldata



 dfs.ha.automatic-failover.enabled
 true




 dfs.client.failover.proxy.provider.myha01
org.apache.hadoop.hdfs.server.namenode.ha.ConfiguredFailoverPr
oxyProvider



 dfs.ha.fencing.methods
 
 sshfence
 shell(/bin/true)
 



 dfs.ha.fencing.ssh.private-key-files
 /home/hadoop/.ssh/id_rsa



 dfs.ha.fencing.ssh.connect-timeout
 30000

mapred-site.xml




 mapreduce.framework.name
 yarn



mapreduce.jobhistory.address
hadoop02:10020



mapreduce.jobhistory.webapp.address
hadoop02:19888

yarn-site.xml




 yarn.resourcemanager.ha.enabled
 true



 yarn.resourcemanager.cluster-id
 yrc



 yarn.resourcemanager.ha.rm-ids
 rm1,rm2



 yarn.resourcemanager.hostname.rm1
 hadoop01


 yarn.resourcemanager.hostname.rm2
 hadoop02



 yarn.resourcemanager.zk-address
 hadoop01:2181,hadoop02:2181,hadoop03:2181



 yarn.nodemanager.aux-services
 mapreduce_shuffle



 yarn.log-aggregation-enable
 true



 yarn.log-aggregation.retain-seconds
 86400



 yarn.resourcemanager.recovery.enabled
 true



 yarn.resourcemanager.store.class
org.apache.hadoop.yarn.server.resourcemanager.recovery.ZKRMStateStore

slaves

hadoop01
hadoop02
hadoop03
4)分发安装包到其他机器

[hadoop@hadoop01 apps]$scp -r hadoop-2.6.5 hadoop@hadoop02:$PWD
[hadoop@hadoop01 apps]$scp -r hadoop-2.6.5 hadoop@hadoop03:$PWD

5)分别配置环境变量

[hadoop@hadoop01 apps]$ vi ~/.bashrc
添加两行:

export HADOOP_HOME=/home/hadoop/apps/hadoop-2.6.5
export PATH=$PATH:$HADOOP_HOME/bin:$HADOOP_HOME/sbin

[hadoop@hadoop01 apps]$ source ~/.bashrc

6)集群初始化操作

先启动 zookeeper 集群
启动:zkServer.sh start
检查启动是否正常:zkServer.sh status
启动 journalnode 进程
[hadoop@hadoop01 ~]$ hadoop-daemon.sh start journalnode
[hadoop@hadoop02 ~]$ hadoop-daemon.sh start journalnode
[hadoop@hadoop03 ~]$ hadoop-daemon.sh start journalnode
然后用 jps 命令查看是否各个 datanode 节点上都启动了 journalnode 进程
在第一个 namenode 上执行格式化操作
[hadoop@hadoop01 ~]$ hadoop namenode -format
hadoop的HA
然后会在 core-site.xml 中配置的临时目录中生成一些集群的信息把他拷贝的第二个 namenode 的相同目录下
hadoop.tmp.dir
/home/hadoop/data/hadoopdata/
两个 namenode 节点该目录中的数据结构是一致的
[hadoop@hadoop01 ~]$ scp -r ~/data/hadoopdata/ hadoop03:~/data
或者在另一个namenode节点上使用:hadoop namenode -bootstrapStandby
格式化 ZKFC(在一台集群上格式化即可):
[hadoop@hadoop01 ~]$ hdfs zkfc -formatZK
启动 HDFS
[hadoop@hadoop01 ~]$ start-dfs.sh
启动 YARN
[hadoop@hadoop01 ~]$ start-yarn.sh
若备用节点的 resourcemanager 没有启动起来,则手动启动起来:
[hadoop@hadoop02 ~]$ yarn-daemon.sh start resourcemanager

7)补充:

查看各主节点的状态
HDFS:
hdfs haadmin -getServiceState nn1
hdfs haadmin -getServiceState nn2

YARN:
yarn rmadmin -getServiceState rm1
yarn rmadmin -getServiceState rm2

4. HA的集群搭建后测试

1.手动杀死active的namenode,看看集群的状况
2.手动杀死active的resourcemanager,看看集群的状况
3.在上传文件时,杀死namenode,查看集群状况
4.在执行任务时,杀死resourcemanager,查看集群状态

另外有需要云服务器可以了解下创新互联scvps.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。


网站标题:hadoop的HA-创新互联
文章分享:http://cdkjz.cn/article/desdjo.html
多年建站经验

多一份参考,总有益处

联系快上网,免费获得专属《策划方案》及报价

咨询相关问题或预约面谈,可以通过以下方式与我们联系

业务热线:400-028-6601 / 大客户专线   成都:13518219792   座机:028-86922220