HDFS分布式文件系统（2）Java API操作HDFS

2023-10-26

文章目录

1. 创建Maven项目

创建Maven项目 - HDFSDemo

2. 添加相关依赖

在pom.xml文件里添加hadoop和junit依赖

<dependencies>             
    <!--hadoop客户端-->                       
    <dependency>                                  
        <groupId>org.apache.hadoop</groupId>      
        <artifactId>hadoop-client</artifactId>    
        <version>3.3.4</version>                  
    </dependency>     
    <!--单元测试框架-->                            
    <dependency>                                  
        <groupId>junit</groupId>                  
        <artifactId>junit</artifactId>            
        <version>4.13.2</version>                 
    </dependency>                                 
</dependencies>

在这里插入图片描述

3. 创建日志属性文件

在resources目录里创建log4j.properties文件

log4j.rootLogger=stdout, logfile
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%d %p [%c] - %m%n
log4j.appender.logfile=org.apache.log4j.FileAppender
log4j.appender.logfile.File=target/hdfs.log
log4j.appender.logfile.layout=org.apache.log4j.PatternLayout
log4j.appender.logfile.layout.ConversionPattern=%d %p [%c] - %m%n

在这里插入图片描述

4. 启动集群HDFS服务

执行命令：start-dfs.sh
在Hadoop WebUI界面查看：

5. 在HDFS上创建文件

创建net.kox.hdfs包，在包里创建CreateFileOnHDFS类
编写create1()方法：

package net.kox.hdfs;

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

import java.net.URI;

public class CreateFileOnHDFS {
    @Test
    public void create1() throws Exception {
        // 创建配置对象
        Configuration conf = new Configuration();
        // 定义统一资源标识符（uri：uniform resource identifier)
        String uri = "hdfs://192.168.218.141:9000";
        // 创建文件系统对象（基于HDFS的文件系统）
        FileSystem fs = FileSystem.get(new URI(uri), conf);
        // 创建路径对象（指向文件）
        Path path = new Path(uri + "/ied01/hadoop.txt");
        // 基于路径对象创建文件
        boolean result = fs.createNewFile(path);
        // 根据返回值判断文件是否创建成功
        if (result) {
            System.out.println("文件[" + path + "]创建成功！");
        } else {
            System.out.println("文件[" + path + "]创建失败！");
        }
    }
}

运行程序，查看结果：
利用Hadoop WebUI查看：
再次运行程序，由于hadoop.txt已经存在，此时会提示用户创建失败
由此编写create2()方法，事先判断文件是否存在

    @Test
    public void create2() throws Exception {
        // 创建配置对象
        Configuration conf = new Configuration();
        // 定义统一资源标识符（uri：uniform resource identifier)
        String uri = "hdfs://192.168.218.141:9000";
        // 创建文件系统对象（基于HDFS的文件系统）
        FileSystem fs = FileSystem.get(new URI(uri), conf);
        // 创建路径对象
        Path path = new Path(uri + "/ied01/hadoop.txt");
        // 判断路径对象指向的文件是否存在
        if (fs.exists(path)) {
            // 提示用户文件已存在
            System.out.println("文件[" + path + "]已经存在！");
        } else {
            // 基于路径对象创建文件
            boolean result = fs.createNewFile(path);
            // 根据返回值判断文件是否创建成功
            if (result) {
                System.out.println("文件[" + path + "]创建成功！");
            } else {
                System.out.println("文件[" + path + "]创建失败！");
            }
        }
    }

运行程序，查看结果：

6. 写入HDFS文件

类似于HDFS Shell里的hdfs dfs -put命令
在net.hw.hdfs包里创建WriteFileOnHDFS类

6.1 将数据直接写入HDFS文件

任务：在/ied01目录里创建hello.txt文件
创建write1()方法：

package net.kox.hdfs;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FSDataOutputStream;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.junit.Test;

import java.net.URI;

public class WriteFileOnHDFS {
    @Test
    public void write1() throws Exception {
        // 创建配置对象
        Configuration conf = new Configuration();
        // 设置节点主机名属性
        conf.set("dfs.client.use.datanode.hostname", "true");
        // 定义统一资源标识符（uri: uniform resource identifier）
        String uri = "hdfs://master:9000";
        // 创建文件系统对象（基于HDFS的文件系统）
        FileSystem fs = FileSystem.get(new URI(uri), conf);
        // 创建路径对象（指向文件）
        Path path = new Path(uri + "/ied01/hello.txt");
        // 创建文件系统数据字节输出流（出水管：数据从程序到文件）
        FSDataOutputStream out = fs.create(path);
        // 通过字节输出流向文件写数据
        out.write("Hello Hadoop World".getBytes());
        // 关闭文件系统数据字节输出流
        out.close();
        // 关闭文件系统对象
        fs.close();
        // 提示用户写文件成功
        System.out.println("文件[" + path + "]写入成功！");
    }
}

运行程序，查看结果：
利用Hadoop WebUI查看hello.txt文件

6.2 将本地文件写入HDFS文件

在项目根目录创建一个文本文件test.txt
创建write2()方法：

@Test
    public void write2() throws Exception {
        // 创建配置对象
        Configuration conf = new Configuration();
        // 设置数据节点主机名属性
        conf.set("dfs.client.use.datanode.hostname","true");
        // 定义统一资源标识符
        String uri = "hdfs://master:9000";
        // 创建文件系统对象(基于HDFS的文件系统）
        FileSystem fs = FileSystem.get(new URI(uri), conf, "root");
        // 创建路径对象（指向文件）
        Path path = new Path(uri + "/ied01/exam.txt");
        // 创建文件系统数据字节输出流（出水管：数据从程序到文件）
        FSDataOutputStream out = fs.create(path);
        // 创建文件字符输入流对象（出水管：数据从文件到程序）
        FileReader fr = new FileReader("test.txt");
        // 创建缓冲字符输入流对象
        BufferedReader br = new BufferedReader(fr);
        // 定义行字符串变量
        String nextLine = "";
        // 通过循环遍历缓冲字符输入流
        while ((nextLine = br.readLine()) != null) {
            // 在控制输出读取的行
            System.out.println(nextLine);
            // 通过文件系统数据字节输出流对象写入指定文件
            out.write(nextLine.getBytes());
        }
        // 关闭缓冲字符输入流
        br.close();
        // 关闭文件字符输入流
        fr.close();
        // 关闭文件习题数据字节输出流
        out.close();
        // 提示用户写入文件成功
        System.out.println("本地文件[test.txt]成功写入[" + path + "]!");
    }

运行write2()测试方法，查看结果：
查看/ied01/exam.txt内容

7. 读取HDFS文件

7.1 读取HDFS文件直接在控制台显示

创建ReadFileOnHDFS类
编写read1()方法：

package net.kox.hdfs;

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 org.junit.Test;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.URI;


public class ReadFileOnHDFS {
    @Test
    public void read1() throws Exception {
        // 创建配置对象
        Configuration conf = new Configuration();
        // 设置数据节点主机名属性
        conf.set("dfs.client.use.datanode.hostname", "true");
        // 定义统一资源标识符（uri: uniform resource identifier）
        String uri = "hdfs://master:9000";
        // 创建文件系统对象（基于HDFS的文件系统）
        FileSystem fs = FileSystem.get(new URI(uri), conf, "root");
        // 创建路径对象（指向文件）
        Path path = new Path(uri + "/ied01/test.txt");
        // 创建文件系统数据字节输入流（进水管：数据从文件到程序）
        FSDataInputStream in = fs.open(path);
        // 创建缓冲字符输入流，提高读取效率（字节流-->字符流-->缓冲流）
        BufferedReader br = new BufferedReader(new InputStreamReader(in));
        // 定义行字符串变量
        String nextLine = "";
        // 通过循环遍历缓冲字符输入流
        while ((nextLine = br.readLine()) != null) {
            // 在控制台输出读取的行
            System.out.println(nextLine);
        }
        // 关闭缓冲字符输入流
        br.close();
        // 关闭文件系统数据字节输入流
        in.close();
        // 关闭文件系统
        fs.close();
    }
}

运行read1()测试方法，查看结果：

7.2 读取HDFS文件，保存为本地文件

创建download目录:
创建 read2()方法：

@Test                                                                           
public void read2() throws Exception {                                          
    // 创建配置对象                                                                   
    Configuration conf = new Configuration();                                   
    // 设置数据节点主机名属性                                                              
    conf.set("dfs.client.use.datanode.hostname", "true");                       
    // 定义统一资源标识符（uri: uniform resource identifier）                              
    String uri = "hdfs://master:9000";                                          
    // 创建文件系统对象（基于HDFS的文件系统）                                                    
    FileSystem fs = FileSystem.get(new URI(uri), conf, "root");                 
    // 创建路径对象（指向文件）                                                             
    Path path = new Path(uri + "/ied01/test.txt");                              
    // 创建文件系统数据字节输入流（进水管：数据从文件到程序）                                              
    FSDataInputStream in = fs.open(path);                                       
    // 创建文件字节输出流（出水管：数据从程序到文件）                                                  
    FileOutputStream out = new FileOutputStream("download/exam.txt");           
    // 利用IOUtils工具类读取HDFS文件（靠输入流），写入本地文件（靠输出流）                                  
    IOUtils.copyBytes(in, out, conf);                                           
    // 关闭文件字节输出流                                                                
    out.close();                                                                
    // 关闭文件系统数据字节流输入流                                                           
    in.close();                                                                 
    // 关闭文件系统                                                                   
    fs.close();                                                                 
    // 提示用户文件下载成功                                                               
    System.out.println("文件[" + path + "]下载到本地文件[download/exam.txt]！");          
}

运行read2()测试方法，查看结果：

8. 重命名目录或文件

创建RenameDirOrFile类

8.1 重命名目录

将/ied01目录更名为/lzy01
编写renameDir()方法：

package net.kox.hdfs;

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

import java.net.URI;

public class RenameDirOrFile {
    @Test
    public void renameDir() throws Exception {
        // 创建配置对象
        Configuration conf = new Configuration();
        // 设置数据节点主机名属性
        conf.set("dfs.client.use.datanode.hostname", "true");
        // 定义统一资源标识符（uri: uniform resource identifier）
        String uri = "hdfs://master:9000";
        // 创建文件系统对象（基于HDFS的文件系统）
        FileSystem fs = FileSystem.get(new URI(uri), conf, "root");
        // 创建源路径对象（指向目录）
        Path sourcePath = new Path(uri + "/ied01");
        // 创建目标路径对象（指向目录）
        Path destinationPath = new Path(uri + "/lzy01");
        // 利用文件系统对象重命名目录
        fs.rename(sourcePath, destinationPath);
        // 关闭文件系统
        fs.close();
        // 提示用户目录更名成功
        System.out.println("目录[" + sourcePath.getName() + "]更名为目录[" + destinationPath.getName() + "]！");
    }
}

运行程序，查看结果：
利用Hadoop WebUI界面查看：

8.2 重命名文件

将lzy01目录下的hello.txt重命名为hi.txt
编写renameFile()方法：

@Test                                                                                                      
public void renameFile() throws Exception {                                                                
    // 创建配置对象                                                                                              
    Configuration conf = new Configuration();                                                              
    // 设置数据节点主机名属性                                                                                         
    conf.set("dfs.client.use.datanode.hostname", "true");                                                  
    // 定义统一资源标识符（uri: uniform resource identifier）                                                         
    String uri = "hdfs://master:9000";                                                                     
    // 创建文件系统对象（基于HDFS的文件系统）                                                                               
    FileSystem fs = FileSystem.get(new URI(uri), conf, "root");                                            
    // 创建源路径对象（指向文件）                                                                                       
    Path sourcePath = new Path(uri + "/lzy01/hello.txt");                                                  
    // 创建目标路径对象（指向文件）                                                                                      
    Path destinationPath = new Path(uri + "/lzy01/hi.txt");                                                
    // 利用文件系统对象重命名文件                                                                                       
    fs.rename(sourcePath, destinationPath);                                                                
    // 关闭文件系统                                                                                              
    fs.close();                                                                                            
    // 提示用户文件更名成功                                                                                          
    System.out.println("文件[" + sourcePath.getName() + "]更名为文件[" + destinationPath.getName() + "]！");       
}

运行程序，查看结果：

9. 显示文件列表

创建ListHDFSFiles类

9.1 显示指定目录下文件全部信息

显示/lzy01目录下的文件列表
编写list1()方法：

package net.kox.hdfs;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.LocatedFileStatus;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.fs.RemoteIterator;
import org.junit.Test;

import java.net.URI;

public class ListHDFSFiles {
    @Test
    public void list1() throws Exception {
        // 创建配置对象
        Configuration conf = new Configuration();
        // 设置数据节点主机名属性
        conf.set("dfs.client.use.datanode.hostname", "true");
        // 定义uri字符串
        String uri = "hdfs://master:9000";
        // 创建文件系统对象
        FileSystem fs = FileSystem.get(new URI(uri), conf, "root");
        // 创建远程迭代器对象，泛型是位置文件状态类（相当于`hdfs dfs -ls -R /lzy01`）
        RemoteIterator<LocatedFileStatus> ri = fs.listFiles(new Path("/lzy01"), true);
        // 遍历远程迭代器
        while (ri.hasNext()) {
            System.out.println(ri.next());
        }
    }
}

运行程序，查看结果：

9.2 显示指定目录下文件路径和长度信息

编写list2()方法：

    @Test
    public void list2() throws Exception {
        // 创建配置对象
        Configuration conf = new Configuration();
        // 设置数据节点主机名属性
        conf.set("dfs.client.use.datanode.hostname", "true");
        // 定义uri字符串
        String uri = "hdfs://master:9000";
        // 创建文件系统对象
        FileSystem fs = FileSystem.get(new URI(uri), conf, "root");
        // 创建远程迭代器对象，泛型式位置文件状态类（相当于‘hdfs dfs-ls-R /lzy01')
        RemoteIterator<LocatedFileStatus> ri = fs.listFiles(new Path("/lzy01"), true);
        // 遍历远程迭代器
        while (ri.hasNext()) {
            LocatedFileStatus lfs = ri.next();
            System.out.println(lfs.getPath() + " " + lfs.getLen() + "字节");
        }
    }

运行list2()测试方法，查看结果：
对照Hadoop WebUI上给出的文件长度信息

10. 获取文件块信息

获取/lzy01/hadoop-3.3.4.tar.gz文件块信息
创建GetBlockLocations类
编写代码，获取文件块信息：

package net.kox.hdfs;

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

import java.net.URI;
import java.util.Arrays;

/**
 * 功能：获取文件块信息
 * 作者：华卫
 * 日期：2022年11月26日
 */
public class GetBlockLocations {
    public static void main(String[] args) throws Exception {
        // 创建配置对象
        Configuration conf = new Configuration();
        // 设置数据节点主机名属性
        conf.set("dfs.client.use.datanode.hostname", "true");
        // 定义uri字符串
        String uri = "hdfs://master:9000";
        // 创建文件系统对象
        FileSystem fs = FileSystem.get(new URI(uri), conf, "root");
        // 创建路径对象，指向文件
        Path path = new Path("/lzy01/hadoop-3.3.4.tar.gz");
        // 获取文件块信息
        BlockLocation[] blks = fs.getFileBlockLocations(path, 0, Integer.MAX_VALUE);
        // 利用Lambda表达式遍历块信息
        Arrays.asList(blks).forEach(blk -> System.out.println(blk));
    }
}

运行程序，查看结果（切点位置，块大小，块存在位置）

11. 创建目录

在HDFS上创建/ied01目录
创建MakeDirOnHDFS类
编写程序:

package net.kox.hdfs;

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

import java.net.URI;

public class MakeDirOnHDFS {
    public static void main(String[] args) throws Exception {
        // 创建配置对象
        Configuration conf = new Configuration();
        // 设置数据节点主机名属性
        conf.set("dfs.client.use.datanode.hostname", "true");
        // 定义uri字符串
        String uri = "hdfs://master:9000";
        // 创建文件系统对象
        FileSystem fs = FileSystem.get(new URI(uri), conf, "root");
        // 创建路径对象，指向目录
        Path path = new Path("/ied01");
        // 利用文件系统创建指定目录
        boolean result = fs.mkdirs(path);
        // 判断目录是否创建成功
        if (result) {
            System.out.println("目录[" + path + "]创建成功！");
        } else {
            System.out.println("目录[" + path + "]创建失败！");
        }
    }
}

运行程序，查看结果:
利用Hadoop WebUI界面查看:

12. 判断目录或文件是否存在

判断HDFS上/ied01目录是否存在，判断/ied01/hadoop.txt文件是否存在
创建DirFileExistsOrNot类
编写dirExists()方法:

package net.kox.hdfs;

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

import java.net.URI;

public class DirFileExistsOrNot {
    @Test
    public void dirExists() throws Exception {
        // 创建配置对象
        Configuration conf = new Configuration();
        // 设置数据节点主机名属性
        conf.set("dfs.client.use.datanode.hostname", "true");
        // 定义uri字符串
        String uri = "hdfs://master:9000";
        // 创建文件系统对象
        FileSystem fs = FileSystem.get(new URI(uri), conf, "root");
        // 创建路径对象，指向目录
        Path path = new Path("/ied01");
        // 判断目录是否存在
        if (fs.exists(path)) {
            System.out.println("目录[" + path + "]存在！");
        } else {
            System.out.println("目录[" + path + "]不存在！");
        }
    }
}

运行程序，查看结果：
修改代码，在进行测试：
运行程序，查看结果：

13. 判断Path指向目录还是文件

创建PathToFileOrDir类
编写代码:

package net.kox.hdfs;

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

import java.net.URI;

public class PathToFileOrDir {
    public static void main(String[] args) throws Exception{
        // 创建配置对象
        Configuration conf = new Configuration();
        // 设置数据节点主机名属性
        conf.set("dfs.client.use.datanode.hostname", "true");
        // 定义uri字符串
        String uri = "hdfs://master:9000";
        // 创建文件系统对象
        FileSystem fs = FileSystem.get(new URI(uri), conf, "root");

        // 创建路径对象，指向目录
        Path path1 = new Path("/ied01");
        if (fs.isDirectory(path1)) {
            System.out.println("[" + path1 + "]指向的式目录!");
        } else {
            System.out.println("[" + path1 + "]指向的是文件！");
        }

        // 创建路径对象，指向文件
        Path path2 = new Path("/lzy01/test.txt");
        if (fs.isFile(path2)) {
            System.out.println("[" + path2 + "]指向的是文件！");
        } else {
            System.out.println("[" + path2 + "]指向的是目录！");
        }

    }
}

运行程序，查看结果：

14. 删除目录或文件

类似于HDFS Shell里的hdfs dfs -rmdir和hdfs dfs -rm -r命令
创建DeleteFileOrDir类

14.1 删除文件

删除/lzy01/hi.txt文件
编写deleteFile()方法

package net.kox.hdfs;

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

import java.net.URI;


public class DeleteFileOrDir {
    @Test
    public void deleteFile() throws Exception {
        // 创建配置对象
        Configuration conf = new Configuration();
        // 设置数据节点主机名属性
        conf.set("dfs.client.use.datanode.hostname", "true");
        // 定义uri字符串
        String uri = "hdfs://master:9000";
        // 创建文件系统对象
        FileSystem fs = FileSystem.get(new URI(uri), conf, "root");
        // 创建路径对象（指向文件）
        Path path = new Path(uri + "/lzy01/hi.txt");
        // 删除路径对象指向的文件（第二个参数表明是否递归，删除文件，不用递归）
        boolean result = fs.delete(path, false);
        // 根据返回结果提示用户
        if (result) {
            System.out.println("文件[" + path + "]删除成功！");
        } else {
            System.out.println("文件[" + path + "]删除失败！");
        }
    }
}

运行程序，查看结果：
利用Hadoop WebUI界面查看：
再运行deleteFile()测试方法，查看结果：
改进代码：

package net.kox.hdfs;

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

import java.net.URI;


public class DeleteFileOrDir {
    @Test
    public void deleteFile() throws Exception {
        // 创建配置对象
        Configuration conf = new Configuration();
        // 设置数据节点主机名属性
        conf.set("dfs.client.use.datanode.hostname", "true");
        // 定义uri字符串
        String uri = "hdfs://master:9000";
        // 创建文件系统对象
        FileSystem fs = FileSystem.get(new URI(uri), conf, "root");
        // 创建路径对象（指向文件）
        Path path = new Path(uri + "/lzy01/hi.txt");
        // 判断路径对象指向的文件是否存在
        if (fs.exists(path)) {
            // 删除路径对象指向的文件（第二个参数表明是否递归，删除文件，不用递归）
            boolean result = fs.delete(path, false);
            // 根据返回结果提示用户
            if (result) {
                System.out.println("文件[" + path + "]删除成功！");
            } else {
                System.out.println("文件[" + path + "]删除失败！");
            }
        } else {
            System.out.println("文件[" + path + "]不存在！");
        }

    }
}

运行程序，查看结果：

14.2 删除目录

删除/lzy01目录
编写deleteDir()方法：

@Test
    public void deleteDir() throws Exception {
        // 创建配置对象
        Configuration conf = new Configuration();
        // 设置数据节点主机名属性
        conf.set("dfs.client.use.datanode.hostname", "true");
        // 定义uri字符串
        String uri = "hdfs://master:9000";
        // 创建文件系统对象
        FileSystem fs = FileSystem.get(new URI(uri), conf, "root");
        // 创建路径对象（指向目录)
        Path path = new Path(uri + "/lzy01");
        // 判断路径对象指向的目录是否存在
        if (fs.exists(path)) {
            boolean result = fs.delete(path, true);
            // 根据返回结果提示用户
            if (result) {
                System.out.println("目录[" + path + "]删除成功！");
            } else {
                System.out.println("目录[" + path + "]删除失败！");
            }
        } else {
            System.out.println("目录[" + path + "]不存在！");
        }
    }

运行程序，查看结果：
再次运行：

14.3 删除目录或文件

进行三个层面的判断：判断类型（目录或文件）、判断是否存在、判断删除是否成功
删除/ied02/exam.txt文件和/lzy01目录
编写delete()方法:

@Test
    public void delete() throws Exception {
        // 创建配置对象                                                         
        Configuration conf = new Configuration();
        // 设置数据节点主机名属性                                                    
        conf.set("dfs.client.use.datanode.hostname", "true");
        // 定义uri字符串                                                       
        String uri = "hdfs://master:9000";
        // 创建文件系统对象                                                       
        FileSystem fs = FileSystem.get(new URI(uri), conf, "root");
        // 定义随机对象                                                         
        Random random = new Random();
        // 产生随机整数 - [0, 1]                                                
        int choice = random.nextInt(100) % 2;
        // 定义路径字符串                                                        
        String[] strPath = {"/ied02/exam.txt", "/lzy01"};
        // 创建路径对象（指向目录或文件）                                                
        Path path = new Path(uri + strPath[choice]);
        // 判断类型：目录或文件                                                     
        String type = "";
        if (fs.isDirectory(path)) {
            type = "目录";
        } else {
            type = "文件";
        }
        // 判断存在性                                                          
        if (fs.exists(path)) {
            // 删除路径对象指向的目录或文件                                             
            boolean result = fs.delete(path, true);
            // 判断删除是否成功                                                   
            if (result) {
                System.out.println(type + "[" + path + "]删除成功！");
            } else {
                System.out.println(type + "[" + path + "]删除失败！");
            }
        } else {
            System.out.println(type + "[" + path + "]不存在！");
        }
    }

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

大数据

Java

HDFS

Hadoop

HDFS分布式文件系统（2）Java API操作HDFS 的相关文章

如何在 IDEA Intellij 上使用 Spring-boot 自动重新加载

我写了一个基于Spring boot tomcat freemarker的项目我运行成功但是每当我修改一些模板和java类时我必须重新启动服务器或使用Intellij上的重新加载更改的类菜单才能使更改生效浪费很多时间然后我尝试
在 Java 中使用 Batik 检查和删除 SVG 中的属性

这个问题基本上说明了一切如何检查 SVG 是否具有 viewBox 属性我正在使用蜡染库我需要这个因为我需要至少通知用户有一个 viewBox 属性我可以删除它吗使用 org w3c dom 类您可以按照以下方式做一些事情
如何在url请求中发送数组

我的要求如下我想给出演员姓名开始日期结束日期并获取他在该时期出演的所有电影因此我的服务请求是这样的 http localhost 8080 MovieDB GetJson name Actor startDate 20120101
使用 Apache POI Excel 写入特定单元格位置

如果我有一个未排序的参数 x y z 列表是否有一种简单的方法将它们写入使用 POI 创建的 Excel 文档中的特定单元格就好像前两个参数是 X 和Y 坐标例如我有如下行 10 4 100 是否可以在第 10 行第 4 列的单元格
最快的高斯模糊实现

如何以最快的速度实施高斯模糊 http en wikipedia org wiki Gaussian blur算法我要用Java来实现它所以GPU http en wikipedia org wiki Graphics processi
Java 卡布局。多张卡中的一个组件

一个组件例如JLabel 在多张卡中使用CardLayout 目前看来该组件仅出现在它添加到的最后一张卡上如果有办法做到这一点我应该吗这是不好的做法吗或者有其他选择吗你是对的它只出现在添加到的最后一张卡中但这与CardL
以有效的方式从 Map 中删除多个键？

我有一个Map
如何将 Java 地图转换为在 Scala 中使用？

我正在开发一个 Scala 程序该程序调用 Java 库中的函数处理结果并生成 CSV 有问题的 Java 函数如下所示 Map
java setFullScreenWindow 在 Mac 中隐藏登录对话框

我使用的是全屏窗口类似于屏幕保护程序使用这里的方法 GraphicsEnvironment getLocalGraphicsEnvironment getDefaultScreenDevice setFullScreenWindow t
如何在 JPA 和 Hibernate 中将数据库生成的列值定义为只读字段？

使用 MariaDB 10 2 可以定义日期时间的默认值例如创建和最后修改我应该如何将此列作为只读字段访问因为这个值应该只在数据库的控制之下并且不应该从代码中修改但我想在代码中读取这个属性这很简单只需设置insertable
在尝试使用 GPS 之前如何检查 GPS 是否已启用

我有以下代码但效果不好因为有时 GPS 需要很长时间我该如何执行以下操作检查GPS是否启用如果启用了 GPS 请使用 GPS 否则请使用网络提供商如果 GPS 时间超过 30 秒请使用网络我可以使用时间或 Thread sl
生成 equals 和 hashcode 时忽略属性

假设我有一个类 Customer public class Customer private String firstName private String lastName private String doNotAddMeToEqual
用于层次结构树角色的 Spring Security / Java EE 解决方案

我知道 Spring Security 非常适合标准角色和基于权限的授权我不确定的是这种情况系统中管理着 10 000 名员工员工被组织成组织结构图跨部门的谁向谁报告的树其中一些员工是用户这些用户仅被允许访问其职责范围内的员工
在带有 Protocol Buffers 的项目中使用 Proguard 有什么特点？

我有一个使用 Google Protocol Buffers 的项目一旦我尝试用 ProGuard 对其进行混淆似乎 protobuf 会导致问题我将所有自己的类打包成mybuildedclasses jar 谷歌代码被打包成prot
HTTP 状态 405 - 此 URL java servlet 不支持 HTTP 方法 POST [重复]

这个问题在这里已经有答案了我无法使页面正常工作我有要发布的表单方法和我的 servlet 实现doPost 然而它不断地向我表明我并不支持POST方法我只是想做一个简单的网站并将值插入到我的 MySQL 数据库中 type Stat
如何以编程方式创建 CardView

我正在开发一个 Android 应用程序Java Android Studio 我想在活动中创建CardView以编程方式我想将以下属性设置为CardView layout width wrap content layout row 0
如何使用Gson仅从Json反序列化某些特定字段？

我有以下 JSON 字符串 channel bvmt initValues data value instrumentIds TN0007250012 TN0007500010 instruments mnemonic ADWYA marc
如何从 JavaFX 中的另一个控制器类访问 UI 元素？

我有一个使用 NetBeans 8 编写的 JavaFX Java 8 应用程序没有SceneBuilder 我的应用程序有一个主窗口该窗口有自己的 FXML 文件 primary fxml 和自己的控制器类 FXMLPrimaryCo
Errors/BindingResult 参数应在模型属性、@RequestBody 或 @RequestPart 参数之后立即声明

我通过剖析示例应用程序来自学 Spring 然后到处添加代码来测试我在剖析过程中开发的理论在测试添加到 Spring 应用程序中的一些代码时我收到以下错误消息 An Errors BindingResult argument is ex
mybatis：使用带有 XML 配置的映射器接口作为全局参数

我喜欢使用 XML 表示法来指定全局参数例如连接字符串我也喜欢 Mapper 注释当我尝试将两者结合起来时我得到这个例外 https stackoverflow com questions 4263832 type interfac

随机推荐

详解不带参数的 Math.max() 返回 -Infinity

Math max 是内置的 JavaScript 函数从给定的一组数字中返回最大值其语法如下 Math max value1 value2 例如让我们从 1 2 以及 3 中找到最大的数字 Math max 1 2 3 gt 3 正如
[架构之路-199] - 可靠性需求与可靠性分析：鱼骨图、故障树分析法FTA、失效模式与影响DFMEA，找到影响故障的主要因素

目录引言第1章故障树分析法与鱼骨图的比较 1 1 相同点 1 2 区别点第2章鱼骨图第3章故障树 3 1 示意图 3 2 故障树解读 3 3 故障树常见符号第4章产品失效 Failure 模式分析DFMEA 引言目标系统
git The following paths are ignored by one of your .gitignore files: Use -f if you really want to ad

git 右键或者命令add 文件或目录不允许提交提示 The following paths are ignored by one of your gitignore files Use f if you really want to
msvcp140.dll重新安装的解决方法（一键安装方法）

msvcp140 dll电脑文件中的dll文件即动态链接库文件若计算机中丢失了某个dll文件就会导致某些软件和游戏等程序无法正常启动运行并且导致电脑系统弹窗报错其安装方法 1 打开浏览器输入 dll修复程序 site 并下载安装m
计算机二级准考证打印通道,2019年9月计算机二级准考证打印快速入口

2019年9月份为全国计算机等级考试时间各省从9月11日起陆续开始打印准考证考生与9月8日起登入打印入口进行打印考点报名者在考点领取即可下面我们快来看看北京上海陕西吉林等各省市的打印时间和打印入口在哪 1 各省计算机二级准考证
Redis 7 第九讲微服务集成Redis 应用篇

Jedis 理论 Jedis是redis的java版本的客户端实现使用Jedis提供的Java API对Redis进行操作是Redis官方推崇的方式并且使用Jedis提供的对Redis的支持也最为灵活全面不足之处就是编码复杂度
Java 区块链BLOCKCHAIN中区块BLOCK的hash值的计算

Java 区块链中区块的hash值的计算计算方法有多种如可以直接String拼接也可以用stringbuffer 或者stringbuilder 这里采用了速度较快的stringbuilder 自己编程的时候可采用stringbuf
实验：使用SSMS创建并管理数据库及其基本表（代码版）

目录一实验要求 1 使用SQL命令创建学生课程 SCC 数据库 2 使用SQL命令学生课程数据库中的学生表 S 课程表 C 选课表 SC 并保存关闭设计窗口 3 使用SQL命令修改基本表结构即增加和删除列 4 使用SQL命令创建及管理
Everything+cpolar内网穿透轻松实现公网远程访问本地硬盘文件

公网远程访问本地硬盘文件内网穿透文章目录公网远程访问本地硬盘文件内网穿透前言 1 下载cpolar和Everything软件 3 设定http服务器端口 4 进入cpolar的设置 5 生成公网连到本地内网穿透数据隧道总结前言
Request和ThreadLocal

Web容器中有三个周期 request Httpsession application 其中request是客户端发出的一个请求这个request的载体就是一个线程实际等同于一个线程的生命周期 Request是封装在线程上面一个抽象概
windows下pip安装mysqlclient失败

环境 windows8家庭版 python3 6 7 在虚拟环境中pip install mysqlclient报错解决方案下载地址 ctrl f键入mysqlclient 找到对应的版本即可博主是python3 6 7 所以选择了倒
2021 程序媛跳槽记：学习计划篇

三妹跳槽系列文章 2021 程序媛跳槽记百度阿里字节等各大厂面经篇 2021 程序媛跳槽记必刷LeetCode算法题附解题报告坦白说我这个人不算聪明基础也不咋样这次跳槽我一开始是很没信心的甚至想把这次尝试当做试水如果受打击
Go_数组遍历、最大值、求和、多维数组

数组数组就是用来存储数据的容器存储多个数据时数据类型要一致如果想要保存任意类型数据需要声明为接口类型数组数组定义完成后可以对数组进行赋值操作数组是通过下标来进行操作的下标的范围是从0开始到数组长度减1的位置特点数组是一种
关闭windows defender教程

由于windows自带的防护软件在后台占用大量内存然后可以使用其他第三方软件来然后本人使用的是火绒这里平时的内存占用了不到100MB 然后其实这里本来应该插入一个windows defender的占用内存我记得是在200 MB 反正
git 上传 github报错 (Permission denied)

文章目录结论起因新建github仓库本地仓库初始化结论 ssh config 中 Host 值可以随意写 cat git config 中 remote origin url git B test demo git url 值后
微服务讲堂--【5】系统自举

这里的系统自举借用了操作系统的概念在操作系统启动之前计算机要先加载自举程序再由自举程序加载操作系统的启动程序整个详细过程不在这里描述可以在网络查阅相关资料为什么要在微服务系统中特别提及系统自举这个概念呢因为这内容很重要而
Unity 勾选development Build 区别，引起的Bug，记录一下

Unity 勾选development Build 区别引起的Bug 记录一下问题编辑器运行正常安卓真机 Build And Run 就出现了奇怪的问题类似数组数据出现了误差勾选development Build 想要真机调试的
第十四届蓝桥杯校内模拟赛(第二期) C++题解分享

本人是在学校机房参加的第二期模拟赛有些题目没有忘海涵若有什么好的建议可以提出来来分享这是本小白第一篇CSDN希望能帮助到大家第一题没啥好说的就是直接暴力枚举这边直接上代码稍微注释答案 2048 include
CTF—web题库笔记(难度2)

CTF web题库笔记难度1 CTF web题库笔记难度4 本篇文章共12道题目录如下目录 1 warmup 2 supersqli 3 Web php include 4 php rce 5 Web php unserialize
HDFS分布式文件系统（2）Java API操作HDFS

文章目录 1 创建Maven项目 2 添加相关依赖 3 创建日志属性文件 4 启动集群HDFS服务 5 在HDFS上创建文件 6 写入HDFS文件 6 1 将数据直接写入HDFS文件 6 2 将本地文件写入HDFS文件 7 读取HDFS文件

HDFS分布式文件系统（2）Java API操作HDFS

文章目录

1. 创建Maven项目

2. 添加相关依赖

3. 创建日志属性文件

4. 启动集群HDFS服务

5. 在HDFS上创建文件

6. 写入HDFS文件

6.1 将数据直接写入HDFS文件

6.2 将本地文件写入HDFS文件

7. 读取HDFS文件

7.1 读取HDFS文件直接在控制台显示

7.2 读取HDFS文件，保存为本地文件

8. 重命名目录或文件

8.1 重命名目录

8.2 重命名文件

9. 显示文件列表

9.1 显示指定目录下文件全部信息

9.2 显示指定目录下文件路径和长度信息

10. 获取文件块信息

11. 创建目录

12. 判断目录或文件是否存在

13. 判断Path指向目录还是文件

14. 删除目录或文件

14.1 删除文件

14.2 删除目录

14.3 删除目录或文件

HDFS分布式文件系统（2）Java API操作HDFS 的相关文章

随机推荐

热门标签