Java socket通讯实现过程及问题解决

package com.test.some.Socket;

import java.io.*;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.UnknownHostException;

/**
* @Description: socket服务端代码
* @Author:   haoqiangwang3
* @CreateDate: 2020/1/9
*/
public class MySocketServer1 {
  // 服务器监听端口
  private static int port = 8081;

  public static void main(String[] args) throws InterruptedException {
    try {
      //1.得到一个socket服务端
      ServerSocket serverSocket = new ServerSocket(port);
      while (true) {

        // 2.等待socket客户端的请求。accept方法在有连接请求时才会返回
        System.out.println("等待客户端请求。。。");
        Socket socket = serverSocket.accept();
        System.out.println("客户端请求来了。。。");

        // 3.获取socket输入流
        InputStream inputStream = socket.getInputStream();
        /* BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream));
        System.out.println("接收到的请求数据为：" + bufferedReader.readLine());*/
        // 读取请求内容的缓冲区
        byte[] bytes = new byte[1024];
        int length = 0;
        StringBuilder sb = new StringBuilder();
        //获取客户端请求的内容
        while ((length = inputStream.read(bytes)) != -1) {
          sb.append(new String(bytes, 0, length, "utf-8"));
        }
        System.out.println("接收到的请求数据为：" + sb.toString());　　　　　　　　　　
　　　　　　　　　　//Thread.sleep(50000);　　　　　　　　　　// 4.获取socket输出流
        OutputStream outputStream = socket.getOutputStream();
        PrintWriter printWriter = new PrintWriter(outputStream);
        String backStr = "服务端接收到了请求";
        printWriter.write(new String(backStr.getBytes(), "utf-8"));
        printWriter.flush();

        //5.关闭资源
        //bufferedReader.close();
        inputStream.close();
        printWriter.close();
        outputStream.close();
        socket.close();
      }

    } catch (IOException e) {
      System.err.println("socket监听失败！" + e);
    }
  }

}

package com.test.some.Socket;

import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;

/**
* @Description: socket客户端代码
* @Author:   haoqiangwang3
* @CreateDate: 2020/1/9
*/
public class MySocketClient1 {
  //socket请求ip地址
  private static String host = "127.0.0.1";

  //socket请求端口
  private static int port = 8081;

  public static void main(String[] args) {
    try {
      //1.建立一个客户端
      Socket socket = new Socket(host, port);

      //2.得到socket输出流
      OutputStream outputStream = socket.getOutputStream();
      PrintWriter printWriter = new PrintWriter(outputStream);
      String sendStr = "发送数据1";
      //发送数据
      printWriter.write(sendStr);
      printWriter.flush();
      socket.shutdownOutput();

      //3.得到socket输入流
      InputStream inputStream = socket.getInputStream();
      StringBuilder sb = new StringBuilder();
      byte[] bytes = new byte[1024];
      while (inputStream.read(bytes) != -1) {
        sb.append(new String(bytes, "utf-8"));
      }
      System.out.println("接收到的返回数据为：" + sb);

      //4.关闭资源
      printWriter.close();
      outputStream.close();
      inputStream.close();
      socket.close();
    } catch (Exception e) {
      System.err.println("socket请求失败" + e);
    }
  }

}