Java NIO 使用场景

Java NIO（New I/O）适用于需要高性能、高并发的网络或文件操作场景。与传统的IO相比，NIO基于通道（Channel）和缓冲区（Buffer）的非阻塞模型更适合以下场景：

• 高并发网络通信：如聊天服务器、游戏服务器等，通过Selector实现多路复用，单线程处理大量连接。
• 文件高效读写：大文件或频繁读写的场景，如日志处理、文件传输。
• 非阻塞式操作：避免线程阻塞，提升系统吞吐量。

NIO 核心组件及示例

通道（Channel）与缓冲区（Buffer）

通道是数据的载体，缓冲区是存储数据的容器。

// 文件读写示例
try (FileChannel channel = FileChannel.open(Paths.get("test.txt"), StandardOpenOption.READ)) {
    ByteBuffer buffer = ByteBuffer.allocate(1024);
    while (channel.read(buffer) > 0) {
        buffer.flip(); // 切换为读模式
        System.out.println(new String(buffer.array(), 0, buffer.limit()));
        buffer.clear(); // 清空缓冲区
    }
} catch (IOException e) {
    e.printStackTrace();
}

选择器（Selector）

实现多路复用，监听多个通道的事件（如连接、读、写）。

// 非阻塞服务器示例
Selector selector = Selector.open();
ServerSocketChannel serverChannel = ServerSocketChannel.open();
serverChannel.bind(new InetSocketAddress(8080));
serverChannel.configureBlocking(false);
serverChannel.register(selector, SelectionKey.OP_ACCEPT);

while (true) {
    selector.select(); // 阻塞直到有事件就绪
    Set<SelectionKey> keys = selector.selectedKeys();
    Iterator<SelectionKey> iter = keys.iterator();
    while (iter.hasNext()) {
        SelectionKey key = iter.next();
        if (key.isAcceptable()) {
            SocketChannel client = serverChannel.accept();
            client.configureBlocking(false);
            client.register(selector, SelectionKey.OP_READ);
        } else if (key.isReadable()) {
            SocketChannel client = (SocketChannel) key.channel();
            ByteBuffer buffer = ByteBuffer.allocate(256);
            client.read(buffer);
            System.out.println("收到数据: " + new String(buffer.array()));
        }
        iter.remove();
    }
}

内存映射文件（MappedByteBuffer）

高效处理大文件，直接操作内存。

// 内存映射文件示例
try (FileChannel channel = FileChannel.open(Paths.get("largefile.bin"), 
    StandardOpenOption.READ, StandardOpenOption.WRITE)) {
    MappedByteBuffer buffer = channel.map(
        FileChannel.MapMode.READ_WRITE, 0, channel.size());
    while (buffer.hasRemaining()) {
        System.out.print((char) buffer.get()); // 直接读取内存
    }
} catch (IOException e) {
    e.printStackTrace();
}

注意事项

• 资源释放：通道和选择器需显式关闭，避免资源泄露。
• 缓冲区管理：注意flip()和clear()的调用时机。
• 线程安全：NIO本身非线程安全，多线程场景需额外同步。

通过合理使用NIO组件，可以显著提升I/O密集型应用的性能。