在線聊天室

鎖定

網絡聊天室

public class RenClient {
    public static void main(String[] args) throws IOException {
        Socket renClient = new Socket("localhost",13669);
        //renClient.setSoTimeout(10000);
        System.out.println("=============>客户端已經啓動，請求連接服務器<-------");
        //獲取鍵盤輸入 
         BufferedReader keyInput = new BufferedReader(new InputStreamReader(System.in));
         //獲取Socket的輸出流，用來發送數據到服務端  
         PrintStream outToServer = new PrintStream(renClient.getOutputStream());
         //獲取Socket的輸入流，用來接收從服務端發送過來的數據  
         BufferedReader inFromServer =  new BufferedReader(new InputStreamReader(renClient.getInputStream()));
         boolean flag = true;
         System.out.println("客户端通過鍵盤輸入信息---->");
         while(flag){
             String request = keyInput.readLine();
             //發送數據到服務端  
              outToServer.println(request);
              //從服務器端接收數據有個時間限制（系統自設，也可以自己設置），超過了這個時間，便會拋出該異常
             String response = inFromServer.readLine();
             if("bye".equals(response)){
                 break;
              }else{
                 System.out.println(response);
              }
          }
          keyInput.close();
          renClient.close(); //只關閉socket，其關聯的輸入輸出流也會被關閉
    }
}

public class RenServer {
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(13669);
        Socket renServer = null;
        //創建ServerSocket實例對象，它的參數是監聽器的端口號
        System.out.println("===============>服務器端已經啓動，正在等待客户端的連接<----------...");
        boolean flag = true;
        while(flag){
            //等待客户端的連接，如果沒有獲取連接
            renServer=serverSocket.accept();
            System.out.println("服務器通過套接字連接客户端的IP地址："+renServer.getInetAddress());
            System.out.println("*******服務器與客户端連接成功！******");
             //為每個客户端連接開啓一個線程
             new Thread(new RenServerThread(renServer)).start();
             break;
         }
          serverSocket.close();
        }
    }