个人中心
gpt4 book ai didi

php获取后台Job管理的实现代码

转载 作者：qq735679552 更新时间：2022-09-29 22:32:09 25 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章php获取后台Job管理的实现代码由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

代码如下

<?php defined('SYSPATH') OR die('No direct access allowed.');  class Controller_Jobs extends Controller_Base{  public function before(){  parent::before();  if(Request::$protocol != "cli"){  die("Only cli allowed!\n");  }  }  public function after(){  parent::after();  //do some cleaning tasks  }  private function _execJobCommand($joburi,$paras){  $php_exec = Kohana::config("picsou.php_exec");  $php_index = APPINDEX;  $command_args = array();  $command_args[] = $php_index;  $command_args[] = "--uri=".$joburi;  foreach ($paras as $para => $value){  $command_args[] = "--".$para."=".$value;  }  //var_dump($command_args);exit;  echo "exec commmand:".$php_exec."\n";  pcntl_exec($php_exec,$command_args);  }  /*  * Running jobs in queues  */  public function action_run(){  $requestCount = 0;  while(true){  $sql = "select * from job_queue where status='1' and approved='1' order by id";  $jobs = DB::query(Database::SELECT,$sql)->execute()->as_array();  if($jobs){  foreach ($jobs as $job){  $requestCount ++;  //update the jobs status as running  DB::update('job_queue')->set(array('status'=>'2'))  ->where('id','=',$job['id'])->execute();  $job_pid = pcntl_fork();  if($job_pid == -1){  die("Could not fork Child");  } else if($job_pid == 0 ){  $this->_execJobCommand($job['job_uri'],json_decode($job['paras'],true));  echo "finish Child\n";  exit(0);  //run jobs here  } else{  echo "Waiting for job\n";  ob_flush();  $child_pid = pcntl_waitpid($job_pid,$status, WUNTRACED);  echo "waitpid end:".$status."\n";  if($status == 0){  //job completed  DB::update('job_queue')->set(array('status'=>'999'))  ->where('id','=',$job['id'])->execute();  echo "Child Finished\n";  ob_flush();  }else{  DB::update('job_queue')->set(array('status'=>'-1'))  ->where('id','=',$job['id'])->execute();  echo "Child Failed\n";  ob_flush();  }  }  }  }  else{  if($requestCount >=10){  echo "Have a rest, I have processed 10 jobs\n";  exit;  }  //no job to run  //echo "No job\n";  ob_flush();  sleep(5);  }  }  }  }  。

最后此篇关于php获取后台Job管理的实现代码的文章就讲到这里了,如果你想了解更多关于php获取后台Job管理的实现代码的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

25 4 0
文章推荐： php中使用Akismet防止垃圾评论的代码
文章推荐： php中通过虚代理实现延迟加载的实现代码
文章推荐： php下通过curl抓取yahoo boss 搜索结果的实现代码
文章推荐： PHP缩略图等比例无损压缩，可填充空白区域补充色
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
全站热门文章
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com