php – 将proc_open()获取的管道重定向到文件,以获取剩余的进程

理想情况下,我希望我的引导脚本：

>启动这项服务
>等待服务达到理想状态
>将控制权交给选择的单元测试框架来运行测试
>在测试结束时清理,适当地正常终止服务
>设置一些方法来捕获服务中的所有输出,以便进行日志记录和调试

我目前正在使用proc_open()来初始化我的服务,使用管道机制捕获输出,通过检查输出来检查服务是否达到了我需要的状态.

但是在这一点上我很难过 – 如何在脚本的剩余时间内捕获剩余的输出(包括STDERR),同时仍允许我的单元测试运行？

我可以想到一些可能冗长的解决方案,但在花时间调查它们之前,我想知道是否有其他人遇到过这个问题以及他们找到了什么解决方案,如果有的话,而不影响响应.

编辑：

这是我在我的引导脚本(使用新的ServiceRunner)初始化的类的缩减版本,供参考：

<?php


namespace Tests;


class ServiceRunner
{
    /**
     * @var resource[]
     */
    private $servicePipes;

    /**
     * @var resource
     */
    private $serviceProc;

    /**
     * @var resource
     */
    private $temp;

    public function __construct()
    {
        // Open my log output buffer
        $this->temp = fopen('php://temp','r+');

        fputs(STDERR,"Launching Service.n");
        $this->serviceProc      = proc_open('/path/to/service',[
            0 => array("pipe","r"),1 => array("pipe","w"),2 => array("pipe",],$this->servicePipes);

        // Set the streams to non-blocking,so stream_select() works
        stream_set_blocking($this->servicePipes[1],false);
        stream_set_blocking($this->servicePipes[2],false);

        // Set up array of pipes to select on
        $readables = [$this->servicePipes[1],$this->servicePipes[2]);

        while(false !== ($streams = stream_select($read = $readables,$w = [],$e = [],1))) {
            // Iterate over pipes that can be read from
            foreach($read as $stream) {
                // Fetch a line of input,and append to my output buffer
                if($line = stream_get_line($stream,8192,"n")) {
                    fputs($this->temp,$line."n");
                }

                // Break out of both loops if the service has attained the desired state
                if(strstr($line,'The Service is Listening' ) !== false) {
                    break 2;
                }

                // If the service has closed one of its output pipes,remove them from those we're selecting on
                if($line === false && feof($stream)) {
                    $readables = array_diff($readables,[$stream]);
                }
            }
        }

        /* SOLUTION REQUIRED SOLUTION REQUIRED SOLUTION REQUIRED SOLUTION REQUIRED */
        /* Set up the pipes to be redirected to $this->temp here */

        register_shutdown_function([$this,'shutDown']);
    }

    public function shutDown()
    {
        fputs(STDERR,"Closing...n");
        fclose($this->servicePipes[0]);
        proc_terminate($this->serviceProc,SIGINT);
        fclose($this->servicePipes[1]);
        fclose($this->servicePipes[2]);
        proc_close($this->serviceProc);
        fputs(STDERR,"Closed servicen");

        $logFile = fopen('log.txt','w');

        rewind($this->temp);
        stream_copy_to_stream($this->temp,$logFile);

        fclose($this->temp);
        fclose($logFile);
    }
}