最重要的四种Channel

  • FileChannel 文件通道，用于文件的读写
  • SocketChannel tcp连接，客户端服务器都能用
  • ServerSocketChannel tcp连接，用于服务器
  • DatagramChannel UDP连接


FileChannel

FileChannel 只能工作在阻塞模式下

获取FileChannel：通过输入输出流或者RandomAccessFile 获取

  • 通过 FileInputStream 获取的 channel 只能读
  • 通过 FileOutputStream 获取的 channel 只能写
  • 通过 RandomAccessFile 是否能读写根据构造 RandomAccessFile 时的读写模式决定


关闭FileChannel**：
channel 必须关闭，不过调用了 FileInputStream、FileOutputStream 或者 RandomAccessFile 的 close 方法会间接地调用 channel 的 close 方法

强制写入：
操作系统出于性能的考虑，会将数据缓存，不是立刻写入磁盘。可以调用 force(true) 方法将文件内容和元数据（文件的权限等信息）立刻写入磁盘

  1.  public static void copyFile1(String sourceFilePath,String targetFilePath){
  2.         var start = System.currentTimeMillis();
  3.         try {
  5.             @Cleanup FileInputStream fis = new FileInputStream(sourceFilePath);
  6.             @Cleanup FileOutputStream fos = new FileOutputStream(targetFilePath);
  7.             @Cleanup FileChannel inChannel = fis.getChannel();
  8.             @Cleanup FileChannel outChannel = fos.getChannel();
  9.             ByteBuffer buffer = ByteBuffer.allocate(1024 * 1024);
  10.             while(inChannel.read(buffer) != -1){
  11.                 //切换为读模式
  12.                 buffer.flip();
  13.                 outChannel.write(buffer);
  14.                 //清除buffer 变为写模式
  15.                 buffer.clear();
  16.             }
  17.             //强制刷盘
  18.             outChannel.force(true);
  20.         } catch (FileNotFoundException e) {
  21.             System.out.println(" 源文件路径：" + sourceFilePath + "复制源文件不存在");
  22.         } catch (IOException e) {
  23.             System.out.println("文件复制异常" + e.getMessage());
  24.         }
  25.         var end = System.currentTimeMillis();
  26.         System.out.println("耗时：" + (end - start));
  27.     }
  30.     /**
  31.      *
  32.      * @param sourceFilePath
  33.      * @param targetFilePath
  34.      */
  35.     public static void copyFile2(String sourceFilePath,String targetFilePath){
  36.         var start = System.currentTimeMillis();
  37.         try {
  38.             FileChannel sourceChannle = new FileInputStream(sourceFilePath).getChannel();
  39.             FileChannel targetChannle = new FileOutputStream(targetFilePath).getChannel();
  41.             long size = sourceChannle.size();
  42.             //表示还剩余多少字节没有传输
  43.             long left = size;
  44.             while (left > 0){
  45.                 //底层会使用操作系统的零拷贝，一次最多传输2g的数据
  46.                 left -=  sourceChannle.transferTo(size - left,sourceChannle.size(),targetChannle);
  47.             }
  48.             targetChannle.force(true);
  49.         } catch (FileNotFoundException e) {
  50.             e.printStackTrace();
  51.         } catch (IOException e) {
  52.             e.printStackTrace();
  53.         }
  54.         var end = System.currentTimeMillis();
  55.         System.out.println("耗时：" + (end - start));
  56.     }

SocketChannel

NIO中涉及网元连接的通道有两个，一个是SocketChannel负责连接传输，另一个ServerSocketChannel负责连接的监听

ServerSocketChannel用于服务端，而SocketChannel同时应用于服务端和客户端，对于一个连接两端都有一个负责传输的SocketChannel传输通道。