构建Hadoop+Hbase+ZooKeeper分布式存储

简介:

 前言* Hadoop是Apache开源组织的一个分布式计算开源框架,在很多大型网站上都已经得到了应用,如亚马逊、Facebook和Yahoo等等。对于我来说,最近的一个使用点就是服务集成平台的日志分析。服务集成平台的日志量将会很大,而这也正好符合了分布式计算的适用场景(日志分析和索引建立就是两大应用场景)。

今天我们来实际搭建一下Hadoop 2.2.0版,实战环境为目前主流服务器操作系统CentOS 6.5系统。

一、实战环境

1
2
3
4
5
6
系统版本:CentOS 6.5 x86_64
JAVA版本:JDK-1.7.0_25
Hadoop版本:hadoop-2.2.0
192.168.172.59   namenode  (充当namenode、secondary namenode和ResourceManager角色)
192.168.172.88   datanode1  (充当datanode、nodemanager角色)
192.168.172.89   datanode2  (充当datanode、nodemanager角色)

二、系统准备

1)Hadoop可以从Apache官方网站直接下载最新版本Hadoop2.2。官方目前是提供了linux32位系统可执行文件,所以如果需要在64位系统上部署则需要单独下载src 源码自行编译。(如果是真实线上环境,请下载64位hadoop版本,这样可以避免很多问题,这里我实验采用的是32位版本)

1
2
3
4
Hadoop下载地址
http: //apache .claz.org /hadoop/common/hadoop-2 .2.0/
Java 下载下载
http: //www .oracle.com /technetwork/java/javase/downloads/index .html

2)我们这里采用三台CnetOS服务器来搭建Hadoop集群,分别的角色如上已经注明。

第一步:我们需要在三台服务器的/etc/hosts里面设置对应的主机名如下(真实环境可以使用内网DNS解析)

1
2
3
4
5
6
7
[root@node1 hadoop] # cat /etc/hosts
# Do not remove the following line, or various programs
# that require network functionality will fail.
127.0.0.1 localhost.localdomain localhost
192.168.172.59  node1
192.168.172.88  node2
192.168.172.89  node3(注* 我们需要在namenode、datanode三台服务器上都配置hosts解析)

3)从namenode上无密码登陆各台datanode服务器,需要做如下配置:

1
2
3
4
在namenode 128上执行 ssh -keygen,一路Enter回车即可。
然后把公钥 /root/ . ssh /id_rsa .pub拷贝到datanode服务器即可,拷贝方法如下:
ssh -copy- id  -i . ssh /id_rsa .pub root@192.168.172.88
ssh -copy- id  -i . ssh /id_rsa .pub root@192.168.172.89

三、Java安装配置

1
2
3
4
5
tar   -xvzf  jdk-7u25-linux-x64. tar .gz && mkdir  -p   /usr/java/   ;  mv    /jdk1 .7.0_25     /usr/java/  即可。
安装完毕并配置java环境变量,在 /etc/profile 末尾添加如下代码:
export  JAVA_HOME= /usr/java/jdk1 .7.0_25/
export  PATH=$JAVA_HOME /bin :$PATH
export  CLASSPATH=$JAVE_HOME /lib/dt .jar:$JAVE_HOME /lib/tools .jar:./

保存退出即可,然后执行source  /etc/profile 生效。在命令行执行java -version 如下代表JAVA安装成功。

1
2
3
4
[root@node1 ~] # java -version
java version  "1.7.0_25"
Java(TM) SE Runtime Environment (build 1.7.0_25-b15)
Java HotSpot(TM) 64-Bit Server VM (build 23.25-b01, mixed mode)

(注* 我们需要在namenode、datanode三台服务器上都安装Java JDK版本)

四、Hadoop版本安装

官方下载的hadoop2.2.0版本,不用编译直接解压安装就可以使用了,如下:

1)解压:

tar  -xzvf  hadoop-2.2.0.tar.gz &&mv hadoop-2.2.0  /data/hadoop/
(注* 先在namenode服务器上都安装hadoop版本即可,datanode先不用安装,待会修改完配置后统一安装datanode)

2)配置变量:

1
2
3
4
5
在 /etc/profile 末尾继续添加如下代码,并执行 source  /etc/profile 生效。
export  HADOOP_HOME= /data/hadoop/
export  PATH=$PATH:$HADOOP_HOME /bin/
export  JAVA_LIBRARY_PATH= /data/hadoop/lib/native/
(注* 我们需要在namenode、datanode三台服务器上都配置Hadoop相关变量)

五、配置Hadoop

在namenode上配置,我们需要修改如下几个地方:

1)修改vi/data/hadoop/etc/hadoop/core-site.xml 内容为如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
<? xml  version = "1.0" ?>
<? xml-stylesheet  type = "text/xsl"  href = "configuration.xsl" ?>
<!-- Put site-specific property overrides in this file. -->
< configuration >
< property >
   < name >fs.default.name</ name >
   < value >hdfs://node1:9000</ value >
  </ property >
< property >
   < name >hadoop.tmp.dir</ name >
   < value >/tmp/hadoop-${user.name}</ value >
   < description >A base for other temporary directories.</ description >
</ property >
</ configuration >

2)修改vi/data/hadoop/etc/hadoop/mapred-site.xml内容为如下:

1
2
3
4
5
6
7
8
9
<? 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 >node1:9001</ value >
      </ property >
</ configuration >

3)修改vi/data/hadoop/etc/hadoop/hdfs-site.xml内容为如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
<? xml  version = "1.0"  encoding = "UTF-8" ?>
<? xml-stylesheet  type = "text/xsl"  href = "configuration.xsl" ?>
< configuration >
< property >
< name >dfs.name.dir</ name >
< value >/data/hadoop/data_name1,/data/hadoop/data_name2</ value >
</ property >
< property >
< name >dfs.data.dir</ name >
< value >/data/hadoop/data_1,/data/hadoop/data_2</ value >
</ property >
< property >
< name >dfs.replication</ name >
< value >2</ value >
</ property >
</ configuration >

4)在/data/hadoop/etc/hadoop/hadoop-env.sh文件末尾追加JAV_HOME变量:

1
echo  "export JAVA_HOME=/usr/java/jdk1.7.0_25/"  >>  /data/hadoop/etc/hadoop/hadoop-env .sh

5)修改 vi /data/hadoop/etc/hadoop/masters文件内容为如下:

1
node1

6)修改vi/data/hadoop/etc/hadoop/slaves文件内容为如下:

1
2
node2
node3

如上配置完毕,以上的配置具体含义在这里就不做过多的解释了,搭建的时候不明白,可以查看一下相关的官方文档。

如上namenode就基本搭建完毕,接下来我们需要部署datanode,部署datanode相对简单,执行如下操作即可。

1
for   i   in   ` seq  88 89 ` ;  do  scp  -r   /data/hadoop/   root@192.168.172.$i: /data/   ;  done

自此整个集群基本搭建完毕,接下来就是启动hadoop集群了。

六、启动hadoop并测试

在启动hadoop之前,我们需要做一步非常关键的步骤,需要在namenode上执行如下命令初始化name目录和数据目录。

1
cd    /data/hadoop/  ; . /bin/hadoop  namenode - format

那如何算初始化成功呢,如下截图成功创建name目录即正常:

wKioL1iryJ_AEMlxAACGaUNkQTA420.gif

然后启动hadoop所有服务,如下命令:

[root@node1 hadoop]# ./sbin/start-all.sh

wKiom1iryN6Qa1lXAACL5AXQH38773.gif

我们还可以查看相应的端口是否启动:netstat -ntpl

wKioL1ir0fPRj4H0AABYgmXmODU129.gif-wh_50

访问如下地址:http://192.168.172.59:50070/

wKioL1iryRCj71g6AABMT7-2-ao865.png-wh_50

访问地址:http://192.168.172.59:8088/

wKioL1ir0g2x-XrpAACJ09JP5ho357.gif-wh_50

搭建完成后,我们简单的实际操作一下,如下图:

wKiom1ir0hrykwkiAABPSgBA6pM612.gif-wh_50

自此hadoop基本搭建完毕。

七、部署ZooKeeper服务

在node1上配置:

下载zookeeper3.4.6版本:

1
2
wget http: //apache .fayea.com /zookeeper/zookeeper-3 .4.6 /zookeeper-3 .4.6. tar .gz
tar  -xzfzookeeper-3.4.6. tar .gz  -C   /export/servers/

#vim   /export/servers/ zookeeper-3.4.6/conf/zoo.cfg写入如下内容:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
# The number of milliseconds of each tick
tickTime=2000
# The number of ticks that the initial
# synchronization phase can take
initLimit=10
# The number of ticks that can pass between
# sending a request and getting an acknowledgement
syncLimit=5
# the directory where the snapshot is stored.
dataDir= /export/zookeeper
# the port at which the clients will connect
clientPort=2181
initLimit=5
syncLimit=2
dataLogDir= /export/zookeeper/logs
server.1=node1:2888:3888
server.2=node2:2888:3888
server.3=node3:2888:3888

注意:zk里面的node节点名称要一一对应哦,然后创建zk数据目录和日志路径:

1
2
mkdir   -p   /export/zookeeper/logs
echo   1  > /export/zookeeper/myid

如上在node1上配置好zk后,把zk整个程序同步到另外两台node2、node3。

执行如下脚本:

1
for   i  in   ` seq  88 89` ;  do  rsync  -aP--delete  /export/servers/zookeeper-3 .4.6/ root@192.168.172.$i: /export/servers/zookeeper-3 .4.6/  ; rsync -av   /export/zookeeper/   root@192.168.172.$i: /export/ ;  done

然后分别修改node2、node3的myid为2和3,命令如下:

在node2上执行:

1
echo   2  > /export/zookeeper/myid

在node3上执行:

1
echo   3  > /export/zookeeper/myid

执行完后,分别启动三台服务器的zk服务:

1
cd /export/servers/zookeeper-3 .4.6/ ;. /bin/zkServer .sh start

wKiom1iryVaQwvZoAAA3d48xFnE195.png-wh_50

如上配置,zookeeper配置完毕。

八、部署Hbase服务

在node1上配置:

1
2
3
4
下载软件:hbase-0.96.2-hadoop2. tar .gz,然后执行如下命令:
tarxf hbase-0.96.2-hadoop2. tar .gz ; mv  hbase-0.96.2-hadoop2  /export/hbase
然后进入hbase配置文件目录,如下图:
cd /export/hbase/conf/

wKioL1iryjqQjqdeAAAU-sPYUCE560.png-wh_50

vim hbase-site.xml内容如下:

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
< configuration >
    < property >
            < name >hbase.tmp.dir</ name >
            < value >/export/hbase/tmp</ value >
         </ property >
            
< property > 
    < name >zookeeper.session.timeout</ name > 
     < value >3600000</ value > 
</ property >
< property > 
    < name >hbase.zookeeper.property.tickTime</ name > 
     < value >180000</ value >
</ property >
         < property >
            < name >hbase.rootdir</ name >
            < value >hdfs://node1:9000/hbase</ value >
         </ property >
         < property >
            < name >hbase.cluster.distributed</ name >
             < value >true</ value >
         </ property >
< property >
            < name >hbase.zookeeper.quorum</ name >
            < value >node1,node2,node3</ value >
</ property >
<!--禁止magor compaction-->
< property >
< name >hbase.hregion.majorcompaction</ name >
< value >0</ value >
</ property >
<!--禁止split-->
  < property >
  < name >hbase.hregion.max.filesize</ name >
    < value >536870912000</ value >
  </ property >
  <!---->
  < property >
  < name >hbase.hstore.blockingStoreFiles</ name >
  < value >2100000000</ value >
  </ property >
  < property >
  < name >hbase.regionserver.handler.count</ name >
  < value >100</ value >
  </ property >
</ configuration >

vim hbase-env.sh内容如下:

1
2
3
4
exportJAVA_HOME= /export/servers/jdk1 .6.0_25/
exportHBASE_OPTS= "-XX:+UseConcMarkSweepGC"
exportHBASE_MANAGES_ZK= false
exportHADOOP_HOME= /export/hadoop/

vim regionservers内容如下:

1
2
node2
node3

然后将node1 habse配置同步至node2、node3:

1
for   i  in   ` seq  88 89` ;  do  rsync  -av   /export/hbase/   root@192.168.172.$i: /export/   ;  done

最好在node1启动整个集群hbase即可:

1
cd  /export/hbase/ ;shbin /start-hbase .sh

wKiom1irylDTng_SAAAcopDn9AI995.png-wh_50

查看node1 JAVA进程信息如下:

wKioL1irymXAKi3QAABy8H6Xjj4062.png-wh_50

最好查看hbase日志如下:

wKiom1ir0i-DxQHWAAD7KcC4ggE078.png-wh_50

通过web查看hbase截图如下:

wKioL1iryorAqYK5AACL-Z7CRoY367.png-wh_50

NODE2状态:

-----------------------------------------------------------

wKiom1irypyBxsolAABypNYshs0494.png-wh_50


你若觉得作者的文章写得不错,请奖励作者几锭银子,让作者感受到来自你满满的鼓励和继续创作的动力!我们支持原创!鼓励原创!

打赏之后,文章底部显示参与打赏者的记录,可以直接通过微信扫描打赏哟,直接按打赏根据提示操作。

自定义打赏金额,友情提示打赏金额不要超过50元哦,土豪可以随意哦,51CTO谢谢您对作者的支持!谢谢你的慷慨大方!

wKioL1lDsc3i7hEqAAAfoPude7I249.png


本文转自 wgkgood 51CTO博客,原文链接:http://blog.51cto.com/wgkgood/1899771


相关文章
|
人工智能 Java Nacos
基于 Spring AI Alibaba + Nacos 的分布式 Multi-Agent 构建指南
本文将针对 Spring AI Alibaba + Nacos 的分布式多智能体构建方案展开介绍,同时结合 Demo 说明快速开发方法与实际效果。
6129 122
|
存储 Kubernetes 微服务
Dapr:用于构建分布式应用程序的便携式事件驱动运行时
Dapr 是一个可移植、事件驱动的运行时,简化了分布式应用程序的开发。它支持多语言、多框架,适用于云和边缘计算环境,提供服务调用、状态管理、消息发布/订阅等构建模块。通过 sidecar 模式,Dapr 帮助开发者轻松应对微服务架构的复杂性,实现弹性、可扩展的应用部署。
750 9
Dapr:用于构建分布式应用程序的便携式事件驱动运行时
|
监控 Java API
Spring Boot 3.2 结合 Spring Cloud 微服务架构实操指南 现代分布式应用系统构建实战教程
Spring Boot 3.2 + Spring Cloud 2023.0 微服务架构实践摘要 本文基于Spring Boot 3.2.5和Spring Cloud 2023.0.1最新稳定版本,演示现代微服务架构的构建过程。主要内容包括: 技术栈选择:采用Spring Cloud Netflix Eureka 4.1.0作为服务注册中心,Resilience4j 2.1.0替代Hystrix实现熔断机制,配合OpenFeign和Gateway等组件。 核心实操步骤: 搭建Eureka注册中心服务 构建商品
1725 3
|
负载均衡 Java API
《深入理解Spring》Spring Cloud 构建分布式系统的微服务全家桶
Spring Cloud为微服务架构提供一站式解决方案,涵盖服务注册、配置管理、负载均衡、熔断限流等核心功能,助力开发者构建高可用、易扩展的分布式系统,并持续向云原生演进。
|
消息中间件 缓存 监控
中间件架构设计与实践:构建高性能分布式系统的核心基石
摘要 本文系统探讨了中间件技术及其在分布式系统中的核心价值。作者首先定义了中间件作为连接系统组件的&quot;神经网络&quot;,强调其在数据传输、系统稳定性和扩展性中的关键作用。随后详细分类了中间件体系,包括通信中间件(如RabbitMQ/Kafka)、数据中间件(如Redis/MyCAT)等类型。文章重点剖析了消息中间件的实现机制,通过Spring Boot代码示例展示了消息生产者的完整实现,涵盖消息ID生成、持久化、批量发送及重试机制等关键技术点。最后,作者指出中间件架构设计对系统性能的决定性影响,
|
数据采集 存储 NoSQL
Scrapy 框架实战:构建高效的快看漫画分布式爬虫
Scrapy 框架实战:构建高效的快看漫画分布式爬虫
|
分布式计算 Ubuntu Hadoop
Ubuntu22.04下搭建Hadoop3.3.6+Hbase2.5.6+Phoenix5.1.3开发环境的指南
呈上,这些步骤如诗如画,但有效且动人。仿佛一个画家在画布上描绘出一幅完美的画面,这就是你的开发环境。接下来,尽情去创造吧,祝编程愉快!
1299 19
|
消息中间件 分布式计算 并行计算
Python 高级编程与实战:构建分布式系统
本文深入探讨了 Python 中的分布式系统,介绍了 ZeroMQ、Celery 和 Dask 等工具的使用方法,并通过实战项目帮助读者掌握这些技术。ZeroMQ 是高性能异步消息库,支持多种通信模式;Celery 是分布式任务队列,支持异步任务执行;Dask 是并行计算库,适用于大规模数据处理。文章结合具体代码示例,帮助读者理解如何使用这些工具构建分布式系统。
|
存储 运维 负载均衡
构建高可用性GraphRAG系统:分布式部署与容错机制
【10月更文挑战第28天】作为一名数据科学家和系统架构师,我在构建和维护大规模分布式系统方面有着丰富的经验。最近,我负责了一个基于GraphRAG(Graph Retrieval-Augmented Generation)模型的项目,该模型用于构建一个高可用性的问答系统。在这个过程中,我深刻体会到分布式部署和容错机制的重要性。本文将详细介绍如何在生产环境中构建一个高可用性的GraphRAG系统,包括分布式部署方案、负载均衡、故障检测与恢复机制等方面的内容。
987 4
构建高可用性GraphRAG系统:分布式部署与容错机制

相关实验场景

更多