webflux的非阻塞?
題主應該聽說過下面這些名詞:
- 阻塞IO
- 非阻塞IO
- 同步IO
- 異步IO
- 同步阻塞IO
- 同步非阻塞IO
- 異步阻塞IO
- 異步非阻塞IO
只要理解了這些,你就能理解webflux的非阻塞了!
IO一個IO操作其實有兩個步驟:發起IO請求和實際的IO操作
阻塞IO和非阻塞IO的區別在于第一個步驟是否阻塞:發起IO請求是否會被阻塞,如果阻塞直到完成那么就是傳統的阻塞IO;如果不阻塞,那么就是非阻塞IO
同步IO和異步IO的區別就在于第二個步驟是否阻塞:如果實際的IO讀寫阻塞請求進程,那么就是同步IO,因此阻塞IO、非阻塞IO、IO復用、信號驅動IO都是同步IO;如果不阻塞,而是操作系統幫你做完IO操作再將結果返回給你,那么就是異步IO
舉個不太恰當的例子 :比如你家網絡斷了,你打電話去中國電信報修!
- 你撥號---客戶端連接服務器
- 電話通了---連接建立
- 你說:“我家網斷了,幫我修下”---發送消息
- 說完你就在那里等,那么就是阻塞IO
- 如果正好你有事,你放下電話,然后處理其他事情了,過一會你來問下,修好了沒---那就是非阻塞IO
- 如果客服說:“馬上幫你處理,你稍等”---同步IO
- 如果客服說:“馬上幫你處理,好了通知你”,然后掛了電話---異步IO
回到問題SpringMVC5以前,一個請求過來后的流程大致是這樣的:
服務端接收到請求,從線程池獲取一個線程來處理
線程處理完成后,返回數據
線程被釋放回線程池中
可以看到,當一個請求過來后,所有的處理結束后才會得到響應。
Webflux基于Reactor模型,一個主從Reactor模型如下圖:
主Reactor用于響應連接請求,接收到請求后就分配一個channel,然后直接響應客戶端
從Reactor用于處理IO操作請求,但是不處理具體邏輯
具體邏輯由工作線程去處理。工作線程處理完成后再去通知響應。