热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

ApacheHadoop2.8.0伪分布式环境搭建

ApacheHadoop是一个支持数据密集型分布式应用程序的开源软件框架,能在大型集群上运行应用程序。Hadoop框架实现了MapReduce编程范式,

Apache Hadoop 是一个支持数据密集型分布式应用程序的开源软件框架,能在大型集群上运行应用程序。Hadoop 框架实现了 MapReduce 编程范式,把应用程序分成许多小部分,每个部分能在任意节点上运行。并且 Hadoop 提供了分布式文件系统存储所有计算节点的数据,为集群带来非常高的带宽。


1 Hadoop 是什么?

Apache Hadoop 是一个支持数据密集型分布式应用程序的开源软件框架,能在大型集群上运行应用程序。Hadoop 框架实现了 MapReduce 编程范式,把应用程序分成许多小部分,每个部分能在任意节点上运行。并且 Hadoop 提供了分布式文件系统存储所有计算节点的数据,为集群带来非常高的带宽。


2 搭建说明

本文几乎所有操作都需要在三台服务器上进行同样的操作,所以为了便于表示,在需要三台服务器上进行同样操作的时候会使用 x3 进行标注。

命令当中的 # 代表 root 用户执行。
命令当中的 $ 代表 hadoop 用户执行。
### 为该命令的注释。
注:可在一台机子上配置好后利用 scp 命令进行复制,若在虚拟机则可直接复制虚拟机。


2.1 节点机器配置


NodeNameOSCPURAMDiskIP
NameNodeCentOS 7.2E7-4830 v3 @ 2.10GHz x22G100G192.168.1.69
DataNode1CentOS 7.2E7-4830 v3 @ 2.10GHz x22G500G192.168.1.70
DataNode2CentOS 7.2E7-4830 v3 @ 2.10GHz x22G500G192.168.1.7

2.2 软件包版本


SoftwareVersion
JDKOracle JDK 1.8.0_131(非OpenJDK)
Hadoop2.8.0

3 安装JDK x3

# mkdir -p /usr/local/java
# cd /usr/local/java
# wget http://download.oracle.com/otn-pub/java/jdk/8u131-b11/d54c1d3a095b4ff2b6607d096fa80163/jdk-8u131-linux-x64.tar.gz
# tar -xvzf jdk-8u131-linux-x64.tar.gz

### 设置新的 JDK 为默认 JDK,如果机器已经安装 OpenJDK,可能需要先卸载。
# echo "export JAVA_HOME=/usr/local/java/jdk1.8.0_131/" >> /etc/profile
# echo "export PATH=$PATH:$JAVA_HOME/bin" >> /etc/profile
# source /etc/profile

# $JAVA_HOME/bin/java -version ### 测试运行

java version "1.8.0_131"Java(TM) SE Runtime Environment (build 1.8.0_131-b11)Java HotSpot(TM) 64-Bit Server VM (build 25.131-b11, mixed mode)

4 关闭防火墙 x3

直接关闭整个防火墙不是一个明智的选择,在具体环境中应该挑选出需要的端口,进行放行,本文由于篇幅原因,不再详细讨论,故采用直接关闭防火墙的方法。

# systemctl stop firewalld.service
# systemctl disable firewalld.service

5 配置 hostname 及局域网映射 x3

# hostnamectl set-hostname namenode ### 为 namenode 节点设置 hostname
# hostnamectl set-hostname datanode1 ### 为 datanode1 节点设置 hostname
# hostnamectl set-hostname datanode2 ### 为 datanode2 节点设置 hostname
# echo "192.168.1.69 namenode" >> /etc/hosts
# echo "192.168.1.70 datanode1" >> /etc/hosts
# echo "192.168.1.71 datanode2" >> /etc/hosts

6 创建 hadoop 用户以及 hadoop 用户组 x3

# groupadd hadoop
# useradd -m -g hadoop hadoop
# passwd hadoop

7 SSH 免密登录

Hadoop 在 namenode 节点中使用 ssh 来访问各节点服务器,例如开启或关闭 hadoop。显然在大型集群中,不可能手动逐个输入密码,在这种情况下,我们可以利用 ssh-agent 代理我们输入密码。
注:该设置只需要在 namenode 节点设置。


7.1 ssh-agent

配置 ssh-agent 开机自动运行

# echo 'eval $(ssh-agent)' >> /etc/profile
# source /etc/profile

7.2 配置免密登录

在 namenode 节点上登录 hadoop 用户

$ ssh-keygen -t rsa -f ~/.ssh/id_rsa ### 输入密钥
$ cat ~/.ssh/id_rsa.pub >> ~/.ssh/authorized_keys
$ chmod 644 ~/.ssh/authorized_keys
$ ssh-copy-id datanode1 ### 将公钥 copy 到 datanode1
$ ssh-copy-id datanode2 ### 将公钥 copy 到 datanode2
$ ssh-add ~/.ssh/id_rsa ### 使用 ssh-agent 实现免密登录
$ ssh datanode1 ### 测试无需密码即可登录 datanode1

8 磁盘挂载(可选) x3

# mkdir /home/hadoop/hdfs
# mount /dev/sdb1 /home/hadoop/hdfs/
# chown -R hadoop:hadoop /home/hadoop/hdfs/
# echo "/dev/sdb1 /home/hadoop/hdfs ext4 defaults 0 0" >> /etc/fstab

9 安装 Hadoop x3

# cd /usr/local
# wget https://mirrors.scau.edu.cn/hadoop/hadoop-2.8.0.tar.gz ### 使用自己的镜像源
# wget https://mirrors.ustc.edu.cn/apache/hadoop/common/hadoop-2.8.0/hadoop-2.8.0.tar.gz
# tar -xvzf hadoop-2.8.0.tar.gz
# chown -R hadoop:hadoop hadoop-2.8.0

10 配置 Hadoop x3

复制默认配置文件,在升级 hadoop 版本时可独立出来。

$ mkdir ~/config/
$ cp -r /usr/local/hadoop-2.8.0/etc/hadoop/ ~/config/

指定 hadoop 运行所使用的 JDK 与配置目录, vim ~/config/hadoop/hadoop-env.sh

$ export JAVA_HOME=/usr/local/java/jdk1.8.0_131/
$ export HADOOP_CONF_DIR=/home/hadoop/config/hadoop/
# echo "export HADOOP_CONF_DIR=/home/hadoop/config/hadoop/" >> /etc/profile ### 最好将该环境变量也加入 /etc/profile

10.1 log 存储位置

修改 hadoop log 存储位置。

$ echo "export HADOOP_LOG_DIR=~/log/hadoop" >> ~/config/hadoop/hadoop-env.sh

修改 YARN log 存储位置,

$ vim config/hadoop/yarn-env.sh。 ###进行如下修改YARN_LOG_DIR="/home/hadoop/log/yarn/"

10.2 配置 core-site.xml

$ vim ~/config/hadoop/core-site.xml ###进行如下修改

<configuration><property><description>默认文件系统及端口description> <name>fs.defaultFSname><value>hdfs://namenode/value><final>truefinal>property>
configuration>

10.3 配置 hdfs-site.xml

$ vim ~/config/hadoop/hdfs-site.xml ###进行如下修改

<configuration><property><description>namedoe 存储永久性的元数据目录列表description> <name>dfs.namenode.name.dirname><value>/home/hadoop/hdfs/name/value><final>truefinal>property><property><description>datanode 存放数据块的目录列表description> <name>dfs.datanode.data.dirname><value>/home/hadoop/hdfs/data/value><final>truefinal>property>
configuration>

10.4 配置 mapred-site.xml

$ vim ~/config/hadoop/mapred-site.xml ###进行如下修改
<configuration><property> <description>MapReduce 执行框架设为 Hadoop YARN. description> <name>mapreduce.framework.namename> <value>yarnvalue> property><property> <description>Map 和 Reduce 执行的比例&#xff0c;Map 执行到百分之几后开始 Reduce 作业description> <name>mapreduce.job.reduce.slowstart.completedmapsname> <value>1.0value> property>
configuration>

10.5 配置 yarn-site.xml

$ vim ~/config/hadoop/yarn-site.xml ###进行如下修改
<configuration>
<property> <description>The address of the applications manager interface in the RM.description> <name>yarn.resourcemanager.addressname> <value>namenode:8032value> property> <property> <name>yarn.nodemanager.aux-servicesname> <value>mapreduce_shufflevalue> property> <property> <description>存储中间数据的本地目录description><name>yarn.nodemanager.local-dirsname> <value>/home/hadoop/nm-local-dirvalue> <final>truefinal>property> <property> <description>每个容器可在 RM 申请的最大内存description><name>yarn.scheduler.maximum-allocation-mbname> <value>2048value> <final>truefinal>property> <property> <description>每个容器可在 RM 申请的最小内存description><name>yarn.scheduler.minimum-allocation-mbname> <value>300value> <final>truefinal>property> <property><description>自动检测节点 CPU 与 Memdescription> <name>yarn.nodemanager.resource.detect-hardware-capabilitiesname> <value>truevalue> property> <property> <description>The address of the scheduler interface.description> <name>yarn.resourcemanager.scheduler.addressname> <value>namenode:8030value> property> <property> <description>The address of the RM web application.description> <name>yarn.resourcemanager.webapp.addressname> <value>namenode:8088value> property> <property> <description>The address of the resource tracker interface.description> <name>yarn.resourcemanager.resource-tracker.addressname> <value>namenode:8031value> property><property> <description>The hostname of the RM.description> <name>yarn.resourcemanager.hostnamename> <value>namenodevalue> property>
configuration>

10.6 配置 slaves

$ vim ~/config/hadoop/slaves &#xff03;&#xff03;&#xff03;进行如下修改namenode
datanode1
datanode2

11 优化 namenode 节点命令使用

$ echo "export PATH&#61;$PATH:/usr/local/hadoop-2.8.0/bin/:/usr/local/hadoop-2.8.0/sbin/" >> ~/.bash_profile
$ source ~/.bash_profile

12 启动集群及测试

测试之前最好重启一遍三台机器&#xff0c;以确保配置都生效&#xff0c;并且没有其他问题。

登录 namenode 节点

$ ssh-add ~/.ssh/id_rsa ### 验证密钥
$ hadoop namenode -format ### 初始化集群
$ start-dfs.sh ### 启动 HDFS
$ start-yarn.sh ### 启动 YARN

12.1 集群总览


NodeNameWebAddress
namenoteHDFShttp://192.168.1.69:50070
RMhttp://192.168.1.69:8088
NMhttp://192.168.1.69:8042
datanode1HDFShttp://192.168.1.70:50075
NMhttp://192.168.1.70:8042
datanode2HDFShttp://192.168.1.71:50075
NMhttp://192.168.1.71:8042

12.2 测试用例

hadoop 自带了许多测试用例&#xff0c;所以可以很方便的快速测试集群是否搭建成功。

$ yarn jar /usr/local/hadoop-2.8.0/share/hadoop/mapreduce/hadoop-mapreduce-examples-2.8.0.jar randomwriter random-data

执行上述命令后&#xff0c;打开 RM 以及 NM 的 URL &#xff0c;查看任务是否被执行&#xff0c;如执行&#xff0c;则搭建成功。


12.3 图片展示

这里写图片描述
这里写图片描述
这里写图片描述


13 总结

本文从零开始搭建了具有三个节点服务器的 Hadoop 集群&#xff0c;示范了 Hadoop 搭建集群的基本配置。并且从中我们可以知道 Hadoop 集群的每台机子的配置几乎是相同的&#xff0c;这是大量重复性的劳动&#xff0c;因此使用 docker 会大大加快集群的部署。文中的配置文件&#xff0c;是我根据我自己的三台服务器的机器硬件所决定的参数&#xff0c;读者应该根据自己的实际情况选择参数的设置&#xff0c;下文的参考资料给出了各种属性的说明以及默认值。


推荐阅读
  • 从0到1搭建大数据平台
    从0到1搭建大数据平台 ... [详细]
  • Hadoop的分布式架构改进与应用
    nsitionalENhttp:www.w3.orgTRxhtml1DTDxhtml1-transitional.dtd ... [详细]
  • Cookie学习小结
    Cookie学习小结 ... [详细]
  • 华为捐赠欧拉操作系统,承诺不推商用版
    华为近日宣布将欧拉开源操作系统捐赠给开放原子开源基金会,并承诺不会推出欧拉的商用发行版。此举旨在推动欧拉和鸿蒙操作系统的全场景融合与生态发展。 ... [详细]
  • Python 数据可视化实战指南
    本文详细介绍如何使用 Python 进行数据可视化,涵盖从环境搭建到具体实例的全过程。 ... [详细]
  • 本文详细介绍了在MySQL中如何高效利用EXPLAIN命令进行查询优化。通过实例解析和步骤说明,文章旨在帮助读者深入理解EXPLAIN命令的工作原理及其在性能调优中的应用,内容通俗易懂且结构清晰,适合各水平的数据库管理员和技术人员参考学习。 ... [详细]
  • Web开发框架概览:Java与JavaScript技术及框架综述
    Web开发涉及服务器端和客户端的协同工作。在服务器端,Java是一种优秀的编程语言,适用于构建各种功能模块,如通过Servlet实现特定服务。客户端则主要依赖HTML进行内容展示,同时借助JavaScript增强交互性和动态效果。此外,现代Web开发还广泛使用各种框架和库,如Spring Boot、React和Vue.js,以提高开发效率和应用性能。 ... [详细]
  • 第二章:Kafka基础入门与核心概念解析
    本章节主要介绍了Kafka的基本概念及其核心特性。Kafka是一种分布式消息发布和订阅系统,以其卓越的性能和高吞吐量而著称。最初,Kafka被设计用于LinkedIn的活动流和运营数据处理,旨在高效地管理和传输大规模的数据流。这些数据主要包括用户活动记录、系统日志和其他实时信息。通过深入解析Kafka的设计原理和应用场景,读者将能够更好地理解其在现代大数据架构中的重要地位。 ... [详细]
  • PHP中元素的计量单位是什么? ... [详细]
  • Hadoop——实验七:MapReduce编程实践
    文章目录一.实验目的二.实验内容三.实验步骤及结果分析 1.基于ubuntukylin14.04(7)版本,安装hadoop-eclipse-kepler-plugi ... [详细]
  • 本文详细介绍如何使用Netzob工具逆向未知通信协议,涵盖从基本安装到高级模糊测试的全过程。通过实例演示,帮助读者掌握Netzob的核心功能。 ... [详细]
  • 通过将常用的外部命令集成到VSCode中,可以提高开发效率。本文介绍如何在VSCode中配置和使用自定义的外部命令,从而简化命令执行过程。 ... [详细]
  • 本文详细介绍了如何在 Android 应用中获取系统的版本号,包括具体的应用场景和实现步骤。 ... [详细]
  • 单片机入门指南:基础理论与实践
    本文介绍了单片机的基础知识及其应用。单片机是一种将微处理器(类似于CPU)、存储器(类似硬盘和内存)以及多种输入输出接口集成在一块硅片上的微型计算机系统。通过详细解析其内部结构和功能,帮助初学者快速掌握单片机的基本原理和实际操作方法。 ... [详细]
  • 阿里云大数据计算服务MaxCompute (原名 ODPS)
     MaxCompute是阿里EB级计算平台,经过十年磨砺,它成为阿里巴巴集团数据中台的计算核心和阿里云大数据的基础服务。去年MaxCompute做了哪些工作,这些工作背后的原因是什 ... [详细]
author-avatar
傻傻的不敢看结5_749
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有