Java中NIO的解析_Java中非阻塞IO的使用

磁力搜索 • 4 天前 • 2 次点击 • 资讯分享

java nio通过非阻塞io和单线程处理多连接提升性能。其核心组件包括channel（双向数据传输，如socketchannel）、buffer（存储数据，如bytebuffer）和selector（监听channel事件）。使用步骤为：1. 创建channel；2. 设置非阻塞模式；3. 注册channel到selector并指定事件类型；4. selector轮询事件；5. 处理事件。nio比传统io更快的原因在于避免了线程阻塞和上下文切换，同时减少数据拷贝次数。零拷贝通过transferto/transferfrom减少用户空间拷贝，但依赖操作系统实现完全零拷贝。应用场景包括高并发网络服务器、netty等框架、cdn文件传输。

Java NIO，简单来说，就是Java提供的非阻塞IO解决方案。它允许单线程处理多个并发连接，提升服务器性能。但要真正用好NIO，理解其底层原理和适用场景至关重要。

解决方案

NIO的核心在于三个组件：Channel、Buffer和Selector。

立即学习“Java免费学习笔记（深入）”；

Channel: 可以把它看作是传统IO的Stream，但Channel是双向的，可以同时进行读写操作。常见的Channel有FileChannel、SocketChannel、ServerSocketChannel等。
Buffer: 用于存储数据的缓冲区，NIO是面向Buffer的，所有数据的读取和写入都通过Buffer进行。Buffer有多种类型，如ByteBuffer、CharBuffer、IntBuffer等，根据存储的数据类型选择合适的Buffer。
Selector: 核心组件，它允许单线程监听多个Channel的事件（如连接、读取、写入等）。通过Selector，我们可以实现非阻塞的IO操作。

使用NIO的一般步骤如下：

创建Channel: 根据需要创建ServerSocketChannel或SocketChannel。ServerSocketChannel用于监听新的连接，SocketChannel用于与客户端进行通信。
配置Channel为非阻塞模式: channel.configureBlocking(false); 这是NIO的关键，设置为非阻塞模式后，IO操作不会阻塞线程。
注册Channel到Selector: channel.register(selector, SelectionKey.OP_ACCEPT); 将Channel注册到Selector，并指定感兴趣的事件类型，如OP_ACCEPT（连接事件）、OP_READ（读取事件）、OP_WRITE（写入事件）。
Selector轮询: selector.select(); Selector会阻塞等待，直到有Channel发生感兴趣的事件。
处理事件: 当Selector返回时，可以通过selector.selectedKeys()获取发生事件的SelectionKey集合。遍历SelectionKey集合，根据Key的类型进行相应的处理，如接受连接、读取数据、写入数据等。

例如，一个简单的ServerSocketChannel的例子：

ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
serverSocketChannel.socket().bind(new InetSocketAddress(8080));
serverSocketChannel.configureBlocking(false);

Selector selector = Selector.open();
serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);

while (true) {
    selector.select();
    Set<SelectionKey> selectedKeys = selector.selectedKeys();
    Iterator<SelectionKey> keyIterator = selectedKeys.iterator();

    while (keyIterator.hasNext()) {
        SelectionKey key = keyIterator.next();
        keyIterator.remove();

        if (key.isAcceptable()) {
            ServerSocketChannel server = (ServerSocketChannel) key.channel();
            SocketChannel client = server.accept();
            client.configureBlocking(false);
            client.register(selector, SelectionKey.OP_READ);
            System.out.println("Accepted connection from: " + client.getRemoteAddress());
        } else if (key.isReadable()) {
            SocketChannel client = (SocketChannel) key.channel();
            ByteBuffer buffer = ByteBuffer.allocate(1024);
            int bytesRead = client.read(buffer);
            if (bytesRead > 0) {
                buffer.flip();
                byte[] data = new byte[buffer.remaining()];
                buffer.get(data);
                String message = new String(data);
                System.out.println("Received: " + message + " from " + client.getRemoteAddress());
                client.write(ByteBuffer.wrap(("Echo: " + message).getBytes())); // Echo back
            } else if (bytesRead == -1) {
                System.out.println("Client disconnected: " + client.getRemoteAddress());
                client.close();
                key.cancel();
            }
        }
    }
}

登录后复制

文章作者：磁力搜索
文章标题：Java中NIO的解析_Java中非阻塞IO的使用
文章链接：https://www.onehaoka.com/2264.html
本站所有文章除特别声明外，均采用 CC BY-NC-SA 4.0 许可协议，转载请注明来自磁力搜索！

Java中NIO的解析_Java中非阻塞IO的使用

📚 推荐阅读