devbox
2023面试高手
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

java仿qq聊天系统 多人聊天室_java多人聊天系统

作者：2023面试高手 | 2024-02-17 02:30:18

赞

踩

java多人聊天系统

目录

项目介绍

项目截图

服务器与客户端

新用户注册

注册新账号成功 

进入聊天室

多人在线

选择发送文件

文件接收提醒

 项目代码参考

服务器入口程序

 服务器请求处理

原理解析

服务器多人网络连接：

如何实现窗口抖动

获取源码

项目介绍

使用 java swing 开发多人聊天室，分为服务端和客户端，属于BS架构。

功能包括：注册、登录、单聊、群聊、窗口抖动、发送文件、选头像。

服务器：可以看到全部已注册用户的列表，用户登录之后也可以在服务器看到在线信息。

客户端：可以注册新用户，注册时可以填写昵称、密码、性别、头像。

登录成功之后会进入聊天室，在聊天室可以看到其他在线用户，也可以选择某个具体用户进行单聊。

也可以给其他用户发送窗口抖动。

也可以给其他用户发送文件。

项目截图

服务器与客户端

新用户注册

可以选择头像

注册新账号成功 

进入聊天室

多人在线

选择发送文件

文件接收提醒

 项目代码参考

服务器入口程序

这是服务器启动的主程序，在这里监听了网络端口，循环接收客户端的连接请求。

  1.  
  2. package server;
  3.  
  4. import java.io.IOException;
  5. import java.net.*;
  6.  
  7. import javax.swing.*;
  8.  
  9. import server.controller.RequestProcessor;
  10. import server.ui.ServerInfoFrame;
  11.  
  12. /** 服务器入口程序 */
  13. public class ServerMain {
  14. 	public static void main(String[] args) {
  15. 		try {//设置外观样式
  16. 			UIManager.setLookAndFeel("com.sun.java.swing.plaf.nimbus.NimbusLookAndFeel"); 
  17. 		} catch (Exception e) {
  18. 			e.printStackTrace();
  19. 		}
  20. 		int port = Integer.parseInt(DataBuffer.configProp.getProperty("port"));
  21. 		//初始化服务器套节字
  22. 		try {
  23. 			DataBuffer.serverSocket = new ServerSocket(port);
  24. 		} catch (IOException e) {
  25. 			e.printStackTrace();
  26. 		}
  27. 		
  28. 		new Thread(new Runnable() {//启动新线程进行客户端连接监听
  29. 			public void run() {
  30. 				try {
  31. 					while (true) {
  32. 						// 监听客户端的连接
  33. 						Socket socket = DataBuffer.serverSocket.accept();
  34. 						System.out.println("客户来了：" 
  35. 								+ socket.getInetAddress().getHostAddress()
  36. 								+ ":" + socket.getPort());
  37. 						
  38. 						//针对每个客户端启动一个线程，在线程中调用请求处理器来处理每个客户端的请求
  39. 						new Thread(new RequestProcessor(socket)).start();
  40. 					}
  41. 				} catch (IOException e) {
  42. 					e.printStackTrace();
  43. 				}
  44. 			}
  45. 		}).start();
  46. 		
  47. 		
  48. 		//启动服务器监控窗体
  49. 		new ServerInfoFrame(); 
  50. 	}
  51. }

 服务器请求处理

服务器对收到的消息进行处理，例如注册、登录、窗口震动、发送文件、接收文件、聊天、拒收文件，以及其他类型的消息都在这进行处理。

  1.  
  2. package server.controller;
  3.  
  4. import java.io.*;
  5. import java.net.Socket;
  6. import java.text.*;
  7. import java.util.concurrent.CopyOnWriteArrayList;
  8. import server.*;
  9. import server.model.service.UserService;
  10. import common.model.entity.*;
  11.  
  12. /** 服务器端请求处理器 */
  13. public class RequestProcessor implements Runnable{
  14. 	private Socket currentClientSocket;  //当前正在请求服务器的客户端Socket
  15. 	
  16. 	public RequestProcessor(Socket currentClientSocket){
  17. 		this.currentClientSocket = currentClientSocket;
  18. 	}
  19. 	
  20. 	public void run() {
  21. 		boolean flag = true; //是否不间断监听
  22. 		try{
  23. 			OnlineClientIOCache currentClientIOCache = new OnlineClientIOCache(
  24. 					new ObjectInputStream(currentClientSocket.getInputStream()), 
  25. 					new ObjectOutputStream(currentClientSocket.getOutputStream()));
  26. 			while(flag){ //不停地读取客户端发过来的请求对象
  27. 				//从请求输入流中读取到客户端提交的请求对象
  28. 				Request request = (Request)currentClientIOCache.getOis().readObject();
  29. 				System.out.println("Server读取了客户端的请求:" + request.getAction());
  30.  
  31. 				String actionName = request.getAction();   //获取请求中的动作
  32. 				if(actionName.equals("userRegiste")){      //用户注册
  33. 					registe(currentClientIOCache, request);
  34. 				}else if(actionName.equals("userLogin")){  //用户登录
  35. 					login(currentClientIOCache, request);
  36. 				}else if("exit".equals(actionName)){       //请求断开连接
  37. 					flag = logout(currentClientIOCache, request);
  38. 				}else if("chat".equals(actionName)){       //聊天
  39. 					chat(request);
  40. 				}else if("shake".equals(actionName)){      //振动
  41. 					shake(request);
  42. 				}else if("toSendFile".equals(actionName)){ //准备发送文件
  43. 					toSendFile(request);
  44. 				}else if("agreeReceiveFile".equals(actionName)){ //同意接收文件
  45. 					agreeReceiveFile(request);
  46. 				}else if("refuseReceiveFile".equals(actionName)){ //拒绝接收文件
  47. 					refuseReceiveFile(request);
  48. 				}
  49. 			}
  50. 		}catch(Exception e){
  51. 			e.printStackTrace();
  52. 		}
  53. 	}
  54.  
  55. 	/** 拒绝接收文件 */
  56. 	private void refuseReceiveFile(Request request) throws IOException {
  57. 		FileInfo sendFile = (FileInfo)request.getAttribute("sendFile");
  58. 		Response response = new Response();  //创建一个响应对象
  59. 		response.setType(ResponseType.REFUSERECEIVEFILE);
  60. 		response.setData("sendFile", sendFile);
  61. 		response.setStatus(ResponseStatus.OK);
  62. 		//向请求方的输出流输出响应
  63. 		OnlineClientIOCache ocic = DataBuffer.onlineUserIOCacheMap.get(sendFile.getFromUser().getId());
  64. 		this.sendResponse(ocic, response);
  65. 	}
  66.  
  67. 	/** 同意接收文件 */
  68. 	private void agreeReceiveFile(Request request) throws IOException {
  69. 		FileInfo sendFile = (FileInfo)request.getAttribute("sendFile");
  70. 		//向请求方(发送方)的输出流输出响应
  71. 		Response response = new Response();  //创建一个响应对象
  72. 		response.setType(ResponseType.AGREERECEIVEFILE);
  73. 		response.setData("sendFile", sendFile);
  74. 		response.setStatus(ResponseStatus.OK);
  75. 		OnlineClientIOCache sendIO = DataBuffer.onlineUserIOCacheMap.get(sendFile.getFromUser().getId());
  76. 		this.sendResponse(sendIO, response);
  77. 		
  78. 		//向接收方发出接收文件的响应
  79. 		Response response2 = new Response();  //创建一个响应对象
  80. 		response2.setType(ResponseType.RECEIVEFILE);
  81. 		response2.setData("sendFile", sendFile);
  82. 		response2.setStatus(ResponseStatus.OK);
  83. 		OnlineClientIOCache receiveIO = DataBuffer.onlineUserIOCacheMap.get(sendFile.getToUser().getId());
  84. 		this.sendResponse(receiveIO, response2);
  85. 	}
  86. 	
  87. 	/** 客户端退出 */
  88. 	public boolean logout(OnlineClientIOCache oio, Request request) throws IOException{
  89. 		System.out.println(currentClientSocket.getInetAddress().getHostAddress()
  90. 				+ ":" + currentClientSocket.getPort() + "走了");
  91.  
  92. 		User user = (User)request.getAttribute("user");
  93. 		//把当前上线客户端的IO从Map中删除
  94. 		DataBuffer.onlineUserIOCacheMap.remove(user.getId());
  95. 		//从在线用户缓存Map中删除当前用户
  96. 		DataBuffer.onlineUsersMap.remove(user.getId());
  97. 			
  98. 		Response response = new Response();  //创建一个响应对象
  99. 		response.setType(ResponseType.LOGOUT);
  100. 		response.setData("logoutUser", user);
  101. 		oio.getOos().writeObject(response);  //把响应对象往客户端写
  102. 		oio.getOos().flush();
  103. 		currentClientSocket.close();  //关闭这个客户端Socket
  104. 		
  105. 		DataBuffer.onlineUserTableModel.remove(user.getId()); //把当前下线用户从在线用户表Model中删除
  106. 		iteratorResponse(response);//通知所有其它在线客户端
  107. 		
  108. 		return false;  //断开监听
  109. 	}
  110. 	/** 注册 */
  111. 	public void registe(OnlineClientIOCache oio, Request request) throws IOException {
  112. 		User user = (User)request.getAttribute("user");
  113. 		UserService userService = new UserService();
  114. 		
  115. 		userService.addUser(user);
  116. 		
  117. 		Response response = new Response();  //创建一个响应对象
  118. 		response.setStatus(ResponseStatus.OK);
  119. 		response.setData("user", user);
  120. 		
  121. 		oio.getOos().writeObject(response);  //把响应对象往客户端写
  122. 		oio.getOos().flush();
  123. 		
  124. 		//把新注册用户添加到RegistedUserTableModel中
  125. 		DataBuffer.registedUserTableModel.add(new String[]{
  126. 			String.valueOf(user.getId()),
  127. 			user.getPassword(),
  128. 			user.getNickname(),
  129. 			String.valueOf(user.getSex())
  130. 		});
  131. 	}
  132. 	
  133. 	/** 登录 */
  134. 	public void login(OnlineClientIOCache currentClientIO, Request request) throws IOException {
  135. 		String idStr = (String)request.getAttribute("id");
  136. 		String password = (String) request.getAttribute("password");
  137. 		UserService userService = new UserService();
  138. 		User user = userService.login(Long.parseLong(idStr), password);
  139. 		
  140. 		Response response = new Response();  //创建一个响应对象
  141. 		if(null != user){
  142. 			if(DataBuffer.onlineUsersMap.containsKey(user.getId())){ //用户已经登录了
  143. 				response.setStatus(ResponseStatus.OK);
  144. 				response.setData("msg", "该 用户已经在别处上线了！");
  145. 				currentClientIO.getOos().writeObject(response);  //把响应对象往客户端写
  146. 				currentClientIO.getOos().flush();
  147. 			}else { //正确登录
  148. 				DataBuffer.onlineUsersMap.put(user.getId(), user); //添加到在线用户
  149. 				//设置在线用户
  150. 				response.setData("onlineUsers", 
  151. 						new CopyOnWriteArrayList<User>(DataBuffer.onlineUsersMap.values()));
  152. 				
  153. 				response.setStatus(ResponseStatus.OK);
  154. 				response.setData("user", user);
  155. 				currentClientIO.getOos().writeObject(response);  //把响应对象往客户端写
  156. 				currentClientIO.getOos().flush();
  157. 				
  158. 				//通知其它用户有人上线了
  159. 				Response response2 = new Response();
  160. 				response2.setType(ResponseType.LOGIN);
  161. 				response2.setData("loginUser", user);
  162. 				iteratorResponse(response2);
  163. 				
  164. 				//把当前上线的用户IO添加到缓存Map中
  165. 				DataBuffer.onlineUserIOCacheMap.put(user.getId(),currentClientIO);
  166. 				
  167. 				//把当前上线用户添加到OnlineUserTableModel中
  168. 				DataBuffer.onlineUserTableModel.add(
  169. 						new String[]{String.valueOf(user.getId()), 
  170. 										user.getNickname(), 
  171. 										String.valueOf(user.getSex())});
  172. 			}
  173. 		}else{ //登录失败
  174. 			response.setStatus(ResponseStatus.OK);
  175. 			response.setData("msg", "账号或密码不正确！");
  176. 			currentClientIO.getOos().writeObject(response);
  177. 			currentClientIO.getOos().flush();
  178. 		}
  179. 	}
  180. 	
  181. 	/** 聊天 */
  182. 	public void chat(Request request) throws IOException {
  183. 		Message msg = (Message)request.getAttribute("msg");
  184. 		Response response = new Response();
  185. 		response.setStatus(ResponseStatus.OK);
  186. 		response.setType(ResponseType.CHAT);
  187. 		response.setData("txtMsg", msg);
  188. 		
  189. 		if(msg.getToUser() != null){ //私聊:只给私聊的对象返回响应
  190. 			OnlineClientIOCache io = DataBuffer.onlineUserIOCacheMap.get(msg.getToUser().getId());
  191. 			sendResponse(io, response);
  192. 		}else{  //群聊:给除了发消息的所有客户端都返回响应
  193. 			for(Long id : DataBuffer.onlineUserIOCacheMap.keySet()){
  194. 				if(msg.getFromUser().getId() == id ){	continue; }
  195. 				sendResponse(DataBuffer.onlineUserIOCacheMap.get(id), response);
  196. 			}
  197. 		}
  198. 	}
  199. 	
  200. 	/** 发送振动 */
  201. 	public void shake(Request request)throws IOException {
  202. 		Message msg = (Message)request.getAttribute("msg");
  203. 		
  204. 		DateFormat df = new SimpleDateFormat("HH:mm:ss");
  205. 		StringBuffer sb = new StringBuffer();
  206. 		sb.append(" ").append(msg.getFromUser().getNickname())
  207. 			.append("(").append(msg.getFromUser().getId()).append(") ")
  208. 			.append(df.format(msg.getSendTime())).append("\n  给您发送了一个窗口抖动\n");
  209. 		msg.setMessage(sb.toString());
  210. 		
  211. 		Response response = new Response();
  212. 		response.setStatus(ResponseStatus.OK);
  213. 		response.setType(ResponseType.SHAKE);
  214. 		response.setData("ShakeMsg", msg);
  215. 		
  216. 		OnlineClientIOCache io = DataBuffer.onlineUserIOCacheMap.get(msg.getToUser().getId());
  217. 		sendResponse(io, response);
  218. 	}
  219. 	
  220. 	/** 准备发送文件 */
  221. 	public void toSendFile(Request request)throws IOException{
  222. 		Response response = new Response();
  223. 		response.setStatus(ResponseStatus.OK);
  224. 		response.setType(ResponseType.TOSENDFILE);
  225. 		FileInfo sendFile = (FileInfo)request.getAttribute("file");
  226. 		response.setData("sendFile", sendFile);
  227. 		//给文件接收方转发文件发送方的请求
  228. 		OnlineClientIOCache ioCache = DataBuffer.onlineUserIOCacheMap.get(sendFile.getToUser().getId());
  229. 		sendResponse(ioCache, response);
  230. 	}
  231. 	
  232. 	/** 给所有在线客户都发送响应 */
  233. 	private void iteratorResponse(Response response) throws IOException {
  234. 		for(OnlineClientIOCache onlineUserIO : DataBuffer.onlineUserIOCacheMap.values()){
  235. 			ObjectOutputStream oos = onlineUserIO.getOos();
  236. 			oos.writeObject(response);
  237. 			oos.flush();
  238. 		}
  239. 	}
  240. 	
  241. 	/** 向指定客户端IO的输出流中输出指定响应 */
  242. 	private void sendResponse(OnlineClientIOCache onlineUserIO, Response response)throws IOException {
  243. 		ObjectOutputStream oos = onlineUserIO.getOos();
  244. 		oos.writeObject(response);
  245. 		oos.flush();
  246. 	}
  247. }

原理解析

服务器多人网络连接：

首先来分析一下要实现的流程

  •  首先建立一个服务器端，构建serversocket并绑定端口
  •  创建socket客户端，连接到指定ip以及其端口
  •  然后使用accept阻塞接收socket发出的连接请求
  • 接收到的socket对象需要使用thread单独处理，
  • 每个用户分配单独的线程进行读写处理
  •  根据输入流和输出流进行两者数据的通信
  •  获取连接后的socket客户端的输入流和输出流

值得一提是：该socket是同步阻塞的，因此在socket客户端需要进行创建一个线程，来分别进行向服务器输出，和接收服务器传输的数据。

如何实现窗口抖动

窗口的左上角是原点，我们首先记录起始坐标，计算出向左上角移动的距离和右下角移动的距离，通过循环语句控制窗口位移，最终将窗口恢复到起始坐标。

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/2023面试高手/article/detail/99183
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号