swoole事件處理流程

本篇文章的主要內容是關於對swoole事件處理流程的解析，感興趣的朋友可以了解一下，希望本文能對你有所幫助。

了解swoole事件處理流程，先了解兩種網路事件處理模式。

Reactor模式

它要求主執行緒(I/O處理單元)只負責監聽檔案描述符上是否有事件發生，有的話就立即將該事件通知工作執行緒/進程(邏輯單元)。除此之外，主執行緒不做任何其他工作。讀寫資料，接受新的連線，以及處理客戶請求均在工作執行緒中完成。

Proactor模式

兩種實現

使用I/O非同步模型實現Proactor模式。原理：將所有I/O操作都交給主執行緒，主執行緒配合和核心來處理，業務邏輯操作就交給邏輯單元。例如使用aio_read來實現。

工作流程：

1. 主執行緒呼叫aio_read函數向核心註冊socket上的讀完成事件。
2. 主執行緒繼續處理其他I/O事件。
3. 當socket上的資料被讀入使用者緩衝區後，核心向應用程式(邏輯單元)傳送一個信號，通知應用程式資料可用。
4. 應用程式讀取資料(用戶端的請求)，處理完後，呼叫aio_write函數向核心註冊socket上的寫事件。
5. 主執行緒繼續處理其他邏輯。
6. 當使用者緩衝區的資料寫入socket後，核心向應用程式傳送一個信號，通知應用程式資料傳送完畢。
7. 應用程式預先定義好的信號處理常式來處理善後處理，比如關閉socket.

使用I/O同步模型實現Proactor模式。原理：主執行緒執行I/O事件資料的讀寫操作，業務邏輯操作就交給邏輯單元。例如使用epoll來實現。

工作流程：

1. 主執行緒往epoll核心事件表中註冊socket上的讀就緒事件。
2. 主執行緒呼叫epoll_wait等待socket上有資料可讀。
3. epoll_wait有返回後，主執行緒從socket上讀取資料，然後將讀取到的資料封裝成一個請求物件(用戶端的請求)，並插入請求佇列。
4. 於是佇列的消費者執行緒處理請求物件，然後在epoll核心事件表中註冊socket上的寫就緒事件。
5. 主執行緒呼叫epoll_wait等待socket可寫。
6. 當socket可寫時，epoll_wait通知主執行緒。主執行緒往socket寫入請求結果。

swoole事件架構圖

從圖可以看出，如果我們把Reactor執行緒和Work行程群組合起來，看成工作執行緒的話，swoole使用的是reactor事件處理模式。

一個請求經歷的步驟如下:

1. 伺服器主執行緒等待用戶端連線。

2. Reactor執行緒處理接連socket，讀取socket上的請求資料(Receive)，將請求封裝好後投遞給work進程。

3. Work進程就是邏輯單元，處理業務資料。

4. Work進程結果返回給Reactor執行緒。

5. Reactor執行緒將結果寫回socket(Send)。

相關教學：swoole視訊教學

以上就是swoole事件處理流程的詳細內容，更多請關注TW511.COM其它相關文章！