Java并发编程中的阻塞和非阻塞操作：Socket案例-蒲公英云

Java并发编程中的阻塞和非阻塞操作：Socket案例

原创傷城~ 2024-11-08 00:51 70阅读 0赞

在Java并发编程中，阻塞和非阻塞操作是两种不同的I/O处理方式，它们在处理网络通信，如Socket编程时，有着不同的应用场景和性能表现。下面我将通过Socket案例来解释这两种操作的区别和应用。

阻塞操作（Blocking I/O）

阻塞I/O是指在数据未准备好时，调用会阻塞当前线程，直到数据准备完毕。在Java中，传统的Socket和ServerSocket类就是基于阻塞I/O实现的。

示例代码：

```javaServerSocket serverSocket = new ServerSocket(port);
Socket clientSocket = serverSocket.accept(); //阻塞，直到客户端连接InputStream input = clientSocket.getInputStream();
OutputStream output = clientSocket.getOutputStream();

byte[] buffer = new byte[1024];
int bytesRead = input.read(buffer); //阻塞，直到有数据可读output.write(buffer,0, bytesRead); // 发送数据output.flush();

clientSocket.close();
serverSocket.close();
``在这个例子中，serverSocket.accept()会阻塞，直到有客户端连接。input.read(buffer)`也会阻塞，直到有数据可读。

非阻塞操作（Non-blocking I/O）

非阻塞I/O是指在数据未准备好时，调用会立即返回，不会阻塞当前线程。Java NIO（New Input/Output）库提供了非阻塞I/O的支持。

示例代码：

```javaAsynchronousServerSocketChannel serverChannel = AsynchronousServerSocketChannel.open().bind(new InetSocketAddress(port));

serverChannel.accept(null, new CompletionHandler() {
@Override public void completed(AsynchronousSocketChannel clientChannel, Void attachment) {
serverChannel.accept(null, this); //继续接受下一个连接//处理客户端连接 clientChannel.read(ByteBuffer.allocate(1024), null, new CompletionHandler() {
@Override public void completed(Integer result, ByteBuffer buffer) {
//处理读取的数据 buffer.flip();
clientChannel.write(ByteBuffer.wrap(“Echo: “.getBytes()));
clientChannel.close();
}

@Override public void failed(Throwable exc, ByteBuffer attachment) {
//处理异常 }
});
}

@Override public void failed(Throwable exc, Void attachment) {
//处理异常 }
});
``在这个例子中，serverChannel.accept(null, this)是非阻塞的，它会立即返回，不会等待客户端连接。clientChannel.read(ByteBuffer.allocate(1024), null, handler)`也是非阻塞的，它会立即返回，不会等待数据可读。