swoole的process模塊建立和使用子進程

swoole中爲咱們提供了一個進程管理模塊 Process，替換PHP的 pcntl 擴展，方便咱們建立進程，管理進程，和進程間的通訊。

swoole提供了2種進程間的通訊：

一、基於 unix socket 的管道 pipe。

二、基於 sysvmsg 的消息隊列。

咱們能夠經過 new swoole_process() 快速的建立一個進程，默認會建立一個 SOCK_DGRAM 類型的管道，用於進程間的通訊，固然能夠設置成其餘類型，也能夠不建立。

1、經過同步阻塞管道進行進程間通訊

<?php

$worker_process_nums = 5;
$worker_process = [];

for ($i = 0; $i < $worker_process_nums; $i++) {
    //建立子進程
    //默認爲每一個子進程建立一個管道，若是不想建立設置$pipe_type參數爲false
    //注意管道默認是同步阻塞，半雙工，若是讀取不到數據就會阻塞
    $worker = new swoole_process(function (swoole_process $worker) {
        //注意，若是主進程中不寫數據write()，那麼子進程這裏read()就會阻塞
        $task = json_decode($worker->read(), true);

        //進行計算任務
        $tmp = 0;
        for ($i = $task['start']; $i < $task['end']; $i++) {
            $tmp += $i;
        }

        echo '子進程 PID : ', $worker->pid, ' 計算 ', $task['start'], ' - ', $task['end'], ' 結果 : ', $tmp, PHP_EOL;
        //往管道中寫入計算的結果
        $worker->write($tmp);
        //子進程退出
        $worker->exit();
    });

    //保存子進程
    $worker_process[$i] = $worker;

    //啓動子進程
    $worker->start();
}

//往每一個子進程管道中投遞任務
for ($i = 0; $i < $worker_process_nums; $i++) {
    $worker_process[$i]->write(json_encode([
        'start' => mt_rand(1, 10),
        'end' => mt_rand(50, 100),
    ]));
}

//父進程監聽子進程退出信號，回收子進程，防止出現殭屍進程
swoole_process::signal(SIGCHLD, function ($sig) {
    //必須爲false，非阻塞模式
    while ($ret = swoole_process::wait(false)) {
        echo "子進程 PID : {$ret['pid']} 退出\n";
    }
});

　　

2、經過 swoole_event_add 將管道設爲異步，來進行通訊

<?php

$worker_process_nums = 5;
$worker_process = [];

for ($i = 0; $i < $worker_process_nums; $i++) {
    $worker = new swoole_process(function ($worker) {
        //在子進程中給管道添加事件監聽
        //底層會自動將該管道設置爲非阻塞模式
        //參數二，是可讀事件回調函數，表示管道能夠讀了
        swoole_event_add($worker->pipe, function ($pipe) use ($worker) {
            $task = json_decode($worker->read(), true);

            $tmp = 0;
            for ($i = $task['start']; $i < $task['end']; $i++) {
                $tmp += $i;
            }
            echo "子進程 : {$worker->pid} 計算 {$task['start']} - {$task['end']} \n";
            //子進程把計算的結果，寫入管道
            $worker->write($tmp);
            //注意，swoole_event_add與swoole_event_del要成對使用
            swoole_event_del($worker->pipe);
            //退出子進程
            $worker->exit();
        });
    });

    $worker_process[$i] = $worker;

    //啓動子進程
    $worker->start();
}

for ($i = 0; $i < $worker_process_nums; $i++) {
    $worker = $worker_process[$i];

    $worker->write(json_encode([
        'start' => mt_rand(1, 10),
        'end' => mt_rand(50, 100),
    ]));

    //主進程中，監聽子進程管道事件
    swoole_event_add($worker->pipe, function ($pipe) use ($worker) {
        $result = $worker->read();
        echo "子進程 : {$worker->pid} 計算結果 {$result} \n";
        swoole_event_del($worker->pipe);
    });
}

//父進程監聽子進程退出信號，回收子進程，防止出現殭屍進程
swoole_process::signal(SIGCHLD, function ($sig) {
    //必須爲false，非阻塞模式
    while ($ret = swoole_process::wait(false)) {
        echo "子進程 PID : {$ret['pid']} 退出\n";
    }
});

　　

3、使用消息隊列來完成進程間通訊

<?php

$worker_process_nums = 5;
$worker_process = [];

for ($i = 0; $i < $worker_process_nums; $i++) {
    //注意，這裏將參數$pipe_type設爲false，表示不建立管道
    $worker = new swoole_process(function ($worker) {
        $task = json_decode($worker->pop(), true);

        $tmp = 0;
        for ($i = $task['start']; $i < $task['end']; $i++) {
            $tmp += $i;
        }
        echo "子進程 : {$worker->pid} 計算 {$task['start']} - {$task['end']} \n";
        $worker->push($tmp);
        $worker->exit();
    }, false, false);

    //使用消息隊列，做爲進程間的通訊
    //注意，消息隊列是共享的
    $worker->useQueue();

    $worker_process[$i] = $worker;

    //啓動子進程
    $worker->start();
}

for ($i = 0; $i < $worker_process_nums; $i++) {
    //只需用一個子進程發送消息便可，由於消息隊列是共享的
    $worker_process[0]->push(json_encode([
        'start' => mt_rand(1, 10),
        'end' => mt_rand(50, 100),
    ]));
}

//注意，這裏要暫停，防止加入隊列的任務，馬上被主進程讀出來。
sleep(1);

for ($i = 0; $i < $worker_process_nums; $i++) {
    $result = $worker_process[0]->pop();
    echo "計算結果 : {$result} \n";
}

//父進程監聽子進程退出信號，回收子進程，防止出現殭屍進程
swoole_process::signal(SIGCHLD, function ($sig) {
    //必須爲false，非阻塞模式
    while ($ret = swoole_process::wait(false)) {
        echo "子進程 PID : {$ret['pid']} 退出\n";
    }
});

　　

4、進程能夠經過 signal 監聽信號，和 alarm 設置定時器。

咱們能夠在父進程上設置監聽信號，當子進程退出時，從新掛起子進程。

也能夠設置定時器，經過 swoole_process::kill($pid, 0); 定時檢測進程是否存活。

<?php

//每隔1秒觸發SIGALAM信號
//注意，alarm不能和Timer同時使用
swoole_process::alarm(1000 * 1000, 0);

swoole_process::signal(SIGALRM, function ($signo) {
    static $cnt = 0;
    $cnt++;
    echo "時鐘定時信號\n";

    if ($cnt > 10) {
        //清除定時器
        swoole_process::alarm(-1);
    }
});

swoole_process::signal(SIGINT, function ($signo) {
    echo "我被ctrl+c了\n";

    //退出主進程，否則將一直沒法正常退出
    exit(0);
});