摘要：首先，確保安裝的版本大于實(shí)例說明本例里待消費(fèi)的是三個(gè)命令，會(huì)分別創(chuàng)建一個(gè)子進(jìn)程來消費(fèi)。通過管道發(fā)數(shù)據(jù)到子進(jìn)程。，重定向子進(jìn)程的標(biāo)準(zhǔn)輸入和輸出。

swoole_process 是swoole提供的進(jìn)程管理模塊，用來替代PHP的pcntl擴(kuò)展。

首先，確保安裝的swoole版本大于1.7.2：

$ php --ri swoole

swoole

swoole support => enabled
Version => 1.10.1

本例里待消費(fèi)的是三個(gè)shell命令，會(huì)分別創(chuàng)建一個(gè)子進(jìn)程來消費(fèi)。消費(fèi)的時(shí)候故意sleep了1秒，以便直觀看到效果。

process_t1.php

start();
    $process->write($cmd); //通過管道發(fā)數(shù)據(jù)到子進(jìn)程。管道是單向的：發(fā)出的數(shù)據(jù)必須由另一端讀取。不能讀取自己發(fā)出去的

    echo $rec = $process->read();//同步阻塞讀取管道數(shù)據(jù)
}

//子進(jìn)程創(chuàng)建成功后要執(zhí)行的函數(shù)
function my_process(swoole_process $worker){
    sleep(1);//暫停1s

    $cmd = $worker->read();

    // $return = exec($cmd);//exec只會(huì)輸出命令執(zhí)行結(jié)果的最后一行內(nèi)容，且需要顯式打印輸出

    ob_start();
    passthru($cmd);//執(zhí)行外部程序并且顯示未經(jīng)處理的、原始輸出，會(huì)直接打印輸出。
    $return = ob_get_clean();
    if(!$return) $return = "null";
    
    $worker->write($return);//寫入數(shù)據(jù)到管道
}

//子進(jìn)程結(jié)束必須要執(zhí)行wait進(jìn)行回收，否則子進(jìn)程會(huì)變成僵尸進(jìn)程
while($ret = swoole_process::wait()){// $ret 是個(gè)數(shù)組 code是進(jìn)程退出狀態(tài)碼，
    $pid = $ret["pid"];
    echo PHP_EOL."Worker Exit, PID=" . $pid . PHP_EOL;
}

$end_time = microtime(TRUE);
echo sprintf("use time:%.3f s
", $end_time - $start_time);

命令行里運(yùn)行：

$ php process_t1.php  

Linux
Sat Apr 21 15:29:55 CST 2018
root

Worker Exit, PID=672

Worker Exit, PID=674

Worker Exit, PID=676
use time:3.080 s

大家會(huì)覺得很奇怪，為什么開了三個(gè)子進(jìn)程，還是用了3秒，應(yīng)該是1秒左右才對呀。

原因是父進(jìn)程讀取子進(jìn)程返回的數(shù)據(jù)的時(shí)候，是同步阻塞讀取:

 echo $rec = $process->read();//同步阻塞讀取管道數(shù)據(jù)

導(dǎo)致的后果就是父進(jìn)程依次等待每個(gè)進(jìn)程處理完并返回了內(nèi)容，才走下一次循環(huán)。

解決方案1：
使用swoole_event_add將管道加入到事件循環(huán)中，變?yōu)楫惒侥Ｊ剑?/p>

// echo $rec = $process->read();//同步阻塞讀取管道數(shù)據(jù)

//使用swoole_event_add將管道加入到事件循環(huán)中，變?yōu)楫惒侥Ｊ?swoole_event_add($process->pipe, function($pipe) use($process) {
    echo $rec = $process->read();
    
    swoole_event_del($process->pipe);//socket處理完成后，從epoll事件中移除管道
});

執(zhí)行結(jié)果：

Worker Exit, PID=686

Worker Exit, PID=687

Worker Exit, PID=688
use time:1.060 s
Linux
Sat Apr 21 15:37:14 CST 2018
root

大家會(huì)發(fā)現(xiàn)，use time數(shù)據(jù)并不是最后打印出來的。已經(jīng)是異步的了。 實(shí)際執(zhí)行時(shí)間1s左右。

解決方案2：
先不獲取子進(jìn)程返回值，循環(huán)結(jié)束后統(tǒng)一返回：

foreach ($cmds as $cmd) {
    $process = new swoole_process( "my_process", true);

    $process->start();
    $process->write($cmd); //通過管道發(fā)數(shù)據(jù)到子進(jìn)程

    $process_arr[] = $process;
}

foreach ($process_arr as $process){
    echo $rec = $process->read();
}

執(zhí)行結(jié)果：

Linux
Sat Apr 21 15:52:24 CST 2018
root

Worker Exit, PID=694

Worker Exit, PID=693

Worker Exit, PID=695
use time:1.061 s

swoole_process::__construct(callable $function, $redirect_stdin_stdout = false, $create_pipe = true);

第一個(gè)參數(shù)是子進(jìn)程創(chuàng)建成功后要執(zhí)行的函數(shù)。
$redirect_stdin_stdout，重定向子進(jìn)程的標(biāo)準(zhǔn)輸入和輸出。啟用此選項(xiàng)后，在子進(jìn)程內(nèi)輸出內(nèi)容將不是打印屏幕，而是寫入到主進(jìn)程管道（例如用echo打印的內(nèi)容也寫入管道）。讀取鍵盤輸入將變?yōu)閺墓艿乐凶x取數(shù)據(jù)。默認(rèn)為阻塞讀取。
$create_pipe，是否創(chuàng)建管道，啟用$redirect_stdin_stdout后，此選項(xiàng)將忽略用戶參數(shù)，強(qiáng)制為true。如果子進(jìn)程內(nèi)沒有進(jìn)程間通信，可以設(shè)置為 false

注意：swoole_process在最新的1.8.0版本已經(jīng)禁止在Web環(huán)境中使用了，所以也只能支持命令行。這時(shí)候如果要做并發(fā)，multi-curl是不錯(cuò)的選擇。

如果跑的服務(wù)需要一直常駐后臺(tái)，可以在$process->start();前面加上：

swoole_process::daemon();

服務(wù)會(huì)在后臺(tái)運(yùn)行。

 $url) {
    $process = new swoole_process(function(swoole_process $worker) use ($url){
        $code = getHttpCode($url);
        $worker->write($code);
    }, true);
    $process->start();

    swoole_event_add($process->pipe, function($pipe) use($process, $url) {
        echo sprintf("%s code: %s
", $url, $process->read());
        swoole_event_del($pipe);
    });
}

echo "ok.
";

while($ret = swoole_process::wait()){
    // echo PHP_EOL."Worker Exit, PID=" . $ret["pid"] . PHP_EOL;
}

/**
 * 獲取網(wǎng)頁http code
 */
function getHttpCode($url){
    $ch = curl_init();
    curl_setopt($ch, CURLOPT_URL, $url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
    curl_setopt($ch, CURLOPT_HEADER, 0);
//        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "HEAD");
    curl_setopt($ch, CURLOPT_NOBODY, true);
    curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); //不驗(yàn)證證書
    curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false); //不驗(yàn)證證書
    curl_setopt ($ch, CURLOPT_TIMEOUT_MS, 1000);//超時(shí)時(shí)間
    curl_exec($ch);
    $info = curl_getinfo($ch);
    curl_close($ch);

    return (string)$info["http_code"];
}

運(yùn)行：

$ php process_get.php
ok.
http://www.52fhy.com code: 403
http://www.52fhy.com/1 code: 404
https://www.baidu.com code: 200
https://www.52fhy.com code: 403
 

push($url.": ".$code);
    }
    $worker->push("exit");
}, false, false); //不創(chuàng)建管道
$process->useQueue(1, 2); //使用消息隊(duì)列。消息隊(duì)列通信方式與管道不可共用。消息隊(duì)列不支持EventLoop，使用消息隊(duì)列后只能使用同步阻塞模式非阻塞
$process->start();

while(1){
    $ret = $process->pop();
    if($ret == "exit") break;
    echo sprintf("%s
", $ret);
}

echo "ok.
";

while($ret = swoole_process::wait()){
    echo PHP_EOL."Worker Exit, PID=" . $ret["pid"] . PHP_EOL;
}

/**
 * 獲取網(wǎng)頁http code
 */
function getHttpCode($url){
   //省略
}

運(yùn)行：

$ php process_get_queue.php
https://www.baidu.com: 200
http://www.52fhy.com: 403
http://www.52fhy.com/1: 404
https://www.52fhy.com: 403
ok.

Worker Exit, PID=1222

1、Process
https://wiki.swoole.com/wiki/...
2、swoole_process->read
https://wiki.swoole.com/wiki/...