• <noscript id="e0iig"><kbd id="e0iig"></kbd></noscript>
  • <td id="e0iig"></td>
  • <option id="e0iig"></option>
  • <noscript id="e0iig"><source id="e0iig"></source></noscript>
  • 高性能Netty學習_01.Java BIO詳解

    標簽: Netty  netty  網絡

    java BIO編程詳解

    一、I/O基本模型

    1. Java BIO
      同步并阻塞(傳統阻塞型), 服務器實現模式為一個連接一個線程, 即客戶端有連接請求時服務器端就需要啟動一個線程進行處理, 如果這個連接不做任何事情會造成不必要的線程開銷 .

    在這里插入圖片描述

    1. Java NIO :

    同步非阻塞, 服務器實現模式為一個線程處理多個請求(連接), 即客戶端發送的連接請求都會注冊到多路復用器上, 多路復用器輪詢到連接有 I/O 請求就進行處理

    [外鏈圖片轉存失敗,源站可能有防盜鏈機制,建議將圖片保存下來直接上傳(img-JlzdOh4A-1600587006597)(C:\Users\蘇瀘斌\AppData\Roaming\Typora\typora-user-images\1600586357279.png)]

    1. Java AIO(NIO.2) :

      異步非阻塞, AIO 引入異步通道的概念, 采用了 Proactor 模式, 簡化了程序編寫, 有效的請求才啟動線程, 它的特點是先由操作系統完成后才通知服務端程序啟動線程去處理, 一般適用于連接數較多且連接時間較長的應用 。

    二、 BIO、 NIO、 AIO 適用場景

    1. BIO 方式適用于連接數目比較小且固定的架構, 這種方式對服務器資源要求比較高, 并發局限于應用中, JDK1.4以前的唯一選擇, 但程序簡單易理解。

    2. NIO 方式適用于連接數目多且連接比較短(輕操作) 的架構, 比如聊天服務器, 彈幕系統, 服務器間通訊等。編程比較復雜, JDK1.4 開始支持。

    3. AIO 方式使用于連接數目多且連接比較長(重操作) 的架構, 比如相冊服務器, 充分調用 OS 參與并發操作,編程比較復雜, JDK7 開始支持。  
      

    三、 Java BIO

    1. Java BIO 就是傳統的 java io 編程, 其相關的類和接口在 java.io
    2. BIO(blocking I/O) : 同步阻塞, 服務器實現模式為一個連接一個線程, 即客戶端有連接請求時服務器端就需要啟動一個線程進行處理, 如果這個連接不做任何事情會造成不必要的線程開銷, 可以通過線程池機制改善(實現多個客戶連接服務器)。
    3. BIO 方式適用于連接數目比較小且固定的架構, 這種方式對服務器資源要求比較高, 并發局限于應用中, JDK1.4以前的唯一選擇, 程序簡單易理解

    [外鏈圖片轉存失敗,源站可能有防盜鏈機制,建議將圖片保存下來直接上傳(img-cE2SRPf7-1600587006600)(C:\Users\蘇瀘斌\AppData\Roaming\Typora\typora-user-images\1600586607146.png)]

    BIO的流程

    1. 服務端啟動一個ServerSocket。
    2. 客戶端啟動 Socket 對服務器進行通信, 默認情況下服務器端需要對每個客戶建立一個線程與之通訊
    3. 客戶端發出請求后, 先咨詢服務器是否有線程響應, 如果沒有則會等待, 或者被拒絕
    4. 如果有響應, 客戶端線程會等待請求結束后, 在繼續執行

    四、BIO編程實戰

    public class BioServer {
    
    
        public static void main(String[] args) throws  Exception{
            //1.創建一個Socket服務器
            ServerSocket serverSocket = new ServerSocket(6666);
            ExecutorService threadPool = Executors.newCachedThreadPool();//創建線程池執行客戶端連接請求
            while(true){
                //接收客戶端socket連接
                Socket socket = serverSocket.accept();
                System.out.println("連接到一個客戶端");
                //對客戶端數據進行處理
                threadPool.execute(new Runnable() {
                    @Override
                    public void run() {
                        handler(socket);
                    }
                });
            }
        }
    
        private static void  handler(Socket socket)  {
            try {
                InputStream inputStream = socket.getInputStream();
    
                byte[] bytes = new byte[1024];
                //讀取數據
                int len = 0;
                while( (len = inputStream.read(bytes) ) != -1) {
                    System.out.println(new String(bytes,0,len));
                }
            }catch (Exception e){
                e.printStackTrace();
            }finally {
                try {
                    if(socket != null ) socket.close();
                }
                catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
    

    五、 Java BIO 問題分析

    1. 每個請求都需要創建獨立的線程,與對應的客戶端進行數據 Read,業務處理,數據 Write 。
    2. 當并發數較大時,需要創建大量線程來處理連接,系統資源占用較大。
    3. 連接建立后,如果當前線程暫時沒有數據可讀, 則線程就阻塞在 Read 操作上, 造成線程資源浪費當并發數較大時, 需要創建大量線程來處理連接,系統資源占用較大。 連接建立后,如果當前線程暫時沒有數據可讀, 則線程就阻塞在 Read 操作上, 造成線程資源浪費

    版權聲明:本文為qq_29787465原創文章,遵循 CC 4.0 BY-SA 版權協議,轉載請附上原文出處鏈接和本聲明。
    本文鏈接:https://blog.csdn.net/qq_29787465/article/details/108693869

    智能推薦

    電腦空間不夠了?教你一個小秒招快速清理 Docker 占用的磁盤空間!

    Docker 很占用空間,每當我們運行容器、拉取鏡像、部署應用、構建自己的鏡像時,我們的磁盤空間會被大量占用。 如果你也被這個問題所困擾,咱們就一起看一下 Docker 是如何使用磁盤空間的,以及如何回收。 docker 占用的空間可以通過下面的命令查看: TYPE 列出了docker 使用磁盤的 4 種類型: Images:所有鏡像占用的空間,包括拉取下來的鏡像,和本地構建的。 Con...

    requests實現全自動PPT模板

    http://www.1ppt.com/moban/ 可以免費的下載PPT模板,當然如果要人工一個個下,還是挺麻煩的,我們可以利用requests輕松下載 訪問這個主頁,我們可以看到下面的樣式 點每一個PPT模板的圖片,我們可以進入到詳細的信息頁面,翻到下面,我們可以看到對應的下載地址 點擊這個下載的按鈕,我們便可以下載對應的PPT壓縮包 那我們就開始做吧 首先,查看網頁的源代碼,我們可以看到每一...

    Linux C系統編程-線程互斥鎖(四)

    互斥鎖 互斥鎖也是屬于線程之間處理同步互斥方式,有上鎖/解鎖兩種狀態。 互斥鎖函數接口 1)初始化互斥鎖 pthread_mutex_init() man 3 pthread_mutex_init (找不到的情況下首先 sudo apt-get install glibc-doc sudo apt-get install manpages-posix-dev) 動態初始化 int pthread_...

    統計學習方法 - 樸素貝葉斯

    引入問題:一機器在良好狀態生產合格產品幾率是 90%,在故障狀態生產合格產品幾率是 30%,機器良好的概率是 75%。若一日第一件產品是合格品,那么此日機器良好的概率是多少。 貝葉斯模型 生成模型與判別模型 判別模型,即要判斷這個東西到底是哪一類,也就是要求y,那就用給定的x去預測。 生成模型,是要生成一個模型,那就是誰根據什么生成了模型,誰就是類別y,根據的內容就是x 以上述例子,判斷一個生產出...

    猜你喜歡

    styled-components —— React 中的 CSS 最佳實踐

    https://zhuanlan.zhihu.com/p/29344146 Styled-components 是目前 React 樣式方案中最受關注的一種,它既具備了 css-in-js 的模塊化與參數化優點,又完全使用CSS的書寫習慣,不會引起額外的學習成本。本文是 styled-components 作者之一 Max Stoiber 所寫,首先總結了前端組件化樣式中的最佳實踐原則,然后在此基...

    基于TCP/IP的網絡聊天室用Java來實現

    基于TCP/IP的網絡聊天室實現 開發工具:eclipse 開發環境:jdk1.8 發送端 接收端 工具類 運行截圖...

    19.vue中封裝echarts組件

    19.vue中封裝echarts組件 1.效果圖 2.echarts組件 3.使用組件 按照組件格式整理好數據格式 傳入組件 home.vue 4.接口返回數據格式...

    劍指Offer39-調整數組順序使奇數位于偶數前面

    一開始想著用冒泡排序的方法來做,但是bug還是很多,后來看了評論區答案,發現直接空間換時間是最簡單的,而且和快排的寫法是類似的。...

    【一只蒟蒻的刷題歷程】【藍橋杯】歷屆試題 九宮重排 (八數碼問題:BFS+集合set)

    資源限制 時間限制:1.0s 內存限制:256.0MB 問題描述 如下面第一個圖的九宮格中,放著 1~8 的數字卡片,還有一個格子空著。與空格子相鄰的格子中的卡片可以移動到空格中。經過若干次移動,可以形成第二個圖所示的局面。 我們把第一個圖的局面記為:12345678. 把第二個圖的局面記為:123.46758 顯然是按從上到下,從左到右的順序記錄數字,空格記為句點。 本題目的任務是已知九宮的初態...

    精品国产乱码久久久久久蜜桃不卡