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

本文主要是介绍Java聊天室----多线程实现群聊、私聊、系统消息（有动图演示呀呀呀），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

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

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

文章目录

一、截图效果展示
- 二、动图演示
- - 三、原理分析：（很重要呀呀）
  - - 四、撸代码（核心）
    - - 五、各种bug吐槽方案
      - 六、分享交流

一、截图效果展示

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

服务端截图：
在这里插入图片描述

客户端截图：
在这里插入图片描述
群聊与私聊截图：

二、动图演示

这里我直接开了三个客户端，不会开的可以留言哈
在这里插入图片描述

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

在这里插入图片描述

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

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

看我画的图：
在这里插入图片描述
说明分析:

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

服务器端

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

多人聊天

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

群聊结构图

分析说明:

服务端通过receive方法(自己封装)，获取数据
然后遍历容器，分发给除掉自身的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();}}