画江湖之 PHP 多进程开发 [监控子进程防止意外中断]
监控的目的
- 想知道子进程的退出状态
- 想自动重启
核心函数
pcntl_wait 等待或返回fork的子进程状态(任意)
等同 pcntl_waitpid(-1, $status, 0) 都是等待任意子进程
pcntl_wtermsig 返回导致子进程中断的信号
代码演示
<?php
echo "Master process id = " . posix_getpid() . PHP_EOL;
$childs = [];//定义一个全局的子进程收集数组
function fork() {//定义一个fork子进程函数
global $childs;
$pid = pcntl_fork();//fork 一个子进程
switch ($pid) {
case -1:
die('Create failed');
break;
case 0:
// Child
echo "Child process id = " . posix_getpid() . PHP_EOL;
while (true) {//死循环 执行任务
sleep(5);
}
break;
default:
// Parent
$childs[$pid] = $pid;//主进程 记录子进程的进程id
break;
}
}
$count = 3;//fork 3个子进程
for ($i = 0; $i < $count; $i++) {
fork();
}
while ( count($childs) ) {//监控
if ( ($exit_id = pcntl_wait($status)) > 0 ) {//如果有子进程意外中断了
echo "Child({$exit_id}) exited.\n";
echo "中断子进程的信号值是 " . pcntl_wtermsig($status) . PHP_EOL;//输出中断的信号量
unset($childs[$exit_id]);//把中断的子进程的进程id 剔除掉
}
if ( count($childs) < 3 ) {//如果子进程的进程数量小于规定的数量
fork();//重新开辟一个子进程
}
}
echo "Done\n";
本作品采用《CC 协议》,转载必须注明作者和本文链接
推荐文章: