Java聊天室----多线程实现群聊、私聊、系统消息 (服务端完整代码奉上)_java多线程聊天室代码

是不是试了很多次都没有达到自己想要的效果呢？
没关系，看到这你就已经有收获了

一、动图效果展示

二、服务端代码（核心）

光说不练歪把子

package socket_study03;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.CopyOnWriteArrayList;

/**
 * 服务端最终版
 *  1.多线程
 * 	2.代码封装
 * 
 * 功能: 群聊、私聊实现
 * 
 * 私聊格式说明：@xxx:msg
 * 
 * @author 放牛娃学编程(公众号)
 *
 */

public class Server {
	//存放客户端的容器
	private static CopyOnWriteArrayList<Channel> all = new CopyOnWriteArrayList<Channel>();
	
	//一个channel就代表一个客户端(将其封装成一个类)
	static class Channel implements Runnable{
		private DataOutputStream dos;
		private DataInputStream dis;
		private boolean flag;
		private String name;
		private Socket socket;
		
		//构造器，用于数据初始化
		public Channel(Socket socket)
		{
			this.socket = socket;
			flag = true;
			try
			{
				dis = new DataInputStream(socket.getInputStream());
				dos = new DataOutputStream(socket.getOutputStream());
				
				//获取聊天昵称(也就是客户端发送的备注)
				this.name = receive();
				
				//当客户加入聊天室后,发送欢迎信息
				this.send("欢迎"+name+"进入到越撸越秃群聊中");
				
				//给其它成员发"某某"加入到越撸越秃群聊中"
				this.sendOthers(name+"加入到越撸越秃群聊中", true);
			}
			catch(IOException e)
			{
				this.flag = false;
				this.release();
			}

		}
		
		//接收消息
		public String receive()
		{
			String msg = "";
			try {
				msg = dis.readUTF();
			} catch (IOException e) {
				// TODO Auto-generated catch block
				release();
			}
			return msg;
		}
		
		//发送消息(发给自己)
		public void send(String msg)
		{
			if(!msg.equals(""))
			{
				try {
					dos.writeUTF(msg);
					dos.flush();
				} catch (IOException e) {
					// TODO Auto-generated catch block
					release();
				}
			}
		}
		
		/**
		 * 1.群聊、发给除了自己以外的人
		 * 2.私聊、规定数据格式@xxx:msg
		 * @param msg
		 * @param isSys, 用来区分是否是系统消息，true为是,反之不是
		 */
		public void sendOthers(String msg, boolean isSys)
		{
			boolean isPrivate = msg.startsWith("@");
			if(isPrivate)  //私聊消息
			{
				//获取冒号下标(便于截取名字)
				int index = msg.indexOf(":");
				
				//截取名字(@人的备注)
				String targetName = msg.substring(1, index);
				
				//截取@的信息
				msg = msg.substring(index + 1);
				
				//遍历容器，找到要@的人
				for(Channel other: all)
				{
					if(other.name.equals(targetName))
					{
						other.send(this.name + "敲敲对你说:"+ msg);  //私聊
						break;   //目标找到，发完私聊消息退出遍历
					}
				}
			}
			else  //不是私聊信息
			{
				//发给其它人,除自己以外,其实就是群聊
				for(Channel other:all)
				{
					if(other != this) //this就代表自己，本通道
					{
						if(!isSys)
						{
							other.send(this.name+"说:"+msg); //不是系统消息
						}
						else
						{
							other.send(msg); //系统消息
						}
						
					}
				}
			}
			
		}
		
		//释放资源
		public void release()
		{
			this.flag = false;
			Utils.release(dos, dis, socket);
			
			//退出
			all.remove(this);
			sendOthers(this.name+"离开了该群聊……", true);
		}

		//线程体
		@Override
		public void run() {
			// TODO Auto-generated method stub
			while(flag)
			{
				//接收消息
				String msg = receive();
				
				//群聊发消息(类似群发)
				if(!msg.equals(""))
				{
					sendOthers(msg, false);  //不是系统消息
				}
			}
			
		}
		
	}

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

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194

三、bug吐槽

1. 遇到问题不要怀疑自己的智商，你比谁都聪明呢！！，有问题可以留言哈
2. 如何运行该项目？ 把服务端、客户端代码都准备好，然后先启动服务端、再多开几个客户端就行了
3. 如何获取完整项目？ 如何获取服务端代码或者是整个项目？ 关注公众号后回复：群聊项目。或者加我微信我亲自发你也行。
4. 如何只获取客户端代码？ 点这就有了呀：Java聊天室----多线程实现群聊、私聊、系统消息（有动图演示呀呀呀）
5. 小伙伴们，这个聊天项目测试通过的哈，它能够完成既定目标（群聊、私聊、系统回复），请放心去尝试的呀！！！

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

四、分享交流

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

（链接时常会失效，若出现此类情况，可以加我微信：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都是之前同学花钱买来备战找实习的，需要的我也分享出去了。