标签：pip hdfs code lock src complete 数据校验 http 初始
HDFS 初始化文件系统分析 && HDFS 文件写入流程 && HDFS 文件读取流程分析
file:/// =====> org.apache.hadoop.hdfs.LocalFileSystem hdfs://xxxx =====> org.apache.hadoop.hdfs.DistributedFileSystem
具体过程描述如下：
1. Client 调用 DistributedFileSystem 对象的 create 方法，创建一个文件输出流（FSDataOutputStream）对象
2. 通过 DistributedFileSystem 对象与 Hadoop 集群的 NameNode 进行一次 RPC 远程调用，在 HDFS 的 Namespace 中创建一个文件条目（Entry），该条目没有任何的 Block
3. 通过 FSDataOutputStream 对象，向 DataNode 写入数据，数据首先被写入 FSDataOutputStream 对象内部的 Buffer 中，然后数据被分割成一个个 Packet 数据包
4. 以 Packet 最小单位，基于 Socket 连接发送到按特定算法选择的 HDFS 集群中一组 DataNode（正常是3个，可能大于等于1）中的一个节点上，在这组 DataNode 组成的 Pipeline 上依次传输 Packet
5. 这组 DataNode 组成的 Pipeline 反方向上，发送ack，最终由Pipeline 中第一个 DataNode 节点将 Pipeline ack 发送给 Client
6. 完成向文件写入数据，Client 在文件输出流（FSDataOutputStream）对象上调用 close 方法，关闭流
7. 调用 DistributedFileSystem 对象的 complete 方法，通知 NameNode 文件写入成功
客户端要向 HDFS 写数据，首先要跟 NameNode 通信以确认可以写文件并获得接收文件 block 的 DataNode，然后，客户端按顺序将文件逐个 block 传递给相应 DataNode ，并由接收到 block 的 DataNode 负责向其他 DataNode 复制 block 的副本
如图：
写详细步骤：
1. Client 与 NameNode 通信请求上传文件，NameNode 检查目标文件是否已存在，父目录是否存在
2. NameNode 返回是否可以上传
3. Client 会先对文件进行切分，比如一个 block 块 128m，文件有 300m 就会被切分成3个块，一个 128M、一个 128M、一个 44M 请求第一个 block 该传输到哪些 DataNode 服务器上
4. NameNode返回 DataNode 的服务器
5. Client 请求一台 DataNode 上传数据（本质上是一个 RPC 调用，建立 Pipeline），第一个 DataNode 收到请求会继续调用第二个 DataNode，然后第二个调用第三个 DataNode，将整个 Pipeline建立完成，逐级返回客户端
6. Client 开始往A上传第一个 block（先从磁盘读取数据放到一个本地内存缓存），以 packet 为单位（一个 packet 为64kb），当然在写入的时候 DataNode 会进行数据校验，它并不是通过一个 packet 进行一次校验而是以 chunk 为单位进行校验（512byte），第一台 DataNode 收到一个 packet 就会传给第二台，第二台传给第三台；第一台每传一个 packet 会放入一个应答队列等待应答
7. 当一个 block 传输完成之后，Client 再次请求 NameNode 上传第二个 block 的服务器。
标签：pip hdfs code lock src complete 数据校验 http 初始
原文地址：https://www.cnblogs.com/share23/p/9877210.html
