简介面向Java课程设计与毕业设计场景的局域网聊天室系统基于Socket编程实现客户端与服务端通信涵盖用户登录、多人在线、消息群发与私聊等核心功能。压缩包共239个文件主要包含c/h源代码、可直接运行的exe程序、doc格式论文文档以及dsp/dsw工程配置和obj等编译中间文件整体大小14.13MB既适合工程实训参考也便于毕业设计二次开发。目前已有106人学习下载。源码覆盖GUI事件处理、多线程并发管理及TCP网络通信的完整实现可对照学习从界面搭建到数据收发的整个链路论文部分提供需求分析、总体设计、详细实现与测试说明能帮助快速梳理论文框架与写作要点。包内还包含wav提示音、图标资源及工程备份文件目录层级清晰方便按模块查阅。1. Java局域网聊天室的定位为什么年年有人选局域网聊天室不是新题目却是Java课程设计和毕业设计里少有的“不依赖外部框架也讲得深”的项目。它的难点不在静态页面而在你自己手写的Socket链路上——谁负责accept、谁负责read、谁负责把消息写回去线程放在哪里、在线表怎么同步这些问题的答案直接决定答辩时能不能接住老师的追问。局域网意味着不需要对外网开放端口服务端开在同一台机器上客户端用127.0.0.1回环地址就能完成全流程联调论文也能顺着TCP三次握手、多线程并发、Swing事件驱动这条主线写出层次。这篇文章按我平时指导课设的路径展开先把通信协议和参数定下来再写服务端和客户端的核心实现最后落到论文结构和演示细节适合拿到源码后想改造成自己版本、而不是原样照抄的读者。2. 局域网聊天室的通信基础端口、协议与UTF-8编码细节2.1 用回环地址在单机上调通局域网聊天室不少人对“局域网聊天室”有个误解以为必须先有两台电脑才能开始写代码。其实局域网通信走的是IP协议只要机器上有一张网卡127.0.0.1就代表本机回环地址客户端和服务端跑在同一台机器上时完全可以用它联调。等到功能验证通过再用侧边栏里的在线用户在另一台机器上测试也不迟。服务端监听时需要决定两个参数监听地址和端口号。Java里直接写new ServerSocket(9000)相当于监听所有网卡的9000端口局域网内其他机器可以通过这台机器的IPv4地址访问。如果改成new ServerSocket()后再bind(new InetSocketAddress(127.0.0.1, 9000))那就只有本机回环能连适合调试但不符合标题里“局域网”的要求。查看本机IPv4地址的命令很简单# Windows终端 ipconfig | findstr /i IPv4 # Linux或macOS ip addr show | grep inet 端口号建议选9000到9999之间避开1到1024的预占用端口也避开常见开发端口。如果服务端启动时报Address already in use用netstat -ano | findstr :9000Windows或者lsof -i:9000Linux/macOS查一下是哪个进程占用了端口课程设计阶段通常直接换一个端口最省事。2.2 消息帧协议设计字段、分隔符与空消息边界聊天室的服务端只做一件事把客户端发来的消息判断类型后分发给其他客户端。判断的前提是双方约定一种文本帧格式我常用的方案是四个字段用竖线分隔TYPE|SENDER|TARGET|PAYLOAD前三个字段是类型、发送者昵称、接收者PAYLOAD是消息正文。选竖线是因为它比逗号、空格更不容易出现在日常聊天内容里万一正文里真的有竖线可以在解析时只按前三个分隔符切分后面的内容全部当作正文。消息类型定义如下表类型方向含义LOGIN客户端→服务端连接后第一条消息注册昵称MSG双向群聊广播PRIV双向私聊TARGET填对方昵称LOGOUT客户端→服务端正常离开聊天室PING客户端→服务端心跳探测PONG服务端→客户端心跳应答协议解析对应的Java工具类不需要依赖第三方库核心代码大约三十行public class ChatProtocol { public static final String SEP |; // 组帧把四个字段拼成一行文本 public static String encode(String type, String from, String target, String content) { return String.join(SEP, type, from, target, content); } // 拆帧只找前三个分隔符正文可以包含竖线 public static String[] decode(String frame) throws IllegalArgumentException { int i1 frame.indexOf(SEP); int i2 frame.indexOf(SEP, i1 1); int i3 frame.indexOf(SEP, i2 1); if (i1 -1 || i2 -1 || i3 -1) { throw new IllegalArgumentException(非法消息帧: frame); } return new String[] { frame.substring(0, i1), frame.substring(i1 1, i2), frame.substring(i2 1, i3), frame.substring(i3 1) }; } }这里decode故意用indexOf而不是split(\\|)原因是split会把连续分隔符之间的空字符串当作合法字段一旦消息正文为空或者聊天内容里出现竖线和特殊组合拆帧结果可能和组帧逻辑对不上。用indexOf手动定位前三个分隔符语义更清楚前三个字段必须存在第四个字段允许为空。后续如果要在帧里加时间戳或消息ID只改encode和decode两处即可不会牵连业务代码。2.3 统一UTF-8编码中文消息不乱码的落地写法局域网聊天室最常被忽略的坑是字符编码。Socket传输的底层是字节流InputStreamReader读取时要指定字符集输出时也要一致。Java 18之前的环境里默认字符集随操作系统变化Windows中文版默认是GBKLinux默认是UTF-8如果客户端和服务端各用各的默认字符集中文消息必然乱码。解决方式是在创建流的两个位置显式指定StandardCharsets.UTF_8。客户端发送用new OutputStreamWriter(socket.getOutputStream(), StandardCharsets.UTF_8)包一层再把PrintWriter的autoFlush设为true服务端读取用同样的字符集构造InputStreamReader。两侧统一后中文昵称、聊天内容、系统提示都不会出问题。顺带说一句协议帧里的分隔符和英文关键字全部用ASCII字符编码只影响正文不影响类型判断。3. 服务端多线程实现连接接入、消息转发与心跳清理3.1 每连接一线程模型与线程池选型服务端的accept()每次返回一个Socket这个Socket后续的读写都是阻塞的。如果在一个主线程里循环读取所有客户端的输入某个客户端不发消息时整个服务端就会卡在readLine()等待上。所以标准做法是每个连接分一个线程主线程只负责accept收到新连接就交给工作线程自己立刻回头继续accept。创建线程不要直接new Thread()原因有两个。一是每来一个连接就创建一个线程超过几十个客户端后线程切换开销明显二是线程没有复用连接断开后线程就结束了。对于局域网聊天室的体量用Executors.newCachedThreadPool()最合适有连接进来就复用空闲线程没有空闲线程才新建空闲超过60秒自动回收。如果你的课程设计里对并发量有更高要求换成newFixedThreadPool(50)也行只是要在连接数超过50时自己处理排队逻辑复杂度会多一截。3.2 服务端代码实现从accept到转发循环服务端核心数据结构是一张ConcurrentHashMapString, PrintWriterkey是昵称value是客户端对应的输出流。用ConcurrentHashMap而不是HashMap的原因很直接多个工作线程同时读这张表做广播HashMap在并发修改时会抛ConcurrentModificationExceptionConcurrentHashMap则允许在遍历时安全地读取。public class ChatServer { // 在线表昵称 - 输出流跨线程访问必须用并发容器 private final MapString, PrintWriter clients new ConcurrentHashMap(); private final ExecutorService pool Executors.newCachedThreadPool(); private final int port; public ChatServer(int port) { this.port port; } public void start() throws IOException { // new ServerSocket(port)默认监听所有网卡局域网内其他机器可访问 ServerSocket server new ServerSocket(port); System.out.println(服务端已监听端口 port); while (true) { Socket socket server.accept(); // 每个连接交给线程池处理主线程继续accept pool.execute(() - handleClient(socket)); } } private void handleClient(Socket socket) { String nick null; try (Socket s socket; BufferedReader in new BufferedReader(new InputStreamReader( s.getInputStream(), StandardCharsets.UTF_8)); PrintWriter out new PrintWriter(new OutputStreamWriter( s.getOutputStream(), StandardCharsets.UTF_8), true)) { // 第一条消息必须是LOGIN否则直接关闭 String[] loginFrame ChatProtocol.decode(in.readLine()); if (!MsgType.LOGIN.equals(loginFrame[0])) { return; } nick loginFrame[1].trim(); // 同名昵称处理put会覆盖旧值更规范的做法是检查putIfAbsent返回值 clients.put(nick, out); broadcast(系统, nick 进入了聊天室); String line; while ((line in.readLine()) ! null) { String[] parts ChatProtocol.decode(line); String type parts[0]; String from parts[1]; String target parts[2]; String content parts[3]; if (MsgType.LOGOUT.equals(type)) { break; } else if (MsgType.MSG.equals(type)) { broadcast(from, content); } else if (MsgType.PRIV.equals(type)) { // 私聊只发给目标客户端 PrintWriter targetOut clients.get(target); if (targetOut ! null) { targetOut.println(ChatProtocol.encode(MsgType.PRIV, from, target, content)); } } } } catch (IOException e) { // 连接异常通常发生在对方拔线或强制关闭进程时 } finally { // finally保证无论正常退出还是异常断开都能清理在线表 if (nick ! null) { clients.remove(nick); broadcast(系统, nick 离开了聊天室); } } } private void broadcast(String from, String content) { String frame ChatProtocol.encode(MsgType.MSG, from, ALL, content); clients.values().forEach(out - out.println(frame)); } }这段代码有四个需要说明的点。第一try-with-resources同时管理Socket和两个流方法结束时自动关闭不用手写close第二readLine()读到null说明对方正常关闭了连接循环退出第三广播是遍历在线表向所有输出流写数据某条输出流写失败时会抛IOException进入catch由finally负责清理第四发送私聊时目标不在线clients.get(target)返回null代码里直接忽略更完善的版本可以给发送者回一条“对方不在线”。3.3 心跳超时与半开连接的识别参数如果客户端程序直接崩溃或电脑突然断电TCP连接不会发送FIN包服务端的readLine()会一直阻塞在线表里这条记录就永远清不掉。要解决这个问题需要在应用层加心跳机制。常见做法是客户端每30秒发一条PING服务端记录每个昵称的最后活跃时间超过90秒没收到任何消息就判定为死连接并主动断开。心跳相关参数建议这样定义参数推荐值说明HEARTBEAT_INTERVAL_MS30000客户端发送PING的间隔TIMEOUT_MS90000服务端判定死连接的超时时间CHECK_PERIOD_MS5000服务端定时扫描间隔服务端用一个ScheduledExecutorService启动定时任务初始化后每5秒扫一次在线表拿当前时间和lastSeen里的时间比较超时就调用socket.close()让处理线程抛出异常后面的finally自然清理。扫描线程和连接线程操作同一个Map要记得lastSeen也用ConcurrentHashMap。4. Swing客户端的线程分工与收发实现4.1 读取线程与UI线程分离为什么不能把readLine放在事件线程Swing是单线程模型所有界面刷新都必须发生在Event Dispatch ThreadEDT上。如果把Socket的readLine()放在EDT里消息还没到达时程序会一直阻塞在读取窗口拖不动、按钮点不了、标题栏显示“未响应”。局域网虽快但没人保证服务端一定会立刻回包所以网络读取必须放在单独的线程里。客户端启动时开一个名为socket-reader的守护线程专门循环读取服务端发来的数据拿到消息后调用SwingUtilities.invokeLater()把界面更新操作交还给EDT。这样网络线程和UI线程各司其职网络线程负责阻塞等待EDT负责把消息追加到聊天记录区。一个容易忽视的细节是线程要设为daemon否则用户点关闭窗口后读取线程还占着JVM进程不会退出。4.2 发送消息与私聊指令的界面处理客户端的核心代码封装在ChatClient类里构造时建立Socket并发LOGIN随后启动读取线程。消息发送则绑定到输入框的回车事件上用户在输入框按回车时触发sendMessage。下面是发送和读取部分的骨架public class ChatClient { private final String nick; private final Socket socket; private final BufferedReader in; private final PrintWriter out; private final JTextArea area new JTextArea(); private final JTextField input new JTextField(); private final DefaultListModelString userList new DefaultListModel(); public ChatClient(String host, int port, String nick) throws IOException { this.nick nick; this.socket new Socket(host, port); this.in new BufferedReader(new InputStreamReader( socket.getInputStream(), StandardCharsets.UTF_8)); this.out new PrintWriter(new OutputStreamWriter( socket.getOutputStream(), StandardCharsets.UTF_8), true); // 连接后第一件事登录 out.println(ChatProtocol.encode(MsgType.LOGIN, nick, ALL, )); Thread reader new Thread(this::readLoop, socket-reader); reader.setDaemon(true); reader.start(); } private void readLoop() { try { String line; while ((line in.readLine()) ! null) { String[] parts ChatProtocol.decode(line); String type parts[0]; String from parts[1]; String target parts[2]; String content parts[3]; String display; if (MsgType.MSG.equals(type)) { // 群聊消息显示为 昵称: 内容 display from : content System.lineSeparator(); } else if (MsgType.PRIV.equals(type)) { // 私聊消息带标记避免和群聊混在一起 display [私聊] from : content System.lineSeparator(); } else { display content System.lineSeparator(); } String finalDisplay display; SwingUtilities.invokeLater(() - area.append(finalDisplay)); } } catch (IOException e) { SwingUtilities.invokeLater(() - area.append(连接断开 System.lineSeparator())); } } public void sendMessage() { String content input.getText().trim(); if (!content.isEmpty()) { // 群聊消息TARGET固定为ALL私聊走单独的输入框 out.println(ChatProtocol.encode(MsgType.MSG, nick, ALL, content)); input.setText(); } } }读取循环里所有界面操作都经过invokeLater这样即使同一秒钟收到几十条消息Swing也只会在EDT里按顺序追加不会出现组件状态不一致。JTextArea默认可以编辑记得在初始化时调用setEditable(false)否则聊天记录区会被用户误删。下方组件对应关系可以参考这张表Swing组件用途关键设置JTextArea聊天记录setEditable(false)JTextField消息输入绑定ActionListener监听回车JScrollPane包裹JTextArea自动滚动到底部JList在线用户用DefaultListModel实时刷新4.3 窗口关闭、异常断开与重连处理的兜底逻辑用户关闭窗口时不能直接退出要先发LOGOUT再关闭Socket否则服务端那边会等一段时间才发现连接断开。在JFrame的WindowListener里做这件事最直接windowClosing事件中发送LOGOUT帧然后调用dispose()。如果客户端被系统杀掉发不了LOGOUT也没关系服务端的心跳超时机制会在90秒后清掉这条在线记录属于上一层已经兜过底的场景。读取线程抛出异常后界面要提示“连接断开”同时禁用输入框避免用户继续敲字发送到已经关闭的流上。对课程设计来说做到这个程度已经超过大多数同学的质量如果你的题目要求加“断线重连”可以把Socket连接逻辑抽到connect()方法里读取线程退出时用ScheduledExecutorService定时重试每次间隔3秒恢复后自动重新发送LOGIN并拉一次在线列表。5. 论文与答辩的关键组织方式让课程设计变成完整毕业设计5.1 论文里必画的四张图与对应评价点毕业设计论文和课程设计报告最明显的区别是系统设计部分要有图。我建议至少准备四张系统体系结构图、客户端时序图、服务端类图和局域网部署图。系统体系结构图表达客户端、服务端、应用协议和界面层之间的调用关系时序图画登录、群聊、私聊、退出四个典型流程各一张类图画核心类和字段方法即可不需要把Swing组件的每个方法都列上去。部署图就画两台机器和一个交换机标注IP和端口。不少同学只贴代码不画时序图老师一眼就知道需求分析是抄的。画时序图的核心技巧是把协议帧的流转画进去客户端发LOGIN|张三|ALL|服务端回广播帧其他客户端收到后刷新在线用户列表。这一条链路的时序关系能覆盖Socket和SWing两条技术线靠一张图就展现出你对整个系统的理解。5.2 演示时的两种运行路径与README写法答辩演示环境不一定是预先装好的实验室机器最常见的是现场只有一台电脑。这时推荐的两条运行路径是单机回环模式客户端连127.0.0.1双机局域网模式两台机器连同一个路由器服务端机器运行ipconfig查看IPv4地址客户端连接这个地址。README里把这两条路径都写清楚并注明防火墙放行规则# 第一步启动服务端监听9000端口 java -jar chat-server.jar 9000 # 第二步启动客户端连接服务端IP java -jar chat-client.jar 192.168.1.20 9000 张三Windows自带防火墙默认会拦截入站连接演示时如果客户端连接超时先检查服务端防火墙入站规则是否放行9000端口再执行ping 192.168.1.20确认网络通不通。README里把这句排错命令写上比答辩时现场翻代码要有说服力得多。论文的目录结构可以按“绪论→需求分析→总体设计→详细设计与实现→测试→总结”组织其中第4章的结构应该和本文第2、3、4章的模块划分一一对应。写这一段时不要大段贴代码而是把每个类的职责、关键方法的参数和返回值讲清楚代码片段只针对核心流程贴出来。答辩前把第五章这两个演示路径在命令行里走两遍确保服务端打印的“进入了聊天室”“离开了聊天室”日志能和界面操作对上这比任何花哨的PPT都更能证明代码是你自己调通的。本文还有配套的精品资源点击获取 Java局域网聊天室开发：Socket通信与多线程并发实践
简介面向Java课程设计与毕业设计场景的局域网聊天室系统基于Socket编程实现客户端与服务端通信涵盖用户登录、多人在线、消息群发与私聊等核心功能。压缩包共239个文件主要包含c/h源代码、可直接运行的exe程序、doc格式论文文档以及dsp/dsw工程配置和obj等编译中间文件整体大小14.13MB既适合工程实训参考也便于毕业设计二次开发。目前已有106人学习下载。源码覆盖GUI事件处理、多线程并发管理及TCP网络通信的完整实现可对照学习从界面搭建到数据收发的整个链路论文部分提供需求分析、总体设计、详细实现与测试说明能帮助快速梳理论文框架与写作要点。包内还包含wav提示音、图标资源及工程备份文件目录层级清晰方便按模块查阅。1. Java局域网聊天室的定位为什么年年有人选局域网聊天室不是新题目却是Java课程设计和毕业设计里少有的“不依赖外部框架也讲得深”的项目。它的难点不在静态页面而在你自己手写的Socket链路上——谁负责accept、谁负责read、谁负责把消息写回去线程放在哪里、在线表怎么同步这些问题的答案直接决定答辩时能不能接住老师的追问。局域网意味着不需要对外网开放端口服务端开在同一台机器上客户端用127.0.0.1回环地址就能完成全流程联调论文也能顺着TCP三次握手、多线程并发、Swing事件驱动这条主线写出层次。这篇文章按我平时指导课设的路径展开先把通信协议和参数定下来再写服务端和客户端的核心实现最后落到论文结构和演示细节适合拿到源码后想改造成自己版本、而不是原样照抄的读者。2. 局域网聊天室的通信基础端口、协议与UTF-8编码细节2.1 用回环地址在单机上调通局域网聊天室不少人对“局域网聊天室”有个误解以为必须先有两台电脑才能开始写代码。其实局域网通信走的是IP协议只要机器上有一张网卡127.0.0.1就代表本机回环地址客户端和服务端跑在同一台机器上时完全可以用它联调。等到功能验证通过再用侧边栏里的在线用户在另一台机器上测试也不迟。服务端监听时需要决定两个参数监听地址和端口号。Java里直接写new ServerSocket(9000)相当于监听所有网卡的9000端口局域网内其他机器可以通过这台机器的IPv4地址访问。如果改成new ServerSocket()后再bind(new InetSocketAddress(127.0.0.1, 9000))那就只有本机回环能连适合调试但不符合标题里“局域网”的要求。查看本机IPv4地址的命令很简单# Windows终端 ipconfig | findstr /i IPv4 # Linux或macOS ip addr show | grep inet 端口号建议选9000到9999之间避开1到1024的预占用端口也避开常见开发端口。如果服务端启动时报Address already in use用netstat -ano | findstr :9000Windows或者lsof -i:9000Linux/macOS查一下是哪个进程占用了端口课程设计阶段通常直接换一个端口最省事。2.2 消息帧协议设计字段、分隔符与空消息边界聊天室的服务端只做一件事把客户端发来的消息判断类型后分发给其他客户端。判断的前提是双方约定一种文本帧格式我常用的方案是四个字段用竖线分隔TYPE|SENDER|TARGET|PAYLOAD前三个字段是类型、发送者昵称、接收者PAYLOAD是消息正文。选竖线是因为它比逗号、空格更不容易出现在日常聊天内容里万一正文里真的有竖线可以在解析时只按前三个分隔符切分后面的内容全部当作正文。消息类型定义如下表类型方向含义LOGIN客户端→服务端连接后第一条消息注册昵称MSG双向群聊广播PRIV双向私聊TARGET填对方昵称LOGOUT客户端→服务端正常离开聊天室PING客户端→服务端心跳探测PONG服务端→客户端心跳应答协议解析对应的Java工具类不需要依赖第三方库核心代码大约三十行public class ChatProtocol { public static final String SEP |; // 组帧把四个字段拼成一行文本 public static String encode(String type, String from, String target, String content) { return String.join(SEP, type, from, target, content); } // 拆帧只找前三个分隔符正文可以包含竖线 public static String[] decode(String frame) throws IllegalArgumentException { int i1 frame.indexOf(SEP); int i2 frame.indexOf(SEP, i1 1); int i3 frame.indexOf(SEP, i2 1); if (i1 -1 || i2 -1 || i3 -1) { throw new IllegalArgumentException(非法消息帧: frame); } return new String[] { frame.substring(0, i1), frame.substring(i1 1, i2), frame.substring(i2 1, i3), frame.substring(i3 1) }; } }这里decode故意用indexOf而不是split(\\|)原因是split会把连续分隔符之间的空字符串当作合法字段一旦消息正文为空或者聊天内容里出现竖线和特殊组合拆帧结果可能和组帧逻辑对不上。用indexOf手动定位前三个分隔符语义更清楚前三个字段必须存在第四个字段允许为空。后续如果要在帧里加时间戳或消息ID只改encode和decode两处即可不会牵连业务代码。2.3 统一UTF-8编码中文消息不乱码的落地写法局域网聊天室最常被忽略的坑是字符编码。Socket传输的底层是字节流InputStreamReader读取时要指定字符集输出时也要一致。Java 18之前的环境里默认字符集随操作系统变化Windows中文版默认是GBKLinux默认是UTF-8如果客户端和服务端各用各的默认字符集中文消息必然乱码。解决方式是在创建流的两个位置显式指定StandardCharsets.UTF_8。客户端发送用new OutputStreamWriter(socket.getOutputStream(), StandardCharsets.UTF_8)包一层再把PrintWriter的autoFlush设为true服务端读取用同样的字符集构造InputStreamReader。两侧统一后中文昵称、聊天内容、系统提示都不会出问题。顺带说一句协议帧里的分隔符和英文关键字全部用ASCII字符编码只影响正文不影响类型判断。3. 服务端多线程实现连接接入、消息转发与心跳清理3.1 每连接一线程模型与线程池选型服务端的accept()每次返回一个Socket这个Socket后续的读写都是阻塞的。如果在一个主线程里循环读取所有客户端的输入某个客户端不发消息时整个服务端就会卡在readLine()等待上。所以标准做法是每个连接分一个线程主线程只负责accept收到新连接就交给工作线程自己立刻回头继续accept。创建线程不要直接new Thread()原因有两个。一是每来一个连接就创建一个线程超过几十个客户端后线程切换开销明显二是线程没有复用连接断开后线程就结束了。对于局域网聊天室的体量用Executors.newCachedThreadPool()最合适有连接进来就复用空闲线程没有空闲线程才新建空闲超过60秒自动回收。如果你的课程设计里对并发量有更高要求换成newFixedThreadPool(50)也行只是要在连接数超过50时自己处理排队逻辑复杂度会多一截。3.2 服务端代码实现从accept到转发循环服务端核心数据结构是一张ConcurrentHashMapString, PrintWriterkey是昵称value是客户端对应的输出流。用ConcurrentHashMap而不是HashMap的原因很直接多个工作线程同时读这张表做广播HashMap在并发修改时会抛ConcurrentModificationExceptionConcurrentHashMap则允许在遍历时安全地读取。public class ChatServer { // 在线表昵称 - 输出流跨线程访问必须用并发容器 private final MapString, PrintWriter clients new ConcurrentHashMap(); private final ExecutorService pool Executors.newCachedThreadPool(); private final int port; public ChatServer(int port) { this.port port; } public void start() throws IOException { // new ServerSocket(port)默认监听所有网卡局域网内其他机器可访问 ServerSocket server new ServerSocket(port); System.out.println(服务端已监听端口 port); while (true) { Socket socket server.accept(); // 每个连接交给线程池处理主线程继续accept pool.execute(() - handleClient(socket)); } } private void handleClient(Socket socket) { String nick null; try (Socket s socket; BufferedReader in new BufferedReader(new InputStreamReader( s.getInputStream(), StandardCharsets.UTF_8)); PrintWriter out new PrintWriter(new OutputStreamWriter( s.getOutputStream(), StandardCharsets.UTF_8), true)) { // 第一条消息必须是LOGIN否则直接关闭 String[] loginFrame ChatProtocol.decode(in.readLine()); if (!MsgType.LOGIN.equals(loginFrame[0])) { return; } nick loginFrame[1].trim(); // 同名昵称处理put会覆盖旧值更规范的做法是检查putIfAbsent返回值 clients.put(nick, out); broadcast(系统, nick 进入了聊天室); String line; while ((line in.readLine()) ! null) { String[] parts ChatProtocol.decode(line); String type parts[0]; String from parts[1]; String target parts[2]; String content parts[3]; if (MsgType.LOGOUT.equals(type)) { break; } else if (MsgType.MSG.equals(type)) { broadcast(from, content); } else if (MsgType.PRIV.equals(type)) { // 私聊只发给目标客户端 PrintWriter targetOut clients.get(target); if (targetOut ! null) { targetOut.println(ChatProtocol.encode(MsgType.PRIV, from, target, content)); } } } } catch (IOException e) { // 连接异常通常发生在对方拔线或强制关闭进程时 } finally { // finally保证无论正常退出还是异常断开都能清理在线表 if (nick ! null) { clients.remove(nick); broadcast(系统, nick 离开了聊天室); } } } private void broadcast(String from, String content) { String frame ChatProtocol.encode(MsgType.MSG, from, ALL, content); clients.values().forEach(out - out.println(frame)); } }这段代码有四个需要说明的点。第一try-with-resources同时管理Socket和两个流方法结束时自动关闭不用手写close第二readLine()读到null说明对方正常关闭了连接循环退出第三广播是遍历在线表向所有输出流写数据某条输出流写失败时会抛IOException进入catch由finally负责清理第四发送私聊时目标不在线clients.get(target)返回null代码里直接忽略更完善的版本可以给发送者回一条“对方不在线”。3.3 心跳超时与半开连接的识别参数如果客户端程序直接崩溃或电脑突然断电TCP连接不会发送FIN包服务端的readLine()会一直阻塞在线表里这条记录就永远清不掉。要解决这个问题需要在应用层加心跳机制。常见做法是客户端每30秒发一条PING服务端记录每个昵称的最后活跃时间超过90秒没收到任何消息就判定为死连接并主动断开。心跳相关参数建议这样定义参数推荐值说明HEARTBEAT_INTERVAL_MS30000客户端发送PING的间隔TIMEOUT_MS90000服务端判定死连接的超时时间CHECK_PERIOD_MS5000服务端定时扫描间隔服务端用一个ScheduledExecutorService启动定时任务初始化后每5秒扫一次在线表拿当前时间和lastSeen里的时间比较超时就调用socket.close()让处理线程抛出异常后面的finally自然清理。扫描线程和连接线程操作同一个Map要记得lastSeen也用ConcurrentHashMap。4. Swing客户端的线程分工与收发实现4.1 读取线程与UI线程分离为什么不能把readLine放在事件线程Swing是单线程模型所有界面刷新都必须发生在Event Dispatch ThreadEDT上。如果把Socket的readLine()放在EDT里消息还没到达时程序会一直阻塞在读取窗口拖不动、按钮点不了、标题栏显示“未响应”。局域网虽快但没人保证服务端一定会立刻回包所以网络读取必须放在单独的线程里。客户端启动时开一个名为socket-reader的守护线程专门循环读取服务端发来的数据拿到消息后调用SwingUtilities.invokeLater()把界面更新操作交还给EDT。这样网络线程和UI线程各司其职网络线程负责阻塞等待EDT负责把消息追加到聊天记录区。一个容易忽视的细节是线程要设为daemon否则用户点关闭窗口后读取线程还占着JVM进程不会退出。4.2 发送消息与私聊指令的界面处理客户端的核心代码封装在ChatClient类里构造时建立Socket并发LOGIN随后启动读取线程。消息发送则绑定到输入框的回车事件上用户在输入框按回车时触发sendMessage。下面是发送和读取部分的骨架public class ChatClient { private final String nick; private final Socket socket; private final BufferedReader in; private final PrintWriter out; private final JTextArea area new JTextArea(); private final JTextField input new JTextField(); private final DefaultListModelString userList new DefaultListModel(); public ChatClient(String host, int port, String nick) throws IOException { this.nick nick; this.socket new Socket(host, port); this.in new BufferedReader(new InputStreamReader( socket.getInputStream(), StandardCharsets.UTF_8)); this.out new PrintWriter(new OutputStreamWriter( socket.getOutputStream(), StandardCharsets.UTF_8), true); // 连接后第一件事登录 out.println(ChatProtocol.encode(MsgType.LOGIN, nick, ALL, )); Thread reader new Thread(this::readLoop, socket-reader); reader.setDaemon(true); reader.start(); } private void readLoop() { try { String line; while ((line in.readLine()) ! null) { String[] parts ChatProtocol.decode(line); String type parts[0]; String from parts[1]; String target parts[2]; String content parts[3]; String display; if (MsgType.MSG.equals(type)) { // 群聊消息显示为 昵称: 内容 display from : content System.lineSeparator(); } else if (MsgType.PRIV.equals(type)) { // 私聊消息带标记避免和群聊混在一起 display [私聊] from : content System.lineSeparator(); } else { display content System.lineSeparator(); } String finalDisplay display; SwingUtilities.invokeLater(() - area.append(finalDisplay)); } } catch (IOException e) { SwingUtilities.invokeLater(() - area.append(连接断开 System.lineSeparator())); } } public void sendMessage() { String content input.getText().trim(); if (!content.isEmpty()) { // 群聊消息TARGET固定为ALL私聊走单独的输入框 out.println(ChatProtocol.encode(MsgType.MSG, nick, ALL, content)); input.setText(); } } }读取循环里所有界面操作都经过invokeLater这样即使同一秒钟收到几十条消息Swing也只会在EDT里按顺序追加不会出现组件状态不一致。JTextArea默认可以编辑记得在初始化时调用setEditable(false)否则聊天记录区会被用户误删。下方组件对应关系可以参考这张表Swing组件用途关键设置JTextArea聊天记录setEditable(false)JTextField消息输入绑定ActionListener监听回车JScrollPane包裹JTextArea自动滚动到底部JList在线用户用DefaultListModel实时刷新4.3 窗口关闭、异常断开与重连处理的兜底逻辑用户关闭窗口时不能直接退出要先发LOGOUT再关闭Socket否则服务端那边会等一段时间才发现连接断开。在JFrame的WindowListener里做这件事最直接windowClosing事件中发送LOGOUT帧然后调用dispose()。如果客户端被系统杀掉发不了LOGOUT也没关系服务端的心跳超时机制会在90秒后清掉这条在线记录属于上一层已经兜过底的场景。读取线程抛出异常后界面要提示“连接断开”同时禁用输入框避免用户继续敲字发送到已经关闭的流上。对课程设计来说做到这个程度已经超过大多数同学的质量如果你的题目要求加“断线重连”可以把Socket连接逻辑抽到connect()方法里读取线程退出时用ScheduledExecutorService定时重试每次间隔3秒恢复后自动重新发送LOGIN并拉一次在线列表。5. 论文与答辩的关键组织方式让课程设计变成完整毕业设计5.1 论文里必画的四张图与对应评价点毕业设计论文和课程设计报告最明显的区别是系统设计部分要有图。我建议至少准备四张系统体系结构图、客户端时序图、服务端类图和局域网部署图。系统体系结构图表达客户端、服务端、应用协议和界面层之间的调用关系时序图画登录、群聊、私聊、退出四个典型流程各一张类图画核心类和字段方法即可不需要把Swing组件的每个方法都列上去。部署图就画两台机器和一个交换机标注IP和端口。不少同学只贴代码不画时序图老师一眼就知道需求分析是抄的。画时序图的核心技巧是把协议帧的流转画进去客户端发LOGIN|张三|ALL|服务端回广播帧其他客户端收到后刷新在线用户列表。这一条链路的时序关系能覆盖Socket和SWing两条技术线靠一张图就展现出你对整个系统的理解。5.2 演示时的两种运行路径与README写法答辩演示环境不一定是预先装好的实验室机器最常见的是现场只有一台电脑。这时推荐的两条运行路径是单机回环模式客户端连127.0.0.1双机局域网模式两台机器连同一个路由器服务端机器运行ipconfig查看IPv4地址客户端连接这个地址。README里把这两条路径都写清楚并注明防火墙放行规则# 第一步启动服务端监听9000端口 java -jar chat-server.jar 9000 # 第二步启动客户端连接服务端IP java -jar chat-client.jar 192.168.1.20 9000 张三Windows自带防火墙默认会拦截入站连接演示时如果客户端连接超时先检查服务端防火墙入站规则是否放行9000端口再执行ping 192.168.1.20确认网络通不通。README里把这句排错命令写上比答辩时现场翻代码要有说服力得多。论文的目录结构可以按“绪论→需求分析→总体设计→详细设计与实现→测试→总结”组织其中第4章的结构应该和本文第2、3、4章的模块划分一一对应。写这一段时不要大段贴代码而是把每个类的职责、关键方法的参数和返回值讲清楚代码片段只针对核心流程贴出来。答辩前把第五章这两个演示路径在命令行里走两遍确保服务端打印的“进入了聊天室”“离开了聊天室”日志能和界面操作对上这比任何花哨的PPT都更能证明代码是你自己调通的。本文还有配套的精品资源点击获取