PHP swoole (3.多进程)

文档: 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使用情况.

• 若需要一个守护进程, 传值会变得比较复杂.