Java socket通訊實(shí)現(xiàn)過(guò)程及問(wèn)題解決

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服務(wù)端代碼
* @Author:   haoqiangwang3
* @CreateDate: 2020/1/9
*/
public class MySocketServer1 {
  // 服務(wù)器監(jiān)聽(tīng)端口
  private static int port = 8081;

  public static void main(String[] args) throws InterruptedException {
    try {
      //1.得到一個(gè)socket服務(wù)端
      ServerSocket serverSocket = new ServerSocket(port);
      while (true) {

        // 2.等待socket客戶端的請(qǐng)求。accept方法在有連接請(qǐng)求時(shí)才會(huì)返回
        System.out.println("等待客戶端請(qǐng)求。。。");
        Socket socket = serverSocket.accept();
        System.out.println("客戶端請(qǐng)求來(lái)了。。。");

        // 3.獲取socket輸入流
        InputStream inputStream = socket.getInputStream();
        /* BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream));
        System.out.println("接收到的請(qǐng)求數(shù)據(jù)為：" + bufferedReader.readLine());*/
        // 讀取請(qǐng)求內(nèi)容的緩沖區(qū)
        byte[] bytes = new byte[1024];
        int length = 0;
        StringBuilder sb = new StringBuilder();
        //獲取客戶端請(qǐng)求的內(nèi)容
        while ((length = inputStream.read(bytes)) != -1) {
          sb.append(new String(bytes, 0, length, "utf-8"));
        }
        System.out.println("接收到的請(qǐng)求數(shù)據(jù)為：" + sb.toString());　　　　　　　　　　
　　　　　　　　　　//Thread.sleep(50000);　　　　　　　　　　// 4.獲取socket輸出流
        OutputStream outputStream = socket.getOutputStream();
        PrintWriter printWriter = new PrintWriter(outputStream);
        String backStr = "服務(wù)端接收到了請(qǐng)求";
        printWriter.write(new String(backStr.getBytes(), "utf-8"));
        printWriter.flush();

        //5.關(guān)閉資源
        //bufferedReader.close();
        inputStream.close();
        printWriter.close();
        outputStream.close();
        socket.close();
      }

    } catch (IOException e) {
      System.err.println("socket監(jiān)聽(tīng)失??！" + 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請(qǐng)求ip地址
  private static String host = "127.0.0.1";

  //socket請(qǐng)求端口
  private static int port = 8081;

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

      //2.得到socket輸出流
      OutputStream outputStream = socket.getOutputStream();
      PrintWriter printWriter = new PrintWriter(outputStream);
      String sendStr = "發(fā)送數(shù)據(jù)1";
      //發(fā)送數(shù)據(jù)
      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("接收到的返回?cái)?shù)據(jù)為：" + sb);

      //4.關(guān)閉資源
      printWriter.close();
      outputStream.close();
      inputStream.close();
      socket.close();
    } catch (Exception e) {
      System.err.println("socket請(qǐng)求失敗" + e);
    }
  }

}