java nio怎么写服务器

下面给你一个最基础、可直接运行的 Java NIO 服务器端示例，并配合关键概念说明，方便你理解。

一、Java NIO 服务器核心组件

Java NIO 主要用这几个类：

• ServerSocketChannel：监听连接
• SocketChannel：客户端连接
• Selector：多路复用器（核心）
• ByteBuffer：数据缓冲区

二、最简 NIO 服务器示例（单线程）

1️⃣ 服务器代码

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

public class NioServer {

    public static void main(String[] args) throws IOException {
        // 1. 打开 Selector
        Selector selector = Selector.open();

        // 2. 打开 ServerSocketChannel
        ServerSocketChannel serverChannel = ServerSocketChannel.open();
        serverChannel.configureBlocking(false); // 非阻塞
        serverChannel.bind(new InetSocketAddress(8080));

        // 3. 注册 Accept 事件
        serverChannel.register(selector, SelectionKey.OP_ACCEPT);

        System.out.println("NIO Server started on port 8080");

        // 4. 事件循环
        while (true) {
            selector.select(); // 阻塞等待事件

            Iterator<SelectionKey> iterator = selector.selectedKeys().iterator();
            while (iterator.hasNext()) {
                SelectionKey key = iterator.next();
                iterator.remove();

                if (key.isAcceptable()) {
                    // 有新连接
                    SocketChannel client = serverChannel.accept();
                    client.configureBlocking(false);
                    client.register(selector, SelectionKey.OP_READ);
                    System.out.println("Client connected");

                } else if (key.isReadable()) {
                    // 可读事件
                    SocketChannel client = (SocketChannel) key.channel();
                    ByteBuffer buffer = ByteBuffer.allocate(1024);

                    int len = client.read(buffer);
                    if (len == -1) {
                        client.close();
                        continue;
                    }

                    buffer.flip();
                    byte[] data = new byte[buffer.remaining()];
                    buffer.get(data);
                    System.out.println("Received: " + new String(data));

                    // 回写客户端
                    buffer.rewind();
                    client.write(buffer);
                }
            }
        }
    }
}

三、运行方式

1. 启动服务器
2. 用 telnet 或 nc 测试：

telnet localhost 8080

输入内容 → 服务器回显

四、核心流程总结

ServerSocketChannel
        ↓ 注册 OP_ACCEPT
     Selector
        ↓ 事件触发
   SocketChannel
        ↓ 注册 OP_READ
     Selector
        ↓ 读/写数据

五、常见进阶点（你可以继续学）

• ✅ 多线程 Reactor 模型
• ✅ OP_WRITE 半包/粘包处理
• ✅ ByteBuffer 堆外内存
• ✅ Netty（生产级 NIO 封装）

如果你愿意，我可以：

• 帮你写 Netty 版服务器
• 讲 Reactor 线程模型
• 写一个 聊天室示例
• 或按你的业务场景定制

你想往哪块深入？