关于Socket的解析以及双方即时通讯的java实现方法

ServerSocket serverSocket=new ServerSocket(8888);

  BufferReader reader = new BufferedReader(
                  new InputStreamReader(socket.getInputStream()));
  PrintWriter writer = new PrintWriter(
                  new OutputStreamWriter(socket.getOutputStream()));

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
/**
* Created by Mezereon on 2017/3/1.
*/
public class TCPServer {
 private Socket socket;
 private ServerSocket serverSocket;
 private BufferedReader reader;
 private PrintWriter writer;
 private Scanner scanner = new Scanner(System.in);
 //开启服务
 public void run() throws IOException {
     startTheSocket();
 }
 public void startTheSocket() throws IOException {
   serverSocket=new ServerSocket(18080); //打开18080端口等待连接
   acceptTheSocket();//接受连接并且初始化Socket，reader，writer
   openTheNewThreadToGetMessageFromClient();
   while(true) {   
      getYourMessage();//获取键盘数据并作为输入
   }
 }
 //接受连接并且初始化Socket，reader，writer
 private void acceptTheSocket() throws IOException {
   socket=serverSocket.accept();//阻塞方法，用于接受Socket连接
   System.out.println("Some one connect me ，it is "+socket.getLocalSocketAddress());//打印地址
   System.out.println("It's port is "+socket.getPort());//打印端口号
   reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));//获得输入流
   writer = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));//获得输出流
 }
 //扫描键盘并输入数据
 private void getYourMessage() throws IOException {
   String yourMessage = scanner.nextLine();
   checkYourMessage(yourMessage);//检查发送给客户端的信息
   writer.println(yourMessage);//发送信息
   writer.flush();//flush方法用于清空缓冲区，注意的是如果不flush你的信息可能发不出去一直存留在缓冲区
 }
 //用于检查是否退出
 private void checkYourMessage(String yourMessage) throws IOException {
   //关闭各种
   if (yourMessage.equals("exit")) {
     socket.close();
     writer.close();
     reader.close();
     System.exit(0);
   }
 }
 //开启一个新的线程来监听客户端发来的信息
 private void openTheNewThreadToGetMessageFromClient() throws IOException {
   //开启一个新的线程
   new Thread(new Runnable() {
     @Override
     public void run() {
       getTheMessageFromClient();
     }
   }).start();

 }
 //不断循环来获取客户端发来的信息
 private void getTheMessageFromClient() {
   while(true) {
     String messageFromClient = null;
     try {
       messageFromClient = reader.readLine();
     } catch (IOException e) {
       e.printStackTrace();
     }
     printTheMessage(messageFromClient);//打印客户端发来的信息
   }
 }
 //打印客户端发来的信息
 private void printTheMessage(String messageFromClient) {
   if(messageFromClient!=null)
     System.out.println("He say:"+messageFromClient);
 }    
}

import java.io.*;
import java.net.Socket;
import java.util.Scanner;

/**
 * Created by Mezereon on 2017/2/27.
 */
public class TCPClient {

  private Socket socket;
  private BufferedReader reader ;
  private PrintWriter writer;
  private Scanner scanner = new Scanner(System.in);

  //开启Socket来连接
  public void run() throws IOException{
      startTheSocket();
  }

  //开始连接服务端
  private void startTheSocket() throws IOException{
      toConnectTheServer();//创建Socket并初始化
      openTheThreadToReceiveInfoFromServer();//开启一个新的线程来接受服务端发来的信息

      //一个循环，用于读取键盘的输入
      while(true) {
        String yourMessage = scanner.nextLine();
        //不为空则发送信息
        if(yourMessage!=null) {
          writer.println(yourMessage);
          writer.flush();//记得flush清空缓冲区
        }
        //判断是否退出
        if (yourMessage.equals("exit")) {
          disConnect();
          System.exit(0);
        }
      }
  }

  //创建一个Socket来连接本机的18080端口的服务端并初始化reader和writer
  private void toConnectTheServer() throws IOException {
    socket=new Socket("127.0.0.1",18080);
    reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
    writer = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()),true);
  }

  private void openTheThreadToReceiveInfoFromServer() throws IOException {
    new Thread(new Runnable() {
      @Override
      public void run() {
        try {
          printMessage();//打印从服务端收到的信息
        } catch (IOException e) {
          e.printStackTrace();
        }
      }
    }).start();
  }

  //循环不断读取服务端的信息
  private void printMessage() throws IOException {
    while (true) {
      String messageFromServer = null;
      try {
        messageFromServer = reader.readLine();//读取信息
        System.out.println("He say:" + messageFromServer);//打印信息
      } catch (IOException e) {
        e.printStackTrace();
      } catch (NullPointerException e) {

      }
      if(messageFromServer.equals("exit")){
        disConnect();//关闭连接
        System.exit(0);
      }
    }
  }

  //关闭各种
  private void disConnect() throws IOException {
    socket.close();
    reader.close();
    writer.close();
  }

}