简介一套面向Java课程设计的局域网即时聊天工具项目基于Socket实现客户端与服务器之间的双向通信包含独立登录模块适合大三Java结课作业、课程设计参考及网络编程入门者学习使用。压缩包共137个文件整体约18.18MB核心为java源码、class编译文件、xml配置同时附带docx课程设计报告、jpg运行截图与txt说明源码、文档、截图等类型齐全便于按需查看和对照运行。项目实现用户登录验证、多客户端消息转发、在线状态管理等功能登录环节帮助理解连接建立、数据校验与异常处理流程消息转发部分展示了多线程处理多个客户端的典型写法GUI界面代码也有助于学习事件驱动设计。已有179人学习下载源码与报告配套既可直接用于大作业提交与答辩展示也可在此基础上二次开发系统梳理Socket编程、多线程和GUI交互的设计脉络。1. 这个题目为什么选 Socket局域网聊天背后的两个判断很多人一看到“Java 课程设计大作业基于局域网的即时聊天工具下意识就去找现成的开源项目改个名交上去。但 Socket 聊天工具这个题目能成为课程设计里的常客恰恰因为它把网络编程当中最容易被忽视的两件事暴露出来了一是 Socket 不是一根网线它是一条有状态、需要双方共同维护的连接二是登录功能让这条连接从能收发字节变成了必须绑定用户身份。也就是说这个作业真正的难点不在new Socket()那一行而在登录态如何与连接绑定、服务端如何管理大量并发连接、以及局域网环境下端口、防火墙、IP 这些问题怎么在本地调试中收敛。这篇文章就按服务端两个类 客户端一个类 一个数据库表的最小结构把登录、私聊、群聊、掉线检测这套完整链路讲清楚。适合正在做课程设计、Java 基础已经过关但没系统写过网络程序的读者。2. Java 课程设计的服务端/客户端拆分与 Socket 选型2.1 先把功能边界划清服务端管状态客户端管界面课程设计最容易翻车的做法是一上来就写类写完才发现消息不知道往哪发。我一般的做法是先把系统拆成三个边界服务端只负责接收客户端连接、认证登录请求、维护在线用户表、转发消息。它不关心里面聊了什么。客户端只负责收集用户输入、渲染聊天记录、维护自己的 Socket 连接。它不关心其他用户在哪。数据库只负责存用户账号信息。登录成功后服务端把用户信息缓存在内存里不再查库。这个边界看起来简单但能直接决定代码规模。很多同学把客户端界面上显示在线列表的逻辑写在了服务端把收到消息弹窗写在了网络线程里结果界面卡死、消息乱序全是因为边界没划清。2.2 为什么是 Socket 而不是 RMI、HTTP 或 Netty课程设计里有一个隐含评价标准你要能解释为什么选这个技术。对比一下各方案在这个题目下的表现方案连接模型适合本作业的理由不选它的理由TCP Socket长连接全双工代码量可控、能看清底层要自己处理粘包和拆包HTTP 轮询/长轮询短连接为主客户端实现简单消息实时性差需要轮询或复杂的长轮询协议Java RMI远程方法调用写起来像本地调用把网络细节藏太深答辩讲不清楚传输过程NettyNIO 事件驱动高性能、面试加分引入框架后核心逻辑被框架覆盖课程设计容易变成调 API答辩老师真正想看到的不是我会用某个框架而是我理解一条消息从 A 发到 B 经过了哪些层。这也是为什么这个题目的标准答案几乎都是原生 Socket 多线程。TCP 是面向连接的、可靠的字节流协议局域网内丢包率极低、延迟极小不需要像公网环境那样考虑复杂的重传策略这个前提让原生 Socket 的实现复杂度刚刚好落在课程设计能承受的范围内。2.3 报文协议不加框架也能把消息传明白Socket 传的是字节流所以双方约好一块数据的格式就叫报文协议。这里先约定一个极简文本协议每行一条消息字段之间用|分隔消息类型|发送者|目标用户|消息内容完整报文示例LOGIN|alice|123456| CHAT|alice|bob|你好我是alice GROUP|alice|ALL|大家好 LOGOUT|alice||这样一个约定的价值在于服务端拿到一行字符串后不需要猜消息意图直接按|切割看第一个字段就知道该走哪条分支。课程设计不需要引入 JSON 库用一个 split 就足够了但要注意split的第二个参数要传限制值防止消息内容里也有|导致数组越界。客户端的发送代码很朴素// 每个消息都以换行结尾服务端按行读取 out.println(CHAT| myName | targetUser | messageText); out.flush();这里用println是因为PrintWriter会在字符串末尾追加换行符配合服务端的readLine()就能做到按行读消息。课程设计里不用考虑粘包问题——TCP 是字节流readLine读到换行符就返回一行内核已经把流切好了少数情况下消息过大导致半包在纯文本聊天场景里几乎不会触发但报告里如果能主动提到这个局限反而比装作没问题更像做过功课。3. 登录模块落地JDBC、密码存储与会话保持3.1 数据库表设计一个表就够但字段别省登录功能对应的数据表只需要一张t_user。字段越少越好维护但密码字段不能省。CREATE TABLE t_user ( id INT AUTO_INCREMENT PRIMARY KEY, username VARCHAR(50) NOT NULL UNIQUE, password_hash CHAR(64) NOT NULL, salt CHAR(16) NOT NULL, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ) DEFAULT CHARSETutf8mb4;字段说明字段类型作用idINT主键不参与业务逻辑usernameVARCHAR(50)登录名加唯一约束防止重复注册password_hashCHAR(64)SHA-256 摘要结果固定 64 个十六进制字符saltCHAR(16)随机盐值每个用户不同created_at是可选字段但建议留着报告里写数据库设计时多一个字段就多一句可写的说明。DEFAULT CHARSETutf8mb4建议显式指定否则 MySQL 8.0 以下版本默认字符集可能不支持下中文。3.2 JDBC 的常见做法PreparedStatement 与防注入课程设计里最常见的数据库访问方式就是 JDBC。要注意的是不要在每次登录时重新DriverManager.getConnection这个操作开销不小而且会让代码显得没有工程意识。用一个静态工具类维护单一连接是课程设计里最合适的粒度写法如下public class DbUtil { private static final String URL jdbc:mysql://localhost:3306/chat_db?useSSLfalseserverTimezoneAsia/Shanghai; private static final String USER root; private static final String PASS 123456; private static Connection conn; public static Connection getConnection() throws SQLException { if (conn null || conn.isClosed()) { conn DriverManager.getConnection(URL, USER, PASS); } return conn; } }注意 URL 里带上了serverTimezone参数。不写这个参数MySQL 8.x 驱动在带TIMESTAMP字段时会直接报时区错误这也是作业里常见的数据库连不上的原因之一。登录校验用PreparedStatement把用户名当参数传入而不是拼 SQL 字符串String sql SELECT id, username, password_hash, salt FROM t_user WHERE username ?; try (PreparedStatement ps DbUtil.getConnection().prepareStatement(sql)) { ps.setString(1, username); try (ResultSet rs ps.executeQuery()) { if (rs.next()) { String salt rs.getString(salt); String hash hashPassword(password, salt); if (hash.equalsIgnoreCase(rs.getString(password_hash))) { // 登录成功返回用户信息 } } } }PreparedStatement在这里的核心价值不是防止 SQL 注入这么一句空话而是它把参数和 SQL 结构分开了——攻击者输入 OR 11时JDBC 会把它当成一个普通字符串值传给数据库而不是拼进 SQL 语法里。这一条在答辩中非常容易被追问值得把原理用自己的话说清楚。3.3 密码不存明文加盐哈希的实现很多课程设计源码里密码直接存明文这样确实能跑通但报告里写出来会很掉价。Java 自带的MessageDigest就能做 SHA-256 加盐哈希不需要引入任何依赖public static String hashPassword(String password, String salt) throws Exception { MessageDigest md MessageDigest.getInstance(SHA-256); byte[] bytes md.digest((salt password).getBytes(StandardCharsets.UTF_8)); StringBuilder sb new StringBuilder(); for (byte b : bytes) { sb.append(String.format(%02x, b)); } return sb.toString(); }这里的逻辑是用户注册时生成一个随机salt把salt password拼起来做 SHA-256 得到password_hash把 salt 和 hash 分别存到数据库。登录时从数据库取出这个用户的 salt再用同样的方式计算 hash比对两个 hash 是否一致。说明一下SHA-256 加盐在课程设计这个语境下已经足够——它的目的是防止数据库泄露时密码被直接读出。生产环境应该用 BCrypt 或 PBKDF2 这类慢哈希算法这个对比如果写进报告的改进与展望一节属于明显的加分项。3.4 登录成功之后把用户名和 Socket 绑定登录验证通过这一步完成后真正的关键操作来了把用户名与当前客户端的 Socket 关联起来。常见做法是服务端维护一个全局 ConcurrentHashMap键是用户名、值是当前用户的 Socket 对象// 登录成功后执行 onlineUsers.put(username, socket); out.println(LOGIN_OK| username);客户端收到LOGIN_OK之后才切换到聊天界面后续的所有聊天消息都复用一个 Socket不再新建连接。这里有一个很容易犯的错误有人会把登录接口和聊天接口做成两个 Socket 连接登录成功后重新new Socket()连一次——这在功能上能通但服务端在线列表里存的还是登录时那个 socket发私聊消息时对方的服务端根本找不到对应的输出流。正确的做法是登录成功那一刻这条连接就变成了用户的专属连接。4. 服务端实现ServerSocket 起服务、线程模型与消息路由4.1 最小可运行的服务端骨架服务端代码的核心就是一段死循环反复 accept 新连接每来一个客户端就开一个线程专门服务它。这是课程设计最标准也最好讲解的线程模型public class ChatServer { private static final int PORT 10086; // key: 用户名, value: 该用户的 Socket private static final MapString, Socket onlineUsers new ConcurrentHashMap(); public static void main(String[] args) throws IOException { ServerSocket serverSocket new ServerSocket(PORT); System.out.println([Server] 端口 PORT 开始监听); while (true) { Socket socket serverSocket.accept(); // 每个客户端连接单独一个线程互不阻塞 new Thread(() - handleClient(socket)).start(); } } private static void handleClient(Socket socket) { try (BufferedReader in new BufferedReader( new InputStreamReader(socket.getInputStream(), StandardCharsets.UTF_8)); PrintWriter out new PrintWriter( new OutputStreamWriter(socket.getOutputStream(), StandardCharsets.UTF_8), true)) { String line; while ((line in.readLine()) ! null) { String[] parts line.split(\\|, 4); switch (parts[0]) { case LOGIN: handleLogin(parts, socket, out); break; case CHAT: handlePrivateChat(parts); break; case GROUP: handleGroupChat(parts); break; case LOGOUT: handleLogout(parts[1]); return; } } } catch (IOException e) { // 客户端异常断开会在心跳检测中被清理 } } }几个容易踩的点split(\\|, 4)的第二个参数 4 表示最多切成 4 段这样消息内容里即使包含|字符也会完整留在第四段不会数组越界。PrintWriter第二个参数传true表示自动 flush每次println写完立刻推给客户端不用手动调flush。StandardCharsets.UTF_8在 Socket 流上必须显式指定否则中文在跨平台传输时可能变成乱码。try-with-resources 会在连接关闭时自动释放流和 Socket省掉了 finally 里一堆 close 判断。从原理上讲这种一个连接一个线程的模型在几十个客户端以内完全够用代价是每个线程要占约 1MB 的栈空间。如果做的是 1000 人同时在线的场景就必须换 NIO 或 Netty 了但课程设计的评价标准是功能完整性和逻辑清晰度这个模型反而最利于讲清楚。4.2 消息路由私聊找目标群聊发所有人服务端的第二个核心能力是路由。私聊的本质是根据目标用户名找到它对应的 Socket把消息写给那个 Socket 的输出流。private static void handlePrivateChat(String[] parts) { String sender parts[1]; String target parts[2]; String content parts[3]; Socket targetSocket onlineUsers.get(target); if (targetSocket null) { // 目标不在线给发送者回一条系统消息 onlineUsers.get(sender).getOutputStream().write( (SYS|系统| sender |用户 target 不在线).getBytes(StandardCharsets.UTF_8)); return; } // 转发给目标用户 PrintWriter pw new PrintWriter( new OutputStreamWriter(targetSocket.getOutputStream(), StandardCharsets.UTF_8), true); pw.println(CHAT| sender | target | content); }这里能明显看出在线表存在的意义onlineUsers把用户名映射到 Socket查询一次哈希表就完成了路由。群聊更简单遍历在线表把消息送给除了发送者以外的所有人private static void handleGroupChat(String[] parts) { String sender parts[1]; String content parts[3]; for (Map.EntryString, Socket entry : onlineUsers.entrySet()) { if (entry.getKey().equals(sender)) { continue; // 不给自己发 } PrintWriter pw new PrintWriter( new OutputStreamWriter(entry.getValue().getOutputStream(), StandardCharsets.UTF_8), true); pw.println(GROUP| sender |ALL| content); } }关于ConcurrentHashMap的选型理由这里值得展开多个客户端线程会同时调用onlineUsers.put和remove如果用的是普通HashMap并发修改轻则丢数据、重则 JDK 7 时代会发生扩容死循环。ConcurrentHashMap的读操作不加锁、写操作按桶加锁正好匹配广播时频繁遍历、登录登出时偶尔写的场景。这个解释在答辩时讲出来比用它更安全要有说服力得多。4.3 心跳检测与掉线清理课程设计里最容易被忽略的就是掉线处理。表现为客户端直接关掉窗口服务端这边 readLine 一直不返回在线列表里这个人永远在线别人给他发消息也不报错。这不是代码 bug而是 TCP 的机制——拔网线、断电、进程被杀这类非正常断开TCP 没有机会发送 FIN 包服务端永远不会感知到连接已死。解决办法是应用层做心跳。设计成客户端每隔固定时间发一条心跳消息服务端如果超过某个时间阈值没收到就认为连接失效并清理在线列表。常见参数如下参数课程设计推荐值说明心跳间隔30 秒15~60 秒之间都合理越小越灵敏但越费流量服务端超时阈值90 秒连续 3 次心跳未收到就判死服务端读超时60 秒socket.setSoTimeout(60000)超时抛异常后由 catch 块清理服务端代码只需要加一行socket.setSoTimeout(60_000)然后在线程的 catch 块里补上清理逻辑} catch (SocketTimeoutException e) { // 长时间没收到任何消息包括心跳按掉线处理 String deadUser findUserBySocket(socket); if (deadUser ! null) { onlineUsers.remove(deadUser); System.out.println([Server] deadUser 已掉线当前在线 onlineUsers.size() 人); } } catch (IOException e) { // 正常断开或异常断开同样清理 String deadUser findUserBySocket(socket); if (deadUser ! null) { onlineUsers.remove(deadUser); } }findUserBySocket是维护一个反向映射遍历onlineUsers找到值为当前 socket 的键。这个操作是 O(n) 的但在几十人在线的规模下完全无所谓。如果追求性能可以再维护一个MapSocket, String的映射表但课程设计里不需要。5. 客户端实现Socket 收发线程与登录界面联调5.1 客户端的线程结构UI 线程绝不碰网络客户端的核心原则是网络 I/O 不能占住界面线程。Swing 的事件分发线程EDT负责重绘界面和处理按钮事件如果直接在按钮点击事件里做new Socket()连接窗口会卡死在那里无法移动、无法关闭看起来像程序崩溃了。所以客户端的标准做法是界面按钮的点击事件里只做一件事——启动一个新线程去连接服务端。新线程负责创建 Socket、发登录消息、等响应拿到结果后再切回 EDT 更新界面。客户端类的基本结构组件职责所在线程登录面板输入 IP、端口、用户名、密码EDT聊天面板显示消息记录、在线列表、输入框EDTClientReader线程循环readLine()收服务端消息独立线程登录线程发起连接、等待登录结果独立线程一次性登录按钮的点击事件实现要点如下private void onLoginClicked() { String host hostField.getText().trim(); int port Integer.parseInt(portField.getText().trim()); String username userField.getText().trim(); String password new String(passField.getPassword()); loginBtn.setEnabled(false); statusLabel.setText(正在连接 host : port ...); new Thread(() - { try { socket new Socket(); socket.connect(new InetSocketAddress(host, port), 3000); out new PrintWriter(new OutputStreamWriter( socket.getOutputStream(), StandardCharsets.UTF_8), true); in new BufferedReader(new InputStreamReader( socket.getInputStream(), StandardCharsets.UTF_8)); // 发送登录请求并等待结果 out.println(LOGIN| username | password |); String response in.readLine(); if (response ! null response.startsWith(LOGIN_OK)) { myName username; startClientReader(); // 登录成功后才启动消息读取线程 SwingUtilities.invokeLater(() - switchToChatPanel()); } else { SwingUtilities.invokeLater(() - { JOptionPane.showMessageDialog(this, 用户名或密码错误); loginBtn.setEnabled(true); }); } } catch (SocketTimeoutException e) { SwingUtilities.invokeLater(() - { JOptionPane.showMessageDialog(this, 连接超时请检查服务端是否启动); loginBtn.setEnabled(true); }); } catch (IOException e) { SwingUtilities.invokeLater(() - { JOptionPane.showMessageDialog(this, 无法连接服务端); loginBtn.setEnabled(true); }); } }).start(); }逻辑说明socket.connect(addr, 3000)带了一个 3 秒超时防止连不上时界面挂起等待系统默认的超时时间可能长达两分钟。登录和聊天共用一个 Socket。LOGIN_OK返回后这个 Socket 的连接已经建立后续消息直接在这个连接上收发。密码框必须用new String(passField.getPassword())而不是getText()JPasswordField的getPassword()返回char[]用完最好立即手动清空这个数组。所有界面更新都经过SwingUtilities.invokeLater切回 EDT这是 Swing 单线程模型的强制要求。违反它的话偶尔能跑通但界面刷新会出现偶发的数据竞争。5.2 ClientReader 线程只读消息只做界面更新登录成功之后客户端需要有一个持续运行的线程永远阻塞在readLine()上等待服务端推送消息。这个线程的写法几乎是固定的private void startClientReader() { new Thread(() - { try { String line; while ((line in.readLine()) ! null) { final String message line; // 切回 EDT 更新界面 SwingUtilities.invokeLater(() - appendMessage(message)); } } catch (IOException e) { SwingUtilities.invokeLater(() - { statusLabel.setText(连接已断开); JOptionPane.showMessageDialog(chatPanel, 与服务器的连接已断开); }); } }).start(); }这里有一个新手常犯的错在appendMessage里直接调用chatArea.append(...)。表面上看起来没问题因为大部分时候 EDT 不会同时操作这个组件但一旦服务端同时在推送两条消息两条线程都会尝试追加文本到同一个组件上就会出现丢字或 UI 刷新异常。用invokeLater把所有对组件的修改排进 EDT 的队列里是 Swing 多线程程序的底线要求。5.3 发送消息与心跳线程聊天输入框的回车事件只做一件事把消息按约定协议发出去。核心就是一个out.printlnprivate void sendMessage() { String content inputField.getText().trim(); if (content.isEmpty()) return; out.println(CHAT| myName | targetUser | content); inputField.setText(); }心跳线程可以复用上面登录线程的模式启动一个循环线程new Thread(() - { while (!closed) { try { out.println(PING| myName ||); Thread.sleep(30_000); // 每 30 秒一次 } catch (InterruptedException e) { Thread.currentThread().interrupt(); break; } } }).start();服务端收到PING后不需要回复逐个消息因为 TCP 连接本身是通的服务端只要在超时时间内收到任何字节就会重置setSoTimeout的计时器。这里有个更优雅的方案是把心跳交给ScheduledExecutorService但课程设计里用一个while sleep线程已经足够报告里提一句可以用定时任务线程池替代就是加分点。6. 排错与验收端口占用、防火墙与报告配图6.1 端口占用与bind: only one usage of each socket address这是本题目里出现频率最高的报错没有之一。它出现在服务端启动时意思是new ServerSocket(10086)时10086 端口已经被另一个进程占用了。最常见的原因是上一次运行的服务端程序没有关闭或者崩了但 JVM 进程还活着。先看看是谁占了端口。Windows 和 Linux 的命令不同# Windows netstat -ano | findstr 10086 taskkill /PID 上一行查到的PID /F # Linux / macOS lsof -i :10086 kill -9 PID命令说明netstat -ano列出所有端口监听状态第三列是本机地址和端口findstr按端口号过滤最后一列的 PID 是进程编号taskkill /F是强制结束该进程。Linux 下lsof -i :10086直接过滤出监听这个端口的进程。如果查完发现没有进程占用但启动仍然报同样的错那大概率是ServerSocket关闭后端口进入了TIME_WAIT状态。TCP 连接关闭后主动关闭方会在这个状态下停留约 2 分钟MSL 的两倍这段时间端口不能立即复用。代码层面的解法是在创建ServerSocket之前开启地址复用ServerSocket serverSocket new ServerSocket(); serverSocket.setReuseAddress(true); serverSocket.bind(new InetSocketAddress(PORT));这个开关的意思是允许端口处于 TIME_WAIT 时重新绑定。注意setReuseAddress必须在bind之前调用顺序反了不生效。6.2 局域网连不上的排查清单客户端在另一台电脑上启动后填入服务端电脑的局域网 IP点击登录后一直提示无法连接服务端。这个问题的排查顺序是固定的从上往下依次验证排查步骤命令/操作判断标准服务端是否在监听netstat -ano | findstr 10086能看到 LISTENING同机能连自己吗客户端 IP 填127.0.0.1能连说明服务端没问题局域网路径通不通ping 服务端IP有回复说明二层三层通了端口通不通telnet 服务端IP 10086黑窗口不退出说明 TCP 通了Windows 10/11 的 Telnet 客户端默认是关闭的可以用 PowerShell 的Test-NetConnection代替Test-NetConnection 192.168.1.100 -Port 10086返回结果里的TcpTestSucceeded : True等效于 telnet 连通。走到这一步发现端口不通九成原因是 Windows 防火墙拦住了入站连接。解法不是关掉防火墙而是添加一条入站规则放行 TCP 10086 端口。课程设计验收时服务端电脑往往是老师的机器防火墙规则大概率没人提前放过这一条排查在答辩现场几乎是必现的。6.3 验收测试的四个场景写完代码之后用下面的四组操作过一遍就能覆盖大部分功能点测试结果整理进报告是一份现成的测试表启动服务端客户端 A 和客户端 B 分别登录服务端控制台显示两人上线。用 A 给 B 发一条中文私聊消息B 窗口即时收到B 给 A 回消息A 也能收到。A 发一条群聊消息B 和 C 同时收到A 自己不应收到自己发的消息。直接关掉 B 的窗口90 秒内服务端控制台输出 B 已掉线A 给 B 发消息时收到用户不在线的系统提示。测试过程里如果第 4 步的掉线检测没有生效优先检查服务端有没有设置setSoTimeout。很多实现忘了这一行心跳就形同虚设。6.4 报告怎么写才不浪费这次实现报告的价值在于让别人相信你真的跑通了而不是你抄对了代码。最有效的做法是把过程数据放进去设计两张表一张是上面四个测试场景的测试记录含预期结果和实际结果另一张是在线人数与消息延迟的简单压测数据——客户端 A 在 20 秒内连续发 200 条消息统计 B 的接收时间和漏发数量。这组数据不需要很专业但能证明你不仅会写代码还知道怎么验证代码。截图也有讲究把服务端控制台、两个客户端聊天窗口、数据库用户表四张图错开摆放拼到一张不超过 1200px 宽的宽图里然后在图注里注明客户端 A 与 B 分别运行在两台不同的主机上。这张图比文字描述支持多人在线有力得多。答辩老师翻到这里会默认你至少完整跑通过不止一次。本文还有配套的精品资源点击获取
