java socket 实现聊天室

太过爱你忘了你带给我的痛 2023-07-08 09:20 21阅读 0赞

**服务端Server:**

/** * */
    package pm.chatroom;
    
    import java.io.BufferedReader;
    import java.io.DataInputStream;
    import java.io.DataOutputStream;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    import java.io.OutputStream;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    /** * @ClassName: Server * @Author beyond * @Desc: TODO * @Date: 2018-9-15 下午5:41:20 */
    public class Server { 
    	// 聊天程序 服务端
    	private static Socket socket;
    	
    	public static void main(String[] args) { 
    		try { 
    			System.out.println("服务器监听 9999 端口...");
    			ServerSocket serverSocket = new ServerSocket(9999);
    			// 接收客户端连接
    			socket = serverSocket.accept();
    			System.out.println("连接成功...");
    		} catch (Exception e) { 
    		}
    		new Thread(new ServerThreadRead(socket)).start();
    		new Thread(new ServerThreadWrite(socket)).start();
    	}
    }	
    
    // 读入类
    class ServerThreadRead implements Runnable{ 
    	private Socket socket;
    	private InputStream is;
    	public ServerThreadRead(Socket socket){ 
    		this.socket = socket;
    		try { 
    			is = socket.getInputStream();
    		} catch (Exception e) { 
    		}
    	}
    	public void run() { 
    		try { 
    			DataInputStream dis = new DataInputStream(is);
    			while(true){ 
    				String msg = dis.readUTF();
    				System.out.println(msg);
    				if(msg.equals("end")){ 
    					break;
    				}
    			}
    			dis.close();
    			socket.close();
    		} catch (Exception e) { 
    			System.out.println("用户已下线");
    		}
    	}
    }
    
    // 发送数据类
    class ServerThreadWrite implements Runnable { 
    	private Socket socket;
    	private OutputStream os;
    	public ServerThreadWrite(Socket socket){ 
    		this.socket = socket;
    		try { 
    			os = socket.getOutputStream();
    		} catch (Exception e) { 
    		}
    	}
    	public void run() { 
    		DataOutputStream dos = new DataOutputStream(os);
    		BufferedReader  br = new BufferedReader(new InputStreamReader(System.in));
    		try { 
    			while(true){ 
    				String msg = br.readLine();
    				dos.writeUTF(msg);
    				dos.flush();
    				if (msg.equals("end")) { 
    					break;
    				}
    			}
    			dos.close();
    			br.close();
    			socket.close();
    		} catch (Exception e) { 
    		}
    	}
    }

**客户端Client：**

/** * */
    package pm.chatroom;
    
    import java.io.BufferedReader;
    import java.io.DataInputStream;
    import java.io.DataOutputStream;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    import java.io.OutputStream;
    import java.net.Socket;
    
    /** * @ClassName: Client * @Author beyond * @Desc: TODO * @Date: 2018-9-15 下午6:01:22 */
    public class Client { 
    	// 聊天程序 客户端
    	private static Socket socket;
    	
    	public static void main(String[] args) { 
    		try { 
    			socket  = new Socket("127.0.0.1",9999);
    		} catch (Exception e) { 
    		}
    		new Thread(new ClientThreadRead(socket)).start();
    		new Thread(new ClientThreadWrite(socket)).start();
    		
    	}
    }
    
    // 接收类
    class ClientThreadRead implements Runnable { 
    	private Socket socket;
    	private InputStream is;
    	public ClientThreadRead(Socket socket){ 
    		this.socket = socket;
    		try { 
    			is = socket.getInputStream();
    		} catch (Exception e) { 
    		}
    	}
    	public void run() { 
    		try { 
    			DataInputStream dis = new DataInputStream(is);
    			while(true){ 
    				String msg = dis.readUTF();
    				System.out.println(msg);
    				if(msg.equals("end")){ 
    					break;
    				}
    			}
    			dis.close();
    			socket.close();
    		} catch (Exception e) { 
    			System.out.println("用户已下线");
    		}
    	}
    }
    
    // 发送类
    class ClientThreadWrite implements Runnable { 
    	private Socket socket;
    	private OutputStream os;
    	public ClientThreadWrite(Socket socket){ 
    		this.socket = socket;
    		try { 
    			os = socket.getOutputStream();
    		} catch (Exception e) { 
    		}
    	}
    	public void run() { 
    		DataOutputStream dos = new DataOutputStream(os);
    		BufferedReader  br = new BufferedReader(new InputStreamReader(System.in));
    		try { 
    			while(true){ 
    				String msg = br.readLine();
    				dos.writeUTF(msg);
    				dos.flush();
    				if (msg.equals("end")) { 
    					break;
    				}
    			}
    			dos.close();
    			br.close();
    			socket.close();
    		} catch (Exception e) { 
    		}
    	}
    }

PS：两年前写的了，最近有同学问我，又被我翻了出来，在此记录一下。