Java Socket通信—聊天室

太过爱你忘了你带给我的痛 2022-07-13 02:56 295阅读 0赞

### Client.java ###

import java.io.*;
    import java.net.*;
    import java.util.*;
    
    public class Client {
    	public int port = 8083;
    	Socket socket = null;
    
    	public static void main(String[] args) {
    		new Client();  //开始执行
    	}
    
    	public Client() {
    
    		try {
    			socket = new Socket("127.0.0.1", port);
    			new Cthread().start();
    
    			BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
    			String msg1;
    			while ((msg1 = br.readLine()) != null) {
    				System.out.println(msg1);
    			}
    		} catch (Exception e) {
    		}
    	}
    
    	class Cthread extends Thread {
    
    		public void run() {
    			try {
    
    				BufferedReader re = new BufferedReader(new InputStreamReader(System.in));
    				PrintWriter pw = new PrintWriter(socket.getOutputStream(), true);
    				String msg2;
    
    				while (true) {
    
    					msg2 = re.readLine();
    					pw.println(msg2);
    				}
    			} catch (Exception e) {
    				e.printStackTrace();
    			}
    
    		}
    	}
    
    }

### Server.java ###

import java.net.*;
    import java.io.*;
    import java.util.*;
    
    public class Server {
    	int port;
    	List<Socket> clients;
    	ServerSocket server;
    	public Server() {
    		try {
    			port = 8083;
    			clients = new ArrayList<Socket>();
    			server = new ServerSocket(port);
    			System.out.println("服务器已启动");
    			int co=1;
    			while (true) {
    				Socket socket = server.accept();
    				clients.add(socket);
    				Mythread mythread = new Mythread(socket,co);
    				co++;
    				mythread.start();
    			}
    
    		} catch (Exception ex) {
    			System.out.println("vv");
    		}
    	}
    
    	public static void main(String[] args) {
    		new Server();
    	}
    
    	class Mythread extends Thread {
    		Socket ssocket;
    		private int count;
    		private BufferedReader br;
    		private PrintWriter pw;
    		public String msg;
    
    		public Mythread(Socket s,int c) {
    			ssocket = s;
    			count=c;
    		}
    
    		public void run() {
    
    			try {
    				br = new BufferedReader(new InputStreamReader(ssocket.getInputStream()));
    				
    				msg = "欢迎【" +"Client "+count + "】进入聊天室！当前聊天室有【" + clients.size() + "】人";
    
    				sendMsg();
    
    				while ((msg = br.readLine()) != null) {
    					
    					msg = "【"  +"Client "+count + "】说：" + msg;
    					sendMsg();
    
    				}
    			} catch (Exception ex) {
    			}
    		}
    		public void sendMsg() {
    			try {
    				System.out.println(msg);
    
    				for (int i = clients.size() - 1; i >= 0; i--) {
    					pw = new PrintWriter(clients.get(i).getOutputStream(), true);
    					pw.println(msg);
    					pw.flush();
    				}
    			} catch (Exception ex) {
    			}
    		}
    	}
    
    }

运行结果：

服务器端：

![Center][]

Client1：

![Center 1][]

Client2：

![Center 2][]

Client3：

![Center 3][]

[Center]: /images/20220713/36058db4648440d3b21ce6d2e85d799b.png
[Center 1]: /images/20220713/1462704ef1d44baa835074c6a5040e8f.png
[Center 2]: /images/20220713/f54796f2877241dfa700bbc37b4bf52f.png
[Center 3]: /images/20220713/64833cde12154adfa7914f57b078601b.png