大多數(shù)網(wǎng)絡(luò)框架都是基于Reactor模型進(jìn)行設(shè)計和開發(fā),Reactor模型基于事件驅(qū)動,特別適合處理海量的I/O事件。
傳統(tǒng)的IO模型
這種模式是傳統(tǒng)設(shè)計,每一個請求到來時,大致都會按照:請求讀取->請求解碼->服務(wù)執(zhí)行->編碼響應(yīng)->發(fā)送答復(fù) 這個流程去處理。
服務(wù)器會分配一個線程去處理,如果請求暴漲起來,那么意味著需要更多的線程來處理該請求。若請求出現(xiàn)暴漲,線程池的工作線程數(shù)量滿載那么其它請求就會出現(xiàn)等待或者被拋棄。若每個小任務(wù)都可以使用非阻塞的模式,然后基于異步回調(diào)模式。這樣就大大提高系統(tǒng)的吞吐量,這便引入了Reactor模型。
Reactor模型中定義的三種角色:
Reactor:負(fù)責(zé)監(jiān)聽和分配事件,將I/O事件分派給對應(yīng)的Handler。新的事件包含連接建立就緒、讀就緒、寫就緒等。Acceptor:處理客戶端新連接,并分派請求到處理器鏈中。Handler:將自身與事件綁定,執(zhí)行非阻塞讀/寫任務(wù),完成channel的讀入,完成處理業(yè)務(wù)邏輯后,負(fù)責(zé)將結(jié)果寫出channel??捎觅Y源池來管理。
單Reactor單線程模型
Reactor線程負(fù)責(zé)多路分離套接字,accept新連接,并分派請求到handler。Redis使用單Reactor單進(jìn)程的模型。
消息處理流程:
Reactor對象通過select監(jiān)控連接事件,收到事件后通過dispatch進(jìn)行轉(zhuǎn)發(fā)。如果是連接建立的事件,則由acceptor接受連接,并創(chuàng)建handler處理后續(xù)事件。如果不是建立連接事件,則Reactor會分發(fā)調(diào)用Handler來響應(yīng)。handler會完成read->業(yè)務(wù)處理->send的完整業(yè)務(wù)流程。
單Reactor多線程模型
將handler的處理池化。
多Reactor多線程模型
主從Reactor模型: 主Reactor用于響應(yīng)連接請求,從Reactor用于處理IO操作請求,讀寫分離了。