Java基于Socket的局域网聊天室实现指南

Ryan

发布时间：2026-10-15 | 4人浏览过

原创

本文介绍使用Java Socket构建局域网聊天室的完整流程，涵盖服务器端监听、客户端连接、多线程并发处理以及自定义消息协议（公聊/私聊）。通过CrazyitMap管理用户会话状态，实现简单的即时通讯功能。

系统架构与核心组件

该聊天室采用典型的 C/S（客户端/服务器）架构。服务端负责接收连接、维护在线用户映射表并转发消息；客户端负责用户交互、输入流读取与网络发送。系统主要包含以下六个核心文件：

Server.java：主服务类，启动ServerSocket监听端口。
ServerThread.java：服务端工作线程，处理单个客户端的IO循环及消息逻辑。
Client.java：主客户端类，建立TCP连接并启动输入输出线程。
ClientThread.java：客户端读线程，持续监听服务器推送的消息。
CrazyitMap.java：线程安全的HashMap封装，用于管理用户名与输出流的映射关系。
CrazyitProtocol.java：接口定义，规定消息包头的特殊标识字符，用于区分消息类型。

服务端实现

服务端是聊天室的核心，负责持久化监听 incoming connections 并进行业务路由。

第1步：启动服务监听

在Server.java中，初始化ServerSocket绑定特定端口（如30000），并通过死循环调用accept()阻塞等待客户端请求。每次接受到一个新Socket连接，便创建一个ServerThread实例并在后台启动。

public void init(){
    try( ServerSocket ss=new ServerSocket(SERVER_PORT)) {
        while(true){
            Socket socket=ss.accept();
            new ServerThread(socket).start();
        }
    }
    catch (IOException ex){
        System.out.println("服务器启动失败，是否端口"+SERVER_PORT+"已被占用");
    }
}

第2步：解析消息与分发逻辑

ServerThread进入run方法后，获取对应的输入输出流。循环读取字符串并根据首尾的特殊协议字符判断消息类型：

登录验证：识别USER_ROUND标识的内容为用户名。若该用户名已存在于Server.clients中，返回拒绝标识；否则允许登录并存入映射表。
私聊处理：识别PRIVATE_ROUND标识的内容。内部使用SPLIT_SIGN分割目标用户名和消息体，仅向目标用户的输出流写入数据。
公聊广播：若非上述两种情况，则视为普通消息。遍历所有在线用户的输出流进行广播发送。

当捕获到IOException时，意味着客户端非正常断开，服务端需从Map中移除该会话资源并关闭IO流。

客户端实现

客户端主要负责与服务器建立握手、格式化本地输入并展示远程消息。

第3步：建立连接与登录

客户端通过Socket("127.0.0.1", SERVER_PORT)发起连接。登录后进入循环，使用Swing JOptionPane提示用户输入名称。将用户名包装上协议头发送后，读取服务器反馈：LOGIN_SUCCESS表示成功，NAME_REP表示重名需重新输入。

第4步：并发读写分离

为保证界面不卡顿且能实时收发消息，采用双线程模型：

写线程（主线程延伸）
不断读取标准输入System.in。根据是否以//开头且包含冒号来区分私聊指令（格式：//Username:Message），并按协议打包发送。
读线程（ClientThread）
启动独立线程持续读取服务器的BufferedReader，一旦有新消息立即打印至控制台。