如何使用Java的Selector实现多路复用网络连接？

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.*;
import java.util.Iterator;

public class SelectorExample {
    public static void main(String[] args) throws IOException {
        // 1. 创建ServerSocketChannel并绑定端口
        ServerSocketChannel serverChannel = ServerSocketChannel.open();
        serverChannel.bind(new InetSocketAddress(8080));
        serverChannel.configureBlocking(false); // 设置为非阻塞模式

        // 2. 创建Selector
        Selector selector = Selector.open();

        // 3. 将ServerSocketChannel注册到Selector，监听OP_ACCEPT事件
        serverChannel.register(selector, SelectionKey.OP_ACCEPT);

        System.out.println("服务器启动，监听端口8080...");

        // 4. 事件循环
        while (true) {
            // 阻塞直到有事件发生
            selector.select();

            // 获取所有已就绪的事件的SelectionKey
            Iterator<SelectionKey> keyIterator = selector.selectedKeys().iterator();
            while (keyIterator.hasNext()) {
                SelectionKey key = keyIterator.next();
                keyIterator.remove(); // 必须手动移除，否则会重复处理

                // 5. 判断事件类型并处理
                if (key.isAcceptable()) {
                    // 处理客户端连接
                    ServerSocketChannel server = (ServerSocketChannel) key.channel();
                    SocketChannel clientChannel = server.accept();
                    clientChannel.configureBlocking(false);
                    System.out.println("接收到新连接：" + clientChannel.getRemoteAddress());
                    // 将客户端通道注册到Selector，监听OP_READ事件
                    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();
                        System.out.println("收到数据：" + new String(buffer.array(), 0, bytesRead));
                        buffer.clear();
                        // 回复客户端
                        clientChannel.write(ByteBuffer.wrap("服务器已收到你的消息！".getBytes()));
                    } else if (bytesRead == -1) {
                        // 客户端关闭连接
                        System.out.println("客户端断开连接：" + clientChannel.getRemoteAddress());
                        clientChannel.close();
                    }
                }
            }
        }
    }
}