• <noscript id="e0iig"><kbd id="e0iig"></kbd></noscript>
  • <td id="e0iig"></td>
  • <option id="e0iig"></option>
  • <noscript id="e0iig"><source id="e0iig"></source></noscript>
  • netty01-bio介紹

    標簽: netty  BIO  NIO

    1.傳統BIO線程模型/阻塞

    1.1 單線程實現

    來看下傳統bio(單線程)的代碼示例:
    package com.hotpot.day01.bio;
    
    import java.io.IOException;
    import java.io.InputStream;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    /**
     * 描述:傳統Socket阻塞案例
     * @author: myx
     * @date: 2018/2/6 0006
     * Copyright  2017-ganinfo. All rights reserved.
     */
    public class TraditionalSocketDemo{
    	@SuppressWarnings("resource")
    	public static void main(String[] args) throws IOException {
    		ServerSocket serverSocket = new ServerSocket(7777);
    		System.out.println("服務端啟動...");
    		while(true){
    			// 獲取socket套接字
    			// accept()阻塞點
    			Socket socket = serverSocket.accept();
    			System.out.println("有新客戶端連接上來了...");
    			// 獲取客戶端輸入流
    			InputStream is = socket.getInputStream();
    			byte[] b = new byte[1024];
    			while(true){
    				// 循環讀取數據
    				// read() 阻塞點
    				int data = is.read(b);
    				if(data != -1){
    					String info = new String(b,0,data,"GBK");
    					System.out.println(info);
    				}else{
    					break;
    				}
    			}
    		}
    	}
    }
    采用一問一達的方式(一個服務端只能為一個客戶端服務),就像是一個餐廳只能服務一個客人。

    1.2 多線程實現

    package com.hotpot.day01.bio;
    
    import java.io.IOException;
    import java.io.InputStream;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    /**
     * 描述:傳統bio多線程版本
     * @author: myx
     * @date: 2018/2/6 0006
     * Copyright  2017-ganinfo. All rights reserved.
     */
    public class TraditionalSocketDemo2{
    	@SuppressWarnings("resource")
    	public static void main(String[] args) throws IOException {
    		ServerSocket serverSocket = new ServerSocket(7777);
    		System.out.println("服務端啟動...");
    		while(true){
    			// 獲取socket套接字
    			// accept()阻塞點
    			Socket socket = serverSocket.accept();
    			System.out.println("有新客戶端連接上來了...");
    			new Thread(new Runnable() {
    				@Override
    				public void run() {
    					try {
    						// 獲取客戶端輸入流
    						InputStream is = socket.getInputStream();
    						byte[] b = new byte[1024];
    						while(true){
    							// 循環讀取數據
    							// read() 阻塞點
    							int data = is.read(b);
    							if(data != -1){
    								String info = new String(b,0,data,"GBK");
    								System.out.println(info);
    							}else{
    								break;
    							}
    						}
    					} catch (Exception e) {
    						e.printStackTrace();
    					}
    				}
    			}).start();
    		}
    	}
    }
    多線程結構圖:

    缺點:
    當用戶一直增長,對于服務的壓力也是越來越大,會導致整個服務掛掉,就像是一個餐廳為了服務N個可能請了N個服務生,自然餐廳最后會黃調

    1.3 線程池實現

    package com.hotpot.day01.bio;
    
    import java.io.IOException;
    import java.io.InputStream;
    import java.net.ServerSocket;
    import java.net.Socket;
    import java.util.concurrent.ExecutorService;
    
    import static java.util.concurrent.Executors.newFixedThreadPool;
    
    /**
     * 描述:傳統BIO 多線程偽異步IO
     * @author: myx
     * @date: 2018/2/6 0006
     * Copyright  2017-ganinfo. All rights reserved.
     */
    public class TraditionalSocketMultiThreadDemo {
    	@SuppressWarnings("resource")
    	public static void main(String[] args) throws IOException {
    //		ExecutorService threadPool = Executors.newCachedThreadPool();// 線程池,緩存,無限大  m:m = 請求:線程  n:m  n=>m=1
    		ExecutorService threadPool = newFixedThreadPool(100); // 請求:線程 = n:m (n>m)
    		ServerSocket serverSocket = new ServerSocket(7777);
    		System.out.println("服務端啟動...");
    		while (true) {
    			// 獲取socket套接字
    			// accept()阻塞點
    			Socket socket = serverSocket.accept();
    			threadPool.execute(new Runnable() {
    				@Override
    				public void run() {
    					try {
    						System.out.println("有新客戶端連接上來了...");
    						// 獲取客戶端輸入流
    						InputStream is = socket.getInputStream();
    						byte[] b = new byte[1024];
    						while (true) {
    							// 循環讀取數據
    							// read() 阻塞點
    							int data = is.read(b);
    							if (data != -1) {
    								String info = new String(b, 0, data, "GBK");
    								System.out.println(info);
    							} else {
    								break;
    							}
    						}
    					} catch (IOException e) {
    						e.printStackTrace();
    					}
    				}
    			});
    		}
    	}
    }


    缺點(偽異步IO):
    當線程池已經用完所有線程,再來新的請求會等待,就像一個餐廳來了100個只有50個服務生,50人需要等待,會有客人不滿意。

    1.4 BIO問題總結

    • 每當一個新的客戶端請求接入時,服務端必須創建一個線程來處理這條鏈路
    • 如果在高性能高并發場景下肯定是沒法用的










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

    智能推薦

    Netty框架學習之網絡編程基礎----BIO介紹,示意圖和demo實例

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

    Netty學習筆記_4(NIO的基本介紹和與BIO的比較)

    Java NIO(non-blocking IO):從jdk1.4開始,Java提供的一系列改進輸入輸出的新特性;同步非阻塞。NIO相關的類都被放在java.nio包及其子包下【java.io包內容改寫】 Java NIO三大核心組件:Channel(管道)、Buffer(緩沖區)、Selector(選擇器)》》提供了面向緩沖區(面向塊)的編程 Java NIO的非阻塞模式:一個線程可以從某通道發...

    網絡編程(BIO、NIO、Netty )

    簡介: BIO:同步阻塞式IO,服務器實現模式為一個連接一個線程,即客戶端有連接請求時服務器端就需要啟動一個線程進行處理,如果這個連接不做任何事情會造成不必要的線程開銷,當然可以通過線程池機制改善。  NIO:同步非阻塞式IO,服務器實現模式為一個請求一個線程,即客戶端發送的連接請求都會注冊到多路復用器上,多路復用器輪詢到連接有I/O請求時才啟動一個線程進行處理。   ...

    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_...

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

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

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