JAVA聊天室的实现——服务器端

川长思鸟来 2022-05-21 05:45 171阅读 0赞

直接代码：

package server; 
    import java.io.BufferedReader;  
    import java.io.IOException;  
    import java.io.InputStreamReader;  
    import java.io.PrintWriter;  
    import java.net.ServerSocket;  
    import java.net.Socket;  
    import java.net.SocketException;  
    import java.util.ArrayList;  
    import java.util.List;  
      
    public class Serv {  
        private List<ServerThread> clients = null;    //创建一个ServerThread数组存储客户端地址
          
        public static void main(String[] args) {  
            new Serv().startUp();  
            
        }  
          
        private void startUp() {  
            ServerSocket ss = null;  
            Socket s = null;  
            try {  
                ss = new ServerSocket(5858);  
                clients = new ArrayList<ServerThread>();  
                while (true) {  
                    s = ss.accept();    //接受客户端请求
                    ServerThread st = new ServerThread(s);   
                    new Thread(st).start();   
                }  
            } catch (IOException e) {  
                e.printStackTrace();  
            } finally {  
                try {  
                    if (ss != null)   
                        ss.close();  
                } catch (IOException e) {  
                    e.printStackTrace();  
                }  
            }  
        }  
          
        private class ServerThread implements Runnable {  
            private Socket s = null;  
            private BufferedReader br;  
            private PrintWriter out;  
            private String name;  
            private boolean flag = true;  
              
            public ServerThread(Socket socket) throws IOException {  
                this.s = socket;  
                br = new BufferedReader(new InputStreamReader(socket.getInputStream()));  
                out = new PrintWriter(socket.getOutputStream(), true);  
                String str = br.readLine();  
                name = str+"["+socket.getInetAddress().getHostAddress()+":"+socket.getPort()+"]";  
                clients.add(this);  
                send(name+"上线了");  
            }  
              
            private void send(String msg) {  
                for (ServerThread st : clients)  
                    st.out.println(msg);  
            }  
              
            private void receive() throws IOException {  
                String str = null;  
                while ((str=br.readLine()) != null) {  
                    if (str.equalsIgnoreCase("quit")) {  
                        stop();  
                        out.println("disconnect");  
                        //System.out.println(msg);   msg中包含要传给客户端的消息，这里可以确定，out.printl是传递消息不是输出
                        break;  
                    }  
                    send(name+":"+str);  
                }  
            }  
              
            private void stop() {  
                clients.remove(this);  
                flag = false;  
                send(name+"已经下线了");  
            }  
      
            @Override  
            public void run() {  
                try {  
                    while (true) {  
                        if (!flag) break;  
                        receive();  
                    }  
                } catch (SocketException e) {  
                    stop();  
                } catch (IOException e) {  
                    e.printStackTrace();  
                } finally {  
                    try {  
                        if (s != null)   
                            s.close();  
                    } catch (IOException e) {  
                        e.printStackTrace();  
                    }  
                }  
            }  
              
        }  
    }