Netty剖析之BIO
標簽: Netty
什么是BIO?
BIO(blocking I/O),同步阻塞IO,服務器實現模式為一個線程處理一個連接,即每當有一個客戶端連接時,就會啟動一個獨立的線程來進行處理,如果這個連接不做任何事情,就會阻塞到那里,從而引起不必要的線程開銷;
BIO方式適用于連接數目比較小且固定的架構,這種方式對服務器資源要求比較高,并發局限于應用中,JDK1.4以前的唯一選擇,程序簡單易理解;
BIO工作原理
- 服務器端啟動一個ServerSocket
- 客戶端啟動Socket對服務器進行通信,默認情況下服務器端需要對每個客戶建立一個線程與之通訊
- 客戶端發出請求后, 先咨詢服務器是否有線程響應,如果沒有則會等待,或者被拒絕
- 如果有響應,客戶端線程會等待請求結束后,再繼續執行
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存在的問題
- 每個請求都需要創建獨立的線程,與對應的客戶端進行數據交互
- 當并發較大時,需要創建大量的線程來進行處理,服務器資源消耗較大
- 連接建立后,如果當前線程暫時沒有數據可讀,則線程就阻塞到read操作上了,造成線程資源浪費
智能推薦
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、...
猜你喜歡
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_...