当前位置:首页 > PHP > 正文内容

php windows多进程,php windows创建多进程,

高老师5年前 (2020-08-06)PHP1435

本人在windows下创建多进程的研究,唯一缺点,主进程所在终端关闭则所有子进程全部关闭。原理是通过proc_open创建多进程,通过环境变量识别父子进程,还能通过proc_open进行父子进程通信

<?php
namespace EasyTask;

use \Exception as Exception;

/**
 * Class Wpc
 * @package EasyTask
 */
class Wpc
{
    /**
     * 进程实例
     * @var resource
     */
    private $instance = null;

    /**
     * 环境变量
     * @var null
     */
    private $env = null;

    /**
     * 进程管道
     * @var null
     */
    private $pipes = [];

    /**
     * 进程工作目录
     * @var null
     */
    private $workDir = null;

    /**
     * 进程文件
     * @var null
     */
    private $filename = '';

    /**
     * 进程执行参数
     * @var null
     */
    private $argument = '';

    /**
     * 标准输入输出描述符
     * @var array
     */
    private $stdStruct = [];

    /**
     * 设置环境变量
     * @param array $env
     * @return $this
     */
    public function setEnv($env)
    {
        $this->env = $env;
        return $this;
    }

    /**
     * 设置进程文件
     * @param string $filename
     * @return $this
     * @throws Exception
     */
    public function setFile($filename)
    {
        $filename = realpath($filename);
        if (!file_exists($filename))
        {
            throw new Exception("the file:{$filename} is not exist");
        }
        $this->filename = $filename;
        return $this;
    }

    /**
     * 设置进程参数
     * @param string $argument
     * @return $this
     */
    public function setArgument($argument)
    {
        $argument = (string)$argument;
        $this->argument = $argument;
        return $this;
    }

    /**
     * 设置进程工作目录
     * @param string $path
     * @return $this
     * @throws Exception
     */
    public function setWorkDir($path)
    {
        $path = realpath($path);
        if (!is_dir($path))
        {
            throw new Exception("the path:{$path} is not exist");
        }
        $this->workDir = $path;
        return $this;
    }

    /**
     * 设置标准输入输出文件描述符
     * @param array $struct
     * @return $this
     */
    public function setStdStruct($struct)
    {
        $this->stdStruct = $struct;
        return $this;
    }

    /**
     * 获取进程ID
     * @return int|false
     */
    public function getPid()
    {
        if (is_resource($this->instance))
        {
            $status = proc_get_status($this->instance);

            return !empty($status['pid']) ? $status['pid'] : false;
        }

        return false;
    }

    /**
     * 获取程是否正在运行
     * @return bool
     */
    public function getIsRunning()
    {
        if (is_resource($this->instance))
        {
            $status = proc_get_status($this->instance);

            return !empty($status['running']) ? $status['running'] : false;
        }

        return false;
    }

    /**
     * 启动进程
     * @return int 进程id
     * @throws
     */
    public function start()
    {
        if (!$this->stdStruct)
        {
            throw new Exception('Please set the file descriptor');
        }
        $this->instance = proc_open("$this->filename $this->argument", $this->stdStruct, $this->pipes, $this->workDir, $this->env, ['bypass_shell' => true]);
        if (!$this->instance)
        {
            throw new Exception('failed to create process through proc_open');
        }

        return $this->getPid();
    }

    /**
     * 停止进程
     * @param bool $force 是否强制退出
     */
    public function stop($force = false)
    {
        if (is_resource($this->instance))
        {
            $this->closePipes();
            if (!$force)
            {
                proc_close($this->instance);
            }
            else
            {
                proc_terminate($this->instance);
            }
        }
    }

    /**
     * 关闭管道
     */
    private function closePipes()
    {
        if (is_resource($this->instance))
        {
            foreach ($this->pipes as $pipe)
            {
                if (is_resource($pipe))
                {
                    fclose($pipe);
                }
            }
        }
    }
}

扫描二维码推送至手机访问。

版权声明:本文由高久峰个人博客发布,如需转载请注明出处。

本文链接:https://blog.20230611.cn/post/147.html

分享给朋友:

“php windows多进程,php windows创建多进程,” 的相关文章

php守护进程

php守护进程

<?php /**  * daemonize让当前脚本为守护进程执行  * @param string $callback 匿名函数  */ function daemonize($callback) {...

php jsonp转json,php jsonp转数组,php jsonp转对象

php jsonp转json,php jsonp转数组,php jsonp转对象

将jsonp转为PHP数组和对象。/**  * jsonp转数组|Jsonp转json  * @param string $jsonp jsonp字符串  * @param bool $as...

 php转换文本编码,php字符编码转换,php编码转换

php转换文本编码,php字符编码转换,php编码转换

整理一个自己用的编码转换方法,不需要知道原字符串的编码,只需要传入字符串,和你想要转换的编码。/**  * 编码转换  * @param string $char  * @param string $...

php交换变量,php交换两个变量的值,php交换2个变量

php交换变量,php交换两个变量的值,php交换2个变量

上代码:<?php $a = 'gao'; $b = 'liu'; echo "交换前: {$a}  {$b}".PHP_EOL; //进行交换 list($...

php去除html标签,php strip_tags

php去除html标签,php strip_tags

最近在采集文章内容时需要对文章提取前100个字符串作为文章摘要,但是输出带有html标签,使用php去除即可。<?php echo strip_tags("Hello <b>world!</b>"); ?>strip_tag...