swoole通往大神之路——swoole任務中心說明及進程任務架構搭建

Swoole多任務處理中心

若是你還不會用swoole就out了，swoole通往大神之路——swoole任務中心說明及進程任務架構搭建

教學視頻：

www.bilibili.com/video/av779…

1、進程的基本知識

什麼是進程，所謂進程其實就是操做系統中一個正在運行的程序，咱們在一個終端當中，經過php，運行一個php文件，這個時候就至關於咱們建立了一個進程，這個進程會在系統中駐存，申請屬於它本身的內存空間系統資源而且運行相應的程序

對於一個進程來講，它的核心內容分爲兩個部分，一個是它的內存，這個內存是這進程建立之初從系統分配的，它全部建立的變量都會存儲在這一片內存環境當中

一個是它的上下文環境咱們知道進程是運行在操做系統的，那麼對於程序來講，它的運行依賴操做系統分配給它的資源，操做系統的一些狀態。

在操做系統中能夠運行多個進程的，對於一個進程來講，它能夠建立本身的子進程，那麼當咱們在一個進程中建立出若干個子進程的時候那麼能夠看到如圖，子進程和父進程同樣，擁有本身的內存空間和上下文環境

 

2、進程間通信

進程間通訊（IPC，Inter-Process Communication），指至少兩個進程或線程間傳送數據或信號的一些技術或方法。每一個進程都有本身的一部分獨立的系統資源，彼此是隔離的。爲了能使不一樣的進程互相訪問資源並進行協調工做，纔有了進程間通訊。

進程通訊有以下的目的：

數據傳輸，一個進程須要將它的數據發送給另外一個進程，發送的數據量在一個字節到幾M之間；

共享數據，多個進程想要操做共享數據，一個進程對數據的修改，其餘進程應該馬上看到；

進程控制，有些進程但願徹底控制另外一個進程的執行（如Debug進程），此時控制進程但願可以攔截另外一個進程的全部異常，並可以及時知道它的狀態改變。

系統進行進程間通訊（IPC）的時候，可用的方式包括管道、命名管道、消息隊列、信號、信號量、共享內存、套接字(socket)等形式。

2.1消息隊列

消息隊列實際上就是一個鏈表，而消息就是鏈表中具備特定格式和優先級的記錄，對消息隊列有寫權限的進程能夠根據必定規則在消息鏈表中添加消息，對消息隊列有讀權限的進程則能夠從消息隊列中得到所需的信息。

在某個進程往一個消息隊列寫入消息以前，並不須要另外某個進程在該隊列上等待消息的到達。對於消息隊列來講，除非顯式刪除，不然其一直存在

php實現消息隊列操做

在php中經過這兩句話就能夠建立一個消息隊列。 ftok 函數，是能夠將一個路徑轉換成消息隊列可用的key值。 msg_get_queue函數的第一個參數 是消息隊列的key，第二個參數是消息隊列的讀寫權限，這個權限跟文件相似

msg_send函數，向指定消息隊列寫入信息。

msg_send ( resource $queue , int $msgtype , mixed $message [, bool $serialize = true [, bool $blocking = true [, int &$errorcode ]]] )

第1個參數 ： resource $queue 表示要寫入的消息隊列資源。

第2個參數 ： int $msgtype 表示寫入消息隊列的 消息類型，這個參數是 配合 msg_receive讀取消息隊列函數 使用的，下面會說。

第3個參數 ： mixed $message 你要發送的信息，最大爲 65536 個字節。

第4個參數 ： bool $serialize = true 爲可選項，是否序列化你發送的消息。

第5個參數 ： bool $blocking = true 是否阻塞，當你發送的消息很大，而此時的消息隊列沒法存入的時候，此時消息隊列就會阻塞，除非等到有別的進程從消息隊列中讀取了別的消息，而後消息隊列有足夠的空間存儲你要發送的信息，才能繼續執行。你能夠設置這個參數爲false，這樣你發送信息就會失敗，此時錯誤信息會在 第6個參數 $errorcode中體現，錯誤碼爲 MSG_EAGAIN ，你能夠根據這個錯誤碼，從新發送你的消息。

第6個參數 ： int &$errorcode 記錄寫入中出現的一系列錯誤。

讀取函數 msg_receive

msg_receive ( resource $queue , int $desiredmsgtype , int &$msgtype , int $maxsize , mixed &$message [, bool $unserialize = true [, int $flags = 0 [, int &$errorcode ]]] )

第1個參數：resource $queue 表示要讀取的消息隊列資源。

第2個參數 ：int $desiredmsgtype 讀取的消息類型。這個參數爲 0 的時候，你能夠讀取 msg_send 以任意 消息類型 發送的消息。 若是此參數和你發送的某個消息類型相同，好比你有 2個消息，一個是經過 1類型發送的，一個是經過2 類型發送的。你用 0 能夠接收這兩種消息 ，而你用 1 只能接收到 以1類型發送的消息。

第3個參數 ： int &$msgtype 你讀取到的信息，它發送時的消息類型會存儲在該參數中。

第4個參數 ： int $maxsize 你以多大的字節去讀取消息，若是這個值小於你要讀取的內容的長度，你會讀取失敗。

第5個參數 ：mixed &$message 讀取的內容。

第6個參數 ： bool $unserialize = true 內容是否序列化

第7個參數 ：int $flags = 0 讀取標識。除了默認的0 以外，還有3個參數可選 MSG_IPC_NOWAIT 這個參數表示若是沒有從消息隊列中讀取到信息，會立馬返回，並返回錯誤碼 MSG_ENOMSG.

MSG_EXCEPT 這個參數 是配合 第2個參數使用的，若是使用這個參數，你讀取到的第一個參數，不是你第一個發送的參數。(隊列先進先出)

MSG_NOERROR 若是讀取的內容過大，而你指定的第4個參數又不夠的時候，它會截斷這個消息，而且不報錯。

銷燬消息隊列的方法 ：

msg_remove_queue($msg_queue);