BIO通信模型

      BIO通信服務端，通常有一個獨立的Acceptor線程負責監聽客戶端的連接。接收到客戶端連接請求后會為每個客戶端創建一個新的線程進行鏈路處理，處理完成后返回應答給客戶端，也就是經典的請求－應答通信模型。但是隨著客戶端并發量上升，服務端的線程數膨脹，系統性能急劇下降，最終會導致系統不可用。

Server端代碼：

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * Created by hao.g on 18/5/7.
 */
public class BioServer {
    public static void main(String[] args) {
        int port = 9090;
        ServerSocket serverSocket = null;

        try {
            serverSocket = new ServerSocket(port);
            while (true){

                //如果沒有客戶端連接則阻塞
                Socket socket = serverSocket.accept();
                new Thread(new BioHandler(socket)).start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            try {
                if (serverSocket != null){
                    serverSocket.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

import java.net.Socket;

/**
 * Created by hao.g on 18/5/7.
 */
public class BioHandler implements Runnable{
    private Socket socket;

    public BioHandler(Socket socket){
        this.socket = socket;
    }

    @Override
    public void run() {
        System.out.println(socket.toString());
    }
}

如果沒有客戶端接入，代碼會一直阻塞在

Socket socket = serverSocket.accept();

啟動server端，通過命令jstack pid觀察線程堆棧信息，主程序確實阻塞在accept方法上

當有客戶端接入時，服務端新建一個線程處理BioHandler，打印客戶端socket相關信息。

Client端代碼：

import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.Socket;

/**
 * Created by hao.g on 18/5/7.
 */
public class BioClient {
    public static void main(String[] args) {
        String host = "127.0.0.1";
        int port = 9090;

        Socket socket = null;
        try {
            socket = new Socket();
            socket.connect(new InetSocketAddress(host, port));
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            try {
                if (socket != null){
                    socket.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

可見每次有新的連接時，服務端都會創建新的線程。這種模型無法滿足高并發，高性能的場景。