Swoole多任務處理中心 如果你還不會用swoole就out了，swoole通往大神之路——swoole任務中心說明及進程任務架構搭建 教學視頻： www.bilibili.com/video/av779… 一、進程的基本知識 什麼是進程，所謂進程其實就是操作系統中一個正在運行的程式，我們在一個終 ...
Swoole多任務處理中心
如果你還不會用swoole就out了，swoole通往大神之路——swoole任務中心說明及進程任務架構搭建
教學視頻：
一、進程的基本知識
什麼是進程，所謂進程其實就是操作系統中一個正在運行的程式，我們在一個終端當中，通過php，運行一個php文件，這個時候就相當於我們創建了一個進程，這個進程會在系統中駐存，申請屬於它自己的記憶體空間系統資源並且運行相應的程式
對於一個進程來說，它的核心內容分為兩個部分，一個是它的記憶體，這個記憶體是這進程創建之初從系統分配的，它所有創建的變數都會存儲在這一片記憶體環境當中
一個是它的上下文環境我們知道進程是運行在操作系統的，那麼對於程式來說，它的運行依賴操作系統分配給它的資源，操作系統的一些狀態。
在操作系統中可以運行多個進程的，對於一個進程來說，它可以創建自己的子進程，那麼當我們在一個進程中創建出若幹個子進程的時候那麼可以看到如圖，子進程和父進程一樣，擁有自己的記憶體空間和上下文環境
二、進程間通訊
進程間通信（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個參數又不夠的時候，它會截斷這個消息，並且不報錯。
