PHP swoole (3.多进程)

2017-06-01 本文已影响538人 Separes

文档: https://wiki.swoole.com/wiki/search/?q=process

关于进程的概念不再赘述.
话不多说,直接上code,然后再做说明:

// Father进程所引用的回调函数
function FatherProcessCallback(swoole_process $o_process)
{
    // 约定创建进程总数
    $i_num_processes = 5;
    // 设置观察变量
    $i_flag = 1;
    for ($i = 0; $i < $i_num_processes; $i++) {
        // 创建Chlidren进程
        $ChildrenProcess = new swoole_process('ChildrenProcessCallback');

        // 使用read/write在父进程与子进程间进行管道通信
        $ChildrenProcess->write($i_flag);

        // // 使用投递消息队列的方式在进程间传递数据
        // $ChildrenProcess->useQueue();
        // $ChildrenProcess->push($i_flag);

        $i_process_id = $ChildrenProcess->start();
        echo($i_process_id . PHP_EOL);
        $i_flag++;
    }
}
// Chlidren进程所引用的回调函数
function ChildrenProcessCallback(swoole_process $o_process)
{
    // 设置五秒等待时间,便于观察
    sleep(5);
    // 管道通信
    $s_recv = $o_process->read();
    // // 消息队列
    // $s_recv = $o_process->pop();
    echo ($s_recv . PHP_EOL);
}

// 创建Father进程
$FatherProcess = new swoole_process('FatherProcessCallback');
$i_process_id = $FatherProcess->start();

说明:

注释已经写的很详细,不再逐行说明;
write/read:
推荐使用这种方式通信,效率很高.
使用write/read管道内存通信方式时,write/read的大小并不一致.
write时$data的长度在Linux系统下最大不超过8K，MacOS/FreeBSD下最大不超过2K;
而read时$buffer_size是缓冲区的大小，默认为8192，最大不超过64K;
详见文档:
write: https://wiki.swoole.com/wiki/page/216.html
read: https://wiki.swoole.com/wiki/page/217.html
push/pop:
消息队列的通信方式,$data长度受限与操作系统内核参数的限制。默认为8192，最大不超过65536, push和pop默认相同;
默认为阻塞模式,非阻塞模式时会立即返回false;
详见文档:
push: https://wiki.swoole.com/wiki/page/290.html
pop: https://wiki.swoole.com/wiki/page/291.html
需要注意的是,在本例中,为了便于描述,特地将父进程与子进程分开封装,但其实demo本身也可以看作一个父进程对象.
子进程不会被全局变量(global variable)所影响,也无法通过常规方式传参,这点要和function的概念区分开来.
swoole_process本质上是pcntl的替代品,理论上效率很高,但是创建进程所需的资源开销很大,所以需要谨慎使用.
子进程会继承父进程的内存和IO句柄, 即子进程会保持父进程的内存和资源, 那么由此可以联想到许多针对cache的玩法 :)
区别与pthreads, 关于pthreads再另行研究.
可使用 vmstat 查询进程及memory使用情况.
若需要一个守护进程, 传值会变得比较复杂.

PHP swoole (3.多进程)

猜你喜欢

热点阅读