import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.net.ServerSocket;

import java.net.Socket;

public class Server {

    public static void main(String[] args) throws  Exception {

       ServerSocket server=new ServerSocket(8888);

       Socket socket=server.accept();

      BufferedReader in=new BufferedReader(new  InputStreamReader(socket.getInputStream()));

      BufferedWriter out=new BufferedWriter(new  OutputStreamWriter(socket.getOutputStream()));

      BufferedReader br = new BufferedReader(new  InputStreamReader(System.in));

       while(true){

          String str=in.readLine();

          System.out.println("客戶端說(shuō)："+str);

          String str2 = "";

          str2 = br.readLine();    //讀到為止，因此一定要輸入換行符！

          out.write(str2+"\n");

          out.flush();

           if(str.equals("end"))

              break;

          }

      in.close();

      out.close();

      socket.close();

   }

}

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.net.InetAddress;

import java.net.Socket;

import java.net.UnknownHostException;

public class Client {

    static Socket server;

    public static void main(String[] args) {

       try {

           server = new Socket(InetAddress.getLocalHost(),  8888);

          BufferedReader in = new BufferedReader(new  InputStreamReader(

                  server.getInputStream()));

          BufferedWriter out = new BufferedWriter(new  OutputStreamWriter(

                  server.getOutputStream()));

          BufferedReader wt = new BufferedReader(new  InputStreamReader(

                 System.in));

           while (true) {

             String str = wt.readLine();

             out.write(str + "\n");

             out.flush();

              if (str.equals("end")) {

                  break;

             }

             System.out.println("服務(wù)器發(fā)說(shuō)：" +  in.readLine());

          }

          out.close();

          in.close();

          wt.close();

           server.close();

      } catch (UnknownHostException e) {

          // TODO Auto-generated catch block

          e.printStackTrace();

      } catch (IOException e) {

          // TODO Auto-generated catch block

          e.printStackTrace();

      }

   }

}