Chiriri's blog Chiriri's blog
首页
  • Java

    • JavaSE
    • JavaEE
    • 设计模式
  • Python

    • Python
    • Python模块
    • 机器学习
  • Golang

    • Golang
    • gRPC
  • 服务器

    • Linux
    • MySQL
    • NoSQL
    • Kubernetes
  • 项目

    • 传智健康
    • 畅购商城
  • Hadoop生态

    • Hadoop
    • Zookeeper
    • Hive
    • Flume
    • Kafka
    • Azkaban
    • Hbase
    • Scala
    • Spark
    • Flink
  • 大数据项目

    • 离线数仓
  • 青训营

    • 第四届青训营
  • HTML

    • HTML
    • JavaScript
  • Vue

    • Vue2
    • TypeScript
    • Vue3
    • Uni-APP
  • 数据结构与算法
  • C语言
  • 考研数据结构
  • 计算机组成原理
  • 计算机操作系统
  • Java基础

    • Java基础
    • Java集合
    • JUC
    • JVM
  • 框架

    • Spring
    • Dubbo
    • Spring Cloud
  • 数据库

    • MySQL
    • Redis
    • Elasticesearch
  • 消息队列

    • RabbitMQ
    • RocketMQ
  • 408

    • 计算机网络
    • 操作系统
    • 算法
  • 分类
  • 标签
  • 归档
  • 导航站
GitHub (opens new window)

Iekr

苦逼后端开发
首页
  • Java

    • JavaSE
    • JavaEE
    • 设计模式
  • Python

    • Python
    • Python模块
    • 机器学习
  • Golang

    • Golang
    • gRPC
  • 服务器

    • Linux
    • MySQL
    • NoSQL
    • Kubernetes
  • 项目

    • 传智健康
    • 畅购商城
  • Hadoop生态

    • Hadoop
    • Zookeeper
    • Hive
    • Flume
    • Kafka
    • Azkaban
    • Hbase
    • Scala
    • Spark
    • Flink
  • 大数据项目

    • 离线数仓
  • 青训营

    • 第四届青训营
  • HTML

    • HTML
    • JavaScript
  • Vue

    • Vue2
    • TypeScript
    • Vue3
    • Uni-APP
  • 数据结构与算法
  • C语言
  • 考研数据结构
  • 计算机组成原理
  • 计算机操作系统
  • Java基础

    • Java基础
    • Java集合
    • JUC
    • JVM
  • 框架

    • Spring
    • Dubbo
    • Spring Cloud
  • 数据库

    • MySQL
    • Redis
    • Elasticesearch
  • 消息队列

    • RabbitMQ
    • RocketMQ
  • 408

    • 计算机网络
    • 操作系统
    • 算法
  • 分类
  • 标签
  • 归档
  • 导航站
GitHub (opens new window)
  • Hadoop

  • Zookeeper

  • Hive

  • Flume

  • Kafka

  • Azkaban

  • Hbase

  • Scala

  • Spark

  • Flink

  • 离线数仓

  • 青训营

    • 第四届青训营

      • SQL Optimizer 解析| 青训营笔记
      • 流/批/OLAP 一体的 Flink 引擎介绍| 青训营笔记
      • Exactly Once 语义在 Flink 中的实现| 青训营笔记
      • 流式计算中的 Window 计算| 青训营笔记
      • Spark 原理与实践| 青训营笔记
      • 大数据 Shuffle 原理与实践| 青训营笔记
      • Presto 架构原理与优化介绍| 青训营笔记
      • HDFS 原理与应用| 青训营笔记
        • HDFS 基本介绍
          • 文件系统
          • 分布式存储系统
          • HDFS功能特性
        • 架构原理
          • Client 写流程
          • Client 读流程
          • NameNode(元数据节点)
          • DataNode(数据节点)
        • 关键设计
          • NameNode 目录树维护
          • NameNode数据放置
          • DataNode
          • HDFS 写异常处理
          • Lease Recovery
          • Pipeline Recovery
          • Client 读异常处理
          • 旁路系统
          • 控制面建设
      • HDFS 高可用与高扩展性机制分析| 青训营笔记
      • 深入浅出 HBase 实战| 青训营笔记
      • 数据湖三剑客:Delta Lake、Hudi 与 Iceberg| 青训营笔记
      • 从 Kafka 到 Pulsar 的数据流演进之路| 青训营笔记
      • Parquet 和 ORC:高性能列式存储| 青训营笔记
      • LSMT 存储引擎浅析| 青训营笔记
      • 浅谈分布式一致性协议| 青训营笔记
      • 走进 YARN 资源管理和调度| 青训营笔记
      • 深入理解 K8S 资源管理和调度| 青训营笔记
      • 实时数据中心建设思路与企业实践| 青训营笔记
      • 用户数据分析理论与最佳实践| 青训营笔记
      • 大数据可视化理论与案例分析| 青训营笔记
  • DolphinScheduler

  • Doris

  • 大数据
  • 青训营
  • 第四届青训营
Iekr
2022-08-03
目录

HDFS 原理与应用| 青训营笔记

# HDFS 原理与应用| 青训营笔记

这是我参与「第四届青训营 」笔记创作活动的的第 8 天

# HDFS 基本介绍

HDFS 全称 Hadoop Distributed File System

Hadoop 技术体系:

  • 应用层
    • Map Reduce
    • Spark 当前业界的使用已经远超于 MapReduce,尽管它不属于 Hadoop 项目,但是和 Hadoop 也有紧密关系。
  • 调度层
    • Yarn
  • 存储层
    • HDFS

# 文件系统

单机文件系统非常普遍,从 Windows NTFS 到 Linux 的 Ext4 等,分布式文件系统是单机文件的延伸,概念术语是相通的,比如目录、文件、目录树等。

  • 单机文件系统:常见的如 Windows NTFS,Linux 的 Ext4、BTRFS、XFS 等,虽然不同的操作系统和实现,但是本质都是一样的,解决相同的问题。
  • 分布式文件系统:本质上扩展、延伸了单机文件系统,提供了大容量、高可靠、低成本等功能特性;实现上一般也更为复杂。 image-20220803111224521

# 分布式存储系统

  • 对象存储:例如 AWS 的 S3,阿里云的 OSS,开源的 Minio。
  • 块存储:例如 AWS 的 EBS,开源社区也有 Ceph 等。
  • 文件系统:HDFS、GlusterFS、CubeFS 等
  • 数据库:KV 数据库比如 Cassandra,关系型数据库如 TiDB、OceanBase 等

# HDFS 功能特性

  1. 分布式:受 GFS 启发,用 Java 实现的开源系统,没有实现完整的 POSIX 文件系统语义
  2. 容错:自动处理、规避多种错误场景,例如常见的网络错误、机器宕机等。
  3. 高可用:一主多备模式实现元数据高可用,数据多副本实现用户数据的高可用
  4. 高吞吐:Client 直接从 DataNode 读取用户数据,服务端支持海量 client 并发读写
  5. 可扩展:支持联邦集群模式,DataNode 数量可达 10w 级别
  6. 廉价:只需要通用硬件,不需要定制高端的昂贵硬件设备

# 架构原理

  • 分布式存储系统的基本概念,这些概念基本上每个分布式存储系统都会涉及到。

    • 容错能力
    • 一致性模型
    • 可扩展性
    • 节点体系模式
    • 数据放置策略
    • 单机存储引擎
  • HDFS 组件 image-20220803113157552

    • Client/SDK:读写操作的发起点,HDFS 很多读写逻辑都是在 SDK 中实现的。
    • NameNode:元数据节点,是 HDFS 的中枢节点,也是服务的入口。
    • DataNode:数据节点,存放实际用户数据。

# Client 写流程

image-20220803113231823

# Client 读流程

image-20220803113745770

# NameNode(元数据节点)

image-20220803113903242

  • 维护目录树:维护目录树的增删改查操作,保证所有修改都能持久化,以便机器掉电不会造成数据丢失或不一致。
  • 维护文件和数据块的关系:文件被切分成多个块,文件以数据块为单位进行多副本存放。
  • 维护文件块存放节点信息:通过接收 DataNode 的心跳汇报信息,维护集群节点的拓扑结构和每个文件块所有副本所在的 DataNode 类表。
  • 分配新文件存放节点:Client 创建新的文件时候,需要有 NameNode 来确定分配目标 DataNode。

# DataNode(数据节点)

image-20220803122059896

  • 数据块存取:DataNode 需要高效实现对数据块在硬盘上的存取。
  • 心跳汇报:把存放在本机的数据块列表发送给 NameNode,以便 NameNode 能维护数据块的位置信息,同时让 NameNode 确定该节点处于正常存活状态。
  • 副本复制:
    • 数据写入时 Pipeline IO 操作
    • 机器故障时补全副本

# 关键设计

分布式存储系统的基本概念,这些概念基本上每个分布式存储系统都会涉及到。

  • 容错能力:能够处理绝大部分异常场景,例如服务器宕机、网络异常、磁盘故障、网络超时等。
  • 一致性模型:为了实现容错,数据必须多副本存放,一致性要解决的问题是如何保障这多个副本的内容都是一致的。
  • 可扩展性:分布式存储系统需要具备横向扩张 scale-out 的能力。
  • 节点体系模式:常见的有主从模式、对等模式等,不管哪种模式,高可用是必须的功能。
  • 数据放置策略:系统是由多个节点组成,数据是多个副本存放时,需要考虑数据存放的策略。
  • 单机存储引擎:在绝大部分存储系统中,数据都是需要落盘持久化,单机引擎需要解决的是根系统特点,如何高效得存取硬盘数据。

# NameNode 目录树维护

完整的 metadata 信息就应该由 FSImage 文件和 edit log 文件组成。fsimage 中存储的信息就相当于整个 hdfs 在某一时刻的一个快照。

image-20220803131943004

  • fsimage
    • 文件系统目录树
    • 完整的存放在内存中
    • 定时存放到硬盘上
    • 修改是只会修改内存中的目录树

image-20220803132028553

  • EditLog
    • 目录树的修改日志
    • client 更新目录树需要持久化 EditLog 后才能表示更新成功
    • EditLog 可存放在本地文件系统,也可存放在专用系统上
    • NameNode HA 方案一个关键点就是如何实现 EditLog 共享

# NameNode 数据放置

image-20220803132706295

  • 数据块信息维护
    • 目录树保存每个文件的块 id
    • NameNode 维护了每个数据块所在的节点信息
    • NameNode 根据 DatalNode 汇报的信息动态维护位置信息
    • NameNode 不会持久化数据块位置信息

# DataNode

  • 数据块的硬盘存放
    • 文件在 NameNode 已分割成 block
    • DataNodellblock 为单位对数据进行存取

image-20220803141154166

image-20220803141447488

  • 启动扫盘
    • DataNode 需要知道本机存放了哪些数据块
    • 启动时把本机硬盘上的数据块列表加载在内存中

# HDFS 写异常处理

# Lease Recovery

租约:CIient 要修改一个文件时,需要通过 NameNode 上锁,这个锁就是租约 (Lease)。

情景:文件写了一半,client 自己挂掉了。可能产生的问题:

  • 副本不一致,当出现不一致时会比较副本之间的大小,选取较小的副本返回
  • Lease 无法释放,客户端获取租约后会有 10 分钟的超时时间,客户端需要定期向 NameNode 续租,如无续租并超时 NameNode 会判断客户端已经挂掉然后把客户端踢掉,并释放租约。

image-20220803141559384

# Pipeline Recovery

情景: 文件写入过程中,DataNode 侧出现异常挂掉了。

image-20220803141914358

异常出现的时机:

  • 创建连接时
  • 数据传输时
  • complete 阶段

# Client 读异常处理

情景:读取文件的过程,DataNode 侧出现异常挂掉了

解决方法:节点 Failover

增强情景:节点半死不过,读取很慢

image-20220803151506770

# 旁路系统

Balancer:均衡 DataNode 的容量

image-20220803151818640

Mover:确保副本放置符合策略要求

image-20220803151844178

# 控制面建设

控制面建设:保障系统稳定运行

**HouseKeeping 组件:** 比如 Balancer,Mover 等, 这些组件不运行不会马上影响读写操作,但是长时间会积累系统性问题,例如读写不均衡导致 IO 热点等。

可观测注设施:

  • 指标埋点
  • 数据采集
  • 访问日志
  • 数据分析

运维体系建设:

  • 运维操作需要平台化
  • NameNode 操作复杂
  • DataNode 机器规模庞大
  • 组件控制面 API
编辑 (opens new window)
上次更新: 2023/12/06, 01:31:48
Presto 架构原理与优化介绍| 青训营笔记
HDFS 高可用与高扩展性机制分析| 青训营笔记

← Presto 架构原理与优化介绍| 青训营笔记 HDFS 高可用与高扩展性机制分析| 青训营笔记→

最近更新
01
k8s
06-06
02
进程与线程
03-04
03
计算机操作系统概述
02-26
更多文章>
Theme by Vdoing | Copyright © 2022-2025 Iekr | Blog
  • 跟随系统
  • 浅色模式
  • 深色模式
  • 阅读模式