您好,登錄后才能下訂單哦!
不懂Java Reactor反應(yīng)器模式是什么??其實(shí)想解決這個(gè)問(wèn)題也不難,下面讓小編帶著大家一起學(xué)習(xí)怎么去解決,希望大家閱讀完這篇文章后大所收獲。
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)器線(xiàn)程、Handlers處理器兩大角色組成:
(1)Reactor反應(yīng)器線(xiàn)程的職責(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è)版本。
多線(xiàn)程O(píng)IO的致命缺陷
在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)題。
感謝你能夠認(rèn)真閱讀完這篇文章,希望小編分享Java Reactor反應(yīng)器模式是什么??jī)?nèi)容對(duì)大家有幫助,同時(shí)也希望大家多多支持億速云,關(guān)注億速云行業(yè)資訊頻道,遇到問(wèn)題就找億速云,詳細(xì)的解決方法等著你來(lái)學(xué)習(xí)!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。