• <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剖析之BIO

    標簽: Netty

    什么是BIO?

    BIO(blocking I/O),同步阻塞IO,服務器實現模式為一個線程處理一個連接,即每當有一個客戶端連接時,就會啟動一個獨立的線程來進行處理,如果這個連接不做任何事情,就會阻塞到那里,從而引起不必要的線程開銷;

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

    BIO工作原理

    在這里插入圖片描述

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

    BIO代碼示例

    public class BIOServer {
    
        public static void main(String[] args) throws Exception {
            // 創建一個線程池
            ExecutorService executorService = Executors.newCachedThreadPool();
    
            // 創建Socket服務,端口為8888
            ServerSocket serverSocket = new ServerSocket(8888);
            System.out.println("socket server start success");
    
            while (true) {
                Thread currentThread = Thread.currentThread();
                System.out.println("main Thread id:[" + currentThread.getId() + "]&name:[" + currentThread.getName() + "]");
    
                System.out.println("client connect start.........");
                // 如果此時沒有客戶端連接,此處會阻塞掉,直到有客戶端連接為止
                final Socket socket = serverSocket.accept();
                System.out.println("client connect end.........");
                executorService.execute(new Runnable() {
                    // 重寫run方法
                    public void run() {
                        // 與客戶端通訊處理
                        handler(socket);
                    }
                });
            }
        }
    
        public static void handler(Socket socket) {
            Thread currentThread = Thread.currentThread();
            System.out.println("Handler Thread id:[" + currentThread.getId() + "]&name:[" + currentThread.getName() + "]");
    
            try {
                byte[] bytes = new byte[1024];
                // 獲取輸入流
                InputStream inputStream = socket.getInputStream();
                System.out.println("read start.............");
    
                while (true) {
                    // 讀取的時候,如果沒有內容,此處會阻塞掉,直到能夠讀取到內容為止
                    int read = inputStream.read(bytes);
                    if (read != -1) {
                        System.out.println(new String(bytes, 0, read));
                    } else {
                        break;
                    }
                }
    
                System.out.println("read end.............");
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
                try {
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
    

    啟動之后,如果沒有客戶都連接,執行serverSocket.accept()代碼就會發生阻塞
    控制臺打印:

    socket server start success
    main Thread id:[1]&name:[main]
    client connect start.........
    

    我們通過telnet方式進行連接,打開cmd命令行,輸入telnet [ip] [port](如果出現不是內部或外部命令,則需要到控制面板 →程序和功能→啟用或關閉windows功能→找到 telnet客戶端 并勾選上,點擊確定即可,注:不同版本操作系統操作方式可能不一致,此處是以Win10為例),然后按’Ctrl+]’:

    C:\Users\Administrator>telnet 127.0.0.1 8888
    

    連接成功之后:

    歡迎使用 Microsoft Telnet Client
    
    Escape 字符為 'CTRL+]'
    
    
    Microsoft Telnet>
    

    此時控制臺也會打印出連接分配的線程信息,由于客戶端沒有發送任何信息,所以阻塞到了讀取內容的代碼上了:

    client connect start.........
    Handler Thread id:[12]&name:[pool-1-thread-1]
    read start.............
    

    在客戶端發送消息,服務端也會即時打印:

    Microsoft Telnet> send 123
    發送字符串 123
    Microsoft Telnet> send hello
    發送字符串 hello
    Microsoft Telnet>
    
    client connect start.........
    Handler Thread id:[12]&name:[pool-1-thread-1]
    read start.............
    123
    hello
    

    我們再新打開一個命令行窗口進行連接:

    Microsoft Telnet> send client2
    發送字符串 client2
    Microsoft Telnet>
    
    client connect start.........
    Handler Thread id:[13]&name:[pool-1-thread-2]
    read start.............
    client2
    

    可以看到又開啟了一個新的線程來處理此客戶端的連接

    BIO存在的問題

    1. 每個請求都需要創建獨立的線程,與對應的客戶端進行數據交互
    2. 當并發較大時,需要創建大量的線程來進行處理,服務器資源消耗較大
    3. 連接建立后,如果當前線程暫時沒有數據可讀,則線程就阻塞到read操作上了,造成線程資源浪費
    版權聲明:本文為chen_changying原創文章,遵循 CC 4.0 BY-SA 版權協議,轉載請附上原文出處鏈接和本聲明。
    本文鏈接:https://blog.csdn.net/chen_changying/article/details/104116694

    智能推薦

    Netty--BIO

    I/O模型 I/O 模型簡單的理解:就是用什么樣的通道進行數據的發送和接收,很大程度上決定了程序通信的性能 Java 共支持 3 種網絡編程模型/IO 模式:BIO、NIO、AIO Java BIO : 同步并阻塞(傳統阻塞型),服務器實現模式為一個連接一個線程,即客戶端有連接請求時服務器 端就需要啟動一個線程進行處理,如果這個連接不做任何事情會造成不必要的線程開銷 Java NIO : 同步非阻...

    Netty基礎------ BIO

    Netty基礎------ BIO(同步阻塞IO) 目錄 Netty基礎------ BIO 1、什么是BIO 2、BIO的工作機制 3、代碼實操演示 4、總結 1、什么是BIO Java BIo就是傳統的 java io編程,其相關的類和接口在 java.io BlO( blocking I/O):同步阻塞,我們熟知的Socket編程就是BIO,每個請求對應一個線程去處理。一個socket連接一...

    Netty -02- BIO

    基本介紹 Java BIO 就是傳統的 java io 編程,其相關的類和接口在 java.io BIO(blocking I/O) : 同步阻塞,服務器實現模式為一個連接一個線程,即客戶端有連接請求時服務器端就需 要啟動一個線程進行處理,如果這個連接不做任何事情會造成不必要的線程開銷,可以通過線程池機制改善(實 現多個客戶連接服務器)。 BIO 方式適用于連接數目比較小且固定的架構,這種方式對服...

    Netty學習--BIO

    一.常見IO模型 1.BIO BIO是一種傳統的同步阻塞的IO模型,每當有一個客戶端發送IO請求時,服務端就要創建一個線程進行處理。當數據還未準備好時,當前線程會一直阻塞,占用CPU資源,造成資源浪費,如下圖所示 BIO是基于流的形式來進行IO操作的,相較于NIO和AIO模型,在性能上相差較大。 2.NIO NIO是同步非阻塞IO模型,它是基于緩沖區來實現的。核心主要包括三個部分:Channel、...

    HTML中常用操作關于:頁面跳轉,空格

    1.頁面跳轉 2.空格的代替符...

    猜你喜歡

    freemarker + ItextRender 根據模板生成PDF文件

    1. 制作模板 2. 獲取模板,并將所獲取的數據加載生成html文件 2. 生成PDF文件 其中由兩個地方需要注意,都是關于獲取文件路徑的問題,由于項目部署的時候是打包成jar包形式,所以在開發過程中時直接安照傳統的獲取方法沒有一點文件,但是當打包后部署,總是出錯。于是參考網上文章,先將文件讀出來到項目的臨時目錄下,然后再按正常方式加載該臨時文件; 還有一個問題至今沒有解決,就是關于生成PDF文件...

    電腦空間不夠了?教你一個小秒招快速清理 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_...

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