php如何使用多进程

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

创新互联服务项目包括双滦网站建设、双滦网站制作、双滦网页制作以及双滦网络营销策划等。多年来，我们专注于互联网行业，利用自身积累的技术优势、行业经验、深度合作伙伴关系等，向广大中小型企业、政府机构等提供互联网行业的解决方案，双滦网站推广取得了明显的社会效益与经济效益。目前，我们服务的客户以成都为中心已经辐射到双滦省份的部分城市，未来相信会继续扩大服务区域并继续获得客户的支持与信任！

1. 代码：

   ]>
   */
   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如何使用多进程”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，让大家可以学到更多知识，如果觉得文章不错，可以把它分享出去让更多的人看到吧！