netty01-bio介紹
1.傳統BIO線程模型/阻塞
1.1 單線程實現
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();
}
}
}
缺點:
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();
}
}
});
}
}
}
1.4 BIO問題總結
- 每當一個新的客戶端請求接入時,服務端必須創建一個線程來處理這條鏈路
- 如果在高性能高并發場景下肯定是沒法用的
智能推薦
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請求時才啟動一個線程進行處理。  ...
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 以上述例子,判斷一個生產出...