12.5-全栈Java笔记:Java网络编程（三）

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("客户端说："+str);

           String str2 = "";

           str2 = br.readLine();     //读到\n为止，因此一定要输入换行符！

           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("服务器发说：" +   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();

       }

    }

}