Reactor單線程模型
在Reactor單線程模型中，所謂的“單線程”主要針對I/O操作而言，即所有的I/O操作（如accept()、read()、write()和connect()）都在同一個線程上完成。然而，在當前的單線程Reactor模型中，不僅I/O操作由Reactor線程處理，非I/O的業務邏輯操作也在該線程上執行。這種設計可能導致I/O請求的響應被顯著延遲，因為耗時的業務邏輯會阻塞Reactor線程，使其無法及時處理后續的I/O事件。
為了優化性能，應當將非I/O的業務邏輯操作從Reactor線程中卸載，轉交給獨立的線程池處理。這樣可以顯著加速Reactor線程對 I/O請求的響應，提升系統的整體吞吐量和響應速度。

Reactor工作者線程池模型
與單線程模型不同，工作者線程池模型引入了工作者線程池（Work Thread Pool），并將非I/O操作從Reactor線程中剝離，交由工作者線程池執行。這種設計能夠顯著提升Reactor線程的I/O響應速度，避免因耗時業務邏輯的阻塞而延遲后續I/O請求的處理。

然而，在工作者線程池模型中，盡管非I/O操作被轉移到了線程池中處理，但所有的I/O操作仍然由Reactor單線程執行。在高負載、高并發或大數據量的應用場景中，這種設計仍然可能成為性能瓶頸。因此，為了進一步優化Reactor模型，衍生出了多線程模型，以更好地應對復雜的應用需求。

Reactor主從多線程模型
1）MainReactor負責監聽Server Socket，處理新連接的建立。通常，MainReactor只暴露一個服務端口，并將建立的Socket連接注冊到SubReactor。由于其主要任務是處理新連接，因此通常只需一個線程即可完成。
2）SubReactor負責維護與客戶端的實際通信，基于I/O多路復用處理讀寫事件，完成網絡數據的讀寫操作。SubReactor通常采用多線程設計，線程數一般設置為處理器核心數的兩倍，以充分利用多核性能。
對于非I/O操作（如業務邏輯處理），任務會被轉交給獨立的工作線程池執行，以避免阻塞SubReactor的事件循環。
為了充分利用多核處理器的系統資源，Reactor模型可以被拆分為兩部分：MainReactor和SubReactor。
這種設計使得每個模塊的職責更加專一，耦合度顯著降低，系統的性能和穩定性得到大幅提升，支持的并發客戶端數量可以達到百萬級別。目前，許多優秀的框架已經成功應用了這種模型，例如Java的Netty等。

Reactor模型和過濾器
過濾器（Filter）是一種數據處理模式，用于在數據傳遞過程中進行預處理或后處理。過濾器通常以鏈式結構（Filter Chain）組織，每個過濾器依次處理數據，負責特定任務（如解碼、驗證、日志記錄等）。
當事件發生時，Reactor將其傳遞給過濾器鏈的第一個過濾器。每個過濾器處理后將結果傳遞給下一個，直到所有過濾器完成處理。最終，處理完成的事件會交給實際的事件處理器進行進一步處理。
過濾器鏈的優勢在于將復雜邏輯分解為一系列簡單、獨立的步驟，每個步驟由專門過濾器負責。這種設計提高了代碼的可讀性和可維護性，同時使添加、刪除或修改處理步驟更加靈活便捷。

Reactor模型和異步編程
異步編程是一種編程范式，允許程序在等待某個操作（如I/O操作）完成時繼續執行其他任務，從而避免阻塞。異步編程通常通過回調函數、Promise、Future等機制實現。
Reactor模型和異步編程通常結合使用，以實現高效的并發處理。Reactor模型提供事件驅動的基礎，而異步編程則用于處理具體的非阻塞操作。
當Reactor監聽事件（如網絡請求到達）。事件循環接收到事件后，向工作線程池提交一個異步操作（如讀取數據）。異步操作返回一個Future對象，表示操作的未來結果。Reactor繼續監聽其他事件，不阻塞當前線程。當異步操作完成后，Future對象的結果被設置，并觸發回調函數。回調函數處理結果，可能觸發新的事件（如發送響應）。

以下偽代碼，展示了Reactor主從多線程模型與濾器鏈，異步編程結合執行過程。

// 偽代碼: 主從Reactor與異步處理
// MainReactor循環
mainReactor.onNewConnection(socket -> {
    // 輪詢選擇一個SubReactor
    SubReactor sub = subReactors.next();
    // 將新連接注冊到SubReactor
    sub.register(socket);
});

// SubReactor循環
subReactor.onReadable(socket, data -> {
    // 提交給工作線程池，并返回一個Future
    Future<Result> future = workerPool.submit(() -> {
        // 經過過濾器鏈處理
        data = filterChain.process(data);
        // 執行耗時的業務邏輯
        return businessLogic(data);
    });

    // 異步處理結果
    future.onComplete(result -> {
        socket.write(result); // 將結果異步寫回
    });
});

未完待續

很高興與你相遇！如果你喜歡本文內容，記得關注哦