本文共 3389 字，大约阅读时间需要 11 分钟。

导入 HDFS jar 包

在 HDFS 开发过程中，若项目使用 Maven，应将相关 HDFS 依赖添加到项目的 pom 文件中，需与 Hadoop 版本匹配。首次下载可能较慢，请耐心等待。

Maven 项目依赖配置

在 pom.xml 添加以下依赖：

       
    
     org.apache.hadoop
        
    
     hadoop-common
        
    
     2.6.5
    
   
       
    
     org.apache.hadoop
        
    
     hadoop-hdfs
        
    
     2.6.5
    
   
       
    
     org.apache.hadoop
        
    
     hadoop-client
        
    
     2.6.5
    
   

以上配置适用于 Maven 项目，需根据实际 Hadoop 版本调整。

非 Maven 项目环境配置

若不使用 Maven，需手动添加 HDFS 核心和相关客户端 jar 包，建议将以下路径加入类路径：

确保上述路径符合你的实际 Hadoop 安装目录，部署前需确认路径号误。

编写 Java 程序

以下是两组用于操作 HDFS 的 Java 代码示例。

检查 HDFS 中文件是否存在

package Hadoop.demo;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.fs.FileSystem;import org.apache.hadoop.fs.Path;public class HdfsTest {    public static void main(String[] args) {        try {            String fileName = "/text/test.txt";            Configuration conf = new Configuration();            conf.set("fs.defaultFS", "hdfs://master:9000");            conf.set("fs.hdfs.impl", "org.apache.hadoop.hdfs.DistributedFileSystem");                        FileSystem fs = FileSystem.get(conf);            if (fs.exists(new Path(fileName))) {                System.out.println("文件存在");            } else {                System.out.println("文件不存在");            }        } catch (Exception e) {            e.printStackTrace();        }    }}

读取 HDFS 文件内容

package Hadoop.demo;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.fs.FSDataInputStream;import org.apache.hadoop.fs.FileSystem;import org.apache.hadoop.fs.Path;import java.io.BufferedReader;import java.io.InputStreamReader;public class HdfsRead {    public static void main(String[] args) {        try {            Configuration conf = new Configuration();            conf.set("fs.defaultFS", "hdfs://master:9000");            conf.set("fs.hdfs.impl", "org.apache.hadoop.hdfs.DistributedFileSystem");                        FileSystem fs = FileSystem.get(conf);            Path file = new Path("/text/test.txt");            FSDataInputStream in = fs.open(file);                        BufferedReader reader = new BufferedReader(new InputStreamReader(in));            String line = reader.readLine();            System.out.println(line);                        reader.close();            in.close();            fs.close();        } catch (Exception e) {            e.printStackTrace();        }    }}

常见问题与解决方案

运行代码可能出现以下错误：

错误示例：

Cannot start process, the working directory 'J:\HadoopTest\HadoopTest' does not exist

解决方法：

C:\regular\bin\hadoop.cmd

chdir J:\HadoopTest\HadoopTest

注意：

• HDFS 是分布式存储，需正确配置网络（jomux）的情况下才能正常工作，请根据实际 [Hadoop 集群配置](http:// hurts:123@ UINavigationController-/search?q=hadoopcluster) 满足网络环境。

• 建议将 Hadoop 服务 (hadoop-daemon) 设置为服务的形式运行，这样在后台管理和停止更为简便。