java nio通过selector实现单线程管理万级连接，核心是事件驱动模型：注册非阻塞channel监听op_accept/op_read等事件，select()阻塞等待就绪，遍历selectedkeys()分发处理，配合bytebuffer缓冲与并发安全的广播机制支撑高并发聊天室。

Java 中用 Selector 实现高并发 TCP 聊天室服务端，核心是基于 NIO 的单线程事件驱动模型，避免传统 BIO 每连接一线程的资源开销。关键不在“写多少代码”，而在理清事件生命周期、缓冲区管理、线程安全边界和客户端状态维护。

用 Selector 管理多个客户端连接

Selector 本身不处理网络 I/O，它只是监听多个 Channel（如 ServerSocketChannel 和 SocketChannel）上就绪的事件（OP_ACCEPT、OP_READ、OP_WRITE）。服务端只需一个线程调用 selector.select() 阻塞等待事件，再遍历 selectedKeys() 分发处理。

• 初始化时，把 ServerSocketChannel 注册为 OP_ACCEPT，监听新连接
• 每次 accept() 成功后，将新得到的 SocketChannel 设为非阻塞，并注册 OP_READ
• 不要在 OP_READ 处理中直接 read() 到业务对象——先读入 ByteBuffer，再解析成完整消息（比如按换行或长度前缀）

消息协议与粘包/半包处理

TCP 是流式协议，一次 read() 可能只读到半个消息，也可能读到多个消息拼在一起。聊天室必须定义简单协议，否则无法区分用户发的每条消息。

Java Development Manual

Java开发手册规约集合，基于阿里巴巴Java开发手册（嵩山版）。 涵盖7大维度：编程规约、异常日志、单元测试、安全规约、MySQL数据库、工程结构、设计规约。 当用户需要：(1) 编写或审查Java代码 (2) 检查命名/代码规范 (3) 处理异常和日志 (4) 编写单元测试 (5) 安全编码 (6) 数据库设...

下载

• 推荐用“行协议”：客户端每发一条消息以 \n 结尾（如 "hello\n"），服务端用 ByteBuffer 缓存未解析字节，遇到 \n 就切出一条完整消息
• 避免用 String.split("\n") 直接切原始字节流——要自己扫描 ByteBuffer，记录已消费位置，防止丢数据
• 每个 SocketChannel 对应一个独立的 ByteBuffer（可放在 SelectionKey.attach() 中），不同连接不共享缓冲区

广播消息与线程安全边界

聊天室的核心逻辑是“收到 A 的消息，转发给除 A 外所有在线用户”。但 Selector 线程不能长时间阻塞或执行耗时操作，否则影响事件响应。

• 收到完整消息后，立即在 selector 线程里解析出发送者 ID 和内容，然后把“广播任务”放入线程安全队列（如 ConcurrentLinkedQueue）
• 另起一个或多个工作线程消费该队列，执行实际的 write()；或者仍由 selector 线程在下一轮 select() 前批量处理（更轻量）
• 所有对在线用户列表（如 Map<socketchannel string nickname></socketchannel>）的增删查操作，必须加锁或用并发容器；注册/取消注册 Channel 时，务必用 selector.wakeup() 唤醒正在阻塞的 select()，确保状态及时生效

资源清理与异常处理

NIO 不会自动关闭失效连接。客户端断网、强制关进程、心跳超时等情况都需主动识别并释放资源。

• 在 OP_READ 时，若 channel.read(buf) 返回 -1，说明对端关闭，应取消 key、关闭 channel、从用户列表移除
• 对长时间无读写活动的连接，可结合时间戳 + 定期检查实现简易心跳（例如每次读写更新 lastActiveTime，空闲超 5 分钟则踢出）
• 捕获 IOException、CancelledKeyException 等典型异常，统一做 close + cancel 处理，避免 key 泄漏导致 CPU 占用飙升

Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南