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次圍觀