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(); //開(kāi)始執(zhí)行 
 } 
 
 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(); 
   } 
 
  } 
 } 
 
} 

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("服務(wù)器已啟動(dòng)"); 
      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 + "】進(jìn)入聊天室！當(dāng)前聊天室有【" + clients.size() + "】人"; 
 
        sendMsg(); 
 
        while ((msg = br.readLine()) != null) { 
           
          msg = "【" +"Client "+count + "】說(shuō)：" + 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) { 
      } 
    } 
  } 
 
}