Java NIO中的非阻塞模式如何设置

在Java NIO（New I/O）中，非阻塞模式是通过设置通道（Channel）为非阻塞模式来实现的。以下是如何设置非阻塞模式的步骤：

1. 首先，需要导入相关的包：

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

2. 创建一个ServerSocketChannel实例，并将其设置为非阻塞模式：

ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
serverSocketChannel.configureBlocking(false);

3. 绑定端口并启动服务器：

InetSocketAddress inetSocketAddress = new InetSocketAddress(8080);
serverSocketChannel.bind(inetSocketAddress);

4. 创建一个Selector实例，用于管理多个通道：

Selector selector = Selector.open();

5. 将ServerSocketChannel注册到Selector，并监听OP_ACCEPT事件：

serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);

6. 在一个循环中处理事件：

while (true) {
    int readyChannels = selector.select();
    if (readyChannels == 0) continue;

    Set<SelectionKey> selectedKeys = selector.selectedKeys();
    Iterator<SelectionKey> keyIterator = selectedKeys.iterator();

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

        if (key.isAcceptable()) {
            // 处理连接请求
            ServerSocketChannel serverChannel = (ServerSocketChannel) key.channel();
            SocketChannel clientChannel = serverChannel.accept();
            clientChannel.configureBlocking(false);
            clientChannel.register(selector, SelectionKey.OP_READ);
        } else if (key.isReadable()) {
            // 处理读取事件
            SocketChannel clientChannel = (SocketChannel) key.channel();
            ByteBuffer buffer = ByteBuffer.allocate(1024);
            int bytesRead = clientChannel.read(buffer);

            if (bytesRead > 0) {
                // 处理接收到的数据
                buffer.flip();
                byte[] data = new byte[buffer.remaining()];
                buffer.get(data);
                String message = new String(data).trim();
                System.out.println("Received: " + message);
            } else if (bytesRead == -1) {
                // 客户端关闭连接
                clientChannel.close();
            }
        }

        keyIterator.remove();
    }
}

在这个示例中，我们创建了一个简单的非阻塞服务器，监听8080端口。当客户端连接时，服务器接受连接并将客户端通道注册到Selector以监听OP_READ事件。当客户端发送数据时，服务器读取数据并处理。整个过程是非阻塞的，因为我们在处理事件时不会等待任何操作完成。