编辑“︁HDFS文件读写流程”︁（章节）

== 1. HDFS文件写入流程 ==

HDFS的文件写入流程涉及客户端、NameNode和多个DataNode的协作。以下是详细的步骤：

=== 1.1 写入流程步骤 ===
# '''客户端请求写入'''：客户端向NameNode发起写入请求，提供文件名、文件大小等信息。
# '''NameNode响应'''：NameNode检查权限和文件系统状态，若允许写入，则返回可用的DataNode列表（包含副本位置）。
# '''数据分块传输'''：客户端将文件分成固定大小的块（默认为128MB），并按顺序写入第一个DataNode。
# '''流水线复制'''：第一个DataNode接收数据后，将其复制到第二个DataNode，第二个再复制到第三个，形成流水线。
# '''确认回传'''：每个DataNode完成写入后，向上一级发送确认信号，最终由客户端确认写入完成。
# '''关闭文件'''：客户端通知NameNode文件写入完成，NameNode更新元数据。

=== 1.2 代码示例 ===
以下是一个使用Hadoop Java API写入文件的示例：
<syntaxhighlight lang="java">
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import java.io.BufferedWriter;
import java.io.OutputStream;
import java.io.OutputStreamWriter;

public class HDFSWriteExample {
    public static void main(String[] args) throws Exception {
        Configuration conf = new Configuration();
        FileSystem fs = FileSystem.get(conf);
        Path filePath = new Path("/user/hadoop/example.txt");
        
        try (OutputStream os = fs.create(filePath);
             BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(os))) {
            writer.write("Hello, HDFS!");
        }
        fs.close();
    }
}
</syntaxhighlight>
'''输出'''：文件`/user/hadoop/example.txt`被写入HDFS，内容为"Hello, HDFS!"。

=== 1.3 流程图 ===
<mermaid>
graph TD
    A[客户端发起写入请求] --> B[NameNode返回DataNode列表]
    B --> C[客户端写入数据到DataNode1]
    C --> D[DataNode1复制到DataNode2]
    D --> E[DataNode2复制到DataNode3]
    E --> F[确认信号回传]
    F --> G[客户端关闭文件]
</mermaid>