JavaSocket多人聊天室实现

 1 try {
 2     while (true) {
 3         // accept()将阻塞线程
 4         Socket socket = serverSocket.accept();
 5 
 6         // 保存连接
 7         sockets.add(socket);
 8 
 9         // 启用新线程处理
10         new Thread(new HandlerConnection(socket, sockets)).start();
11     }
12 } catch (Exception e) {
13     System.out.println("connect client failed:" + e.toString());
14 }

1 PrintWriter printWriter;
2 try {
3     for (Socket socket : sockets) {
4         printWriter = new PrintWriter(socket.getOutputStream(), true);
5         printWriter.println(message);
6     }
7 } catch (Exception e) {
8     System.out.println("[sendToClients]" + e.toString());
9 }

 1 public void run() {
 2     BufferedReader reader;
 3     try {
 4         reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
 5         while (true) {
 6             Thread.sleep(10);
 7             System.out.println(reader.readLine());
 8         }
 9     } catch (Exception e) {
10         System.out.println("[Receive message failed]" + e.toString());
11     }
12 }

 1 public void run() {
 2     Scanner scanner = null;
 3     PrintWriter printWriter = null;
 4     try {
 5         scanner = new Scanner(System.in);
 6         printWriter = new PrintWriter(socket.getOutputStream(), true/*auto flush*/);
 7 
 8         Boolean eof = false;
 9         while (!eof && scanner.hasNext()) {
10             String message = scanner.nextLine();
11             printWriter.println("Client-1: " + message);
12             if (QUIT.equals(message.trim())) {
13                 eof = true;
14             }
15         }
16     } catch (IOException e) {
17         System.out.println("[Send message failed]" + e.toString());
18     } finally {
19         // close resource
20         if (null != scanner) {
21             scanner.close();
22         }
23         if (null != printWriter) {
24             printWriter.close();
25         }
26         try {
27             socket.close();
28         } catch (IOException e) {
29             System.out.println("[Close client socket failed]" + e.toString());
30         }
31     }
32 }