文件读取

1. 客户端调用 FileSystem 对象的 open（）函数，打开想要读取的文件。其中FileSystem 是 DistributeFileSystem 的一个实例；
2. DistributedFileSystem 通过使用 RPC（远程过程调用） 访NameNode 以确定文件起始块的位置，同一 Block 按照重复数会返回多个位置，这些位置按照 Hadoop 集群拓扑结构排序，距离客户端近的排在前面；
3. DistributedFileSystem 返 回 FSDataInputStream 输入流给客户端， FSDataInputStream 存储着文件起始块的 DataNode 地址，通过对数据流反复调用 read()方法，可以将数据从 DataNode 传输到客户端；
4. 当此数据块读取完成时，DFSInputStream 数据流和此 DataNode 的连接被关闭，然后再继续连接此文件下一个数据块的最近的 DataNode
5. 当客户端读取完全部数据的时，会调用 FSDataInputStream 的 close()方法关闭该HDFS 文件

下面是简略版本：

客户端向NameNode 发起读请求，说我要读取文件了，NameNode进行一些判断，看看这个客户端是否有读取权限呀、这个文件是否存在呀，判断可以之后，NameNode就会查询这个文件的元数据，获取这个文件的数据块位置列表，然后返回给客户端一个输入流对象，客户端就通过这个输入流对象不断的从DataNode中读取数据。在读的过程中，数据是以二进制流传输的。当一个块读完后，就关闭掉这个输入流，再和下一个数据块所在的DataNode建立一个数据流来读取下一个数据块。在整个过程中，因为一个数据块可能拥有多个副本，所以会得到多个DataNode的地址，在读的时候，根据就近原则选择离客户端最近的DataNode。

---

文件的写入

1. HDFS Client 通过调用 DistributedFileSystem 的 create()方法创建新文件;
2. DistributedFileSystem 通过 RPC 访问 NameNode, 在文件系统的命名空间中创建一个新的文件，创建前 NameNode 会验证客户端地权限并确认该文件不存在，如果检查通过，NameNode 会为新文件添加一条记录，否则就会抛出 IO 异常;
3. 客户端开始写文件，DFSOutputStream 会将文件分割成 packets 数据包，HDFS 中每个 block 默认情况下是128M，由于每个块比较大，所以在写数据的过程中是把数据块拆分成一个个的数据包（ packet ）以管道的形式发送的。然后将这些 packets 写到其内部的一个叫做 data queue(数据队列)。data queue 会向 NameNode 节点请求适合存储数据副本的DataNode 节点的列表，然后这些 DataNode 之前生成一个 Pipeline 数据流管道，我们假设副本因子参数为3，那么这个数据流管道中就有三个 DataNode 节点；
4. 首先 DFSOutputStream 会将 packets 向 Pipeline 数据流管道中的第一个 DataNod e节点写数据，第一个 DataNode 接收 packets 然后把 packets 写向 Pipeline 中的第二个节点，同理，第二个节点保存接收到的数据然后将数据写向 Pipeline 中的第三个 DataNode 节点；
5. DFSOutputStream 内部同样维护另外一个内部的写数据确认队列——ack queue。当 Pipeline 中的第三个 DataNode 节点将 packets 成功保存后，该节点回向第二个 DataNode 返回一个确认数据写成功的信息，第二个 DataNode 接收到该确认信息后在当前节点数据写成功后也会向 Pipeline 中第一个 DataNode 节点发送一个确认数据写成功的信息，然后第一个节点在收到该信息后如果该节点的数据也写成功后，会将 packets 从 ack queue 中将数据删除；
6. 当数据写入完成时，就调用 DistributedFileSystem 的 close()函数关闭写入流

下面是简略版本：

客户端向NameNode发出写文件请求。同样，NameNode 接受到请求后，会做一些校验工作，如文件是否存在、客户端是否有写权限等，并将写操作记录到 edits 文件中。接着NameNode 将给客户端返回每个 block 存放的 DataNode 列表。假如一个block总共有三个副本，客户端在向DataNode写的时候，会和这三个副本所在的3个DataNode建立起一个管道，然后客户端通过输出流向第一个DataNode传送数据流，是以包的形式传送的，然后这个包会直接在pipeline里传给第二个、第三个。每个DataNode写完一个块后，会返回确认信息。当客户端收到3个确认信息之后就知道都写好了。如果没收够确认消息，那就再重新指定一个 DataNode 进行写操作。

使用 管道 的方式进行写操作，不需要客户端写三份备份，因为客户端写文件时是通过网络传输，所有备份由客户端写的话将严重影响写操作的速度。