1、I/O模型之BIO

I/O模型之BIO

基本介紹

• Java BIO 就是傳統的 Java IO 編程，其相關的類和接口再 java.io 包下
• BIO（blocking I/O）：同步阻塞，服務器實現模式爲一個鏈接一個線程，即客戶端有鏈接請求時服務器端就須要啓動一個線程進行處理，可是若是新啓動的這一個線程不作任何事情就會形成沒必要要的開銷，能夠經過線程池機制改善
• BIO 模型適用於鏈接數目比較小且固定的架構，這種方式對服務器資源要求比較高，併發性能差，JDK1.4之前使用

BIO編程的流程

1. 服務器端啓動一個SeverSocket
2. 客戶端啓動Socket對服務器端進行通訊，默認狀況下服務器端須要對每一個客戶創建一個線程與之通信
3. 客戶端發出請求後，先諮詢服務器是否有線程響應，若是沒有則會等待或者被拒絕
4. 若是服務器有響應，客戶端當前線程會等待請求結束後才繼續執行

應用實例

實例說明

1. 使用BIO模型編寫一個服務器端，監聽6666端口，當有客戶鏈接時，就啓動一個線程與之通信
2. 要求使用線程池機制改善，能夠鏈接多個客戶端
3. 服務器端能夠接收客戶端發送的數據（使用telnet）

實例代碼：

public class BIOServer {
    public static void main(String[] args) throws Exception {
        //一、建立一個線程池
        ExecutorService threadPool = Executors.newCachedThreadPool();

        ServerSocket serverSocket = new ServerSocket(6666);

        System.out.println("服務器啓動了！！！");
        while (true){
            //監聽，等待客戶端鏈接
            final Socket socket = serverSocket.accept();
            System.out.println("鏈接到一個客戶端");
            //二、若是有客戶端鏈接了，就建立一個線程，與之通信（單獨寫一個方法）
            threadPool.execute(new Runnable() {
                public void run() {
                    //與客戶端進行通信
                    handler(socket);
                }
            });
        }

    }

    //編寫一個與客戶端通信的handler方法
    public static void handler(Socket socket){
        //用於接收數據
        byte[] bytes = new byte[1024];
        //經過socket獲取輸入流
        InputStream inputStream = null;
        try {
            System.out.println("線程id="+Thread.currentThread().getId()+"名字="+Thread.currentThread().getName());
            inputStream = socket.getInputStream();

            //循環讀取客戶端發送的數據
            while(true){
                int read = inputStream.read(bytes);
                if (read!=-1){
                    //輸出客戶端發送的數據
                    System.out.println(「收到信息：」+new String(bytes,0,read));
                }else{
                    break;
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            System.out.println("關閉與客戶端的鏈接......");
            try {
                inputStream.close();
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

測試結果：

服務器啓動了！！！
鏈接到一個客戶端
線程id=12名字=pool-1-thread-1
收到消息：nihao