Java控制台聊天室核心是多线程协作与实时通信：服务端用线程池管理客户端连接，客户端双线程分离收发，ConcurrentHashMap维护在线用户，约定换行符协议并做好异常清理。
用Java开发控制台聊天室，核心在于多线程协作与实时通信机制的设计。服务端需同时处理多个客户端连接，客户端需分离收发逻辑避免阻塞，而线程间的数据同步与消息分发是关键难点。
服务端：用线程池管理客户端连接
服务端启动一个ServerSocket监听端口，每接受一个客户端连接，就交给线程池中的新线程处理，避免串行阻塞。每个客户端连接对应一个独立的Socket和专属线程，负责该用户的读写。
建议使用ExecutorService而非手动new Thread，便于资源管控：
- 定义固定大小线程池（如Executors.newCachedThreadPool()或带界线程池）
- 为每个Socket创建ClientHandler线程类，实现Runnable，封装输入流读取、消息广播、异常断连处理
- 维护一个ConcurrentHashMap
在线用户表，键为昵称（需去重校验），值为对应客户端的输出流，用于精准推送
客户端：双线程分离收发逻辑
控制台客户端不能让“接收消息”阻塞“发送消息”，必须拆成两个线程：一个监听System.in读取用户输入并发送；另一个持续从Socket输入流读取服务端下发的消息并打印。
立即学习“Java免费学习笔记（深入）”；
java-api-doc-generator
下载
分析 Java Spring Boot 后端 Controller 代码，自动生成 Markdown 格式的接口文档。当用户说“生成 Java 接口文档”、“生成 API 文档”、“从 Spring 代码生成文档”时触发。
常见错误是只用单线程顺序执行send/receive，导致一发消息就卡住无法收新消息。正确做法：
- 主线程启动后，立即开启一个新线程运行Receiver（不断调用bufferedReader.readLine()）
- 主线程继续循环Scanner.nextLine()，获取输入后通过PrintWriter发给服务端
- 双方约定简单协议，例如用"/nick 用户名"设置昵称，用"/quit"主动下线
消息广播与线程安全
服务端收到某用户消息后，需转发给其他所有在线用户。注意避免遍历Map时发生ConcurrentModificationException。
推荐方式：
- 用ConcurrentHashMap存储用户输出流，其keySet()、values()等方法是弱一致性快照，适合遍历广播
- 每次广播前可先复制活跃流集合：Collection
recipients = new ArrayList(onlineUsers.values()) - 对每个PrintWriter单独try-catch，个别客户端断连时仅关闭其流、移除对应条目，不影响其他用户
基础通信协议与健壮性设计
没有协议的裸Socket容易因粘包、半包、空行等问题崩溃。建议引入轻量级文本协议：
- 每条消息以换行符\n结尾（readLine()天然适配）
- 服务端向客户端推送系统通知时加前缀"[SYS]"，普通聊天不加，方便客户端区分处理
- 客户端发送前trim()去首尾空格，空消息直接忽略，防止误触回车刷屏
- Socket读写操作统一包裹try-with-resources或显式close，并在finally中清理线程与Map条目
不复杂但容易忽略的是异常传播路径——网络中断、用户强退、流关闭异常必须被捕获并触发清理逻辑，否则会出现“僵尸连接”占用线程和内存。把连接生命周期管理清楚，整个框架就立住了。
