从proc_open()打开的两个进程说起

起因

最近工作不太紧张，于是看起了《PHP Reactive Programming》这本书，其中举了个Chat Server的例子。

这是一个Cli App，默认启动一个Server Manager，根据Stdin的输入进行Chat Server的创建，Server Manager建立一个Unix Socket Server，其创建的Chat Server通过连接Socket Server与Server Manager进行状态通信；而Chat Server监听服务器的某个指定端口，创建一个WebSocket Server；其他客户端通过连接这个WebSocket Server进行Chat动作，而Chat Server会实时将在线、聊天数量上报给Server Manager。

用的当然是书中提到的Reactive Programming，使用了PHP的stream族函数进行非阻塞编程。

其中，由于之前对黄旭说过的socketpair比较感兴趣，所以详细看了一下Server Manager创建Chat Server的部分。

这一部分采用了symfony/process组件，对Chat Server的创建并不是通过fork的方式进行的，而是通过proc_open进行的。

之后，参照proc_open()文档中给的例子，在不同的机器上实验了一下，这就试出了毛病。

问题

<?php
$descriptorspec = array(
   0 => array("pipe", "r"),  // stdin is a pipe that the child will read from
   1 => array("pipe", "w"),  // stdout is a pipe that the child will write to
   2 => array("file", "/tmp/error-output.txt", "a") // stderr is a file to write to
);

$cwd = '/tmp';
$env = array('some_option' => 'aeiou');

$process = proc_open('sleep 100', $descriptorspec, $pipes, $cwd, $env);

if (is_resource($process)) {
    // $pipes now looks like this:
    // 0 => writeable handle connected to child stdin
    // 1 => readable handle connected to child stdout
    // Any error output will be appended to /tmp/error-output.txt

    fwrite($pipes[0], '<?php print_r($_ENV); ?>');
    fclose($pipes[0]);

    echo stream_get_contents($pipes[1]);
    fclose($pipes[1]);

    // It is important that you close any pipes before calling
    // proc_close in order to avoid a deadlock
    $return_value = proc_close($process);

    echo "command returned $return_value\n";
}