Java Socket聊天室需服务端用ConcurrentHashMap管理连接并多线程处理客户端,客户端双线程分离收发;消息以换行符分隔防粘包;/quit退出更可靠。

用Java Socket实现一个简单聊天室,核心在于服务端维护客户端连接列表、转发消息,客户端负责收发数据——不复杂但容易忽略线程安全和连接管理细节。
服务端:多线程处理多个客户端
服务端需用red">ServerSocket监听端口,每接受一个连接就启动新线程处理该客户端的输入输出。关键点:
- 用ConcurrentHashMap或CopyOnWriteArrayList保存在线用户(避免遍历时修改引发异常)
- 每个客户端线程独立读取其BufferedReader,收到消息后广播给其他所有客户端的PrintWriter
- 捕获IOException或SocketException时及时清理该客户端连接并通知他人“XX已下线”
客户端:双线程分离收发逻辑
单线程阻塞读会导致无法同时发送消息。推荐结构:
- 主线程:从控制台读取用户输入,通过PrintWriter发送到服务端
- 另起守护线程:持续调用BufferedReader.readLine()接收服务端广播,并打印到控制台
- 关闭前调用socket.close(),触发服务端连接清理
消息协议:用分隔符避免粘包
TCP无消息边界,连续发送“hello”和“world”可能被合并成“helloworld”。简单方案:
立即学习“Java免费学习笔记(深入)”;
- 约定每条消息以换行符\n结尾(println()自动添加)
- 服务端用readLine()按行解析;客户端也按行发送
- 如需扩展,可加简单头信息,例如[USER:张三]你好,便于识别发送者
运行与调试建议
本地测试时,先启动服务端,再开多个命令行窗口运行客户端:
- 服务端打印日志(如“新连接:/127.0.0.1:50001”、“当前在线:3人”)便于追踪状态
- 客户端输入/quit主动断开,比直接关窗口更干净
- 遇到连接拒绝,检查端口是否被占用;收不到消息,确认双方是否都用了flush()或println()










