Java中IO操作的阻塞与非阻塞示例

原创短命女 2024-11-21 11:54 7阅读 0赞

在Java中，IO（Input/Output）操作可以分为阻塞和非阻塞两种方式。

1. 阻塞I/O：

- 当调用同步方法如`read()`、`write()`等时，如果数据未准备好，那么线程会立即被操作系统挂起，直到有数据准备。

示例：
```java
Socket socket = new Socket("localhost", 8080);
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream())));

String inputLine;
while ((inputLine = in.readLine()) != null) {
    System.out.println(inputLine);
}

in.close();
socket.close();
```
2. 非阻塞I/O：

- Java通过NIO（New IO）提供非阻塞的IO操作，主要包括`SelectChannel`、`SocketChannel`等。

示例：
```java
import java.nio.*;
import java.nio.channels.*;

public class NonBlockingExample {
    public static void main(String[] args) throws Exception {
        // 创建一个选择通道
        SelectChannel sel = Channels.newSelector();

// 注册SocketChannel，使其可以被监听
        SocketChannel sock = new SocketChannel();
        sock.configureBlocking(false); // 设置非阻塞模式
        sel.register(sock, SelectionKey.OP_READ)); // 监听读事件

while (true) {
            // 等待有可读的数据或连接请求
            int ready = sel.selectNow();
            if (ready > 0) { // 处理到的事件
                Iterator<SelectionKey> it = sel.selectedKeys().iterator();
                while (it.hasNext()) {
                    SelectionKey key = it.next();
                    if (key.isReadable() && sock.socket() != null) {
                        byte[] buffer = new byte[1024]; // 读取缓冲区
                        int bytesRead = sock.read(buffer); // 从Socket读取数据
                        if (bytesRead > 0) { // 处理读取到的数据
                            String input = new String(buffer, 0, bytesRead)); // 创建字符串
                            System.out.println("Received: " + input);
                        }
                    }
                }
            }
        }
    }
}
```
这个示例中，我们创建了一个非阻塞的SocketChannel，并监听其读事件。当有可读数据到达时，我们从Socket读取数据并处理。