当前位置: 首页 > news >正文

Hadoop- Hadoop详解

首先所有知识以官网为准,所有的内容在官网上都有展示,所有的变动与改进,新增内容都以官网为准。hadoop.apache.org

Hadoop是一个开源的可拓展的分布式并行处理计算平台,利用服务器集群根据用户的自定义业务逻辑,对海量数据进行分布式处理。Hadoop提供了一个可靠的共享存储和分析系统,Hadoop的核心三大组件有HDFS(分布式文件系统),MapReduce(分布式运算编程框架),YARN(运算资源调度系统)。HDFS实现了数据的存储,负责对文件的读写;MapReduce实现了数据的分析和处理;Yarn负责为MapReduce程序分配运算硬件资源。以其高拓展,高效率,高可靠,可构建在廉价的机器上等优点得到了越来越广泛的应用。

分布式存储HDFS详解

重点概念:文件切块,副本存放,元数据

HDFS的概念和特性

什么是分布式文件系统?

  计算机通过文件系统管理、存储数据,而信息爆炸时代中人们可以获取的数据成指数倍的增长,单纯通过增加硬盘个数来扩展计算机文件系统的存储容量的方式,在容量大小、容量增长速度、数据备份、数据安全等方面的表现都差强人意。分布式文件系统可以有效解决数据的存储和管理难题:将固定于某个地点的某个文件系统,扩展到任意多个地点/多个文件系统,众多的节点组成一个文件系统网络。每个节点可以分布在不同的地点,通过网络进行节点间的通信和数据传输。人们在使用分布式文件系统时,无需关心数据是存储在哪个节点上、或者是从哪个节点从获取的,只需要像使用本地文件系统一样管理和存储文件系统中的数据。这是来自百度的介绍,我就偷下懒。

分布式存储:

1.数据块分布在多台机器上

2.每一数据块都可以冗余存储在多台机器上,以提高数据块的高可用性

分布式存储集群:

master/slave结构集群

1.存在slave上的文件

  表示真实存放数据的文件即本地磁盘文件

2.存在master上的文件

  表示逻辑文件,它表示这个逻辑文件全路径名,与这个全路径对应的有数据块的存储信息(数据位置等)

HDFS的设计目标:

将大文件、大批量的文件,分布式存储在大量的服务器上,以便采取分而治之的方式对海量数据进行运算分析。

在大数据系统中的作用:

为各类分布式运算框架(如:mapreduce,spark,tez,......)提供数据存储服务

HDFS的概念和特征

首先它是一个文件系统,用于存储文件,通过通过统一的命名空间——目录树来定位文件

其次它是分布式的,由很多服务器联合起来实现其功能。

重要特性如下:

(1)HDFS中的文件在物理上是分块存储(block,块的大小可以通过配置参数( dfs.blocksize)来规定,默认大小在hadoop2.x版本中是128M,老版本中是64M 

(2)HDFS文件系统会给客户端提供一个统一的抽象目录树,客户端通过路径来访问文件,形如:hdfs://namenode:port/dir-a/dir-b/dir-c/file.data

(3)目录结构及文件分块信息(元数据)的管理由namenode节点承担

——namenode是HDFS集群主节点,负责维护整个hdfs文件系统的目录树,以及每一个路径(文件)所对应的block块信息(block的id,及所在的datanode服务器) 

(4)文件的各个block的存储管理由datanode节点承担

---- datanode是HDFS集群从节点,每一个block都可以在多个datanode上存储多个副本(副本数量也可以通过参数设置dfs.replication)

 (5)HDFS是设计成适应一次写入,多次读出的场景,且不支持文件的修改

 (注:适合用来做数据分析,并不适合用来做网盘应用,因为,不便修改,延迟大,网络开销大,成本太高,但可以合并小文件)

 

Hadoop的配置文件详解

  客户端连接hadoop集群时,可以指定配置文件。用户根据自己的需求对配置选项修改。Hadoop在运行时,会优先使用用户的配置文件

  Configuration conf = new Configuration()

1.向namenode通信请求上传文件。

2.namenode检查目标文件是否已存在,父目录是否存在

3.namenode返回是否可以上传

4.Client请求第一个block该传输到哪些datanode服务器上(首先提供要保存多少个副本,默认是配置文件的副本数)

5.namenode返回3个datanode服务器A,B,C

6.Client通过socket请求3台datanode的一台上传数据(本质上是一个RPC调用,建立pipeline),A收到请求就会继续调用B,然后B调用C将整个pipeline建立完成,逐级返回客户端

7.client开始往A上传第一个block(先从磁盘读取数据到一个本地内存缓存),以packet为单位,A收到一个packet就会传给B,B传给C;A每传一个packet会放入一个应答队列等待应答

8当一个block传输完成之后,client再次请求namenode上传第二个block的服务器。循环以上4到7的步骤。

HDFS主从结构

Namenode:是主节点,保存文件元数据信息,文件属性(生成时间,副本数,文件权限),以及每个文件的块列表和块所在DataNode等,服务器,文件怎么存;Namenode将元数据一部分存放在内存中,一部分存放在本地磁盘中(fsimage:镜像文件和edits:编辑日志)

Datanode:存文件(在本地文件系统中存储文件块数据,以及块的校验和),心跳

 

辅助

Secondary NameNode 用来监控HDFS状态的辅助后台程序,每隔一段时间获取HDFS元数据的快照。

 

 

NameNode是由哪个文件中的哪个配置属性指定的呢?

core-site.xml文件中;
    <property>
                <name>fs.defaultFS</name>
               <value>hdfs://ns1:8020</value>
    </property>

DataNodes:是由哪个文件中的哪个配置属性指定的呢?

slaves配置文件中的配置项

SecondaryNameNode是由哪个文件中的哪个配置属性指定的呢?

hdfs-site.xml文件中

<property>
  <name>dfs.namenode.secondary.http-address</name>
  <value>hadoop-senior.ibeifeng.com:50090</value>
</property>

 

拓展:跨服务器的通信怎么做?

RPC通信框架,自定义RPC,IPC

 

关于Hadoop的一些配置可以看官网,官网上面有属性看,但是没有描述,比如这时候可以看

hadoop-2.6.1\share\hadoop\yarn\hadoop-yarn-server-common-2.6.1.jar 里面有个yarn-default.xml

里面有详细的描述。

 

MapReduce的理解参考:

Hadoop- MapReduce分布式计算框架原理

转载于:https://www.cnblogs.com/RzCong/p/7628968.html

相关文章:

  • numpy的random模块
  • Django的思维导图
  • IPhone8才是真正的智能手机
  • Sublime Text 中配置 Eslint 代码检查和自动修复
  • JQuery UI 入门
  • 记录一下open***,填坑之路
  • 一个更好的可视化微服务架构的方式
  • get/set方法
  • 用C#实现字符串相似度算法(编辑距离算法 Levenshtein Distance)
  • Solaris大半年使用感触
  • python源码分析:dict对象的实现
  • 轻院1089 阶乘的最高位
  • Spring MVC遭遇checkbox的问题解决方式
  • Mac转Windows的拯救指南
  • thinkphp 3.1.3 redis 只能读取 无法写入的问题
  • 【跃迁之路】【699天】程序员高效学习方法论探索系列(实验阶段456-2019.1.19)...
  • 【跃迁之路】【735天】程序员高效学习方法论探索系列(实验阶段492-2019.2.25)...
  • android高仿小视频、应用锁、3种存储库、QQ小红点动画、仿支付宝图表等源码...
  • angular2 简述
  • Apache Spark Streaming 使用实例
  • css选择器
  • Idea+maven+scala构建包并在spark on yarn 运行
  • Java的Interrupt与线程中断
  • node 版本过低
  • node学习系列之简单文件上传
  • PHP 的 SAPI 是个什么东西
  • tensorflow学习笔记3——MNIST应用篇
  • 从零搭建Koa2 Server
  • 关于extract.autodesk.io的一些说明
  • 使用Maven插件构建SpringBoot项目,生成Docker镜像push到DockerHub上
  • 世界上最简单的无等待算法(getAndIncrement)
  • 我感觉这是史上最牛的防sql注入方法类
  • HanLP分词命名实体提取详解
  • JavaScript 新语法详解:Class 的私有属性与私有方法 ...
  • ​一文看懂数据清洗:缺失值、异常值和重复值的处理
  • #AngularJS#$sce.trustAsResourceUrl
  • #我与Java虚拟机的故事#连载14:挑战高薪面试必看
  • $.extend({},旧的,新的);合并对象,后面的覆盖前面的
  • (1)(1.9) MSP (version 4.2)
  • (C语言)字符分类函数
  • (编程语言界的丐帮 C#).NET MD5 HASH 哈希 加密 与JAVA 互通
  • (二十一)devops持续集成开发——使用jenkins的Docker Pipeline插件完成docker项目的pipeline流水线发布
  • (附源码)ssm高校志愿者服务系统 毕业设计 011648
  • (论文阅读26/100)Weakly-supervised learning with convolutional neural networks
  • * CIL library *(* CIL module *) : error LNK2005: _DllMain@12 already defined in mfcs120u.lib(dllmodu
  • .cn根服务器被攻击之后
  • .Net 4.0并行库实用性演练
  • .NET Core实战项目之CMS 第一章 入门篇-开篇及总体规划
  • .NET CORE使用Redis分布式锁续命(续期)问题
  • .net 受管制代码
  • .NET牛人应该知道些什么(2):中级.NET开发人员
  • .net中应用SQL缓存(实例使用)
  • ?php echo $logosrc[0];?,如何在一行中显示logo和标题?
  • [ linux ] linux 命令英文全称及解释
  • [ vulhub漏洞复现篇 ] ThinkPHP 5.0.23-Rce