package com;

 import java.io.*;

 import java.net.ServerSocket;

 import java.net.Socket;

 /**

  * Socket Server

  * <p>

  * Created by Administrator on 2018/5/2.

  */

 public class Server {

     public static void main(String[] args) {

         try {

             // 1.初始化服务端socket连接，并监听8888端口的socket请求

             ServerSocket serverSocket = new ServerSocket(8888);

             System.out.println("****** I am Server, now begin to wait the client ******");

             Socket socket = serverSocket.accept();

             // 2.server接收消息

             InputStream inputStream = socket.getInputStream();

             InputStreamReader inputStreamReader = new InputStreamReader(inputStream);

             BufferedReader bufferedReader = new BufferedReader(inputStreamReader);

             String str;

             if ((str = bufferedReader.readLine()) != null) {

                 System.out.println("I am Server, now get message from Client: " + str);

             }

             socket.shutdownInput();

             // 3.server发送消息

             OutputStream outputStream = socket.getOutputStream();

             PrintWriter printWriter = new PrintWriter(outputStream);

             printWriter.write("[welcome to you!]");

             printWriter.flush();

             // 4.关闭资源

             printWriter.close();

             outputStream.close();

             bufferedReader.close();

             inputStreamReader.close();

             inputStream.close();

             socket.close();

             serverSocket.close();

         } catch (IOException e) {

             e.printStackTrace();

         }

     }

 }

 package com;

 import java.io.*;

 import java.net.Socket;

 /**

  * Socket Client

  * <p>

  * Created by Administrator on 2018/5/2.

  */

 public class Client {

     public static void main(String[] args) {

         try {

             // 1.初始化客户端socket连接

             Socket socket = new Socket("localhost", 8888);

             // 2.client发送消息

             OutputStream outputStream = socket.getOutputStream();

             PrintWriter printWriter = new PrintWriter(outputStream);

             printWriter.write("[name:tom, pwd:123]");

             printWriter.flush();

             socket.shutdownOutput();

             // 3.client接收消息

             InputStream inputStream = socket.getInputStream();

             InputStreamReader inputStreamReader = new InputStreamReader(inputStream);

             BufferedReader bufferedReader = new BufferedReader(inputStreamReader);

             String str;

             while ((str = bufferedReader.readLine()) != null) {

                 System.out.println("I am Client, now get message from Server:" + str);

             }

             // 4.关闭资源

             bufferedReader.close();

             inputStreamReader.close();

             inputStream.close();

             printWriter.close();

             outputStream.close();

             socket.close();

         } catch (IOException e) {

             e.printStackTrace();

         }

     }

 }