import java.io.BufferedReader; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.io.InputStreamReader; import java.net.ServerSocket; import java.net.Socket;  public class Server {    public static final int PORT = 8000;//監(jiān)聽的端口號      public static void main(String[] args) {      Server server = new Server();      server.init();    }     public void init() {      ServerSocket serverSocket = null;     try {        serverSocket = new ServerSocket(PORT);        while (true) {          Socket client = serverSocket.accept();          //一個客戶端連接就開戶兩個線程處理讀寫          new Thread(new ReadHandlerThread(client)).start();          new Thread(new WriteHandlerThread(client)).start();        }      } catch (Exception e) {        e.printStackTrace();      } finally{       try {         if(serverSocket != null){           serverSocket.close();         }       } catch (IOException e) {         e.printStackTrace();       }     }   }  }   /*  *處理讀操作的線程   */ class ReadHandlerThread implements Runnable{   private Socket client;    public ReadHandlerThread(Socket client) {     this.client = client;   }    @Override   public void run() {     DataInputStream dis = null;     try{       while(true){         //讀取客戶端數(shù)據(jù)          dis = new DataInputStream(client.getInputStream());         String reciver = dis.readUTF();         System.out.println("客戶端發(fā)過來的內(nèi)容:" + reciver);        }     }catch(Exception e){       e.printStackTrace();     }finally{       try {         if(dis != null){           dis.close();         }         if(client != null){           client = null;         }       } catch (IOException e) {         e.printStackTrace();       }     }   } }  /*  * 處理寫操作的線程  */ class WriteHandlerThread implements Runnable{   private Socket client;    public WriteHandlerThread(Socket client) {     this.client = client;   }    @Override   public void run() {     DataOutputStream dos = null;     BufferedReader br = null;     try{       while(true){         //向客戶端回復(fù)信息          dos = new DataOutputStream(client.getOutputStream());          System.out.print("請輸入:/t");          // 鍵盤錄入          br = new BufferedReader(new InputStreamReader(System.in));         String send = br.readLine();          //發(fā)送數(shù)據(jù)         dos.writeUTF(send);        }     }catch(Exception e){       e.printStackTrace();     }finally{       try {         if(dos != null){           dos.close();         }         if(br != null){           br.close();         }         if(client != null){           client = null;         }       } catch (IOException e) {         e.printStackTrace();       }     }   } } 

import java.io.BufferedReader; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.io.InputStreamReader; import java.net.Socket;  public class Client {    public static final String IP = "localhost";//服務(wù)器地址    public static final int PORT = 8000;//服務(wù)器端口號     public static void main(String[] args) {      handler();    }    private static void handler(){     try {       //實例化一個Socket，并指定服務(wù)器地址和端口       Socket client = new Socket(IP, PORT);       //開啟兩個線程，一個負責讀，一個負責寫       new Thread(new ReadHandlerThread(client)).start();       new Thread(new WriteHandlerThread(client)).start();     } catch (Exception e) {       e.printStackTrace();     }   } }   /*  *處理讀操作的線程   */ class ReadHandlerThread implements Runnable{   private Socket client;    public ReadHandlerThread(Socket client) {     this.client = client;   }    @Override   public void run() {     DataInputStream dis = null;     try {       while(true){         //讀取服務(wù)器端數(shù)據(jù)          dis = new DataInputStream(client.getInputStream());         String receive = dis.readUTF();           System.out.println("服務(wù)器端返回過來的是: " + receive);        }     } catch (IOException e) {       e.printStackTrace();     } finally{       try {         if(dis != null){           dis.close();         }         if(client != null){           client = null;         }       } catch (IOException e) {         e.printStackTrace();       }     }   } }  /*  * 處理寫操作的線程  */ class WriteHandlerThread implements Runnable{   private Socket client;    public WriteHandlerThread(Socket client) {     this.client = client;   }    @Override   public void run() {     DataOutputStream dos = null;     BufferedReader br = null;     try {       while(true){         //取得輸出流         dos = new DataOutputStream(client.getOutputStream());         System.out.print("請輸入: /t");          //鍵盤錄入         br = new BufferedReader(new InputStreamReader(System.in));         String send = br.readLine();          //發(fā)送數(shù)據(jù)         dos.writeUTF(send);        }     } catch (IOException e) {       e.printStackTrace();     } finally{       try{         if(dos != null){           dos.close();         }         if(br != null){           br.close();         }         if(client != null){           client = null;         }       }catch(Exception e){         e.printStackTrace();       }     }   } }