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配置進行相應的更改。