jyxiaozhi.taobao.com php는 백그라운드 작업 관리 구현 코드를 얻습니다.

复aze代码 代码如下:

class Controller_Jobs는 Controller_Base를 확장합니다{
public function before(){
parent::before();
if(요청::$protocol != "cli"){
die("cli만 허용됩니다!n");
}
}
공용 함수 after(){
parent::after();
//정리 작업 수행
}
private function _execJobCommand($joburi,$paras){
$php_exec = Kohana::config("picsou.php_exec");
$php_index = APPINDEX;
$command_args = 배열();
$command_args[] = $php_index;
$command_args[] = "--uri=".$joburi;
foreach($paras를 $para => $value로){
$command_args[] = "--".$para."=".$value;
}
//var_dump($command_args);exit;
echo "실행 명령:".$php_exec."n";
pcntl_exec($php_exec,$command_args);
}
/*
* 대기열에서 작업 실행
*/
공용 함수 action_run(){
$requestCount = 0;
while(true){
$sql = "상태='1'이고 승인='1'인 job_queue에서 *를 선택하여 ID별 주문";
$jobs = DB::query(Database::SELECT,$sql)->execute()->as_array();
if($jobs){
foreach($jobs를 $job으로){
$requestCount ;
//실행 중인 작업 상태 업데이트
DB::update('job_queue')->set(array('status'=>'2'))
->where(' id','=',$job['id'])->execute();
$job_pid = pcntl_fork();
if($job_pid == -1){
die("자식을 포크할 수 없습니다.");
} else if($job_pid == 0 ){
$this->_execJobCommand($job['job_uri'],json_decode($job['paras'],true));
echo "마침 어린이";
출구(0);
//여기서 작업 실행
} else{
echo "작업 대기 중";
ob_flush();
$child_pid = pcntl_waitpid($job_pid,$status, WUNTRACED);
echo "waitpid end:".$status."n";
if($status == 0){
//작업 완료
DB::update('job_queue')->set(array('status'=>'999'))
->where('id','=',$job['id'])->execute();
echo "하위 완료n";
ob_flush();
}else{
DB::update('job_queue')->set(array('status'=>'-1'))
->where('id',' =',$job['id'])->execute();
echo "하위 실패n";
ob_flush();
}
}
}
}
else{
if($requestCount >=10){
echo "푹 쉬세요. 작업 10개를 처리했습니다n";
퇴장;
}
//실행할 작업이 없습니다.
//echo "No jobn";
ob_flush();
수면(5);
}
}
}
}

以上就介绍了jyxiaozhi.taobao.com php获取后台Job管理的实现代码，包括了jyxiaozhi.taobao.com 内容，希望对PHP教程兴趣的朋友有所帮助。