一个故事讲清楚 NIO：老张的茶馆与现代化餐厅

// 智能餐厅老板小张 (NIO Server)
public class NioServer {
    public static void main(String[] args) throws IOException {
        // 1. 创建选择器 (迎宾台的登记表)
        Selector selector = Selector.open();
 
        // 2. 创建 ServerSocketChannel (餐厅大门)
        ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
        serverSocketChannel.bind(new InetSocketAddress(8080));
        serverSocketChannel.configureBlocking(false); // 设置为非阻塞模式！
 
        // 3. 将 Channel 注册到 Selector，监听 ACCEPT 事件 (告诉迎宾台，只关注“新客人到来”这件事)
        serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
        System.out.println("服务器启动在端口 8080...");
 
        // 4. 开始轮询 (小张开始不停地查看登记表)
        while (true) {
            // 检查登记表上是否有新事件，等待1000毫秒，如果没有事件就继续
            if (selector.select(1000) == 0) {
                continue;
            }
 
            // 获取所有已就绪的事件的 SelectionKey 集合
            Set<SelectionKey> selectedKeys = selector.selectedKeys();
            Iterator<SelectionKey> keyIterator = selectedKeys.iterator();
 
            while (keyIterator.hasNext()) {
                SelectionKey key = keyIterator.next();
 
                // 处理 “新连接” 事件
                if (key.isAcceptable()) {
                    // 接受新连接，相当于迎接新客人
                    SocketChannel clientChannel = serverSocketChannel.accept();
                    clientChannel.configureBlocking(false);
                    // 将新连接的通道注册到选择器，监听 READ 事件 (告诉迎宾台，现在要关注这位客人“是否需要点餐/传菜”)
                    clientChannel.register(selector, SelectionKey.OP_READ);
                    System.out.println("客户端连接: " + clientChannel.getRemoteAddress());
                }
 
                // 处理 “数据可读” 事件
                if (key.isReadable()) {
                    // 获取与这个 Key 关联的 Channel
                    SocketChannel clientChannel = (SocketChannel) key.channel();
                    // 准备一个缓冲区 (拿来菜单)
                    ByteBuffer buffer = ByteBuffer.allocate(1024);
                    try {
                        int bytesRead = clientChannel.read(buffer);
                        if (bytesRead > 0) {
                            buffer.flip(); // 切换为读模式
                            byte[] bytes = new byte[buffer.remaining()];
                            buffer.get(bytes);
                            String message = new String(bytes, StandardCharsets.UTF_8);
                            System.out.println("收到来自客户端的消息: " + message);
 
                            // 可以在这里进行业务处理，并准备回写数据...
                            String response = "服务器回复: 已收到你的消息 - " + message;
                            ByteBuffer writeBuffer = ByteBuffer.wrap(response.getBytes());
                            clientChannel.write(writeBuffer);
                        } else if (bytesRead == -1) {
                            // 客户端关闭连接
                            System.out.println("客户端断开连接: " + clientChannel.getRemoteAddress());
                            key.cancel();
                            clientChannel.close();
                        }
                    } catch (IOException e) {
                        // 客户端异常断开
                        key.cancel();
                        try { clientChannel.close(); } catch (IOException ex) { ex.printStackTrace(); }
                    }
                }
 
                // 非常重要：处理完当前 Key 后，要将其从迭代器中移除
                // 相当于小张处理完一个需求后，在登记表上把它划掉
                keyIterator.remove();
            }
        }
    }
}