Java控制台聊天室的核心是保障不卡死、不断连、不丢消息,需用多线程分离Socket读写,服务端用ServerSocket配合线程池处理并发连接,客户端需拆分输入输出线程,PrintWriter须启用自动flush,广播时用CopyOnWriteArrayList并捕获IO异常清理失效连接,掉线检测依赖心跳或读超时。

Java 控制台聊天室的核心不是“做出来”,而是“不卡死、不断连、不丢消息”——这要求你必须用多线程分离 Socket 的读写,且服务端得能同时处理多个客户端连接。
服务端必须用 ServerSocket + 多线程接受连接
单线程 accept() 只能串行处理客户端,第二个用户会一直阻塞等待。正确做法是每来一个连接就启动一个新线程(或交给 ExecutorService)专门处理该客户端的 InputStream 和 OutputStream。
常见错误:在主线程里直接调用 socket.getInputStream().read(),导致整个服务端被某个发呆客户端拖住。
- 用
new Thread(() -> handleClient(socket)).start()最直观,适合教学和小规模测试 - 生产级建议用
ExecutorService fixedThreadPool = Executors.newFixedThreadPool(10)控制并发数 -
ServerSocket创建时可设setSoTimeout(5000)避免accept()永久阻塞(调试时有用)
客户端输入/输出不能共用一个线程
控制台程序最典型的卡死场景:用同一个线程先 System.in 读用户输入,再 socket.getInputStream().read() 等服务器回包——任一环节阻塞,另一方就彻底失联。
立即学习“Java免费学习笔记(深入)”;
必须拆成两个线程:
- 输入线程:循环读
Scanner(System.in),把内容写进PrintWriter发给服务端 - 接收线程:循环调用
BufferedReader.readLine()从socket.getInputStream()读消息并打印
注意:Scanner.nextLine() 在 Windows 下可能因换行符差异吞掉首行,建议统一用 BufferedReader(new InputStreamReader(System.in))。
PrintWriter 默认不自动 flush,消息发不出去
这是新手最常踩的坑:写了 pw.println("hello") 却收不到,因为缓冲区没刷出去。
- 创建时务必加
true参数:new PrintWriter(socket.getOutputStream(), true) - 不要混用
PrintWriter和BufferedWriter,后者需要手动flush(),极易遗漏 - 如果服务端用
DataInputStream.readLine()(已废弃),客户端必须用\r\n结尾;现代写法统一用BufferedReader.readLine()+PrintWriter.println()即可
消息广播需共享在线客户端列表,但要注意线程安全
服务端要把某客户发的消息转发给其他所有人,就得维护一个 Collection 或 List。问题在于:添加、遍历、移除都在不同线程发生。
- 别用
ArrayList—— 并发修改会抛ConcurrentModificationException - 用
Collections.synchronizedList(new ArrayList())或更推荐CopyOnWriteArrayList(读多写少场景合适) - 遍历时别直接调用
pw.println(),万一某个客户端断连会导致 IO 异常中断整个广播;应捕获IOException并清理失效的PrintWriter
for (PrintWriter pw : clients) {
try {
pw.println(message);
} catch (Exception e) {
clients.remove(pw); // 客户端已断开
}
}
真正难的不是写完,而是让所有客户端在断网、强制关窗、长时间无响应时,服务端能及时感知并清理资源——Socket.isClosed() 和 Socket.isConnected() 都不可靠,得靠心跳或读操作超时配合 setSoTimeout() 才能准确定义“掉线”。










