本文闡述了socket編程、IO網路模型，以及各種IO模型的適用場景，

RPC架構設計

文章更新歷史

2022/03/01 初稿，

2022/05/04 修改相關描述，

socket

socket網路編程

socket概述

socket套接字是兩臺主機之間邏輯連接的端點，

TCP/IP協議是傳輸層協議，主要解決資料在網路中的傳輸

socket是網路通信之間的抽象介面，它包含網路通信的五種基礎資訊：連接使用的協議、本地主機的ip地址、本地行程協議埠、遠程主機ip地址、遠程行程的協議埠，

socket整體流程

socket編程主要包括客戶端和服務端兩個方面，

首先在服務端創建一個服務端套接字（ServerSocket），并把它附加到一個埠上，服務端從這個埠監聽鏈接，

埠范圍是 0-65536 ，注意 0-1024 是特權服務保留的埠，可選擇任意一個不被其他行程使用的埠，

客戶端請求與服務端連接時，根據服務端的域名或者ip地址，加上埠號，打開一個套接字，當服務器接受連接后，服務器和客戶端之間的操作可以像輸入輸出流一樣操作，

代碼實作

服務端代碼

/**
 * 服務端
 *
 * @name: ServerDemo
 * @author: terwer
 * @date: 2022-04-17 14:20
 **/
public class ServerDemo {
    public static void main(String[] args) throws IOException {
        // 1.創建一個執行緒池，如果有客戶端鏈接就創建一個執行緒與之通信
        ExecutorService executorService = Executors.newCachedThreadPool();
        // 2.創建ServerSocket
        ServerSocket serverSocket = new ServerSocket(9999);
        System.out.println("服務器已啟動");
        while (true) {
            // 3.監聽客戶端
            Socket socket = serverSocket.accept();
            System.out.println("有客戶端鏈接");
            executorService.execute(new Runnable() {
                @Override
                public void run() {
                    handle(socket);
                }
            });
        }
    }

    private static void handle(Socket socket) {
        try {
            System.out.println("執行緒ID:" + Thread.currentThread().getId() + ",執行緒名稱：" + Thread.currentThread().getName());
            // 從連接中取出輸入流
            InputStream inputStream = socket.getInputStream();
            byte[] b = new byte[1024];
            int read = inputStream.read(b);
            System.out.println("客戶端" + new String(b, 0, read));

            // 鏈接中取出輸出流并回話
            OutputStream outputStream = socket.getOutputStream();
            outputStream.write("沒有".getBytes());
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

客戶端代碼

/**
 * 客戶端
 *
 * @name: ClientDemo
 * @author: terwer
 * @date: 2022-04-17 15:30
 **/
public class ClientDemo {
    public static void main(String[] args) throws IOException {
        while (true) {
            // 1.創建客戶端socket
            Socket s = new Socket("127.0.0.1", 9999);
            // 2.從連接中獲取輸出流并發送訊息
            OutputStream os = s.getOutputStream();
            System.out.println("請輸入:");
            Scanner sc = new Scanner(System.in);
            String msg = sc.nextLine();
            os.write(msg.getBytes());

            // 3.從連接中取出輸入流并接受會話
            InputStream is = s.getInputStream();
            byte[] b = new byte[1024];
            // 下面寫法錯了
            // int read = is.read();
            // 應該是
            int read = is.read(b);
            System.out.println("老板說:" + new String(b, 0, read).trim());

            s.close();
        }
    }
}

IO模型

IO模型說明

簡單理解：用什么樣的通道進行資料的發送和接收，在很大程度上決定了程式通信的性能，
Java支持三種網路編程模型I/O模式：BIO（同步阻塞）、NIO（同步非阻塞）、AIO（異步非阻塞）

阻塞與非阻塞

指的是網路IO的執行緒是否處于阻塞或者等待狀態

執行緒訪問資源，該資源是否準備就緒的一種處理方式

同步和異步

指的是資料的請求方式，同步和異步是請求資料的一種方式，