1. 1. Java NIO 的核心概念
1.1 非阻塞 I/O 的工作机制
Java NIO 的核心思想是通过缓冲区（Buffer）和通道（Channel）实现高效的数据传输，并在需要时借助选择器（Selector）实现非阻塞模式。与传统 I/O 相比，NIO 把数据从流式读取切换到“就地缓冲”，降低了上下文切换成本，从而在高并发场景下获得更好的吞吐量。
Buffer 与 Channel 的角色分工明确：Buffer 是数据的容器，负责读写数据的临时存放；Channel 则是数据的传输通道，负责实际的 I/O 操作。通过 将 Buffer 提供给 Channel，数据就能在硬件驱动和应用程序之间高效移动。
使用教程的定位在于把这些概念落地到代码层面：从最基本的字节缓冲区操作到复杂的网络服务器架构，逐步掌握异步与非阻塞的应用场景。
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;
import java.nio.file.Paths;
import java.nio.file.StandardOpenOption;public class ByteBufferDemo {public static void main(String[] args) throws Exception {ByteBuffer buffer = ByteBuffer.allocate(256);// 写入数据buffer.put((byte) 65);// 切换为读取模式buffer.flip();// 读取数据byte b = buffer.get();System.out.println((char) b);}
}
2. 2. Buffer 的结构与操作
2.1 ByteBuffer 的核心属性与生命周期
ByteBuffer 的核心属性包括 capacity、position、limit 三个概念：capacity 是缓冲区的总容量，position 是下一个读写的位置指针，limit 是当前可读/写的边界。通过这三个属性，可以精确控制数据的读写范围。
缓冲区的生命周期通常经历 allocate/allocateDirect、wrap、flip、compact、clear 等阶段。flip() 将写模式切换为读模式，compact() 将未读数据移动到缓冲区起始处并为后续写入腾出空间。
常见操作要点包括 put 写入数据、get 读取数据、remaining 计算可读可写字节数，以及 hasRemaining 判断是否还有可读数据。
import java.nio.ByteBuffer;public class ByteBufferOps {public static void main(String[] args) {ByteBuffer buf = ByteBuffer.allocate(10);buf.put((byte)1);buf.put((byte)2);buf.flip(); // 进入读取模式while (buf.hasRemaining()) {System.out.println(buf.get());}}
}
3. 3. 常用 Buffer 类型与生命周期
3.1 常见的 Buffer 类型与对应场景
ByteBuffer、CharBuffer、ShortBuffer 等是根据数据类型设计的缓冲区家族。ByteBuffer最常用于字节级 I/O，CharBuffer适合字符数据处理，而 Direct Buffer（通过 allocateDirect）则避免了额外的内存拷贝，适合高吞吐场景。
内存管理的要点，直接缓冲区通常成本较高但吞吐大，堆内存缓冲区成本低但可能涉及多次拷贝。对于随机读写密集型的网络 I/O，直接缓冲区往往能提升性能。
Memory-mapped 文件（通过 FileChannel.map）允许将磁盘块直接映射到内存视图，适用于大文件的随机访问和去拷贝数据处理。
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;
import java.nio.file.Paths;
import java.nio.file.StandardOpenOption;public class DirectBufferDemo {public static void main(String[] args) throws Exception {ByteBuffer direct = ByteBuffer.allocateDirect(1024);direct.put((byte)42);direct.flip();System.out.println(direct.get());}
}
3.2 缓冲区的生命周期与重复利用
重复利用缓冲区可以降低 GC 压力：通过 clear() 或 compact() 重新安排缓冲区的可用空间，避免频繁新建缓冲区。clear() 将 position、limit 重置为初始状态，但数据仍在缓冲区中，直到被覆盖。
缓冲区的安全性，尽量不在同一缓冲区上并发写入而不做好同步控制；在多线程场景，考虑为每个线程维护独立缓冲区或使用线程局部缓冲区。
import java.nio.ByteBuffer;public class BufferReuse {public static void main(String[] args) {ByteBuffer buf = ByteBuffer.allocate(512);for (int i = 0; i < 1000; i++) {buf.clear();buf.putInt(i);buf.flip();// 读取或传输数据while (buf.hasRemaining()) {buf.get();}}}
}
4. 4. Channel 的工作原理与应用场景
4.1 常用 Channel 类型及基本用法
Channel 是数据传输的桥梁，常见类型包括 FileChannel、SocketChannel、ServerSocketChannel 等。Channel 支持阻塞和非阻塞两种模式，结合 Buffer 可以实现高效的数据读写。
阻塞与非阻塞的差异在于读取时是否会阻塞线程：阻塞模式下进行 I/O 时线程会等待数据就绪；非阻塞模式下，线程可以继续执行，随后轮询就绪的 I/O 事件。
简单使用要点包括打开通道、配置为非阻塞、将感兴趣的事件注册到选择器、以及在事件发生时进行读写操作。
import java.nio.channels.FileChannel;
import java.nio.file.Paths;
import java.nio.file.StandardOpenOption;public class FileChannelDemo {public static void main(String[] args) throws Exception {try (FileChannel fc = FileChannel.open(Paths.get("data.bin"), StandardOpenOption.READ)) {ByteBuffer buffer = ByteBuffer.allocate(1024);int read = fc.read(buffer);// 处理 buffer}}
}
5. 5. 非阻塞 I/O 与选择器（Selector）
5.1 Selector 的工作原理与事件类型
Selector 允许单个线程监控多个 Channel 的就绪状态，通过 SelectionKey 指示 Channel 的就绪事件，如 OP_ACCEPT、OP_READ、OP_WRITE、OP_CONNECT。
事件循环的结构通常包括注册阶段、选择就绪、遍历就绪集合、处理业务、循环等待下一次就绪。通过这种模式，可以高效地处理大量并发连接。
常见编码要点是将非阻塞通道注册到选择器，并在循环中处理就绪的 I/O 事件，避免阻塞等待。
import java.nio.channels.Selector;
import java.nio.channels.SelectionKey;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.util.Set;public class NioServer {public static void main(String[] args) throws Exception {Selector selector = Selector.open();ServerSocketChannel server = ServerSocketChannel.open();server.bind(new InetSocketAddress(8080));server.configureBlocking(false);server.register(selector, SelectionKey.OP_ACCEPT);ByteBuffer buffer = ByteBuffer.allocate(1024);while (true) {selector.select();Set keys = selector.selectedKeys();for (SelectionKey key : keys) {if (key.isAcceptable()) {SocketChannel sc = server.accept();sc.configureBlocking(false);sc.register(selector, SelectionKey.OP_READ);} else if (key.isReadable()) {SocketChannel sc = (SocketChannel) key.channel();buffer.clear();int n = sc.read(buffer);if (n <= 0) {sc.close();} else {buffer.flip();sc.write(buffer);}}}keys.clear();}}
}
6. 6. 实战一：基于 FileChannel 的文件拷贝
6.1 使用 transferTo/transferFrom 实现零拷贝拷贝
文件拷贝的高效实现通常使用 FileChannel 的 transferTo 或 transferFrom，直接在内核空间完成数据传输，减少用户态与内核态之间的数据拷贝。
示例要点包括打开源文件和目标文件的 FileChannel、确定大小、并调用 transferTo 进行传输，以及处理可能的返回值与异常。
import java.nio.channels.FileChannel;
import java.nio.file.Paths;
import java.nio.file.StandardOpenOption;
import java.nio.file.Files;
import java.nio.file.attribute.FileAttribute;
import java.nio.channels.FileChannel;
import java.io.IOException;public class FileCopyTransfer {public static void main(String[] args) throws IOException {try (FileChannel src = FileChannel.open(Paths.get("src.bin"), StandardOpenOption.READ);FileChannel dest = FileChannel.open(Paths.get("dest.bin"), StandardOpenOption.WRITE, StandardOpenOption.CREATE)) {long size = src.size();long transferred = 0;while (transferred < size) {transferred += src.transferTo(transferred, size - transferred, dest);}}}
}
7. 7. 实战二：基于 SocketChannel 的简单回音服务器
7.1 基本结构与处理流程
回音服务器是 NIO 应用的典型场景，它接收客户端发来的数据后原样返回。通过 非阻塞模式 + 选择器，可以在单线程中处理多个连接，达到高并发处理能力。
处理流程要点包括接收连接、为客户端分配缓冲区、读取数据、将数据写回客户端，以及在连接关闭时清理资源。
代码要点在于正确处理缓冲区的翻转、可读性检查以及对半关闭连接的处理。
import java.nio.channels.Selector;
import java.nio.channels.SelectionKey;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.nio.ByteBuffer;
import java.net.InetSocketAddress;
import java.util.Set;public class EchoServer {public static void main(String[] args) throws Exception {Selector selector = Selector.open();ServerSocketChannel server = ServerSocketChannel.open();server.bind(new InetSocketAddress(9000));server.configureBlocking(false);server.register(selector, SelectionKey.OP_ACCEPT);ByteBuffer buffer = ByteBuffer.allocateDirect(1024);while (true) {selector.select();Set keys = selector.selectedKeys();for (SelectionKey key : keys) {if (key.isAcceptable()) {SocketChannel sc = server.accept();sc.configureBlocking(false);sc.register(selector, SelectionKey.OP_READ);} else if (key.isReadable()) {SocketChannel sc = (SocketChannel) key.channel();buffer.clear();int read = sc.read(buffer);if (read <= 0) {sc.close();} else {buffer.flip();sc.write(buffer);}}}keys.clear();}}
}
8. 8. 进阶优化与内存管理
8.1 直接缓冲区与内存分配策略
直接缓冲区的好处在于避免多次内核与用户态拷贝，适用于高吞吐、低延迟的 I/O 场景。allocateDirect() 可以直接分配直接缓冲区，但创建成本较高，通常复用策略更重要。
缓冲区复用的原则包括避免频繁创建新缓冲区、尽量在 I/O 循环外部维护缓冲池、对连接数较多的场景采用按连接分配的本地缓冲区。
内存映射的应用边界，Memory-mapped 文件适合随机访问大文件的场景，但不宜用于频繁小范围修改的场景，因为映射区域的维护成本较高。
import java.nio.ByteBuffer;public class DirectBufferPoolDemo {public static ByteBuffer acquireBuffer() {// 假设通过池化机制获得一个直接缓冲区return ByteBuffer.allocateDirect(4096);}
}
9. 9. 高级主题：内存映射文件与直接缓冲区
9.1 Memory-mapped 文件的使用场景与示例
Memory-mapped ByteBuffer让文件的某个区域直接映射到内存视图，读写数据时像操作普通缓冲区一样高效。它的优势在于支持大文件的随机访问、降低拷贝成本。
典型用法要点包括通过 FileChannel.map 将区域映射为 MappedByteBuffer、对映射区进行字节级写入或读取、并注意避免对映射区域的超出范围访问。
import java.io.RandomAccessFile;
import java.nio.MappedByteBuffer;
import java.nio.channels.FileChannel;
import java.nio.file.Paths;public class MemoryMappedExample {public static void main(String[] args) throws Exception {try (RandomAccessFile raf = new RandomAccessFile("large.dat", "rw");FileChannel fc = raf.getChannel()) {MappedByteBuffer map = fc.map(FileChannel.MapMode.READ_WRITE, 0, fc.size());map.put(0, (byte) 1);byte b = map.get(0);System.out.println(b);}}
}
