Java Reactor反應(yīng)器模式使用方法詳解
Reactor反應(yīng)器模式
到目前為止，高性能網(wǎng)絡(luò)編程都繞不開反應(yīng)器模式。很多著名的服務(wù)器軟件或者中間件都是基于反應(yīng)器模式實(shí)現(xiàn)的，如Nginx、Redis、Netty。
反應(yīng)器模式是高性能網(wǎng)絡(luò)編程的必知、必會的模式。
Reactor簡介
反應(yīng)器模式由Reactor反應(yīng)器線程、Handlers處理器兩大角色組成：
（1）Reactor反應(yīng)器線程的職責(zé)：負(fù)責(zé)響應(yīng)IO事件，并且分發(fā)到Handlers處理器。
（2）Handlers處理器的職責(zé)：非阻塞的執(zhí)行業(yè)務(wù)處理邏輯。
從上面的反應(yīng)器模式定義，看不出這種模式有什么神奇的地方。當(dāng)然，從簡單到復(fù)雜，反應(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ù)器來說，這是一個嚴(yán)重的問題。
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
java 記錄一個子串在整串中出現(xiàn)的次數(shù)實(shí)例
今天小編就為大家分享一篇java 記錄一個子串在整串中出現(xiàn)的次數(shù)實(shí)例，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2018-07-07
這篇文章主要介紹了ArrayList的remove方法使用，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教。</p>2021-09-09
今天小編就為大家分享一篇關(guān)于Java多線程工具篇BlockingQueue的詳解，小編覺得內(nèi)容挺不錯的，現(xiàn)在分享給大家，具有很好的參考價值，需要的朋友一起跟隨小編來看看吧2019-03-03
這篇文章主要介紹了詳解Spring中的AOP及AspectJ五大通知注解,AOP面向切面編程是一種新的方法論，是對傳統(tǒng)OOP面向?qū)ο缶幊痰难a(bǔ)充,AOP?的主要編程對象是切面(aspect),切面模塊化橫切關(guān)注點(diǎn),需要的朋友可以參考下2023-08-08
Maven的國內(nèi)鏡像(快速解決jar下載過慢的問題)
下面小編就為大家?guī)硪黄狹aven的國內(nèi)鏡像(快速解決jar下載過慢的問題)。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-06-06
Java的ConcurrentLinkedQueue源碼分析
這篇文章主要介紹了Java的ConcurrentLinkedQueue源碼分析,ConcurrentLinkedQueue 是一個基于鏈接節(jié)點(diǎn)的無界線程安全的隊(duì)列,當(dāng)我們添加一個元素的時候,它會添加到隊(duì)列的尾部,當(dāng)我們獲取一個元素時,它會返回隊(duì)列頭部的元素,需要的朋友可以參考下2023-12-12
這篇文章主要介紹了SpringBoot 編寫配置文件的兩種方法，幫助大家更好的理解和使用springboot框架，感興趣的朋友可以了解下2020-11-11
本文是關(guān)于Java IO文件流和垃圾回收問題，一個小的測試程序搞清楚Java IO的問題，希望能幫助有需要的小伙伴2016-07-07
springcloud?gateway高級功能之集成apollo后動態(tài)刷新路由方式
這篇文章主要介紹了springcloud?gateway高級功能之集成apollo后動態(tài)刷新路由方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2023-08-08
AOP 從功能的角度來講，可能看作OOP編程方式的一種補(bǔ)充，提供了一種不同的代碼或者系統(tǒng)組織方式，下面這篇文章主要給大家介紹了關(guān)于Spring學(xué)習(xí)教程之AOP模塊的相關(guān)資料，文中通過圖文介紹的非常詳細(xì)，需要的朋友可以參考下2018-05-05