使用Java API方式连接HDFS Client测试

好的，以下是连接HDFS Client的Java API代码示例：

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;

import java.io.IOException;

public class HdfsClientTest {
    public static void main(String[] args) throws IOException {
        Configuration conf = new Configuration();
        conf.set("fs.defaultFS", "hdfs://localhost:9000"); // 设置HDFS的URI

        FileSystem fs = FileSystem.get(conf);
        Path path = new Path("/test.txt");
        if (fs.exists(path)) {
            System.out.println("文件已存在");
        } else {
            System.out.println("文件不存在");
        }
        fs.close();
    }
}

这个示例中，我们使用了`FileSystem`类来连接HDFS并访问文件系统。首先，我们需要创建一个`Configuration`对象，并设置HDFS的URI。然后，我们使用`FileSystem.get(conf)`方法来获取一个`FileSystem`对象，这个对象可以用来访问HDFS文件系统。最后，我们可以通过`Path`对象来指定文件路径，并使用`fs.exists(path)`方法来判断文件是否存在。完毕后，通过`fs.close()`方法关闭连接。