php如何使用多进程
更新:HHH   时间:2023-1-7


这篇文章给大家分享的是有关php如何使用多进程的内容。小编觉得挺实用的,因此分享给大家做个参考,一起跟随小编过来看看吧。

  1. 代码:

    <?php
    /**
    * @desc:多进程处理任务类
    * @author [Lee] <[<complet@163.com>]>
    */
    class process{
    public $num = 10;  #  进程数
    public $timeout = 4;  #  延迟时间
    public $pipedir = "pipe/";  #  管道目录
    public $logdir = "log/";  #  日志目录
    public $errlog = "err.log";  #  错误日志
    public $successlog = "success.log";  #  成功日志
    /*
     @desc:构造方法,创建相关目录,检察是否支持扩展
     */
    public function __construct(){
        $pipedir = $this->pipedir;
        $logdir = $this->logdir;
        if(!is_dir($pipedir)){
            if(!mkdir($pipedir)){
                $this->write_log(1,"创建管道目录{$pipedir}失败");
            }
        }
        if(!is_dir($logdir)){
            if(!mkdir($logdir)){
                $this->write_log(1,"创建日志目录{$logdir}失败");
            }
        }
        if (!function_exists('pcntl_fork')) {
            $this->write_log(1,'未安装pcntl扩展');
            exit;
        }
    }
    /*
     @desc:内部方法,写日志
     @param type 日志类型 1错误日志 2成功日志
     @param msg 日志消息 
     */
    private function write_log($type,$msg){
        $logdir = $this->logdir;
        $errlog = $this->errlog;
        $successlog = $this->successlog;
        $prelog = date('Y-m-d H:i:s').":";
        if($type == 1){
            $logname = $logdir.$errlog;
        }else{
            $logname = $logdir.$successlog;
        }
        file_put_contents($logname,$prelog.$msg.PHP_EOL,FILE_APPEND);
    }
    /*
     @desc:主方法,执行程序
     @param name 执行命令的回调函数
     */
    public function run($name){
        $num = $this->num;
        $timeout = $this->timeout;
        $pipedir = $this->pipedir;
        $pipefile = $pipedir.posix_getpid();
        if (!posix_mkfifo($pipefile, 0666)) {
            $this->write_log(1,"创建管道文件{$pipefile}失败");
            exit;
        }
        #  处理任务
        for ($i = 0; $i < $num; ++$i ) {
            $cpid = pcntl_fork();  #  创建子进程
            if ($cpid == 0) {
                #  子进程过程
                call_user_func($name,$i);
                $pw = fopen($pipefile, 'w');
                fwrite($pw, $i."\n");  #  当前任务处理完比,在管道中写入数据
                fclose($pw);
                exit(0);  #  执行完后退出
            }
        }
        #  父进程
        $pr = fopen($pipefile, 'r');
        stream_set_blocking($pr, FALSE);  #  将管道设置为非堵塞,用于适应超时机制
        $pdata = '';  #  存放管道中的数据
        $sline = 0;  #  成功执行的进程数量
        $stime = time();
        while ($sline < $num && (time() - $stime) < $timeout) {
            $tline = fread($pr, 1024);
            if (empty($tline)) {
                continue;   
            }
            #  用于分析多少任务处理完毕,通过'\n'标识
            foreach(str_split($tline) as $v) {
                if ("\n" == $v) {
                    ++$sline;
                }
            }
            $pdata .= $tline;
        }
        $this->write_log(2,"总共{$sline}个任务执行成功");
        fclose($pr);
        unlink($pipefile);  #  删除管道,已经没有作用了
        #  等待子进程执行完毕,避免僵尸进程
        $n = 0;
        while ($n < $num) {
            $status = -1;
            $cpid = pcntl_wait($status, WNOHANG);
            if ($cpid > 0) {
                $this->write_log(2,"进程{$cpid}执行结束");
                ++$n;
            }
        }
        #  验证结果,主要查看结果中是否每个任务都完成了
        $arr = array();
        foreach(explode("\n", $pdata) as $i) {
            if (is_numeric(trim($i))) {
                array_push($arr, $i);  
            }
        }
        $arr = array_unique($arr);
        if ( count($arr) == $num) {  
            $this->write_log(2,var_export($arr,true));
        } else {
            $this->write_log(1,"执行成功数量:".count($arr));
            $this->write_log(1,"执行成功的线程:".var_export($arr,true));
        }
    }
    }
  2. 测试:

    $process = new process();
    $process->num = 5;  #  修改进程数为5
    $process->run('todo');
    /*
    @desc:真实处理业务的方法
    @param pid 进程id
    */
    function todo($pid){
    $num = 19;  #  总任务数
    $anum = ceil($num/5);  #  平均每个进程处理任务数
    $lnum = $num - $anum*(5-1);  #  最后一个进程处理任务数
    $minnum = $anum*$pid;  #  当前进程处理的最小值
    $maxnum;  #  当前进程处理的最大值
    if($pid<(5-1)){
        $maxnum = $minnum + $anum;
    }else{
        $maxnum = $num;
    }
    for($i=$minnum;$i<$maxnum;$i++){
        echo "进程号:{$pid};输出:{$i}".PHP_EOL;
    }
    }
  3. 输出:

    进程号:1;输出:4
    进程号:1;输出:5
    进程号:1;输出:6
    进程号:1;输出:7
    进程号:2;输出:8
    进程号:2;输出:9
    进程号:2;输出:10
    进程号:2;输出:11
    进程号:3;输出:12
    进程号:3;输出:13
    进程号:3;输出:14
    进程号:3;输出:15
    进程号:4;输出:16
    进程号:4;输出:17
    进程号:4;输出:18
    进程号:0;输出:0
    进程号:0;输出:1
    进程号:0;输出:2
    进程号:0;输出:3

感谢各位的阅读!关于“php如何使用多进程”这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,让大家可以学到更多知识,如果觉得文章不错,可以把它分享出去让更多的人看到吧!

返回web开发教程...