swoole事件處理模式有哪些

這篇文章給大家分享的是有關swoole事件處理模式有哪些的內容。小編覺得挺實用的，因此分享給大家做個參考。一起跟隨小編過來看看吧。

了解swoole事件處理流程，先了解兩種網(wǎng)絡事件處理模式。

Reactor模式

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

Proactor模式

兩種實現(xiàn)

使用I/O異步模型實現(xiàn)Proactor模式。原理：將所有I/O操作都交給主線程，主線程配合和內核來處理，業(yè)務邏輯操作就交給邏輯單元。例如使用aio_read來實現(xiàn)。

工作流程：

1. 主線程調用aio_read函數(shù)向內核注冊socket上的讀完成事件。
2. 主線程繼續(xù)處理其他I/O事件。
3. 當socket上的數(shù)據(jù)被讀入用戶緩沖區(qū)后，內核向應用程序(邏輯單元)發(fā)送一個信號，通知應用程序數(shù)據(jù)可用。
4. 應用程序讀取數(shù)據(jù)(客戶端的請求)，處理完后，調用aio_write函數(shù)向內核注冊socket上的寫事件。
5. 主線程繼續(xù)處理其他邏輯。
6. 當用戶緩沖區(qū)的數(shù)據(jù)寫入socket后，內核向應用程序發(fā)送一個信號，通知應用程序數(shù)據(jù)發(fā)送完畢。
7. 應用程序預先定義好的信號處理函數(shù)來處理善后處理，比如關閉socket.

使用I/O同步模型實現(xiàn)Proactor模式。原理：主線程執(zhí)行I/O事件數(shù)據(jù)的讀寫操作，業(yè)務邏輯操作就交給邏輯單元。例如使用epoll來實現(xiàn)。

工作流程：

1. 主線程往epoll內核事件表中注冊socket上的讀就緒事件。
2. 主線程調用epoll_wait等待socket上有數(shù)據(jù)可讀。
3. epoll_wait有返回后，主線程從socket上讀取數(shù)據(jù)，然后將讀取到的數(shù)據(jù)封裝成一個請求對象(客戶端的請求)，并插入請求隊列。
4. 于是隊列的消費者線程處理請求對象，然后在epoll內核事件表中注冊socket上的寫就緒事件。
5. 主線程調用epoll_wait等待socket可寫。
6. 當socket可寫時，epoll_wait通知主線程。主線程往socket寫入請求結果。

swoole事件架構圖

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

一個請求經(jīng)歷的步驟如下:

1. 服務器主線程等待客戶端連接。

2. Reactor線程處理接連socket，讀取socket上的請求數(shù)據(jù)(Receive)，將請求封裝好后投遞給work進程。

3. Work進程就是邏輯單元，處理業(yè)務數(shù)據(jù)。

4. Work進程結果返回給Reactor線程。

5. Reactor線程將結果寫回socket(Send)。

感謝各位的閱讀！關于swoole事件處理模式有哪些就分享到這里了，希望以上內容可以對大家有一定的幫助，讓大家可以學到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到吧！