Java中的五种I/O模型详解

一、阻塞I/O（Blocking I/O）

1.1 概念

阻塞I/O是最传统的I/O模型。在该模型中，当一个线程执行I/O操作时，如果没有数据可读或可写，线程将会被阻塞，直到I/O操作完成。

1.2 工作原理

当线程调用读取或写入数据的方法时，如果操作无法立即完成，线程将进入阻塞状态。
阻塞状态持续到操作完成或发生错误。

1.3 示例代码

import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;public class BlockingIOExample {public static void main(String[] args) {try (BufferedReader reader = new BufferedReader(new FileReader("example.txt"))) {String line;while ((line = reader.readLine()) != null) {System.out.println(line);}} catch (IOException e) {e.printStackTrace();}}
}

1.4 优缺点

优点：
- 实现简单，易于理解和使用。
缺点：
- 线程阻塞会浪费系统资源，尤其在高并发场景下，效率较低。

1.5 适用场景

适合于I/O操作较少或对性能要求不高的场景，如简单的文件读写操作。

二、非阻塞I/O（Non-blocking I/O）

2.1 概念

非阻塞I/O模型允许线程在执行I/O操作时不被阻塞。当I/O操作无法立即完成时，线程可以继续执行其他任务。

2.2 工作原理

使用非阻塞模式打开I/O通道。
当调用读取或写入方法时，方法立即返回，指示操作是否成功。
线程可以在之后的某个时间再尝试I/O操作。

2.3 示例代码

import java.io.IOException;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;public class NonBlockingIOExample {public static void main(String[] args) {try {Selector selector = Selector.open();ServerSocketChannel serverChannel = ServerSocketChannel.open();serverChannel.configureBlocking(false);serverChannel.socket().bind(new java.net.InetSocketAddress(8080));serverChannel.register(selector, SelectionKey.OP_ACCEPT);while (true) {selector.select();for (SelectionKey key : selector.selectedKeys()) {// 处理I/O操作}}} catch (IOException e) {e.printStackTrace();}}
}

2.4 优缺点

优点：
- 提高了程序的灵活性，允许线程同时处理多个I/O操作。
缺点：
- 编码复杂度增加，管理状态和错误处理较为麻烦。

2.5 适用场景

适用于高并发场景，如网络服务器，能够有效提高资源利用率。

三、选择器I/O（Selector I/O）

3.1 概念

选择器I/O是Java NIO中的一部分，通过选择器（Selector）来管理多个通道的I/O操作。选择器可以同时监控多个通道的状态，线程可以根据需要进行处理。

3.2 工作原理

使用选择器注册多个通道。
选择器可以监听通道的可读、可写等事件。
当某个通道的状态发生变化时，选择器会通知相关线程。

3.3 示例代码

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;public class SelectorIOExample {public static void main(String[] args) {try {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();for (var key : selector.selectedKeys()) {if (key.isAcceptable()) {SocketChannel clientChannel = serverChannel.accept();clientChannel.configureBlocking(false);clientChannel.register(selector, SelectionKey.OP_READ);}if (key.isReadable()) {// 读取数据}}}} catch (IOException e) {e.printStackTrace();}}
}

3.4 优缺点

优点：
- 可以有效管理多个I/O通道，提高并发处理能力。
缺点：
- 实现较复杂，需要对选择器和通道有深入了解。

3.5 适用场景

适用于需要处理大量连接的网络服务器，特别是当连接数远超线程数时。

四、NIO（New I/O）

4.1 概念

Java NIO是Java 1.4引入的一个新的I/O库，提供了更为高效的I/O处理能力。NIO支持缓冲区、通道、选择器等概念，支持非阻塞I/O操作。

4.2 工作原理

缓冲区：数据在传输过程中先被存放在缓冲区中，提高了数据读写的效率。
通道：通过通道进行数据传输，支持非阻塞操作。
选择器：用于管理多个通道，提高I/O处理能力。

4.3 示例代码

import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;
import java.nio.file.FileChannel;
import java.nio.file.StandardOpenOption;public class NIOExample {public static void main(String[] args) {try (FileChannel fileChannel = FileChannel.open(java.nio.file.Paths.get("example.txt"), StandardOpenOption.READ)) {ByteBuffer buffer = ByteBuffer.allocate(1024);int bytesRead = fileChannel.read(buffer);while (bytesRead != -1) {System.out.println("Read " + bytesRead + " bytes.");buffer.clear();bytesRead = fileChannel.read(buffer);}} catch (IOException e) {e.printStackTrace();}}
}

4.4 优缺点

优点：
- 提高了I/O性能，特别是在高并发场景下。
- 支持文件、网络、数据流等多种I/O操作。
缺点：
- 学习曲线较陡，API相对复杂。

4.5 适用场景

适用于高性能和高并发的应用，如网络服务器、文件服务器等。

五、异步I/O（Asynchronous I/O）

5.1 概念

异步I/O是指在进行I/O操作时，程序不需要等待操作完成，而是可以继续执行其他任务。Java通过java.nio.channels.AsynchronousChannel类提供了异步I/O支持。

5.2 工作原理

异步I/O操作通过回调机制来处理结果。
当I/O操作完成后，系统会自动调用注册的回调函数。

5.3 示例代码

import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.AsynchronousFileChannel;
import java.nio.file.Paths;
import java.nio.file.StandardOpenOption;public class AsyncIOExample {public static void main(String[] args) {try (AsynchronousFileChannel fileChannel = AsynchronousFileChannel.open(Paths.get("example.txt"), StandardOpenOption.READ)) {ByteBuffer buffer = ByteBuffer.allocate(1024);fileChannel.read(buffer, 0, null, new java.nio.channels.CompletionHandler<Integer, Void>() {@Overridepublic void completed(Integer result, Void attachment) {System.out.println("Read " + result + " bytes.");}@Overridepublic void failed(Throwable exc, Void attachment) {exc.printStackTrace();}});} catch (IOException e) {e.printStackTrace();}}
}