“有的时候博客内容会有变动，首发博客是最新的，其他博客地址可能会未同步,认准
”https://blog.zysicyj.top
1. 什么是NIO?
NIO（New I/O）是Java提供的一种非阻塞I/O模型，它在JDK 1.4中引入。与传统的I/O模型相比，NIO提供了更高效、更灵活的I/O操作方式。
2. 为什么需要NIO?
传统的I/O模型使用阻塞式I/O，在进行读写操作时会导致线程被阻塞，直到数据准备好或者写入完成。这种模型对于并发处理能力较弱，当有大量连接同时请求时，每个连接都需要一个独立的线程来处理，造成资源浪费和性能下降。
而NIO采用了事件驱动的方式，通过Selector轮询注册的通道，只有在通道真正有读写事件发生时才会进行处理，避免了线程被阻塞的情况，提高了系统的并发处理能力。
3. NIO的实现原理?
NIO的核心组件包括：Channel、Buffer和Selector。
- Channel: 类似于传统I/O中的流，可以通过Channel进行数据的读取和写入。常见的Channel类型有SocketChannel、ServerSocketChannel、FileChannel等。
- Buffer: 缓冲区，用于存储数据。在NIO中，所有的数据都是通过Buffer进行读写的。常见的Buffer类型有ByteBuffer、CharBuffer、IntBuffer等。
- Selector: 选择器，用于监听多个Channel的事件。通过Selector可以实现单线程处理多个通道的读写操作。
NIO的工作原理如下：
- 创建一个Selector，并将其注册到需要监听的Channel上。
- 当有数据准备好时，Selector会轮询已注册的Channel，发现有事件发生的Channel后进行处理。
- 根据不同的事件类型（读、写、连接、接收），使用对应的方法进行处理。
4. NIO的使用示例
以下是一个简单的NIO服务器示例，用于接收客户端发送的消息并返回相同的消息给客户端：
import java.io.IOException; import java.net.InetSocketAddress; import java.nio.ByteBuffer; import java.nio.channels.SelectionKey; import java.nio.channels.Selector; import java.nio.channels.ServerSocketChannel; import java.nio.channels.SocketChannel; import java.util.Iterator; public class NIOServer { public static void main(String[] args) throws IOException { // 创建ServerSocketChannel ServerSocketChannel serverSocketChannel = ServerSocketChannel.open(); serverSocketChannel.socket().bind(new InetSocketAddress(8888)); serverSocketChannel.configureBlocking(false); // 创建Selector Selector selector = Selector.open(); serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT); while (true) { // 阻塞等待就绪的Channel int readyChannels = selector.select(); if (readyChannels == 0) { continue; } // 获取就绪的SelectionKey集合 Iterator<SelectionKey> keyIterator = selector.selectedKeys().iterator(); while (keyIterator.hasNext()) { SelectionKey key = keyIterator.next(); if (key.isAcceptable()) { // 接收新的连接 ServerSocketChannel serverChannel = (ServerSocketChannel) key.channel(); SocketChannel socketChannel = serverChannel.accept(); socketChannel.configureBlocking(false); socketChannel.register(selector, SelectionKey.OP_READ); } else if (key.isReadable()) { // 读取数据 SocketChannel socketChannel = (SocketChannel) key.channel(); ByteBuffer buffer = ByteBuffer.allocate(1024); int bytesRead = socketChannel.read(buffer); if (bytesRead > 0) { buffer.flip(); byte[] data = new byte[buffer.remaining()]; buffer.get(data); String message = new String(data, "UTF-8"); System.out.println("Received message: " + message); // 返回相同的消息给客户端 ByteBuffer responseBuffer = ByteBuffer.wrap(data); socketChannel.write(responseBuffer); } else if (bytesRead < 0) { // 客户端关闭连接 socketChannel.close(); } } // 移除处理过的SelectionKey keyIterator.remove(); } } } }
5. NIO的优点
- 高并发性：NIO采用了事件驱动的方式，可以使用单线程处理多个通道的读写操作，提高系统的并发处理能力。
- 非阻塞式I/O：NIO模型中的通道是非阻塞的，不会因为某个通道的读写操作而导致线程被阻塞，提高了系统的响应速度和吞吐量。
- 内存管理优化：NIO使用了直接内存缓冲区，可以减少数据在Java堆和操作系统之间的拷贝次数，提高了I/O性能。
6. NIO的缺点
- 复杂性较高：相比传统的阻塞式I/O模型，NIO的编程模型更加复杂，需要处理事件驱动、多路复用等概念。
- 对编程人员要求较高：由于NIO的复杂性，对编程人员的技术要求较高，需要熟悉NIO相关的API和底层原理。
7. NIO的使用注意事项
- 需要合理设置缓冲区大小：过小的缓冲区可能导致频繁的读写操作，影响性能；过大的缓冲区可能造成资源浪费。
- 注意正确释放资源：在使用完Channel和Buffer后，需要及时关闭并释放资源，避免出现资源泄露问题。
- 谨慎处理异常情况：NIO中的异常处理相对复杂，需要仔细处理各种异常情况，以保证程序的稳定性和可靠性。
8. 总结
NIO是一种非阻塞I/O模型，通过事件驱动和选择器机制实现高效的I/O操作。它具有高并发性、非阻塞式I/O和内存管理优化等优点，但也存在复杂性较高和对编程人员要求较高的缺点。在使用NIO时需要注意合理设置缓冲区大小、正确释放资源和谨慎处理异常情况。
本文由 mdnice 多平台发布
