首頁  >  文章  >  後端開發  >  swoole事件處理流程

swoole事件處理流程

little bottle
little bottle轉載
2019-04-26 15:50:222341瀏覽

本篇文章的主要內容是關於對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事件處理流程的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述:
本文轉載於:cnblogs.com。如有侵權,請聯絡admin@php.cn刪除