Java NIO中的SocketChannel如何进行非阻塞读写

在Java NIO中，SocketChannel可以通过设置为非阻塞模式来实现非阻塞读写。以下是如何将SocketChannel设置为非阻塞模式以及如何进行非阻塞读写的步骤：

1. 导入所需的包：

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SocketChannel;

2. 创建一个SocketChannel并连接到服务器：

SocketChannel socketChannel = SocketChannel.open();
socketChannel.configureBlocking(false); // 设置为非阻塞模式
socketChannel.connect(new InetSocketAddress("localhost", 8080));

3. 在非阻塞模式下，读写操作可能会返回-1或者0，表示当前没有数据可读或者没有数据可写。因此，需要在循环中处理这些情况：

while (true) {
    // 连接服务器
    if (!socketChannel.finishConnect()) {
        System.out.println("正在连接服务器...");
        continue;
    }

    // 发送数据
    String message = "你好，服务器!";
    ByteBuffer buffer = ByteBuffer.wrap(message.getBytes());
    while (buffer.hasRemaining()) {
        socketChannel.write(buffer);
    }

    // 接收数据
    buffer.clear();
    int bytesRead = socketChannel.read(buffer);
    while (bytesRead != -1) {
        if (bytesRead == 0) {
            break;
        }
        buffer.flip();
        while (buffer.hasRemaining()) {
            System.out.print((char) buffer.get());
        }
        buffer.clear();
        bytesRead = socketChannel.read(buffer);
    }

    // 关闭SocketChannel
    socketChannel.close();
    break;
}

在这个示例中，我们首先创建了一个SocketChannel并将其设置为非阻塞模式。然后，我们尝试连接到服务器。如果连接尚未完成，我们将继续尝试连接。

接下来，我们发送一条消息给服务器。由于SocketChannel是非阻塞的，write()方法可能会立即返回，即使没有发送所有数据。因此，我们需要在一个循环中调用write()方法，直到所有数据都被发送。

然后，我们尝试从服务器接收数据。同样，由于SocketChannel是非阻塞的，read()方法可能会立即返回，即使没有数据可读。因此，我们需要在一个循环中调用read()方法，直到返回-1表示连接已关闭或者返回0表示没有数据可读。

最后，我们关闭SocketChannel并退出循环。