Java聊天室私聊群聊代码详细实现教程 附完整可运行源码

我们会重点讲两个关键功能：群聊时如何让服务端把消息转发给所有在线用户，私聊时怎样通过“用户名+消息”的格式识别接收对象；还会解决常见的坑，比如客户端断开连接后服务端如何清理资源、避免程序崩溃。最实用的是，文章末尾附上了完整可运行的源码，你下载后直接运行就能看到效果，改改参数还能二次开发。

不管你是刚学Java网络编程想练手，还是项目里需要加个简单的聊天功能，跟着这篇教程走，不用再对着零散代码发愁，半小时就能搭出一个能群聊、能私聊的Java聊天室雏形。

你有没有试过想做个Java聊天室，群聊消息发出去所有人都能看到，但私聊总把消息发给陌生人？或者服务端一接多个客户端就卡成“木头人”？我去年帮实习生小周改他的聊天室代码时，他就卡在这——群聊消息要么丢一半，要么所有人都收不到；私聊更离谱，要么把消息发给了所有人，要么直接报“空指针异常”。后来我带着他拆了服务端的消息分发逻辑，再加了个线程安全的用户列表，半小时就跑通了能同时支持群聊+私聊的版本。今天就把这套从“地基”到“精装修”的实现逻辑，连同一堆踩过的坑，一起说给你听。

先把地基打牢：Java聊天室的核心框架怎么搭？

要做聊天室，得先想清楚它的本质——C/S架构的网络通讯：服务端（Server）负责监听连接、管理用户、分发消息；客户端（Client）负责连接服务端、发送消息、接收消息。我见过很多新手上来就写“发消息”的代码，结果连服务端和客户端怎么连都没搞懂，最后全是bug。

服务端：做个“总机”，每个客户端都要有专属“接线员”

服务端的核心是ServerSocket，它像个“总机”，监听某个端口（比如8888），等客户端来连接。但要注意：ServerSocket的accept()方法是阻塞的——如果不处理，服务端只能接一个客户端，第二个客户端连的时候会直接卡住。我第一次做的时候就踩过这坑：没开多线程，结果第一个客户端连进来没事，第二个连的时候服务端直接“死机”，后来查Oracle的Java文档（https://docs.oracle.com/javase/tutorial/networking/sockets/server.htmlnofollow）才知道，得用多线程或者线程池，给每个客户端分配一个“接线员”（Handler线程）。

具体代码结构很简单：

小周之前写ClientHandler的时候，用InputStream直接读消息，结果发中文全是问号——后来我让他换成BufferedReader（字符流），并指定UTF-8编码，问题就解决了。记住：处理中文消息一定要用字符流+正确编码，否则乱码会让你怀疑人生。

客户端：做个“电话机”，能听也能说

客户端的核心是Socket，它像个“电话机”，连接服务端的IP和端口（比如localhost:8888）。但客户端要做两件事：读消息（听服务端发的内容）和写消息（说自己的内容）——这两件事得用两个线程分开做，否则会阻塞。比如：

小周之前没分开线程，结果客户端输入消息的时候，没法接收服务端的消息——比如他在输入框打字，服务端发的群聊消息根本看不到，后来加了两个线程才正常。

群聊+私聊的核心：消息怎么“精准投递”？

框架搭好后，最关键的是消息分发逻辑——怎么让群聊消息发给所有人，私聊消息只发给指定的人？我帮小周解决的核心问题，就是在这里加了个线程安全的用户列表，让服务端知道“谁在线”“该发给谁”。

第一步：维护在线用户列表，服务端要“认识”每个人

服务端得知道“谁在线”，否则群聊没法广播，私聊没法定向。我用的是ConcurrentHashMap：

为什么用ConcurrentHashMap？因为多线程环境下，HashMap会有并发修改异常（比如两个客户端同时改用户名），而ConcurrentHashMap是线程安全的——我之前用HashMap的时候，就遇到过两个客户端同时加入，导致ConcurrentModificationException，换成ConcurrentHashMap就没事了。

具体操作：

小周之前没做“移除”操作，结果客户端关了，服务端还在给它发消息，直接报IOException——后来加了try-catch捕捉断开事件，再从map里移除，就解决了。

第二步：群聊vs私聊，消息格式要“打标签”

服务端要区分“群聊”和“私聊”，得让客户端发消息时打标签。我和小周约定了一套简单的格式（用冒号:分隔），你也可以直接用：

小周之前没加“标签”，结果服务端不知道是群聊还是私聊，要么把私聊发给所有人，要么直接忽略——后来加了前缀，服务端用split(":")解析消息，比如收到“PRIVATE:李四:晚上打球？”，就知道是“私聊”，接收者是“李四”，内容是“晚上打球？”。

第二步：消息分发，精准到“每一个人”

有了用户列表和消息格式，分发消息就简单了：

这里要注意两个坑：

最后：跑通代码的关键——先测“地基”，再测“功能”

你按上面的逻辑写好代码后，一定要分步测试：

如果群聊没收到，先查服务端的broadcast()方法有没有遍历所有用户；如果私聊没收到，先查消息格式对不对（有没有加“PRIVATE:接收者:”前缀），再查用户列表里有没有接收者。

我帮小周改代码的时候，他就是群聊没收到——后来发现他的broadcast()方法里，遍历的是HashMap的keySet()，但ClientHandler里没存用户名，导致遍历错了对象。你写的时候一定要注意：用户列表的Key是用户名，Value是ClientHandler，别搞反了。

你要是按这个逻辑写，遇到问题可以留评论，我帮你看看——毕竟我踩过的坑，能让你少踩一半。对了，文章末尾有完整可运行的源码（链接我放评论区了），直接下载就能跑，记得改端口号和IP地址哦～

服务端和客户端连不上，可能是什么原因？

先检查服务端的ServerSocket有没有正确启动，比如端口号（比如8888）是不是和客户端填的一致，IP地址是不是对的（本地测试用localhost或127.0.0.1，局域网要用服务端真实IP）。然后看防火墙有没有挡住端口，比如Windows防火墙可能拦截Java程序的网络请求，得手动放行。还有，服务端的accept()方法有没有用多线程——要是没开多线程，第二个客户端连的时候会卡住，这是新手常踩的坑，得给每个客户端分配专属的ClientHandler线程。

群聊消息发出去但其他人收不到，怎么排查？

先查服务端的broadcast()方法：有没有遍历ConcurrentHashMap里的所有ClientHandler？要是遍历的时候漏了，肯定有人收不到。再看broadcast()方法有没有加同步锁——多个线程同时发群聊会导致消息乱序或丢失，加synchronized锁能解决。还有，客户端的读消息线程有没有正常工作？比如客户端有没有用BufferedReader读服务端的消息，编码是不是UTF-8，要是用字节流读中文会乱码，也可能以为没收不到消息。

私聊消息要么发给所有人，要么收不到，问题出在哪？

首先检查消息格式对不对，私聊必须加“PRIVATE:接收者:内容”的前缀——比如要发给“李四”，得写“PRIVATE:李四:晚上打球？”，要是漏了前缀或者分隔符错了（比如用逗号代替冒号），服务端解析不出来，要么当成普通消息广播，要么直接忽略。然后看接收者是不是在线：服务端的ConcurrentHashMap里有没有这个用户名，要是接收者没连接或者已经断开，得给发送者返回“对方不在线”的提示，不然会报空指针异常。还有，私聊的消息分发逻辑有没有写错——是不是只给接收者的ClientHandler发消息，而不是遍历所有用户？

客户端断开连接后，服务端报“NullPointerException”，怎么解决？

这是因为客户端断开后，服务端没及时从用户列表里移除它的信息。得在ClientHandler的run()方法里加try-catch，捕捉IOException（比如客户端关闭Socket），然后把这个用户从ConcurrentHashMap里remove掉。比如用userMap.remove(username)，这样服务端再发消息的时候，就不会访问已经断开的ClientHandler了。还有，私聊的时候要先判断接收者在不在userMap里，不在的话就给发送者返回提示，别直接调用send方法，不然肯定空指针。

下载的源码跑不起来，需要重点检查哪些地方？

先看端口号和IP是不是改对了：源码里的服务端端口（比如8888）是不是和客户端的一致，本地测试的话IP用localhost就行，要是部署到服务器，得改成服务器的公网IP。然后检查依赖有没有问题，Java聊天室基本不用额外依赖，只要JDK版本对（比如JDK8及以上）就行。再分步测试：先开服务端，看控制台有没有“服务端启动，监听端口8888”的提示；再开客户端，输入用户名，看服务端有没有收到“XX加入聊天室”的通知；然后测群聊，两个客户端互相发消息，最后测私聊。要是某一步没通，就停在那一步排查，比如连不上就查连接逻辑，群聊收不到就查broadcast方法，别一下子把所有功能都打开。

服务端和客户端连不上，可能是什么原因？

先检查服务端的ServerSocket有没有正确启动，比如端口号（比如8888）是不是和客户端填的一致，IP地址是不是对的（本地测试用localhost或127.0.0.1，局域网测试要用服务端的真实IP）。然后看防火墙有没有挡住端口，比如Windows的防火墙可能会拦截Java程序的网络请求，得手动放行。还有，服务端的accept()方法有没有用多线程，要是没开多线程，第二个客户端连的时候会卡住，这是很多新手的通病。

客户端的Socket构造器参数有没有写错，比如把IP写成了服务端的外网IP但其实是本地测试，或者端口号输错了一位，这些小错误很容易忽略，得仔细核对。

群聊消息发出去但其他人收不到，怎么排查？

先查服务端的broadcast()方法：有没有遍历ConcurrentHashMap里的所有ClientHandler？要是遍历的时候漏了或者只遍历了一部分，肯定有人收不到。然后看broadcast()方法有没有加同步锁，比如synchronized，要是多个线程同时发群聊，没锁的话消息会乱序甚至丢失，这是小周之前踩过的坑。

再看客户端的接收逻辑：有没有用单独的线程读消息？要是把读消息和写消息放在一个线程里，客户端输入的时候会阻塞接收，导致群聊消息收不到。还有，消息编码是不是UTF-8？要是用字节流读中文，会变成问号，也会以为没收不到消息。

私聊消息要么发给所有人要么收不到，问题出在哪？

最常见的原因是消息格式不对——私聊必须加“PRIVATE:接收者:内容”的前缀，比如“PRIVATE:李四:晚上打球？”，要是漏了“PRIVATE:”前缀，服务端会当成群聊消息广播；要是分隔符用错（比如用逗号代替冒号），split(“:”)解析的时候会出错，导致接收者识别错。

然后检查接收者是不是在线：服务端的ConcurrentHashMap里有没有这个用户名？要是接收者没连接或者已经断开，服务端找不到对应的ClientHandler，要么报空指针，要么发不出去。还有，私聊的发送逻辑有没有写错——是不是只调用了接收者的send方法，而不是遍历所有用户？要是写成遍历，肯定发给所有人了。

客户端断开后服务端报错，怎么解决？

这是因为客户端断开后，服务端没及时清理它的信息。得在ClientHandler的run()方法里加try-catch，捕捉IOException（比如客户端关闭Socket），然后执行userMap.remove(username)，把这个用户从在线列表里删掉。这样服务端再发消息的时候，就不会访问已经失效的ClientHandler了。

私聊的时候要先判断接收者在不在userMap里，比如用if(userMap.containsKey(receiver))，不在的话就给发送者返回“对方不在线”的提示，别直接调用send方法，不然肯定空指针。

下载的源码跑不起来，需要重点检查哪些地方？

先改端口和IP：源码里的服务端端口（比如8888）是不是和客户端的一致，本地测试的话IP用localhost或127.0.0.1就行，要是部署到服务器，得改成服务器的公网IP。然后看JDK版本，比如源码用的是JDK8，你电脑上装的是JDK17，虽然兼容但偶尔会有小问题，最好用同一版本。

再分步测试：先开服务端，看控制台有没有“服务端启动，监听端口XX”的提示；再开客户端，输入用户名，看服务端有没有“XX加入聊天室”的通知；然后测群聊，两个客户端互相发消息；最后测私聊。要是某一步没反应，就停在那一步查，比如连不上查连接逻辑，群聊收不到查broadcast方法，别一下子全打开。

YUANLEISVIP

收藏 链接