swoole多進程

版權聲明：只要有樹葉飛舞的地方,火就會燃燒,火的影子照耀着村子,新的樹葉就會發芽。 https://blog.csdn.net/koastal/article/details/52871316
多個任務同時執行

    將順序執行的任務，轉化爲並行執行（任務在邏輯上能夠並行執行）

好比，咱們要對已知的用戶數據進行判斷，是否須要發送郵件和短信，若是須要發送則發送。

不使用多進程時，咱們首先判斷是否發送郵件，若是須要則發送；而後再判斷是否須要發送短信，若是須要則發送。若是發送郵件耗時2s，發送短信耗時2s，那麼咱們完成任務大概須要4s左右的時間。

若是咱們使用多線程的話，能夠開兩個線程，一個用於處理郵件，一個用於處理短信，則耗時一共須要2s左右，處理時間縮短了一半。

<?php
/**
 * Created by PhpStorm.
 * User: zhezhao
 * Date: 2016/10/20
 * Time: 10:37
 */
$info = array(
    "sendmail"=>1,
    "mailto"=>"12345@qq.com",
    "sendsms"=>1,
    "smsto"=>"123456"
);
echo "start:".date("Y-m-d H:i:s").PHP_EOL;
$mail_process = new swoole_process('sendMail',true);
$mail_process->start();
$sms_process = new swoole_process('sendSMS',true);
$sms_process->start();
//主進程輸出子進程範圍內容
echo $mail_process->read();
echo PHP_EOL;
echo $sms_process->read();
echo PHP_EOL;
echo "end:".date("Y-m-d H:i:s").PHP_EOL;
//並行函數
function sendMail(swoole_process $worker){
    global $info;
    if($info['sendmail']==1){
        sleep(2);
        $worker->write("send mail to ".$info['mailto']);
    }
}
function sendSMS(swoole_process $worker){
    global $info;
    if($info['sendmail']==1){
        sleep(2);
        $worker->write("send sms to ".$info['smsto']);
    }
}

 

這裏寫圖片描述
大任務劃分紅多個小任務

    將循環執行的任務，劃分爲多個進程執行，提升工做效率

假設咱們如今有一個經過curl抓取網頁內容的需求，須要抓取10個網頁，url地址經過數組讀取，每一個curl耗時2s。若是咱們經過for循環來抓取這10個網頁，須要耗時20s，使用多進程咱們能夠將任務劃分紅5份，分別由5個進程執行，每一個進程抓取2個url，併發執行，共耗時4s，效率提升5倍。

<?php
/**
 * Created by PhpStorm.
 * User: zhezhao
 * Date: 2016/10/20
 * Time: 10:51
 */
$url_arr = array();
for ($i=0;$i<10;$i++){
    $url_arr[] = "www.baidu.com?wd=".$i;
}
echo "start:".date("Y-m-d H:i:s").PHP_EOL;
$workers = array();
for ($i=0;$i<5;$i++){
    $process = new swoole_process('getContents',true);
    $process->start();
    $process->write($i);
    $workers[] = $process;
}
//主進程數據結果
foreach ($workers as $process){
    echo $process->read();
    echo PHP_EOL;
}
echo "end:".date("Y-m-d H:i:s").PHP_EOL;
function getContents(swoole_process $worker){
    $i = $worker->read();
    global $url_arr;
    $res1 = execCurl($url_arr[($i*2)]);
    $res2 = execCurl($url_arr[($i*2+1)]);
    echo $res1.PHP_EOL.$res2;
}
function execCurl($url){
    sleep(2);
    return "handle ".$url." finished";
}

   

這裏寫圖片描述
總結

以上兩種狀況，本質上都是將邏輯上沒有前後關係的任務，用多個進程程併發執行，提升效率。

php機制自己不提供多線程的操做，ptcl擴展提供了php操做linux多進程的接口。

我的感受swoole的多進程process方法更加方便一些。

關於二者的比較：http://wiki.swoole.com/wiki/page/214.html