swoole多程序

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

多個任務同時執行

    将順序執行的任務，轉化為并行執行（任務在邏輯上可以并行執行）

比如，我們要對已知的使用者資料進行判斷，是否需要發送郵件和短信，如果需要發送則發送。

不使用多程序時，我們首先判斷是否發送郵件，如果需要則發送；然後再判斷是否需要發送短信，如果需要則發送。如果發送郵件耗時2s，發送短信耗時2s，那麼我們完成任務大概需要4s左右的時間。

如果我們使用多線程的話，可以開兩個線程，一個用于處理郵件，一個用于處理短信，則耗時一共需要2s左右，處理時間縮短了一半。

<?php

$info = array(

    "sendmail"=>1,

    "mailto"=>"[email protected]",

    "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

$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

參考文章：

https://segmentfault.com/a/1190000002946586

---------------------

作者：koastal

來源：CSDN

原文：https://blog.csdn.net/koastal/article/details/52871316

版權聲明：本文為部落客原創文章，轉載請附上博文連結！

轉載于:https://www.cnblogs.com/hoewang/p/10257187.html