简介这是一份面向Java初学者与网络编程进阶者的综合实践项目源码围绕网络聊天室场景将Socket通信、多线程并发与数据库管理三大核心技术串联落地适合用于课程设计、毕业设计参考或自学练手。压缩包共46个文件约199KB以20个class编译文件、7个java源码、10张jpg与2张gif界面素材为主另含db数据库文件、txt说明文档及project、classpath等工程配置覆盖源码、资源与运行说明结构完整。项目实现了用户注册登录验证、消息广播、在线状态跟踪与聊天记录存储等模块服务器端为每个连接分配独立线程处理并发请求客户端监听消息并刷新界面密码经加密后写入数据库。已有193人学习下载读者可借此理解Socket连接建立、多线程调度与数据库接口调用的完整链路并参考其中的异常捕获与调试思路快速搭建可运行的聊天室原型。1. 从一份 Java 聊天室源码说起Socket、多线程、数据库到底怎么串起来很多人第一次接触网络编程都是从写一个能群聊的 Java 程序开始的。这份资源就是一套完整的 Java 网络聊天室实现核心用到了三样东西Socket 通信负责客户端和服务端之间的消息收发多线程负责让服务端同时接住多个客户端、让客户端一边发一边收数据库负责把用户信息、聊天记录这些需要持久化的数据存下来。它解决的不是能不能连上这种玩具问题而是一个能跑起来、能多人同时在线、能查历史消息的小型系统。适合谁正在学 Java 网络编程想找个能跑通的完整例子的人准备课程设计或毕业设计需要一套可改可扩的骨架的人以及面试前想把 Socket、多线程、JDBC 这三块串成一条线讲清楚的人。下面我按这东西怎么搭起来、参数怎么设、哪里容易翻车的顺序拆一遍。2. 服务端骨架ServerSocket 监听与多线程接入模型2.1 为什么是一连接一线程而不是单线程轮询服务端要同时服务多个客户端最朴素的做法是单线程里用一个循环去轮询所有连接但 Socket 的read()是阻塞的一个客户端不发数据整个循环就卡死其他人全被拖住。所以这份实现走的是主线程只负责 accept每接进来一个客户端就丢给一个新线程去处理的模型。主线程的accept()返回一个Socket这个 Socket 代表一条已经建立的双向连接把它交给ClientHandler线程主线程立刻回去继续accept下一个。这样 N 个客户端就有 N 个处理线程彼此互不阻塞。这个模型的好处是逻辑直白、调试容易每个客户端的读写都在自己线程里不用考虑状态机。代价是线程数量随连接数线性增长几百上千连接时线程切换开销会明显。常见做法是连接数不大几十到一两百时直接用这个模型真上量了再换 NIO 或 Netty。这份资源属于前者学习和小规模使用完全够。2.2 服务端启动与端口参数public class ChatServer { // 端口建议 1024 以上避免与系统保留端口冲突 private static final int PORT 8888; // 用线程安全的集合保存在线客户端key 为用户名 private static final MapString, ClientHandler ONLINE new ConcurrentHashMap(); public static void main(String[] args) throws IOException { ServerSocket serverSocket new ServerSocket(PORT); System.out.println(聊天室服务端已启动监听端口 PORT); while (true) { // accept 阻塞直到有客户端连进来 Socket socket serverSocket.accept(); // 每个连接开一个线程处理 new Thread(new ClientHandler(socket)).start(); } } }逻辑说明ServerSocket绑定端口后进入死循环accept()每返回一个 Socket 就新建线程。ONLINE用ConcurrentHashMap而不是HashMap因为多个处理线程会同时往里增删普通 HashMap 在并发写时会出问题甚至死循环。参数上端口选 8888 只是习惯实际部署要确认没被占用new Thread(...)这种写法在生产里一般换成线程池学习阶段够用。2.3 客户端处理线程读消息、广播、断线清理public class ClientHandler implements Runnable { private Socket socket; private BufferedReader in; private PrintWriter out; private String userName; public ClientHandler(Socket socket) { this.socket socket; } Override public void run() { try { in new BufferedReader(new InputStreamReader(socket.getInputStream(), UTF-8)); out new PrintWriter(new OutputStreamWriter(socket.getOutputStream(), UTF-8), true); // 第一条消息约定为用户名 userName in.readLine(); ChatServer.ONLINE.put(userName, this); broadcast(系统 userName 加入了聊天室); String msg; while ((msg in.readLine()) ! null) { broadcast(userName msg); } } catch (IOException e) { // 客户端异常断开走 finally 清理 } finally { ChatServer.ONLINE.remove(userName); broadcast(系统 userName 离开了聊天室); close(); } } // 向所有在线客户端转发消息 private void broadcast(String msg) { for (ClientHandler h : ChatServer.ONLINE.values()) { h.out.println(msg); } } private void close() { try { if (socket ! null) socket.close(); } catch (IOException ignored) {} } }逻辑说明run()里先读第一行当用户名注册进在线表然后进入while循环不断读消息并广播。PrintWriter构造时第二个参数传true表示自动 flush否则消息会卡在缓冲区发不出去这是新手最常踩的坑之一。finally块保证无论正常退出还是异常断开都会把用户从在线表移除并通知其他人避免幽灵用户。字符编码统一用 UTF-8两端必须一致否则中文会乱码。3. 客户端实现收发分离与消息协议约定3.1 为什么客户端也要两个线程客户端有个天然矛盾主线程如果去readLine()等消息就没法同时让用户输入如果去等用户输入就收不到别人发的消息。解决办法是把收和发拆到两个线程主线程负责读键盘输入并发送另开一个线程专门readLine()接收服务端推来的消息并打印。这样用户随时能打字消息也能实时刷出来。3.2 客户端收发代码public class ChatClient { public static void main(String[] args) throws IOException { Socket socket new Socket(127.0.0.1, 8888); BufferedReader in new BufferedReader(new InputStreamReader(socket.getInputStream(), UTF-8)); PrintWriter out new PrintWriter(new OutputStreamWriter(socket.getOutputStream(), UTF-8), true); BufferedReader keyboard new BufferedReader(new InputStreamReader(System.in)); // 接收线程持续打印服务端推来的消息 new Thread(() - { try { String msg; while ((msg in.readLine()) ! null) { System.out.println(msg); } } catch (IOException e) { System.out.println(与服务端断开连接); } }).start(); // 主线程读键盘输入并发送 System.out.print(请输入用户名); out.println(keyboard.readLine()); String line; while ((line keyboard.readLine()) ! null) { out.println(line); } } }逻辑说明Socket构造时传入服务端 IP 和端口本机测试用127.0.0.1。接收线程用 lambda 起循环读服务端消息打印。主线程先发用户名再循环把键盘输入发出去。注意keyboard.readLine()在 IDE 控制台里可能因为编码问题读中文异常命令行运行时加-Dfile.encodingUTF-8更稳。3.3 消息协议别用裸字符串硬拼上面用的是最简单的纯文本行协议一行一条消息。它够用但扩展性差——想区分私聊群发系统通知就得靠字符串前缀去startsWith判断很容易解析错。常见做法是约定一个简单格式比如类型|发送者|内容接收端按|切分。这份资源如果只做群聊纯文本行没问题一旦要加私聊、文件传输就该升级协议。升级时注意内容里如果本身含分隔符会切错稳妥点用 JSON 或先对内容做转义。4. 数据库落地用户表、消息表与 JDBC 增删改查4.1 表结构怎么设计聊天室需要持久化的主要是两类用户账号、密码、昵称和聊天记录发送者、内容、时间。用户表用于登录校验消息表用于查历史。下面是最小可用的建表语句。CREATE TABLE t_user ( id INT PRIMARY KEY AUTO_INCREMENT, username VARCHAR(32) NOT NULL UNIQUE, password VARCHAR(64) NOT NULL, nickname VARCHAR(32), create_time DATETIME DEFAULT CURRENT_TIMESTAMP ); CREATE TABLE t_message ( id BIGINT PRIMARY KEY AUTO_INCREMENT, sender VARCHAR(32) NOT NULL, content VARCHAR(500) NOT NULL, send_time DATETIME DEFAULT CURRENT_TIMESTAMP, INDEX idx_send_time (send_time) );逻辑说明username加UNIQUE防止重复注册密码字段留 64 位是为了以后存哈希值而不是明文。消息表给send_time建索引因为查历史记录通常按时间倒序取最近 N 条没索引数据一多就慢。content用VARCHAR(500)限制长度避免有人发超长文本撑爆表。4.2 JDBC 工具类与增删改查public class DBUtil { private static final String URL jdbc:mysql://localhost:3306/chatdb?useUnicodetruecharacterEncodingutf8serverTimezoneAsia/Shanghai; private static final String USER root; private static final String PASSWORD your_password; static { try { Class.forName(com.mysql.cj.jdbc.Driver); } catch (ClassNotFoundException e) { throw new RuntimeException(MySQL 驱动未加载, e); } } public static Connection getConnection() throws SQLException { return DriverManager.getConnection(URL, USER, PASSWORD); } // 保存一条聊天记录 public static void saveMessage(String sender, String content) { String sql INSERT INTO t_message(sender, content) VALUES(?, ?); try (Connection conn getConnection(); PreparedStatement ps conn.prepareStatement(sql)) { ps.setString(1, sender); ps.setString(2, content); ps.executeUpdate(); } catch (SQLException e) { e.printStackTrace(); } } // 查询最近 20 条历史消息 public static ListString recentMessages() { ListString list new ArrayList(); String sql SELECT sender, content FROM t_message ORDER BY send_time DESC LIMIT 20; try (Connection conn getConnection(); PreparedStatement ps conn.prepareStatement(sql); ResultSet rs ps.executeQuery()) { while (rs.next()) { list.add(rs.getString(sender) rs.getString(content)); } } catch (SQLException e) { e.printStackTrace(); } return list; } }逻辑说明连接串里serverTimezoneAsia/Shanghai是 MySQL 8 必须带的否则时间字段会报时区错误。Class.forName加载驱动在旧版本要写com.mysql.jdbc.DriverMySQL 8 用com.mysql.cj.jdbc.Driver写错会报找不到驱动。用PreparedStatement而不是拼接字符串既防 SQL 注入又省去转义麻烦。try-with-resources保证连接和语句自动关闭避免连接泄漏——连接池耗尽时整个服务就卡死了。4.3 把数据库接进聊天流程在ClientHandler的广播逻辑里收到消息后先落库再转发这样历史记录不会丢。注意落库是 IO 操作如果每条消息都同步写库高并发时会拖慢广播。常见做法是丢给一个单独的写库线程或队列异步处理。学习阶段直接同步写没问题但要意识到这个瓶颈在哪。5. 避坑与排查那些让聊天室跑不起来的常见问题5.1 现象客户端连不上报 Connection refused原因通常是服务端没启动或者端口被占用导致ServerSocket没绑上也可能是防火墙拦了。解决先确认服务端控制台有没有打印已启动再用netstat -ano | findstr 8888Windows或lsof -i:8888Linux/Mac看端口状态。如果端口被占换一个端口或者杀掉占用进程。跨机测试时确认两台机器网络互通、防火墙放行。5.2 现象中文全是乱码原因是两端编码不一致或者没指定编码用了系统默认。解决InputStreamReader和OutputStreamWriter都显式传UTF-8数据库连接串加characterEncodingutf8建表时字段字符集用utf8mb4。命令行运行加-Dfile.encodingUTF-8。三处都对齐了才不会乱。5.3 现象消息发出去对方收不到或者要发好几条才显示原因是PrintWriter没开自动 flush数据卡在缓冲区。解决构造PrintWriter时第二个参数传true或者每次println后手动flush()。这个坑很隐蔽因为本地测试偶尔能通一上网络就暴露。5.4 现象用户退出后名字还在在线列表里别人还能看到原因是客户端异常断开时没走清理逻辑或者清理代码写在try里没放finally。解决把ONLINE.remove()和广播离线消息放进finally块保证无论怎么退出都执行。另外readLine()返回null代表对端关闭循环要能正常退出。5.5 现象并发一高就报数据库连接过多或程序卡死原因是每个操作都新建连接、用完不关或者同步写库阻塞了广播线程。解决用连接池如 HikariCP、Druid管理连接设置最大连接数写库改成异步用一个BlockingQueue加单独消费线程。学习阶段至少保证try-with-resources把连接关掉。6. 进阶技巧把聊天记录查询做成可验证的功能前面把骨架搭完了最后说一个能立刻验证整套链路是否打通的技巧做一个进房拉历史的功能。新客户端连上、发完用户名后服务端立刻从数据库查最近 20 条消息推给它。这样你一眼就能看出 Socket 通不通、数据库连没连上、编码对不对——三个环节任何一环出问题历史消息就显示不出来。// 在 ClientHandler 注册用户名之后调用 ListString history DBUtil.recentMessages(); // 倒序查出来的反转成正序再发 Collections.reverse(history); for (String h : history) { out.println(h); }逻辑说明recentMessages()按时间倒序取 20 条展示时要反转成正序否则聊天记录是倒着读的。这一步同时验证了三件事DBUtil能拿到连接、SQL 能执行、结果能通过 Socket 发回客户端。如果历史为空但新消息正常说明数据库写入或查询有问题如果历史乱码说明编码没对齐如果客户端直接卡住说明out没 flush 或服务端在查库时抛了异常没处理。我自己的习惯是每加一个新功能先想一个能一眼看出通没通的验证点而不是等全部写完再联调。当年做第一个聊天室时我图省事把清理逻辑写在try里结果测试时客户端一崩服务端在线列表就残留一堆幽灵用户排查了半天才发现是finally没写对。从那以后我每次写涉及资源释放和状态清理的代码都强制先确认finally或try-with-resources到位再往下写业务。希望这套拆解能帮到你把 Socket、多线程、数据库这三块真正串成一条能跑通的线。本文还有配套的精品资源点击获取
