hadoop java连接端口

Hadoop使用Java连接端口的方式是使用Hadoop的HDFS API或YARN API。以下是一个示例代码，演示怎样使用Java连接到Hadoop的HDFS端口：

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

public class HadoopConnection {


public static void main(String[] args) {


try {


// 创建Hadoop配置对象


Configuration conf = new Configuration();


// 设置Hadoop的文件系统为HDFS


conf.set("fs.defaultFS", "hdfs://localhost:9000");


// 创建Hadoop文件系统对象


FileSystem fs = FileSystem.get(conf);


// 创建文件路径


Path filePath = new Path("/path/to/file.txt");


// 判断文件是否是存在


boolean exists = fs.exists(filePath);


if (exists) {


System.out.println("File exists!");


} else {


System.out.println("File does not exist!");


}


// 关闭文件系统连接


fs.close();


} catch (Exception e) {


e.printStackTrace();


}


}
}


在上面的示例中，我们首先创建一个Hadoop的配置对象，然后设置文件系统为HDFS。然后，我们使用FileSystem.get(conf)来获得HDFS的文件系统对象。接下来，我们可使用文件系统对象履行各种操作，例如检查文件是否是存在。最后，我们关闭文件系统连接。

请注意，上述示例假定Hadoop的HDFS端口是9000，您需要根据您的Hadoop配置进行相应的更改。