Java7 Parh，Files和AIO中AsynchronousFileChannel

比眉伴天荒 2024-04-18 18:32 23阅读 0赞

AIO (Asynchronous I/O) 异步非阻塞I/O 是 Java 1.7 之后的,，在java.nio包，AIO是是 NIO 的升级版本（所以AIO又叫NIO.2），提供了异步非堵塞的 IO 操作方式，异步 IO 是基于事件和回调机制实现的，也就是应用操作之后会直接返回，不会堵塞在那里，当后台处理完成，操作系统会通知相应的线程进行后续的操作。

AIO和NIO相比，同样有Channel和Buffer，但没有Selector。

Paths，Path与Files是在JDK7中新添加进来的，都在 java.nio.file包下面，使用时注意JDK版本

### 一、Paths类和Path接口 ###

**1、java.nio.file.Paths类**

**作用：**由专门的静态方法返回一个 **Path对象**，通过转换路径字符串或 URI。

Paths类是 final修饰的，仅由两个static方法组成。

*   *  <table> 
         <tbody> 
          <tr> 
           <td><code>static <a rel="nofollow">Path</a></code></td> 
           <td><code><a rel="nofollow">get</a>(<a rel="nofollow">String</a>&nbsp;first, <a rel="nofollow">String</a>...&nbsp;more)</code> <p>将路径字符串或连接到路径字符串的字符串序列转换为 <code>Path</code> 。</p> </td> 
          </tr> 
          <tr> 
           <td><code>static <a rel="nofollow">Path</a></code></td> 
           <td><code><a rel="nofollow">get</a>(<a rel="nofollow">URI</a>&nbsp;uri)</code> <p>将给定的URI转换为<a rel="nofollow"><code>Path</code></a>对象。</p> </td> 
          </tr> 
         </tbody> 
        </table>

注意：文件系统的分隔符（Unix文件系统是 / ，Windows是 \\，/也可以 ）

路径中的第一个部件可以是根部件，例如 / 或 C:\\ 。以根部件开始的是绝对路径；否则就是相对路径。

![2019091015544084.png][]

@Test
        public void testPaths() throws URISyntaxException {
            Path path = Paths.get("E:/java");
            System.out.println(path); // E:\java
    
            Path path2 = Paths.get("E:/java","/赵云.jpg");
            System.out.println(path2);// E:\java\赵云.jpg
    
            URI uri = new URI("file:///E:/java/赵云.jpg");
            Path path3 = Paths.get(uri);
            System.out.println(path3); //E:\java\赵云.jpg
        }

**2、java.nio.file.Path接口**

Path实例表示文件系统中的路径。路径可以指向一个文件或目录。它通常表示系统相关的文件路径，可用于在文件系统中定位文件的对象。

在许多情况下，Path接口可以取代File类的使用。Path类包含一些对文件或目录处理的方法，但是和File类处理上也有一些区别。[传送门：Java中 File类(文件、目录和文件过滤器)][Java_ File]

**1）判断路径以某一分层路径的开始或结束**

*   *  <table> 
         <tbody> 
          <tr> 
           <td><code>boolean</code></td> 
           <td><code><a rel="nofollow">endsWith</a>(<a rel="nofollow">Path</a>&nbsp;other)</code> <p>测试此路径是否以给定的路径结束。</p> </td> 
          </tr> 
          <tr> 
           <td><code>boolean</code></td> 
           <td><code><a rel="nofollow">endsWith</a>(<a rel="nofollow">String</a>&nbsp;other)</code> <p>测试此路径是否以 <code>Path</code>结束，通过转换给定的路径字符串，完全按照 <a rel="nofollow"><code>endsWith(Path)</code></a>方法指定的方式构建。</p> </td> 
          </tr> 
          <tr> 
           <td><code>boolean</code></td> 
           <td><code><a rel="nofollow">startsWith</a>(<a rel="nofollow">Path</a>&nbsp;other)</code> <p>测试此路径是否以给定的路径开始。</p> </td> 
          </tr> 
          <tr> 
           <td><code>boolean</code></td> 
           <td><code><a rel="nofollow">startsWith</a>(<a rel="nofollow">String</a>&nbsp;other)</code> <p>测试此路径是否以 <code>Path</code> ，通过转换给定的路径字符串，按照 <a rel="nofollow"><code>startsWith(Path)</code></a>方法指定的方式构建。</p> </td> 
          </tr> 
         </tbody> 
        </table>

@Test
        public void testPaths() throws URISyntaxException {
            Path path = Paths.get("E:/java","/赵云.jpg");
            System.out.println(path);// E:\java\赵云.jpg
    
            System.out.println(path.endsWith("jpg"));//false  以某一分层路径
            System.out.println(path.endsWith("赵云.jpg"));//true
            System.out.println(path.startsWith(Paths.get("E:/java")));// true
        }

**2）File 和 Path之间的转换，File和URI之间的转换**

*   *  <table> 
         <tbody> 
          <tr> 
           <td><code><a rel="nofollow">File</a></code></td> 
           <td><code><a rel="nofollow">toFile</a>()</code> <p>返回表示此路径的<a rel="nofollow"><code>File</code></a>对象。</p> </td> 
          </tr> 
          <tr> 
           <td><code><a rel="nofollow">URI</a></code></td> 
           <td><code><a rel="nofollow">toUri</a>()</code> <p>返回一个URI来表示此路径。</p> </td> 
          </tr> 
         </tbody> 
        </table>

@Test
        public void testPaths() throws URISyntaxException {
            Path path = Paths.get("E:/java","/赵云.jpg");
            File file = path.toFile();
            URI uri = path.toUri();
    
            Path path1 = file.toPath();
            URI uri1 = file.toURI();
        }

**3）其他的一些方法 **

*   *  <table> 
         <tbody> 
          <tr> 
           <td><code><a rel="nofollow">Path</a></code></td> 
           <td><code><a rel="nofollow">getParent</a>()</code> <p>返回 <em>父路径</em> ，或 <code>null</code>如果此路径没有父。</p> </td> 
          </tr> 
          <tr> 
           <td><code><a rel="nofollow">Path</a></code></td> 
           <td><code><a rel="nofollow">getRoot</a>()</code> <p>返回此路径的根组分作为 <code>Path</code>对象，或 <code>null</code>如果该路径不具有根组件。</p> </td> 
          </tr> 
          <tr> 
           <td><code>int</code></td> 
           <td><code><a rel="nofollow">compareTo</a>(<a rel="nofollow">Path</a>&nbsp;other)</code> <p>比较两个抽象路径字典。</p> </td> 
          </tr> 
          <tr> 
           <td><code>boolean</code></td> 
           <td><code><a rel="nofollow">endsWith</a>(<a rel="nofollow">Path</a>&nbsp;other)</code> <p>测试，如果这个路径结束与给定的路径。</p> </td> 
          </tr> 
          <tr> 
           <td><code><a rel="nofollow">Path</a></code></td> 
           <td><code><a rel="nofollow">getFileName</a>()</code> <p>将此路径表示的文件或目录的名称返回为 <code>Path</code>对象。</p> </td> 
          </tr> 
          <tr> 
           <td><code><a rel="nofollow">FileSystem</a></code></td> 
           <td><code><a rel="nofollow">getFileSystem</a>()</code> <p>返回创建此对象的文件系统。</p> </td> 
          </tr> 
          <tr> 
           <td><code>boolean</code></td> 
           <td><code><a rel="nofollow">isAbsolute</a>()</code> <p>告诉这条路是否是绝对的。</p> </td> 
          </tr> 
          <tr> 
           <td><code><a rel="nofollow">Iterator</a>&lt;<a rel="nofollow">Path</a>&gt;</code></td> 
           <td><code><a rel="nofollow">iterator</a>()</code> <p>返回此路径的名称元素的迭代器。</p> </td> 
          </tr> 
          <tr> 
           <td><code><a rel="nofollow">Path</a></code></td> 
           <td><code><a rel="nofollow">toRealPath</a>(<a rel="nofollow">LinkOption</a>...&nbsp;options)</code> <p>返回现有文件的 <em>真实</em>路径。</p> </td> 
          </tr> 
         </tbody> 
        </table>

### 二、java.nio.file.Files类 ###

Files类提供了对文件、目录或者其他类型文件进行操作的静态方法。例如文件复制，移动，删除，读取文件内容，写入文件内容等。

Files类与Path实例一起配合使用。下面介绍一些常用的方法：

**1、文件、目录判断与创建，删除**

*   *  <table> 
         <tbody> 
          <tr> 
           <td><code>static boolean</code></td> 
           <td><code><a rel="nofollow">exists</a>(<a rel="nofollow">Path</a>&nbsp;path, <a rel="nofollow">LinkOption</a>...&nbsp;options)</code> <p>测试一个文件是否存在。</p> </td> 
          </tr> 
          <tr> 
           <td><code>static boolean</code></td> 
           <td><code><a rel="nofollow"><span style="color:#f33b45;">notExists</span></a>(<a rel="nofollow">Path</a>&nbsp;path, <a rel="nofollow">LinkOption</a>...&nbsp;options)</code> <p>测试位于此路径的文件是否不存在。</p> </td> 
          </tr> 
          <tr> 
           <td><code>static long</code></td> 
           <td><code><a rel="nofollow">size</a>(<a rel="nofollow">Path</a>&nbsp;path)</code> <p>返回一个文件的大小（以字节为单位）。</p> </td> 
          </tr> 
          <tr> 
           <td><code>static <a rel="nofollow">Path</a></code></td> 
           <td><code><a rel="nofollow"><span style="color:#f33b45;">createDirectories</span></a>(<a rel="nofollow">Path</a>&nbsp;dir, <a rel="nofollow">FileAttribute</a>&lt;?&gt;...&nbsp;attrs)</code> <p>创建一个目录，通过创建所有不存在的父目录。</p> </td> 
          </tr> 
          <tr> 
           <td><code>static <a rel="nofollow">Path</a></code></td> 
           <td><code><a rel="nofollow">createDirectory</a>(<a rel="nofollow">Path</a>&nbsp;dir, <a rel="nofollow">FileAttribute</a>&lt;?&gt;...&nbsp;attrs)</code> <p>创建一个新目录。</p> </td> 
          </tr> 
          <tr> 
           <td><code>static <a rel="nofollow">Path</a></code></td> 
           <td><code><a rel="nofollow"><span style="color:#f33b45;">createFile</span></a>(<a rel="nofollow">Path</a>&nbsp;path, <a rel="nofollow">FileAttribute</a>&lt;?&gt;...&nbsp;attrs)</code> <p>创建一个新的和空的文件，如果文件已经存在，失败了。</p> </td> 
          </tr> 
          <tr> 
           <td><code>static <a rel="nofollow">Path</a></code></td> 
           <td><code><a rel="nofollow">createLink</a>(<a rel="nofollow">Path</a>&nbsp;link, <a rel="nofollow">Path</a>&nbsp;existing)</code> <p>创建一个新的链接（目录项）为现有的文件（可选操作）。</p> </td> 
          </tr> 
          <tr> 
           <td><code>static void</code></td> 
           <td><code><a rel="nofollow">delete</a>(<a rel="nofollow">Path</a>&nbsp;path)</code> <p>删除一个文件。</p> </td> 
          </tr> 
          <tr> 
           <td><code>static boolean</code></td> 
           <td><code><a rel="nofollow">deleteIfExists</a>(<a rel="nofollow">Path</a>&nbsp;path)</code> <p>如果它存在的话，删除一个文件。</p> </td> 
          </tr> 
          <tr> 
           <td><code>static boolean</code></td> 
           <td><code><a rel="nofollow"><span style="color:#f33b45;">isDirectory</span></a>(<a rel="nofollow">Path</a>&nbsp;path, <a rel="nofollow">LinkOption</a>...&nbsp;options)</code> <p>测试一个文件是否是一个目录。</p> </td> 
          </tr> 
          <tr> 
           <td><code>static boolean</code></td> 
           <td><code><a rel="nofollow">isExecutable</a>(<a rel="nofollow">Path</a>&nbsp;path)</code> <p>测试一个文件是否可执行。</p> </td> 
          </tr> 
          <tr> 
           <td><code>static boolean</code></td> 
           <td><code><a rel="nofollow">isHidden</a>(<a rel="nofollow">Path</a>&nbsp;path)</code> <p>告诉是否一个文件被认为是隐藏的。</p> </td> 
          </tr> 
          <tr> 
           <td><code>static boolean</code></td> 
           <td><code><a rel="nofollow">isReadable</a>(<a rel="nofollow">Path</a>&nbsp;path)</code> <p>测试一个文件是否可读。</p> </td> 
          </tr> 
          <tr> 
           <td><code>static boolean</code></td> 
           <td><code><a rel="nofollow">isWritable</a>(<a rel="nofollow">Path</a>&nbsp;path)</code> <p>测试文件是否可写。</p> </td> 
          </tr> 
         </tbody> 
        </table>

java.nio.file.LinkOption枚举类定义如何处理符号链接的选项，但是只有一个字段NOFOLLOW\_LINKS（不遵循符号链接），所以固定写法。

**注意：**

**新文件创建：**

如果该新文件已经存在，则会抛出java.nio.file.FileAlreadyExistsException。

如果该新文件的父目录不存在或者其他I/O错误，则会抛出IOException。

**目录创建使用 createDirectories（），父目录不存在也会创建。**

**文件删除：**

NoSuchFileException -如果文件不存在（可选特定异常）

DirectoryNotEmptyException -如果文件是一个目录，否则不能被删除，因为目录不是空的（可选特定异常）

**目录删除：**delete()方法只会删除一个文件和空目录。目录不为空时，抛异常。

public static void main(String[] args) throws IOException {
            Path path = Paths.get("E:/java000/AIO/aa");
    
            if (Files.notExists(path)) {
                Files.createDirectories(path);
            }
            System.out.println(Files.isDirectory(path)); // true
    
            Path path2 = Paths.get("E:/java000/AIO/aa/text000.txt");
            if (Files.notExists(path2, LinkOption.NOFOLLOW_LINKS)) {
                if (!Files.isDirectory(path2)) {
                    Files.createFile(path2);
                }
            }
            Files.deleteIfExists(path2);
            Files.delete(path); // DirectoryNotEmptyException: 
        }

**2、文件复制与移动**

*   *  <table> 
         <tbody> 
          <tr> 
           <td><code>static long</code></td> 
           <td><code><a rel="nofollow">copy</a>(<a rel="nofollow">InputStream</a>&nbsp;in, <a rel="nofollow">Path</a>&nbsp;target, <a rel="nofollow">CopyOption</a>...&nbsp;options)</code> <p>将输入流中的所有字节复制到文件。</p> </td> 
          </tr> 
          <tr> 
           <td><code>static long</code></td> 
           <td><code><a rel="nofollow">copy</a>(<a rel="nofollow">Path</a>&nbsp;source, <a rel="nofollow">OutputStream</a>&nbsp;out)</code> <p>将文件中的所有字节复制到输出流。</p> </td> 
          </tr> 
          <tr> 
           <td><code>static <a rel="nofollow">Path</a></code></td> 
           <td><code><a rel="nofollow">copy</a>(<a rel="nofollow">Path</a>&nbsp;source, <a rel="nofollow">Path</a>&nbsp;target, <a rel="nofollow">CopyOption</a>...&nbsp;options)</code> <p>将文件复制到目标文件。</p> </td> 
          </tr> 
          <tr> 
           <td><code>static <a rel="nofollow">Path</a></code></td> 
           <td><code><a rel="nofollow">move</a>(<a rel="nofollow">Path</a>&nbsp;source, <a rel="nofollow">Path</a>&nbsp;target, <a rel="nofollow">CopyOption</a>...&nbsp;options)</code> <p>移动或重命名一个文件到目标文件。</p> </td> 
          </tr> 
         </tbody> 
        </table>

@Test
        public void testPaths() throws Exception {
            Path path = Paths.get("E:/java","/赵云image.jpg");
            FileInputStream inputStream = new FileInputStream(new File("E:/java/赵云.jpg"));
            // REPLACE_EXISTING - 如果目标文件已经存在，则替换
            Files.copy(inputStream, path, StandardCopyOption.REPLACE_EXISTING);
    
            Path destPath = Paths.get("E:/java/aa/aa赵云image.txt");
            Files.move(path, destPath, StandardCopyOption.REPLACE_EXISTING);
        }

注意：FileAlreadyExistsException -如果目标文件存在，并且没有指定 StandardCopyOption.REPLACE\_EXISTING选项替换（可选特定异常）

**3、遍历一个文件夹目录获取文件（不包含嵌套文件夹中文件）：newDirectoryStream**

*   *  <table> 
         <tbody> 
          <tr> 
           <td><code>static <a rel="nofollow">DirectoryStream</a>&lt;<a rel="nofollow">Path</a>&gt;</code></td> 
           <td><code><a rel="nofollow">newDirectoryStream</a>(<a rel="nofollow">Path</a>&nbsp;dir)</code> <p>打开一个目录，返回一个<a rel="nofollow"><code>DirectoryStream</code></a>以遍历<a rel="nofollow">目录</a>中的所有条目。</p> </td> 
          </tr> 
          <tr> 
           <td><code>static <a rel="nofollow">DirectoryStream</a>&lt;<a rel="nofollow">Path</a>&gt;</code></td> 
           <td><code><a rel="nofollow">newDirectoryStream</a>(<a rel="nofollow">Path</a>&nbsp;dir, <a rel="nofollow">DirectoryStream.Filter</a>&lt;? super <a rel="nofollow">Path</a>&gt;&nbsp;filter)</code> <p>打开一个目录，返回一个<a rel="nofollow"><code>DirectoryStream</code></a>来迭代<a rel="nofollow">目录</a>中的条目。</p> </td> 
          </tr> 
          <tr> 
           <td><code>static <a rel="nofollow">DirectoryStream</a>&lt;<a rel="nofollow">Path</a>&gt;</code></td> 
           <td><code><a rel="nofollow">newDirectoryStream</a>(<a rel="nofollow">Path</a>&nbsp;dir, <a rel="nofollow">String</a>&nbsp;glob)</code> <p>打开一个目录，返回一个<a rel="nofollow"><code>DirectoryStream</code></a>来迭代<a rel="nofollow">目录</a>中的条目。</p> </td> 
          </tr> 
         </tbody> 
        </table>

@Test
        public void testPaths() throws Exception {
            Path path = Paths.get("E:/java/file03");
    
            if(Files.exists(path)){
                DirectoryStream<Path> paths = Files.newDirectoryStream(path);
    //         DirectoryStream<Path> paths = Files.newDirectoryStream(path, "text.txt");
    //         DirectoryStream<Path> paths = Files.newDirectoryStream(path, new DirectoryStream.Filter<Path>(){
                @Override
                public boolean accept(Path entry) throws IOException {
                    return entry.toString().endsWith(".txt");
                }
            });
                paths.forEach(p -> {
                    if(!Files.isDirectory(p)){
                        System.out.println(p.getFileName());
                    }
                });
            }
        }

![20190910170929430.png][]        4-  ![20190910171834587.png][]      5-

**4、遍历一个文件夹目录获取文件，（包含嵌套文件夹中文件）：walkFileTree**

*   *  <table> 
         <tbody> 
          <tr> 
           <td><code>static <a rel="nofollow">Path</a></code></td> 
           <td><code><a rel="nofollow">walkFileTree</a>(<a rel="nofollow">Path</a>&nbsp;start, <a rel="nofollow">FileVisitor</a>&lt;? super <a rel="nofollow">Path</a>&gt;&nbsp;visitor)</code> <p>走一个文件树。</p> </td> 
          </tr> 
          <tr> 
           <td><code>static <a rel="nofollow">Path</a></code></td> 
           <td><code><a rel="nofollow">walkFileTree</a>(<a rel="nofollow">Path</a>&nbsp;start, <a rel="nofollow">Set</a>&lt;<a rel="nofollow">FileVisitOption</a>&gt;&nbsp;options, int&nbsp;maxDepth, <a rel="nofollow">FileVisitor</a>&lt;? super <a rel="nofollow">Path</a>&gt;&nbsp;visitor)</code> <p>走一个文件树。</p> </td> 
          </tr> 
         </tbody> 
        </table>

walkFileTree方法需要FileVisitor类型的参数，FileVisitor是一个接口，如果使用FileVisitor接口，则的每一个方法都将被调用。如果不需要实现所有的方法，那么可以使用SimpleFileVisitor类，它包含FileVisitor接口中所有方法的默认实现。遍历文件和目录时会触发定义在FileVisitor中的方法：

*   *  <table> 
         <tbody> 
          <tr> 
           <td><code><a rel="nofollow">FileVisitResult</a></code></td> 
           <td><code><a rel="nofollow">postVisitDirectory</a>(<a rel="nofollow">T</a>&nbsp;dir, <a rel="nofollow">IOException</a>&nbsp;exc)</code> <p>在目录中的条目之后调用目录，并且已经访问了所有的后代。</p> </td> 
          </tr> 
          <tr> 
           <td><code><a rel="nofollow">FileVisitResult</a></code></td> 
           <td><code><a rel="nofollow">preVisitDirectory</a>(<a rel="nofollow">T</a>&nbsp;dir, <a rel="nofollow">BasicFileAttributes</a>&nbsp;attrs)</code> <p>在目录中的条目被访问之前调用一个目录。</p> </td> 
          </tr> 
          <tr> 
           <td><code><a rel="nofollow">FileVisitResult</a></code></td> 
           <td><code><a rel="nofollow">visitFile</a>(<a rel="nofollow">T</a>&nbsp;file, <a rel="nofollow">BasicFileAttributes</a>&nbsp;attrs)</code> <p>为目录中的文件调用。它不会访问目录，只会访问文件。</p> </td> 
          </tr> 
          <tr> 
           <td><code><a rel="nofollow">FileVisitResult</a></code></td> 
           <td><code><a rel="nofollow">visitFileFailed</a>(<a rel="nofollow">T</a>&nbsp;file, <a rel="nofollow">IOException</a>&nbsp;exc)</code> <p>为无法访问的文件调用。</p> </td> 
          </tr> 
         </tbody> 
        </table>

上面4个方法都返回 FileVisitResult 对象，定义了4种访问后的行为。

*   *  <table> 
         <tbody> 
          <tr> 
           <td><code><a rel="nofollow">CONTINUE</a>&nbsp; &nbsp;</code>继续。</td> 
          </tr> 
          <tr> 
           <td><code><a rel="nofollow">SKIP_SIBLINGS</a>&nbsp; &nbsp;</code>继续，不要访问此文件或目录的 <em>兄弟姐妹</em> 。</td> 
          </tr> 
          <tr> 
           <td><code><a rel="nofollow">SKIP_SUBTREE</a>&nbsp; &nbsp;</code>继续访问此目录中的条目。</td> 
          </tr> 
          <tr> 
           <td><code><a rel="nofollow">TERMINATE</a>&nbsp; &nbsp;</code>终止。</td> 
          </tr> 
         </tbody> 
        </table>

@Test
        public void testPaths() throws IOException {
            Path path = Paths.get("E:/java/file03");
    
            if(Files.exists(path)){
                Files.walkFileTree(path, new SimpleFileVisitor<Path>() {
                        // 访问文件时触发
                        @Override
                        public FileVisitResult visitFile(Path file, BasicFileAttributes attrs) throws IOException {
                            if (file.endsWith("abc雪02.jpg")) {
                                System.out.println("已经找到abc雪02.jpg文件！停止查找！");
                                return FileVisitResult.TERMINATE;
                            }
                            System.out.println("正在访问文件" + file);
                            return FileVisitResult.CONTINUE;
                        }
    
                        // 访问目录时触发
                        @Override
                        public FileVisitResult preVisitDirectory(Path dir, BasicFileAttributes attrs) throws IOException {
                            System.out.println("正在访问目录：" + dir);
                            return FileVisitResult.CONTINUE;
                        }
                    });
            }
        }

![20190910173729426.png][]    ![20190910173742169.png][]

5**、递归删除目录**

@Test
        public void testPaths() throws IOException {
            Path path = Paths.get("E:/java/file03");
    
            // 递归删除file03
            if (Files.exists(path)) {
                Path path1 = Files.walkFileTree(path, new SimpleFileVisitor<Path>() {
                    @Override
                    public FileVisitResult visitFile(Path file, BasicFileAttributes attrs) throws IOException {
                        System.out.println("delete file: " + file.toString());
                        Files.delete(file);
                        return FileVisitResult.CONTINUE;
                    }
    
                    @Override
                    public FileVisitResult postVisitDirectory(Path dir, IOException exc) throws IOException {
                        Files.delete(dir);
                        System.out.println("delete dir: " + dir.toString());
                        return FileVisitResult.CONTINUE;
                    }
                });
            }
        }

###  三、AIO中AsynchronousFileChannel ###

在 Java 7 中，AsynchronousFileChannel（异步文件通道） 已添加到 Java NIO 中，在java.nio.channels包中，它可以异步读取数据并将数据写入文件。

**1、AsynchronousFileChannel一些方法**

*   *  <table> 
         <tbody> 
          <tr> 
           <td style="width:248px;"><code>static <a rel="nofollow">AsynchronousFileChannel</a></code></td> 
           <td style="width:592px;"><code><a rel="nofollow"><span style="color:#f33b45;">open</span></a>(<a rel="nofollow">Path</a>&nbsp;file, <a rel="nofollow">OpenOption</a>...&nbsp;options)</code> <p>打开或创建一个用于读取和/或写入的文件，返回一个异步文件通道来访问该文件。</p> </td> 
          </tr> 
          <tr> 
           <td style="width:248px;"><code>static <a rel="nofollow"><span style="color:#f33b45;">AsynchronousFileChannel</span></a></code></td> 
           <td style="width:592px;"><code><a rel="nofollow">open</a>(<a rel="nofollow">Path</a>&nbsp;file, <a rel="nofollow">Set</a>&lt;? extends <a rel="nofollow">OpenOption</a>&gt;&nbsp;options, <a rel="nofollow">ExecutorService</a>&nbsp;executor, <a rel="nofollow">FileAttribute</a>&lt;?&gt;...&nbsp;attrs)</code> <p>打开或创建一个用于读取和/或写入的文件，返回一个异步文件通道来访问该文件。</p> </td> 
          </tr> 
          <tr> 
           <td style="width:248px;"><code>abstract <a rel="nofollow"><span style="color:#f33b45;">Future</span></a>&lt;<a rel="nofollow">Integer</a>&gt;</code></td> 
           <td style="width:592px;"><code><a rel="nofollow">read</a>(<a rel="nofollow">ByteBuffer</a>&nbsp;dst, long&nbsp;position)</code> <p>从这个通道读取一个字节序列到给定的缓冲区，从给定的文件位置开始。</p> </td> 
          </tr> 
          <tr> 
           <td style="width:248px;"><code>abstract &lt;A&gt;&nbsp;void</code></td> 
           <td style="width:592px;"><code><a rel="nofollow">read</a>(<a rel="nofollow">ByteBuffer</a>&nbsp;dst, long&nbsp;position, A&nbsp;attachment, <a rel="nofollow">CompletionHandler</a>&lt;<a rel="nofollow">Integer</a>,? super A&gt;&nbsp;handler)</code> <p>从这个通道读取一个字节序列到给定的缓冲区，从给定的文件位置开始。</p> </td> 
          </tr> 
          <tr> 
           <td style="width:248px;"><code>abstract <a rel="nofollow">Future</a>&lt;<a rel="nofollow">Integer</a>&gt;</code></td> 
           <td style="width:592px;"><code><a rel="nofollow">write</a>(<a rel="nofollow">ByteBuffer</a>&nbsp;src, long&nbsp;position)</code> <p>从给定的缓冲区中从给定的缓冲区中写入一个字节序列，从给定的文件位置开始。</p> </td> 
          </tr> 
          <tr> 
           <td style="width:248px;"><code>abstract &lt;A&gt;&nbsp;void</code></td> 
           <td style="width:592px;"><code><a rel="nofollow">write</a>(<a rel="nofollow">ByteBuffer</a>&nbsp;src, long&nbsp;position, A&nbsp;attachment, <a rel="nofollow">CompletionHandler</a>&lt;<a rel="nofollow">Integer</a>,? super A&gt;&nbsp;handler)</code> <p>从给定的缓冲区中从给定的缓冲区中写入一个字节序列，从给定的文件位置开始。</p> </td> 
          </tr> 
          <tr> 
           <td style="width:248px;"><code>abstract long</code></td> 
           <td style="width:592px;"><code><a rel="nofollow">size</a>()</code> <p>返回此通道文件的当前大小。</p> </td> 
          </tr> 
         </tbody> 
        </table>

OpenOption参数是可选的，表示打开文件的方式 。如：StandardOpenOption.READ，StandardOpenOption.WRITE等。

**2、读数据**

**方式一：通过 Future 读数据**

AsynchronousFileChannel fileChannel = null;
            try {
                Path path = Paths.get("D:/E/AIO/aa/text.txt");
                // 缓冲区
                ByteBuffer byteBuffer = ByteBuffer.allocate(1024);
    
                // 1.创建AsynchronousFileChannel
                fileChannel = AsynchronousFileChannel.open(path, StandardOpenOption.READ);
                // 2.读数据
                Future<Integer> future = fileChannel.read(byteBuffer, 0);
                // 在调用 read() 之后，循环调用 Future 的 isDone() 方法直到返回 true，则数据读完了。
                while (!future.isDone()) {
                }
                // 3.写数据
                System.out.println(new String(byteBuffer.array()));
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
                // 4.关闭资源
                if (fileChannel != null) {
                    try {
                        fileChannel.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
            }
        }

read()接受一个ByteBuffer作为第一个参数，数据会被读取到ByteBuffer中。第二个参数是开始读取数据的位置。

read()方法会立刻返回，即使读操作没有完成。我们可以通过isDone()方法检查操作是否完成。一直循环，直到返回的isDone()方法返回true。循环操作比较低效，需要等到读取操作完成之后才会执行。

这里读取操作完成后，数据读取到ByteBuffer中，然后把缓冲区中的字符串打印。

**方式二：通过 CompletionHandler 读数据**

public static void main(String[] args) {
            AsynchronousFileChannel fileChannel = null;
            try {
                Path path = Paths.get("D:/E/AIO/aa/text.txt");
                // 缓冲区
                ByteBuffer byteBuffer = ByteBuffer.allocate(1024);
    
                // 1.创建AsynchronousFileChannel
                fileChannel = AsynchronousFileChannel.open(path, StandardOpenOption.READ);
                // 2.读数据
                fileChannel.read(byteBuffer, 0, byteBuffer, new CompletionHandler<Integer, ByteBuffer>() {
                    /**
                     * 从通道中把数据读到缓冲区完成之后，会调用它
                     * @param result - 读取得字节数
                     * @param attachment
                     */
                    @Override
                    public void completed(Integer result, ByteBuffer attachment) {
                        System.out.println("result: " + result);
                        System.out.println(new String(attachment.array()));
                    }
    
                    @Override
                    public void failed(Throwable exc, ByteBuffer attachment) {
    
                    }
                });
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
                // 4.关闭资源
                if (fileChannel != null) {
                    try {
                        fileChannel.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
            }
    
            // 给显示留一些时间，实际项目可以删除
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

这里，一旦读取完成，将会触发CompletionHandler的completed()方法，并传入一个Integer和ByteBuffer。第一个参数Integer表示的是读取到的字节数大小。第二个参数ByteBuffer也可以换成其他合适的对象方便数据写入。 如果读取操作失败了，那么会触发failed()方法。

**3、写数据**

**方式一：通过 Future 写数据**

首先把文件已写方式打开，然后把缓冲区的数据写入。最后检查一下是否写入完成。 注意：文件必须是已经存在的，否则会抛出一个java.nio.file.NoSuchFileException。

**方式二：通过 CompletionHandler 写数据**

public static void main(String[] args) {
            AsynchronousFileChannel fileChannel = null;
            try {
                Path path = Paths.get("D:/E/AIO/aa/text1.txt");
                if(Files.notExists(path)){
                    Files.createFile(path);
                }
                // 缓冲区
                ByteBuffer byteBuffer = ByteBuffer.allocate(1024);
                byteBuffer.put("test data123121".getBytes());
                byteBuffer.flip();
    
                // 1.创建AsynchronousFileChannel
                fileChannel = AsynchronousFileChannel.open(path, StandardOpenOption.WRITE);
                // 2.写数据
                fileChannel.write(byteBuffer, 0, byteBuffer, new CompletionHandler<Integer, ByteBuffer>() {
                    @Override
                    public void completed(Integer result, ByteBuffer attachment) {
                        System.out.println("result: " + result);
                        System.out.println(new String(attachment.array()));
                    }
    
                    @Override
                    public void failed(Throwable exc, ByteBuffer attachment) {
    
                    }
                });
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
                // 4.关闭资源
                if (fileChannel != null) {
                    try {
                        fileChannel.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
            }
    
            // 给显示留一些时间，实际项目可以删除
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

当数据写入完成后completed()会被调用，如果失败了那么failed()会被调用。

参考文章：[异步文件通道 AsynchronousFileChannel][AsynchronousFileChannel]

ends~

[2019091015544084.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/f69c5e14e2274d4ba12f7915520dc7e1.png
[Java_ File]: https://blog.csdn.net/qq_42402854/article/details/81154532
[20190910170929430.png]: https://img-blog.csdnimg.cn/20190910170929430.png
[20190910171834587.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/2e9f4a7295ec4c1c9f567fdc2033142f.png
[20190910173729426.png]: https://img-blog.csdnimg.cn/20190910173729426.png
[20190910173742169.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/b0ae326a482149d1acccd5a758d72d49.png
[AsynchronousFileChannel]: https://www.cnblogs.com/czwbig/p/10056131.html