Swoole 編程須知

sleep/usleep的影響

在異步IO的程序中，不得使用sleep/usleep/time_sleep_until/time_nanosleep。（下文中使用sleep泛指所有睡眠函數(shù)）

• sleep函數(shù)會(huì)使進(jìn)程陷入睡眠阻塞
• 直到指定的時(shí)間后操作系統(tǒng)才會(huì)重新喚醒當(dāng)前的進(jìn)程
• sleep過(guò)程中，只有信號(hào)可以打斷
• 由于swoole的信號(hào)處理是基于signalfd實(shí)現(xiàn)的，所以即使發(fā)送信號(hào)也無(wú)法中斷sleep

swoole提供的swoole_event_add、swoole_timer_tick、swoole_timer_after、swoole_process::signal、異步swoole_client 在進(jìn)程sleep后會(huì)停止工作。swoole_server也無(wú)法再處理新的請(qǐng)求。

實(shí)例程序

$serv = new swoole_server("127.0.0.1", 9501);
$serv->on('receive', function ($serv, $fd, $from_id, $data) {
    sleep(100);
    $serv->send($fd, 'Swoole: '.$data);
});
$serv->start();

onReceive事件中執(zhí)行了sleep函數(shù)，server在100秒內(nèi)無(wú)法再收到任何客戶端請(qǐng)求。

exit/die函數(shù)的影響

在swoole程序中禁止使用exit/die，如果PHP代碼中有exit/die，當(dāng)前工作的Worker進(jìn)程、Task進(jìn)程、User進(jìn)程、以及swoole_process進(jìn)程會(huì)立即退出。

建議使用try/catch的方式替換exit/die，實(shí)現(xiàn)中斷執(zhí)行跳出PHP函數(shù)調(diào)用棧。

function swoole_exit($msg)
{
    //php-fpm的環(huán)境
    if (ENV=='php')
    {
        exit($msg);
    }
    //swoole的環(huán)境
    else
    {
        throw new Swoole\ExitException($msg);
    }
}

異常處理的方式比exit/die更友好，因?yàn)楫惓Ｊ强煽氐模?span style="font-family:Consolas, Liberation Mono, Courier, monospace;">exit/die不可控。在最外層進(jìn)行try/catch即可捕獲異常，僅終止當(dāng)前的任務(wù)。Worker進(jìn)程可以繼續(xù)處理新的請(qǐng)求，而exit/die會(huì)導(dǎo)致進(jìn)程直接退出，當(dāng)前進(jìn)程保存的所有變量和資源都會(huì)被銷毀。如果進(jìn)程內(nèi)還有其他任務(wù)要處理，遇到exit/die也將全部丟棄。

while循環(huán)的影響

異步程序如果遇到死循環(huán)，事件將無(wú)法觸發(fā)。異步IO程序使用Reactor模型，運(yùn)行過(guò)程中必須在reactor->wait處輪詢。如果遇到死循環(huán)，那么程序的控制權(quán)就在while中了，reactor無(wú)法得到控制權(quán)，無(wú)法檢測(cè)事件，所以IO事件回調(diào)函數(shù)也將無(wú)法觸發(fā)。

密集運(yùn)算的代碼不是阻塞

實(shí)例程序

$serv = new swoole_server("127.0.0.1", 9501);
$serv->on('receive', function ($serv, $fd, $from_id, $data) {
    while(1)
    {
        $i ++;
    }
    $serv->send($fd, 'Swoole: '.$data);
});
$serv->start();

onReceive事件中執(zhí)行了死循環(huán)，server在無(wú)法再收到任何客戶端請(qǐng)求，必須等待循環(huán)結(jié)束才能繼續(xù)處理新的事件。