Java简易聊天室

Java简易聊天室

支持多人向服务器端发送消息并由服务器发送至各个客户端

服务器端代码：

[java]

1. /* 
2. *   @topic:服务器端 
3. */  
4. import java.io.*;  
5. import java.net.*;  
6. import java.util.List;  
7. import java.util.ArrayList;  
8. import java.util.concurrent.ExecutorService;  
9. import java.util.concurrent.Executors;  
10. public class Server{  
11.     //服务器端口   
12.     private static final int SERVERPORT = 8889 ;  
13.     //客户端连接   
14.     private static List<Socket> mClientList = new ArrayList<Socket>();  
15.     //线程池   
16.     private ExecutorService mExecutorService;  
17.     //ServerSocket对象   
18.     private ServerSocket mServerSocket;  
19.     public static void main(String[] args){  
20.         //System.out.println("Hello Landor!");   
21.         new Server();  
22.     }  
23.   
24.     public Server(){  
25.         try{  
26.             //设置服务器端口   
27.             mServerSocket = new ServerSocket(SERVERPORT);  
28.             //创建一个线程池   
29.             mExecutorService = Executors.newCachedThreadPool();  
30.             System.out.println("wait client :");  
31.             //用来临时保存客户端连接的Socket对象   
32.             Socket client = null;  
33.             while(true){  
34.                 //接收客户连接并添加到List中   
35.                 client = mServerSocket.accept();  
36.                 mClientList.add(client);  
37.                 //开启一个客户端线程   
38.                 mExecutorService.execute(new ThreadServer(client));  
39.             }  
40.         }catch(IOException e){  
41.             e.printStackTrace();  
42.         }  
43.     }  
44.     //每个客户端单独开启一个线程   
45.     static class ThreadServer implements Runnable{  
46.         private Socket mSocket;  
47.         private BufferedReader mBufferedReader;  
48.         private PrintWriter mPrintWriter;  
49.         private String mStrMSG;  
50.   
51.         public ThreadServer(Socket socket) throws IOException{  
52.             this.mSocket = socket;  
53.             mBufferedReader = new BufferedReader(new InputStreamReader(  
54.                 socket.getInputStream()));  
55.             mStrMSG = "user: "+this.mSocket.getInetAddress()+" come total:"  
56.                     + mClientList.size();  
57.             sendMessage();  
58.         }  
59.   
60.         public void run(){  
61.             try{  
62.                 while((mStrMSG = mBufferedReader.readLine())!=null){  
63.                     if(mStrMSG.trim().equals("exit")){  
64.                         //当一个客户端退出时   
65.                         mClientList.remove(mSocket);  
66.                         mBufferedReader.close();  
67.                         mPrintWriter.close();  
68.                         mStrMSG = "user:" + this.mSocket.getInetAddress()  
69.                                 + " exit total:" + mClientList.size();  
70.                         mSocket.close();  
71.                         sendMessage();  
72.                         break;  
73.                     }else{  
74.                         mStrMSG = mSocket.getInetAddress() + ":" + mStrMSG;  
75.                         sendMessage();  
76.                     }  
77.                 }  
78.             }catch(IOException e){  
79.                 e.printStackTrace();  
80.             }  
81.         }  
82.   
83.         //发送消息给所有客户端   
84.         private void sendMessage() throws IOException {  
85.             System.out.println(mStrMSG);  
86.             for(Socket client : mClientList){  
87.                 mPrintWriter = new PrintWriter(client.getOutputStream(),true);  
88.                 mPrintWriter.println(mStrMSG);  
89.             }  
90.         }  
91.     }  
92. }  

客户端：

[java]

1. import java.io.BufferedReader;  
2. import java.io.InputStreamReader;  
3. import java.io.PrintWriter;  
4. import java.net.Socket;  
5. import java.util.concurrent.ExecutorService;  
6. import java.util.concurrent.Executors;  
7. /* 
8. *   @topic:客户端 
9. */  
10. public class Client{  
11.     private static final int PORT = 8889;  
12.     private static ExecutorService exec = Executors.newCachedThreadPool();  
13.   
14.     public static void main(String[] args) throws Exception{  
15.         //System.out.println("Hello Landor!");   
16.         new Client();  
17.     }  
18.   
19.     public Client(){  
20.         try{  
21.             Socket socket = new Socket("localhost",PORT);  
22.             exec.execute(new Sender(socket));  
23.             BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));  
24.             String msg;  
25.             while((msg = br.readLine())!=null){  
26.                 System.out.println(msg);  
27.             }  
28.         }catch(Exception e){  
29.             e.printStackTrace();  
30.         }  
31.     }  
32.   
33.     //客户端线程获取控制台输入消息   
34.     static class Sender implements Runnable{  
35.         private Socket socket;  
36.           
37.         public Sender(Socket socket){  
38.             this.socket = socket;  
39.         }  
40.   
41.         public void run(){  
42.             try{  
43.                 BufferedReader br = new BufferedReader(new InputStreamReader(System.in));  
44.                 PrintWriter pw = new PrintWriter(socket.getOutputStream(), true);  
45.                 while(true){  
46.                     String msg = br.readLine();  
47.                     pw.println(msg);  
48.                     if (msg.trim().equals("exit")) {  
49.                         pw.close();  
50.                         br.close();  
51.                         exec.shutdownNow();  
52.                         break;  
53.                     }  
54.                 }  
55.             }catch(Exception e){  
56.                 e.printStackTrace();  
57.             }  
58.         }  
59.     }  
60. }