Java聊天室----多线程实现群聊、私聊、系统消息（有动图演示呀呀呀）

是不是找了很多类似的博文都不能实现各个博主展示的效果呢？

原因在这我不谈，但是我保证，你看了这篇文章，只要你动手，那肯定有收获，没收获，那就是我蠢了

一、截图效果展示

有效果才有动力，这里我就先展示效果

服务端截图：

客户端截图：

群聊与私聊截图：

二、动图演示

这里我直接开了三个客户端，不会开的可以留言哈

客户端要定住它，不然它老是被切换，不会定的也可留言呀！！！

三、原理分析：（很重要呀呀）

• 首先要知道客户端与服务端的联系。

看我画的图：

说明分析:

1. 流

1. 输出流：OutputStream（发送数据）
2. 输入流: InputStream（读取数据）
3. 如果这个知识点你都不是很了解，那就去补补IO流知识哈

2. 服务器端

• 小伙伴们，这里你别把服务器端想的太过于复杂高大尚
• 这里其实就是一个类，它主要是用来存储数据、分发数据(我的理解)
• 然后就是一个无限循环，等待相应客户端，就这么简单哈

• 多人聊天

1. 多人聊天意味着服务端要响应多个客户端，所以要在服务端开启无限循环模式
2. 因为要多人聊天，所以就必须要加入多线程，不然就一直等待，直到某个客户端退出
3. 需要一个容器来管理客户端，用它来进行各种操作（群发消息、私聊，系统消息）

• 群聊结构图
  
  分析说明:

1. 服务端通过receive方法(自己封装)，获取数据
2. 然后遍历容器，分发给除掉自身的socket，调用其send()方法（也需要自行封装）

四、撸代码（核心）

光说不练歪把子

代码都有详细的解释，我不信你看不懂，为了代码的可维护性，和整洁性，我将其进行了封装（其实就是各自写个函数、或者写成一个类而已，没有什么大不了的哈）

工具类：

package socket_study03;import java.io.Closeable;
import java.io.IOException;/*** .工具类* 用途：用于关闭各种流操作，封装一些代码* @author 放牛娃学编程**/public class Utils {//释放资源(后边带...，它代表可变参数)public static void release(Closeable...targets){for(Closeable target: targets){try{if(null != target){target.close();}}catch(IOException e){e.printStackTrace();}}}
}

客户端：

package socket_study03;import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.InetAddress;
import java.net.Socket;/*** 最终版：* 1.用多线程实现客户端* 2.读写分开* 3.封装代码* * 功能：群聊、私聊* * 私聊格式说明：@xxx:msg* 		* @author 放牛娃学编程(公众号)**///发送(写)线程类
class Send implements Runnable{private BufferedReader console;private DataOutputStream dos;private Socket client;private boolean flag;private String name;   //群聊时的备注//构造器(用于数据初始化)public Send(Socket client, String name){this.client = client;flag = true;this.name = name;console = new BufferedReader(new InputStreamReader(System.in));try {dos = new DataOutputStream(client.getOutputStream());//先将自己的备注发过去(服务端)send(name);} catch (IOException e) {// TODO Auto-generated catch blockthis.release();}}//从控制台获取数据public String getFromConsole(){String msg = "";try {msg = console.readLine();} catch (IOException e) {// TODO Auto-generated catch blockrelease();}return msg;}//发送消息public void send(String msg){if(!msg.equals("")){try{dos.writeUTF(msg);dos.flush();}catch(IOException e){e.printStackTrace();}}}//释放资源public void release(){Utils.release(dos, client);this.flag = false;}//线程体@Overridepublic void run() {// TODO Auto-generated method stubwhile(flag){//获取控制台输入的消息String msg = getFromConsole();//发送消息send(msg);}}}//接收(消息)线程类
class Receive implements Runnable{private DataInputStream dis;private boolean flag;private Socket client;//构造器，用于对数据的初始化public Receive(Socket client){this.client = client;flag = true;try {dis = new DataInputStream(client.getInputStream());} catch (IOException e) {// TODO Auto-generated catch blockthis.release();}}//接收消息public void receive(){String msg = "";try {msg = dis.readUTF();} catch (IOException e) {// TODO Auto-generated catch blockrelease();}if(!msg.equals("")){System.out.println(msg);}}//释放资源//释放资源public void release(){Utils.release(dis, client);this.flag = false;}//线程体@Overridepublic void run() {// TODO Auto-generated method stubwhile(flag){//接收消息receive();}}}public class Client {public static void main(String[] args) throws IOException {// TODO Auto-generated method stubSystem.out.println("-------这是客户端-----------");//获取控制台输入流BufferedReader br = new BufferedReader(new java.io.InputStreamReader(System.in));System.out.println("进入群聊前，请输入你的备注");String name = br.readLine();//获取socket管道Socket client = new Socket(InetAddress.getLocalHost(), 9898);//发送(写)线程new Thread(new Send(client, name)).start();//接收(读)线程new Thread(new Receive(client)).start();}
}

服务端：

限于篇幅这里我只给出主线程的代码（需要的自行提取）

	public static void main(String[] args) throws IOException {// TODO Auto-generated method stubSystem.out.println("-----这是服务端----------");//获取ServerSocket管道ServerSocket sSocket = new ServerSocket(9898);while(true){//获取客户端的socketSocket client = sSocket.accept();System.out.println("一个客户端连接成功");Channel channel = new Channel(client);//将每个客户端添加到容器中，进行统一管理all.add(channel);//启动线程new Thread(channel).start();}}

五、 各种bug吐槽方案

1. 直接复制这里的代码在eclipse中运行是报错的？ 因为服务端的代码不全呀！！
2. 如何获取服务端代码或者是整个项目？ 关注公众号后回复：群聊项目。或者加我微信我亲自发你也行。
3. 只需要服务端代码，如何获取？ 点这就有了：Java聊天室----多线程实现群聊、私聊、系统消息 (服务端完整代码奉上)
4. 小伙伴们，这个聊天项目测试通过，能够完成既定目标（群聊、私聊、系统回复）

如果遇到问题，没关系，多去折腾就完事了，也欢迎小伙伴们留言交流学习。

六、分享交流

最后有兴趣一起交流的，可以关注我的公众号：这里你能够学到很实用的技巧，不是常用的我不说，公众号回复提取码即可获取以下学习资料啦啦啦啦，喜欢就拿去吧！！

（链接时常会失效，若出现此类情况，可以加我微信：17722328325（加时请备注：学习资料））

1. Java web从入门到精通电子书

2. Python机器学习电子书

3. Python400集（北京尚学堂）

4. JavaScript项目案例、经典面试题

5. Java300集（入门、精通）

6. Java后端培训机构录集（同事培训内部提供）

7. IO流文档

8. JavaEE面试题及其参考答案文档

9. JavaSE面试题及其参考答案文档

10. java多线程技术文档

11. java网络编程文档

7~11都是之前同学花钱买来备战找实习的，需要的我也分享出去了。