歡迎您光臨本站 註冊首頁

Java Reactor反應器模式使用方法詳解

←手機掃碼閱讀     sl_ivan @ 2020-06-14 , reply:0

Reactor反應器模式
 

到目前為止,高性能網絡編程都繞不開反應器模式。很多著名的服務器軟件或者中間件都是基於反應器模式實現的,如Nginx、Redis、Netty。

反應器模式是高性能網絡編程的必知、必會的模式。

Reactor簡介
 

反應器模式由Reactor反應器線程、Handlers處理器兩大角色組成:

(1)Reactor反應器線程的職責:負責響應IO事件,並且分發到Handlers處理器。

(2)Handlers處理器的職責:非阻塞的執行業務處理邏輯。

  從上面的反應器模式定義,看不出這種模式有什麼神奇的地方。當然,從簡單到複雜,反應器模式也有很多版本。根據前面的定義,僅僅是最為簡單的一個版本。

多線程OIO的致命缺陷
 

在Java的OIO編程中,最初和最原始的網絡服務器程序,是用一個while循環,不斷地監聽端口是否有新的連接。如果有,就調用一個和處理函數來完成,示例代碼如下:

  @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();     }   }

 

這種方法的最大問題是:如果前一個網絡連接的handle(socket)沒有處理完,那麼後面的連接請求沒法被接收,於是後面的請求通通會被阻塞住,服務器的吞吐量就太低了。對於服務器來說,這是一個嚴重的問題。


[sl_ivan ] Java Reactor反應器模式使用方法詳解已經有230次圍觀

http://coctec.com/docs/java/show-post-238535.html