HDFS 的 API 操作中文件如何上传？

1．编写源代码

@Test public void testCopyFromLocalFile() throws IOException, InterruptedException, URISyntaxException {

	// 1 获取文件系统
	Configuration configuration = new Configuration();
	configuration.set("dfs.replication", "2");
	FileSystem fs = FileSystem.get(new URI("hdfs://hadoop102:9000"), configuration, "atguigu");

	// 2 上传文件
	fs.copyFromLocalFile(new Path("e:/banzhang.txt"), new Path("/banzhang.txt"));

	// 3 关闭资源
	fs.close();

	System.out.println("over");

}

2．将 hdfs-site.xml 拷贝到项目的根目录下

dfs.replication 1

3．参数优先级

参数优先级排序： 客户端代码中设置的值 > ClassPath 下的用户自定义配置文件 > 然后是服务器的默认配置