一、引言：Java

I/O

包中提供的流式（Stream）I/O

I/O，简称

的特点是：每个连接必须由一个独立的线程处理，当线程执行读或写操作时，如果数据尚未就绪，线程会被阻塞，直到数据可用。

这种“一线程一连接”的模式在并发量较小、连接数不多的传统应用中可以工作，但随着互联网的发展，高并发场景下会暴露出严重问题：

• 线程开销巨大：每个线程占用内存（如栈空间），大量线程会导致上下文切换频繁，CPU

  利用率下降。

• 阻塞导致资源浪费：大量线程处于空闲等待状态，无法有效利用

  CPU。

为了解决这些问题，Java

1.4

I/O），它位于java.nio包中。

NIO

提供了非阻塞的、基于缓冲区（Buffer）和通道（Channel）的

I/O

操作，并引入了选择器（Selector）机制，使得单个线程可以管理多个通道（连接），从而极大地提高了系统在高并发下的伸缩性。

Java

1.7

I/O）至今仍是许多高性能框架（如

NIO

的核心概念、原理机制、代码示例、高级特性以及常见问题等方面，详细剖析

NIO

I/O，但从其工作方式来看，也可以理解为Non-blocking

Java

有本质的不同：

• 面向流

  面向缓冲区

  对象中，没有缓冲区的概念（虽然有缓冲流，但底层仍然是流式的）。

  NIO

  是面向缓冲区的，所有数据都是先用缓冲区（Buffer）包装，然后通过通道（Channel）进行传输。

  缓冲区提供了对数据的结构化访问，以及读写位置的指针控制。

• 阻塞

  非阻塞

  操作是阻塞的，如果数据不可读或不可写，线程会一直阻塞。

  NIO

  允许设置通道为非阻塞模式，当数据未就绪时，读/写操作会立即返回，而不是阻塞线程。

  这为线程复用提供了基础。

• 无选择器

  有选择器

  的选择器（Selector）允许单线程同时监控多个通道的

  I/O

  事件（可读、可写、连接等），使得一个线程可以处理大量并发连接。

NIO

主要由三大组件构成：

1. Buffer（缓冲区）：数据的容器，所有读写都通过

   Buffer

   进行。

2. Channel（通道）：数据传输的双向通道，既可读也可写。

3. Selector（选择器）：多路复用器，用于监听多个

   Channel

   的事件。

下面分别详细阐述。

/>

三、NIO

Buffer（缓冲区）

Buffer

NIO

除外）：ByteBuffer、CharBuffer、ShortBuffer、IntBuffer、LongBuffer、FloatBuffer、DoubleBuffer。

最常用的是

内部维护了四个指针，用于标记读写位置：

• capacity（容量）：缓冲区的最大容量，一旦设定不可改变。

• limit（界限）：第一个不能读/写的索引。

  在写模式下，limit

  capacity；在读模式下，limit

  等于可读数据的最大位置。

• position（位置）：当前要读/写的索引，随操作自动更新。

• mark（标记）：一个备忘位置，可以通过mark()设定，通过reset()回到该位置。

这四个属性满足关系：0

<=

的常用操作

• allocate(int

  capacity)：分配一个指定大小的

  Buffer（在

  堆内存中）。

• put()

  Buffer

  读取数据。

• flip()：将

  Buffer

  mark。

• rewind()：将

  position

  0，用于重新读取数据。

• clear()：清空

  Buffer，将

  capacity，准备重新写入（但数据并未真正删除）。

• compact()：压缩未读数据，将未读数据移到

  Buffer

  capacity，准备写入新数据（常用于部分读取后继续写入）。

• mark()

  reset()

  回到该标记。

直接缓冲区与非直接缓冲区

ByteBuffer

有两种类型：

• 非直接缓冲区（HeapByteBuffer）：分配在

  JVM

  时，需要将数据从堆内存复制到内核空间（通过临时缓冲区），多了一次拷贝。

• 直接缓冲区（DirectByteBuffer）：通过ByteBuffer.allocateDirect()分配，其内存在

  JVM

  堆外（由操作系统管理）。

  它避免了中间拷贝，直接在操作系统内存与

  I/O

  设备之间传输，性能更高，尤其适合大数据量、长生命周期的场景。

  但分配和释放成本较高，需谨慎使用。

2.

Channel（通道）

Channel

NIO

的流，但有几个重要区别：

• 双向性：流是单向的（InputStream

  只写），而

  可以同时读写。

• 非阻塞：Channel

  Buffer

  交互，不能直接读写字节数组。

主要

Channel

实现

• FileChannel：文件读写通道，用于文件

  只能阻塞，不能设置为非阻塞模式（因为文件

  I/O

  配合多线程模拟非阻塞）。

• SocketChannel：TCP

  套接字通道，支持非阻塞。

• ServerSocketChannel：TCP

  服务器套接字通道，用于监听连接，也支持非阻塞。

• DatagramChannel：UDP

  数据报通道，支持非阻塞。

FileChannel

的常用操作

• read(ByteBuffer

  dst)：从

  Buffer。

• write(ByteBuffer

  src)：将

  Channel。

• position()/position(long

  newPosition)：获取或设置文件位置。

• size()：文件大小。

• truncate(long

  size)：截断文件。

• force(boolean

  metaData)：强制将数据刷到磁盘。

• transferTo(long

  position,

  target)/transferFrom(...)：直接在两个通道之间传输数据，零拷贝，高效。

3.

Selector（选择器）

Selector

NIO

事件（连接、读、写等）。

Selector

Channel，如果某个

集合，进行后续处理。

Selector

的使用步骤

1. 创建

   Selector：Selector

   selector

   Selector.open();

2. 将

   Channel

   上：channel.register(Selector

   sel,

   是感兴趣的事件集合（用位掩码表示），如SelectionKey.OP_READ、OP_WRITE、OP_CONNECT、OP_ACCEPT。

   ServerSocketChannel

   OP_READ

   OP_WRITE。

3. 轮询就绪事件：调用selector.select()（阻塞直到至少一个事件就绪）、select(long

   timeout)（超时返回）或selectNow()（非阻塞立即返回）。

   返回值为就绪

   Channel

   的数量。

4. 处理就绪事件：通过selector.selectedKeys()获取就绪的

   SelectionKey

   Key，判断事件类型并做出相应处理（如接受连接、读取数据等）。

   处理完后需手动移除

   Key，避免下次重复处理。

5. 关闭：使用完后关闭

   Selector。

SelectionKey

对象

当

SelectionKey，它包含了以下信息：

• interest

  set：感兴趣的事件集合（注册时指定）。

• ready

  Selector

  更新）。

• Channel：获取关联的

  Channel。

• Selector：获取关联的

  Selector。

• 附加对象（attachment）：可以在注册时携带一个对象，方便在处理事件时使用。

Selector

的底层实现（多路复用）

Selector

的select()方法底层依赖于操作系统的多路复用函数：

• 在

  Linux

  select。

• 在

  Windows

  IOCP）。

• 在

  相比于

  的优势在于：

  • 无最大文件描述符限制。

  • 事件驱动，避免轮询所有

    fd。

  • 内存映射技术，减少用户态和内核态的数据拷贝。

  />

  四、NIO

  I/O模型（Synchronous

  Non-blocking

  I/O）。

  要理解这一概念，需要对比几种常见的

  I/O

  模型：

  • 同步阻塞

    I/O

    后，若内核数据未就绪，线程阻塞，直到数据从内核复制到用户空间才返回。

  • 同步非阻塞

    I/O

    (NIO)：用户线程不断轮询内核数据是否就绪（非阻塞系统调用），若未就绪立即返回错误，线程可以继续做其他事，然后再次轮询。

    当数据就绪后，线程执行

    read

    操作（仍然阻塞等待数据从内核复制到用户空间），因此整个过程是同步的（线程亲自等待复制完成）。

  • I/O

    多路复用

    read/write。

    它本质上是同步非阻塞的一种优化，因为线程可以同时等待多个

    fd。

  • 异步非阻塞

    I/O

    后立即返回，内核完成数据准备和复制后，主动通知线程（回调或信号）。

    整个过程线程无需参与，是真正的异步。

  NIO

  实际上属于同步非阻塞

  的select()方法阻塞，但那是阻塞在事件等待上，而非阻塞在数据读写上。

  一旦事件就绪，线程可以执行非阻塞的读写（如果

  Channel

  模式（反应器模式）。

  Reactor

  Reactor

  Handler（或通过附加对象关联业务处理器）。

  典型的单线程

  Reactor

  流程如下：

  1. Reactor

     Selector

     的事件。

  2. 当某个事件就绪，Selector

     SelectionKey。

  3. Reactor

     线程根据

     的事件类型，调用不同的处理逻辑（如

     accept、read、write）。

  4. 处理过程中，可能将任务提交给线程池执行（避免阻塞

     Reactor

     等框架就是基于这种思想，提供了更高级的抽象。

     3.

     NIO

     的处理流程可以细化为以下步骤：

     1. 创建

        ServerSocketChannel，设置为非阻塞模式。

     2. 绑定端口，并注册到

        Selector

        事件。

     3. Selector

        轮询：主线程调用select()阻塞，直到有事件发生。

     4. 处理

        accept

        事件：当有客户端连接时，select()返回，通过selectedKeys()获取

        OP_ACCEPT。

        调用serverChannel.accept()接受连接，获得

        SocketChannel，将其设置为非阻塞，并注册到

        Selector

        OP_READ）。

     5. 处理

        read

        事件：当客户端发送数据，对应的

        SocketChannel

        处于可读状态。

        select()返回，处理该

        Key，执行channel.read(buffer)读取数据。

        可能读取部分数据，需要循环读取直到读完。

     6. 处理

        write

        事件：当需要向客户端发送数据时，不能直接在业务逻辑中调用

        write，因为可能缓冲区满导致阻塞。

        通常做法是先注册

        OP_WRITE

        事件，在可写时再写入。

        但要注意，当可写事件一直就绪时，会频繁触发，所以通常写完立即取消

        OP_WRITE

        注册。

     7. 重复轮询。

     关键点：所有

     Channel

     没有读到完整数据，也不会阻塞线程，线程可以继续处理其他就绪事件。

     4.

     零拷贝技术

     NIO

     的transferTo()/transferFrom()方法利用了操作系统底层的零拷贝技术（如

     Linux

     sendfile），可以在两个文件描述符之间直接传输数据，无需经过用户空间缓冲区，从而减少上下文切换和内存拷贝次数，极大提升文件传输性能。

     这是

     NIO

     服务器和客户端示例，演示基本流程。

     服务器端代码

     java

     import
     java.io.IOException;
     serverChannel.configureBlocking(false);
     Selector
     serverChannel.register(selector,
     System.out.println("服务器启动，端口
     8888");
     clientChannel.configureBlocking(false);
     注册读事件，并附加一个缓冲区（可选）
     clientChannel.register(selector,
     System.out.println("客户端连接："
     +
     clientChannel.getRemoteAddress());
     else
     System.out.println("客户端断开");
     else
     System.out.println("收到消息："
     +
     }

     客户端代码

     java

     import
     java.io.IOException;
     java.nio.channels.SocketChannel;
     import
     socketChannel.configureBlocking(false);
     InetSocketAddress("localhost",
     8888));
     (!socketChannel.finishConnect())
     System.out.println("连接服务器成功");
     发送数据
     System.out.println("服务器回显："
     +
     }

     注意：客户端为了简化，使用了阻塞模式等待连接完成，实际高并发中可以采用非阻塞模式并注册

     OP_CONNECT

     内存映射文件（MappedByteBuffer）

     FileChannel.map()方法可以将文件的部分区域映射到内存中，返回

     MappedByteBuffer。

     应用程序可以直接通过修改内存来修改文件，无需显式读写。

     这对于大文件的随机访问非常高效。

     java

     RandomAccessFile
     file
     RandomAccessFile("test.txt",
     "rw");
     channel.map(FileChannel.MapMode.READ_WRITE,
     1024);
     channel.close();

     映射的缓冲区可以是堆外直接内存，操作由操作系统虚拟内存管理，性能极高。

     2.

     文件锁（FileLock）

     NIO

     支持文件锁定，允许同步访问共享文件。

     可以通过FileChannel.lock()或tryLock()获取锁。

     锁可以是共享锁或独占锁，取决于操作系统支持。

     java

     FileChannel
     channel
     RandomAccessFile("test.txt",
     FileLock
     管道（Pipe）
     Pipe
     SinkChannel
     字符集编码（Charset）
     NIO
     Charset
     相互转换。
     例如：
     java
     Charset
     charset
     charset.encode("Hello");
     CharBuffer
     charset.decode(buffer);
     />
     七、NIO.2（AIO）简介
     Java
     1.7
     I/O。
     其主要特性包括：
     异步文件通道：AsynchronousFileChannel，支持文件读写操作，返回
     Future
     回调。
     异步套接字通道：AsynchronousServerSocketChannel、AsynchronousSocketChannel，用于网络异步
     I/O。
     增强的文件系统
     API：Path、Files、FileSystem
     等，提供符号链接、文件属性访问等现代文件操作。
     AIO
     I/O
     但支持有限），当读写操作完成后，系统会主动通知应用。
     但由于实现复杂度和
     Linux
     的性能优势与适用场景
     性能优势
     线程资源节省：一个线程可以管理成千上万个连接，大大减少线程上下文切换开销。
     减少数据拷贝：直接缓冲区、零拷贝技术提升了
     I/O
     吞吐量。
     事件驱动模型：只在有事件时处理，避免无意义的轮询。
     适用场景
     高并发网络服务器：如
     Web
     框架（Dubbo）、游戏服务器、聊天系统等。
     大文件传输：使用零拷贝和内存映射。
     需要精细控制
     I/O
     行为的应用：如自定义协议解析、部分读写处理。
     Selector
     中，即使没有就绪事件，select()也可能立即返回
     0，导致
     空转（称为“空轮询”）。
     Netty
     Selector
     使用
     初学者容易忘记在读写之间调用flip()切换模式，导致数据混乱。
     记住：写数据后需要
     flip
     不一定写完
     SocketChannel.write()在非阻塞模式下可能只写入部分字节，必须检查返回值，循环写入直到
     buffer
     OP_WRITE，发送完成后立即取消。
     5.
     连接失败处理
     非阻塞
     需要调用finishConnect()确认连接是否完成，并处理可能出现的异常。
     6.
     内存泄漏
     直接缓冲区（DirectByteBuffer）分配在堆外，需要及时释放。
     虽然
     ByteBuffer
     可能不及时。
     最好显式使用sun.misc.Cleaner或框架提供的工具类清理。
     />
     十、总结
     NIO（New
     Java
     框架。
     其核心思想是：通过缓冲区（Buffer）和通道（Channel）替代流，通过选择器（Selector）实现单线程管理多连接的事件驱动模型。
     NIO
     属于同步非阻塞
     多路复用，底层依赖操作系统的多路复用机制（如
     Java
     在互联网高并发领域的发展，许多高性能中间件都基于
     NIO
     的原理和使用，不仅是面试必备，更是深入理解网络编程和高性能架构的基础。
     随着技术的发展，NIO.2（AIO）提供了更高级的异步
     I/O，但在实际应用中，由于复杂性和平台差异，NIO