術語概念描述:
IO有內存IO、網絡IO和磁盤IO三種,通常我們說的IO指的是后兩者。
阻塞和非阻塞,是函數/方法的實現方式,即在數據就緒之前是立刻返回還是等待。
以文件IO為例,一個IO讀過程是文件數據從磁盤→內核緩沖區→用戶內存的過程。同步與異步的區別主要在於數據從內核緩沖區→用戶內存這個過程需不需要用戶進程等待。有個數據拷貝的過程,是拷貝完再通知還是在內核緩沖區就通知。(網絡IO把磁盤換做網卡即可)
Linux IO模型
- 同步阻塞
- 同步非阻塞
- IO復用
- 信號驅動
- 異步非阻塞
同步阻塞
去餐館吃飯,點一個自己最愛吃的蓋澆飯,然后在原地等着一直到蓋澆飯做好,自己端到餐桌就餐。這就是典型的同步阻塞。當廚師給你做飯的時候,你需要一直在那里等着。
網絡編程中,讀取客戶端的數據需要調用recvfrom。在默認情況下,這個調用會一直阻塞直到數據接收完畢,就是一個同步阻塞的IO方式。這也是最簡單的IO模型,在通常fd(文件描述句柄)較少、就緒很快的情況下使用是沒有問題的。

同步非阻塞
你每次點完飯就在那里等着,突然有一天你發現自己真傻。於是,你點完之后,就回桌子那里坐着,然后估計差不多了,就問老板飯好了沒,如果好了就去端,沒好的話就等一會再去問,依次循環直到飯做好。這就是同步非阻塞。
這種方式在編程中對socket設置O_NONBLOCK即可。但此方式僅僅針對網絡IO有效,對磁盤IO並沒有作用。因為本地文件IO就沒有被認為是阻塞,我們所說的網絡IO的阻塞是因為網路IO有無限阻塞的可能,而本地文件除非是被鎖住,否則是不可能無限阻塞的,因此只有鎖這種情況下,O_NONBLOCK才會有作用。而且,磁盤IO時要么數據在內核緩沖區中直接可以返回,要么需要調用物理設備去讀取,這時候進程的其他工作都需要等待。因此,后續的IO復用和信號驅動IO對文件IO也是沒有意義的。

IO復用
你點一份飯然后循環的去問好沒好顯然有點得不償失,還不如就等在那里直到准備好,但是當你點了好幾樣飯菜的時候,你每次都去問一下所有飯菜的狀態(未做好/已做好)肯定比你每次阻塞在那里等着好多了。當然,你問的時候是需要阻塞的,一直到有准備好的飯菜或者你等的不耐煩(超時)。這就引出了IO復用,也叫多路IO就緒通知。這是一種進程預先告知內核的能力,讓內核發現進程指定的一個或多個IO條件就緒了,就通知進程。使得一個進程能在一連串的事件上等待。
IO復用的實現方式目前主要有select、poll和epoll。
select和poll的原理基本相同:
-
注冊待偵聽的fd(這里的fd創建時最好使用非阻塞)
-
每次調用都去檢查這些fd的狀態,當有一個或者多個fd就緒的時候返回
-
返回結果中包括已就緒和未就緒的fd
相比select,poll解決了單個進程能夠打開的文件描述符數量有限制這個問題:select受限於FD_SIZE的限制,如果修改則需要修改這個宏重新編譯內核;而poll通過一個pollfd數組向內核傳遞需要關注的事件,避開了文件描述符數量限制。此外,select和poll共同具有的一個很大的缺點就是包含大量fd的數組被整體復制於用戶態和內核態地址空間之間,開銷會隨着fd數量增多而線性增大。
select和poll就類似於上面說的就餐方式。但當你每次都去詢問時,老板會把所有你點的飯菜都輪詢一遍再告訴你情況,當大量飯菜很長時間都不能准備好的情況下是很低效的。於是,老板有些不耐煩了,就讓廚師每做好一個菜就記下來他。這樣每次你再去問的時候,他會直接把已經准備好的菜告訴你,你再去端。這就是事件驅動IO就緒通知的方式epoll。
epoll的出現,解決了select、poll的缺點:
-
基於事件驅動的方式,避免了每次都要把所有fd都掃描一遍。
-
epoll_wait只返回就緒的fd。
-
epoll使用nmap內存映射技術避免了內存復制的開銷。
-
epoll的fd數量上限是操作系統的最大文件句柄數目,這個數目一般和內存有關,通常遠大於1024。
總結:
- select:支持注冊 FD_SETSIZE(1024) 個 socket。
- poll: poll 作為 select 的替代者,最大的區別就是,poll 不再限制 socket 數量。
- epoll:epoll 能直接返回具體的准備好的通道,時間復雜度 O(1)。
ps:select 和 poll 都有一個共同的問題,那就是它們都只會返回所有通道(channel),但是不會告訴你具體是哪幾個通道已經就緒。一旦知道有通道准備好以后,需要進行一次掃描,通道少的時候還行,一旦通道的數量是幾十萬個以上的時候,掃描一次的時間復雜度 O(n)。后來才催生了epoll實現。
此外,對於IO復用還有一個水平觸發和邊緣觸發的概念:
-
水平觸發:當就緒的fd未被用戶進程處理后,下一次查詢依舊會返回,這是select和poll的觸發方式。
-
邊緣觸發:無論就緒的fd是否被處理,下一次不再返回。理論上性能更高,但是實現相當復雜,並且任何意外的丟失事件都會造成請求處理錯誤。epoll默認使用水平觸發,通過相應選項可以使用邊緣觸發。

信號驅動
上文的就餐方式還是需要你每次都去問一下飯菜狀況。於是,你再次不耐煩了,就跟老板說,哪個飯菜好了就通知我一聲吧。然后就自己坐在桌子那里干自己的事情。更甚者,你可以把手機號留給老板,自己出門,等飯菜好了直接發條短信給你。這就類似信號驅動的IO模型。
流程如下:
-
開啟套接字信號驅動IO功能
-
系統調用sigaction執行信號處理函數(非阻塞,立刻返回)
-
數據就緒(在內核緩沖區),生成sigio信號,通過信號回調通知應用來讀取數據。

異步非阻塞
之前的就餐方式,到最后總是需要你自己去把飯菜端到餐桌。這下你也不耐煩了,於是就告訴老板,能不能飯好了直接端到你的面前或者送到你的家里(數據在用戶內存就緒)。這就是異步非阻塞IO了。
對比信號驅動IO,異步IO的主要區別在於:信號驅動由內核告訴我們何時可以開始一個IO操作(數據在內核緩沖區中),而異步IO則由內核通知IO操作何時已經完成(數據已經在用戶空間中)。異步IO又叫做事件驅動IO,在Unix中,POSIX1003.1標准為異步方式訪問文件定義了一套庫函數,定義了AIO的一系列接口。使用aio_read或者aio_write發起異步IO操作。使用aio_error檢查正在運行的IO操作的狀態。

網絡編程模型
Java的I/O發展簡史:
從JDK1.0到JDK1.3,Java的I/O類庫都非常原始,很多UNIX網絡編程中的概念或者接口在I/O類庫中都沒有體現,例如Pipe、Channel、Buffer和Selector等。2002年發布JDK1.4時,NIO以JSR-51的身份正式隨JDK發布。它新增了個java.nio包,提供了很多進行異步I/O開發的API和類庫,主要的類和接口如下。
- 進行異步I/O操作的緩沖區ByteBuffer等;
- 進行異步I/O操作的管道Pipe;
- 進行各種I/O操作(異步或者同步)的Channel,包括ServerSocketChannel和SocketChannel;
- 多種字符集的編碼能力和解碼能力;
- 實現非阻塞I/O操作的多路復用器selector;
- 基於流行的Perl實現的正則表達式類庫;
- 文件通道FileChannel。
新的NIO類庫的提供,極大地促進了基於Java的異步非阻塞編程的發展和應用,但是,它依然有不完善的地方,特別是對文件系統的處理能力仍顯不足,主要問題如下。
- 沒有統一的文件屬性(例如讀寫權限);
- API能力比較弱,例如目錄的級聯創建和遞歸遍歷,往往需要自己實現;
- 底層存儲系統的一些高級API無法使用;
- 所有的文件操作都是同步阻塞調用,不支持異步文件讀寫操作。
2011年7月28日,JDK1.7正式發布。它的一個比較大的亮點就是將原來的NIO類庫進行了升級,被稱為NIO2.0。
NIO2.0由JSR-203演進而來,它主要提供了如下三個方面的改進。
- 提供能夠批量獲取文件屬性的API,這些API具有平台無關性,不與特性的文件系統相耦合,另外它還提供了標准文件系統的SPI,供各個服務提供商擴展實現;
- 提供AIO功能,支持基於文件的異步I/O操作和針對網絡套接字的異步操作;
- 完成JSR-51定義的通道功能,包括對配置和多播數據報的支持等。
上文講述了UNIX環境的五種IO模型。基於這五種模型,在Java中,隨着NIO和NIO2.0(AIO)的引入,一般具有以下幾種網絡編程模型:
- BIO
- NIO
- AIO
BIO
BIO是一個典型的網絡編程模型,是通常我們實現一個服務端程序的過程,步驟如下:
-
主線程accept請求阻塞
-
請求到達,創建新的線程來處理這個套接字,完成對客戶端的響應。
-
主線程繼續accept下一個請求
這種模型有一個很大的問題是:當客戶端連接增多時,服務端創建的線程也會暴漲,系統性能會急劇下降。因此,在此模型的基礎上,類似於 tomcat的bio connector,采用的是線程池來避免對於每一個客戶端都創建一個線程。有些地方把這種方式叫做偽異步IO(把請求拋到線程池中異步等待處理)。
NIO
JDK1.4開始引入了NIO類庫,這里的NIO指的是Non-blcok IO,主要是使用Selector多路復用器來實現。Selector在Linux等主流操作系統上是通過epoll實現的。
NIO的實現流程,類似於select:
-
創建ServerSocketChannel監聽客戶端連接並綁定監聽端口,設置為非阻塞模式。
-
創建Reactor線程,創建多路復用器(Selector)並啟動線程。
-
將ServerSocketChannel注冊到Reactor線程的Selector上。監聽accept事件。
-
Selector在線程run方法中無線循環輪詢准備就緒的Key。
-
Selector監聽到新的客戶端接入,處理新的請求,完成tcp三次握手,建立物理連接。
-
將新的客戶端連接注冊到Selector上,監聽讀操作。讀取客戶端發送的網絡消息。
-
客戶端發送的數據就緒則讀取客戶端請求,進行處理。
相比BIO,NIO的編程非常復雜。
AIO
JDK1.7引入NIO2.0,提供了異步文件通道和異步套接字通道的實現,是真正的異步非阻塞IO, 對應於Unix中的異步IO。
通常會有一個線程池用於執行異步任務,提交任務的線程將任務提交到線程池就可以立馬返回,不必等到任務真正完成。如果想要知道任務的執行結果,通常是通過傳遞一個回調函數任務結束后去調用這個函數(任務結束后去系統調用這個函數)或者Future get(需要用時編碼阻塞獲取)的方式,任務結束后去調用這個函數。同樣的原理,Java 中的異步 IO 也是一樣的,都是由一個線程池來負責執行任務,然后使用回調或自己去查詢結果。異步 IO 主要是為了控制線程數量,減少過多的線程帶來的內存消耗和 CPU 在線程調度上的開銷。
-
創建AsynchronousServerSocketChannel,綁定監聽端口
-
調用AsynchronousServerSocketChannel的accpet方法,傳入自己實現的CompletionHandler(回調函數)。包括上一步,都是非阻塞的
-
連接傳入,回調CompletionHandler的completed方法,在里面,調用AsynchronousSocketChannel的read方法,傳入負責處理數據的CompletionHandler。
-
數據就緒,觸發負責處理數據的CompletionHandler的completed方法。繼續做下一步處理即可。
-
寫入操作類似,也需要傳入CompletionHandler。
總結

