Java聊天室——实现多人聊天、私聊、群聊

客户端

package project.java;
//客户端
//输入、输出流分别为处于一个线程import java.io.IOException;
import java.io.PrintStream;
import java.net.Socket;
import java.util.Scanner;class OutToServer2 implements Runnable{private Socket client;public OutToServer2(Socket client) {super();this.client = client;}@Overridepublic void run() {PrintStream printStream;try {printStream = new PrintStream(client.getOutputStream(),true);Scanner scanner = new Scanner(System.in);scanner.useDelimiter("\n");while(true) {System.out.println("请输入：");while(scanner.hasNext()) {String string = scanner.nextLine();printStream.println(string);if(string.equals("拜拜")) {System.out.println("客户端退出");printStream.close();scanner.close();//client.close();break;}}}} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}class ReadFromServer2 implements Runnable{private Socket client;public ReadFromServer2(Socket client) {super();this.client = client;}public void run() {try {Scanner scanner = new Scanner(client.getInputStream());scanner.useDelimiter("\n");while(scanner.hasNext()) {System.out.println("服务器端输入："+scanner.nextLine());}} catch (IOException e) {e.printStackTrace();}}}public class SingelClient2 {public static void main(String[] args) {String serverName = "127.0.0.1";int port = 6666;Socket client;try {client = new Socket(serverName,port);Thread ouThread = new Thread(new OutToServer2(client));Thread inThread = new Thread(new ReadFromServer2(client));ouThread.start();inThread.start();} catch (Exception e) {e.printStackTrace();} }
}

服务器端

package project.java;import java.io.IOException;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Scanner;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
//服务器端
/*** Map<String,Socket>* 用户注册：username:yyy* 群聊：G:hello* 私聊：P:yyy-hhh
*/class  ExcuteClientServer1 implements Runnable{private Socket client;private Map<String,Socket> clientMap;public ExcuteClientServer1(Socket client, Map<String, Socket> clientMap) {super();this.client = client;this.clientMap = clientMap;}public void run() {try {//拿到客户端输入流，读取用户信息Scanner scanner = new Scanner(client.getInputStream());String string = null;while(true){if(scanner.hasNext()) {string = scanner.nextLine();Pattern pattern = Pattern.compile("\r\n|\r|\n");Matcher matcher = pattern.matcher(string);string = matcher.replaceAll("");//用户注册if(string.startsWith("user")) {//获取用户名String useName = string.split("\\:")[1];userRegist(useName, client);continue;}//群聊else if(string.startsWith("G")) {String message = string.split("\\:")[1];gropChat(message);continue;}//私聊else if(string.startsWith("P")) {String temp = string.split("\\:")[1];//取得用户名String useName = temp.split("\\-")[0];//取得消息内容String message = temp.split("\\-")[1];privateChat(useName, message);continue;}//用户退出else if(string.contains("拜拜")) {//先根据Socket知道用户名String useName = getUseName(client);System.out.println("用户名为"+useName +"的用户下线了！！！");clientMap.remove(useName);continue;}} }}catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}}//获取key值（即由端口号找到用户名）public String getUseName(Socket socket) {String useName = null;for(String getKey : clientMap.keySet()) {if(clientMap.get(getKey).equals(socket)) {useName = getKey;}}return useName;}//注册实现public void userRegist(String useName,Socket client) {System.out.println("用户姓名为：" + useName);System.out.println("用户socket为：" + client);System.out.println("用户名为"+ useName +"的用户上线了！");System.out.println("当前用户数为："+ (clientMap.size()+1) +"人");clientMap.put(useName, client);}//群聊实现public void gropChat(String message) {Iterator<Entry<String, Socket>> iterable = clientMap.entrySet().iterator();for(Map.Entry<String, Socket> stringSocketEntry:clientMap.entrySet()) {try {Socket socket = stringSocketEntry.getValue();PrintStream printStream = new PrintStream(socket.getOutputStream(),true);System.out.println("用户说"+message);    printStream.println(message);} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}//私聊实现public void privateChat(String useName,String message) {//根据对应的useName找到对应的SocketSocket privateSocket = clientMap.get(useName);try {PrintStream printStream = new PrintStream(privateSocket.getOutputStream());printStream.println("用户名为"+getUseName(client)+"的用户对你说："+message);} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}}
}public class SingleServer2 {public static void main(String[] args) throws IOException {ServerSocket serverSocket = new ServerSocket(6666);//存取用户信息（用户名和Socket）Map<String, Socket> map = new HashMap<String, Socket>();//线程池，线程大小为20ExecutorService executorService =Executors.newFixedThreadPool(20);System.out.println("等待客户连接中...");try {for(int i = 0;i < 20;i ++) {Socket socket = serverSocket.accept();System.out.println("有新的用户连接："+socket.getInetAddress()+socket.getPort());executorService.execute(new ExcuteClientServer1(socket,map));}executorService.shutdown();serverSocket.close();} catch (Exception e) {}}
}

Java聊天室——实现多人聊天、私聊、群聊相关推荐

h5移动端聊天室|仿微信界面聊天室|h5多人聊天室
今年的FIFA世界杯甚是精彩,最近兴致高涨就利用HTML5开发了一个手机端仿微信界面聊天室,该h5聊天室采用750px全新伸缩flex布局,以及使用rem响应式配合fontsize.js,页面弹窗则是 ...
C++搭建集群聊天室（十四）：群聊功能
文章目录群聊功能思路放码过来 groupuser.hpp group.hpp groupmodel.hpp groupmodel.cpp 群聊功能思路 1.创建群聊,提交群信息,返回群号 2.拉取 ...
微信小程序之聊天室（多人聊天室）总结
实现方式一: 使用nodejs + socket.io实现缺点:引用weapp.socket.io.js 大小100kb 实现方式二: 使用小程序云开发- 数据库实时监听来实现缺点:目前不可以跨 ...
javaWeb实现聊天室（私聊+群聊）
写在前面近几天,迎来了第一个小项目,不做不知道,一做吓一跳.好多知识都掌握的不够扎实,看似会了,但其实似懂非懂,不能真正掌握原理,导致使用起来错误百出.而且深深体会到,知识只有到用时方恨少,一个简单 ...
Java Socket实现简易多人聊天室传输聊天内容或文件
Java Socket实现简易多人聊天室传输聊天内容或文件 Java小练手项目:用Java Socket实现多人聊天室,聊天室功能包括传输聊天内容或者文件.相比于其它的聊天室,增加了传输文件的功能供参 ...
Java websocket + redis 实现多人单聊天室，多人多聊天室，一对一聊天
多人,单聊天室版 FEATURE 多人聊天, 界面简洁美观, 使用ueditor支持发送文字,图片信息群聊成员列表, 登入登出公告存储聊天记录, 查看历史消息技术点使用CopyOnWriteM ...
SpringBoot与webSocket实现在线聊天室——实现私聊+群聊+聊天记录保存
SpringBoot与webSocket实现在线聊天室--实现私聊+群聊+聊天记录保存引用参考:原文章地址:https://blog.csdn.net/qq_41463655/article/det ...
java仿qq聊天系统多人聊天室
目录项目介绍项目截图服务器与客户端新用户注册注册新账号成功进入聊天室多人在线选择发送文件文件接收提醒项目代码参考服务器入口程序服务器请求处理原理解析服务器多人网络连接: 如 ...
java控制台输出版多人聊天室
多人聊天室就要用到网络以及多线程以及输入输出流的知识多人聊天室就是多个人同时聊天,一个发一条信息所有人都是可以接收得到. 接下来我们捋清楚一下思路在这里面服务器充当了一个转发的作用,服务器要做的事 ...

Java聊天室——实现多人聊天、私聊、群聊

客户端

服务器端

Java聊天室——实现多人聊天、私聊、群聊相关推荐

最新文章

热门文章