HDFS读写数据流程
2019-01-10 16:44
176 查看
HDFS写流程
客户端要向HDFS写数据,首先要跟namenode通信以确认可以写文件并获得接收文件block的datanode,然后,客户端按顺序将文件逐个block传递给相应datanode,并由接收到block的datanode负责向其他datanode复制block的副本。
写详细步骤:
- 向namenode通信请求上传文件,namenode检查目标文件是否已存在,父目录是否存在 。
- namenode返回是否可以上传 。
- client会先对文件进行切分,比如一个blok块128M,文件有300M就会被切分成3个块,一个128M、一个128M、一个44M请求第一个 block该传输到哪些datanode服务器上 。
- namenode返回datanode的服务器 。
- client请求一台datanode上传数据(本质上是一个RPC调用,建立pipeline)。
- 第一个datanode收到请求会继续调用第二个datanode,然后第二个调用第三个datanode,将整个pipeline建立完成,逐级返回客户端 。第一个datanode收到请求会继续调用第二个datanode,然后第二个调用第三个datanode,将整个pipeline建立完成,逐级返回客户端 。
- client开始往A上传第一个block(先从磁盘读取数据放到一个本地内存缓存),以packet为单位(一个packet为64kb),当然在写入的时候datanode会进行数据校验,它并不是通过一个packet进行一次校验而是以chunk为单位进行校验(512byte),第一台datanode收到一个packet就会传给第二台,第二台传给第三台;第一台每传一个packet会放入一个应答队列等待应答 。
- 当一个block传输完成之后,client再次请求namenode上传第二个block的服务器,重复图上3-11步骤。
- 当全部写完后,datanode告知namenode写完毕,记录元数据
HDFS读流程
客户端将要读取的文件路径发送给namenode,namenode获取文件的元信息(主要是block的存放位置信息)返回给客户端,客户端根据返回的信息找到相应datanode逐个获取文件的block并在客户端本地进行数据追加合并从而获得整个文件。
读详细步骤:
- 跟namenode通信查询元数据(block所在的datanode节点),找到文件块所在的datanode服务器 。
- 挑选一台datanode(就近原则,然后随机)服务器,请求建立socket流 。
- datanode开始发送数据(从磁盘里面读取数据放入流,以packet为单位来做校验) 。
- 客户端以packet为单位接收,先在本地缓存,然后写入目标文件,后面的block块就相当于是append到前面的block块最后合成最终需要的文件。
相关文章推荐
- 大数据-Hadoop生态(8)-HDFS的读写数据流程以及机架感知
- Hdfs读写数据流程
- HDFS上读写数据的流程解释
- HDFS上读写数据的流程解释
- 大数据学习9:HDFS读写流程理解
- HDFS读写数据流程
- hadoop源码解析之hdfs读取数据全流程分析
- HDFS 读写流程
- hdfs读写流程
- hadoop总结及hdfs的读写流程
- hbase 读写数据流程----文字简介
- HDFS文件读写流程
- hdfs的读写数据流
- BCache源码浅析之三数据读写流程
- Hadoop之HDFS分布式文件系统读写流程详解
- HDFS读写数据的原理
- hdfs读写数据操作分析总结
- HDFS的读写流程
- hdfs工作机制及读写数据简要流程图
- HDFS详解(2)——HDFS中的读写数据流