Java Reactor反應(yīng)器模式使用方法詳解
Reactor反應(yīng)器模式
到目前為止,高性能網(wǎng)絡(luò)編程都繞不開反應(yīng)器模式。很多著名的服務(wù)器軟件或者中間件都是基于反應(yīng)器模式實現(xiàn)的,如Nginx、Redis、Netty。
反應(yīng)器模式是高性能網(wǎng)絡(luò)編程的必知、必會的模式。
Reactor簡介
反應(yīng)器模式由Reactor反應(yīng)器線程、Handlers處理器兩大角色組成:
(1)Reactor反應(yīng)器線程的職責:負責響應(yīng)IO事件,并且分發(fā)到Handlers處理器。
(2)Handlers處理器的職責:非阻塞的執(zhí)行業(yè)務(wù)處理邏輯。
從上面的反應(yīng)器模式定義,看不出這種模式有什么神奇的地方。當然,從簡單到復雜,反應(yīng)器模式也有很多版本。根據(jù)前面的定義,僅僅是最為簡單的一個版本。
多線程OIO的致命缺陷
在Java的OIO編程中,最初和最原始的網(wǎng)絡(luò)服務(wù)器程序,是用一個while循環(huán),不斷地監(jiān)聽端口是否有新的連接。如果有,就調(diào)用一個和處理函數(shù)來完成,示例代碼如下:
@Test public void client() throws IOException { Socket client = new Socket("127.0.0.1", 9999); Writer writer = new OutputStreamWriter(client.getOutputStream()); writer.write("Hello World"); writer.flush(); writer.close(); client.close(); } @Test public void server() throws IOException { ServerSocket server = new ServerSocket(9999); while (true){ Socket socket = server.accept(); Reader reader = new InputStreamReader(socket.getInputStream()); print(reader); reader.close(); socket.close(); server.close(); } }
這種方法的最大問題是:如果前一個網(wǎng)絡(luò)連接的handle(socket)沒有處理完,那么后面的連接請求沒法被接收,于是后面的請求通通會被阻塞住,服務(wù)器的吞吐量就太低了。對于服務(wù)器來說,這是一個嚴重的問題。
以上就是本文的全部內(nèi)容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
Java修改eclipse中web項目的server部署路徑問題
這篇文章主要介紹了Java修改eclipse中web項目的server部署路徑,本文給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2020-11-11SpringBoot 中 AutoConfiguration的使用方法
這篇文章主要介紹了SpringBoot 中 AutoConfiguration的使用方法,本文通過實例代碼給大家介紹的非常詳細,具有一定的參考借鑒價值,需要的朋友可以參考下2019-04-04Struts2中Action三種接收參數(shù)形式與簡單的表單驗證功能
本文以登錄驗證為例,進行代碼展示,下面給大家詳細介紹Struts2中Action三種接收參數(shù)形式與簡單的表單驗證功能,需要的朋友參考下2017-03-03Java服務(wù)調(diào)用RestTemplate與HttpClient的使用詳解
無論是微服務(wù)還是SOA,都面臨著服務(wù)間的遠程調(diào)用,這篇文章主要介紹了服務(wù)調(diào)用RestTemplate與HttpClient的使用,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2022-06-06