swoole的架構分析

這篇文章帶給大家的內容是關於對swoole的架構分析，有一定的參考價值，有需要的朋友可以參考一下，希望對你有幫助。

結構圖如下:

swoole主要由Master進程(主進程)和Manager進程配合使用完成其功能。

Master流程

是一個多執行緒的程式。其中有一組很重要的線程，稱為Reactor線程。它就是真正處理TCP連接，收發資料的線程。

Manager進程

管理worker/task進程。 worker/task進程都是由Manager進程Fork並管理的。

Reactor線程

主線程(Master進程)在Accept新的連接後，會將這個連接分配給一個固定的Reactor線程，並由這個線程負責監聽此socket。在socket可讀時讀取數據，並進行協定解析，將請求投遞到Worker進程。

• 負責維護客戶端TCP連線、處理網路IO、處理協定、收發資料

• 完全是非同步非阻塞的模式

• 全部為C程式碼，除Start/Shudown 事件回調外，不執行任何PHP代碼

• 將TCP客戶端發送的資料緩衝、拼接、分割成完整的一個請求數據套件

• Reactor以多執行緒的方式運行

Work進程

類似與php- fpm進程。

• 接受由Reactor執行緒投遞的請求資料包，並執行PHP回呼函數處理資料

• 產生回應資料並發給Reactor線程，由Reactor線程傳送給TCP客戶端

• ##可以是非同步模式，也可以是同步模式

• Worker以多進程的方式運行

TaskWorker進程

非同步處理其他任務的進程，使用方方式類似與Gearman。

• 接受由

  Worker進程透過swoole_server->task/taskwait方法投遞的任務

• ##處理任務，並將結果資料傳回(

  swoole_server->finish
)給

Worker

進程

##TaskWorker以多進程的方式運行關係可以理解為Reactor就是nginx，Worker就是php-fpm。 Reactor

執行緒非同步並行地處理網路請求，然後再轉送給

Worker進程中去處理(在回調函數中處理)。 Reactor和Worker

間透過

UnixSocket

進行通訊。

事件處理流程

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

Reactor模式

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

1. Proactor模式
   兩種實作
2. 使用I/O非同步模型實作Proactor模式。原理：將所有I/O操作交給主線程，主線程配合和核心來處理，業務邏輯操作就交給邏輯單元。例如使用aio_read來實作。
   工作流程：

3. 主執行緒呼叫aio_read函數向核心註冊socket上的讀取完成事件。

4. 主執行緒繼續處理其他I/O事件。

5. 當socket上的資料被讀入使用者緩衝區後，核心向應用程式(邏輯單元)發送一個訊號，通知應用程式資料可用。

6. 應用程式讀取資料(客戶端的請求)，處理完後，呼叫aio_write函數向核心註冊socket上的寫事件。

7. 主執行緒繼續處理其他邏輯。

當使用者緩衝區的資料寫入socket後，核心向應用程式發送一個訊號，通知應用程式資料發送完畢。

1. 應用程式預先定義好的訊號處理函數來處理善後處理，例如關閉socket.

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

3. 主執行緒往epoll核心事件表中註冊socket上的讀取就緒事件。 ############主執行緒呼叫epoll_wait等待socket上有資料可讀。 ############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)。

每個模組的工作請回顧上面的結構介紹。

相關推薦：

如何自訂一個Model？ ThinkPHP3.2自訂基底類別Model的用法

如何用PHP讀取excel檔案內容、取得儲存格資料

#

以上是swoole的架構分析的詳細內容。更多資訊請關注PHP中文網其他相關文章！