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