PHP怎么限制定时任务的进程数量
这篇文章主要介绍PHP怎么限制定时任务的进程数量,文中介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们一定要看完!
可能存在的问题
当我们处理大量数据的时候,脚本的执行时间可能很长,或者重复处理某条数据(写错的情况下)。
为了避免数据的重复处理、运行脚本过多导致服务器压力过大等问题,我们需要限制脚本的运行数量。
如何做
思路一
查询某种标识的进程数量,如果超过一定数量,则直接退出,不处理。
思路二
记录每次的PID,可以使用 文件、redis、memcached 等来存储。
当启动一个新进程的时候,去查一下这个标识下面有哪些PID,是否还在运行,且与当前标识有关系。
当超过一定数量的时候,直接退出,不处理。
实践
思路一实践
这里通过 linux 的 ps、grep、wc 的命令来获取指定标识的运行进程数。
<?phpfunction canRun($ident, $maxNum){ $cmd = sprintf('ps ax | grep %s | grep -v /bin/sh | grep -v grep | wc -l', $ident); $fp = @popen($cmd, 'r'); $num = (int)trim(@fread($fp, 2096)); @pclose($fp); return $num <= $maxNum;}
思路二实践
这里使用 redis 存储 pid 信息。
通过 /proc/{pid}/cmdline 文件检测指定进程是否还在运行。
<?phpfunction isSurvive($pid, $ident){ // 获取指定pid的cmdline文件 $cmdlinePath = sprintf('/proc/%s/cmdline', $pid); if (!is_file($cmdlinePath)) { return false; } $cmdline = trim(file_get_contents($cmdlinePath)); // 检查标识是否在 cmdline 中 return strpos($cmdline, $ident) !== false;}function canRun($ident, $maxNum){ // 假设已经链接上 $redisHandler = getRedis(); // 定义一个key $key = sprintf('php:job:%s:pid', $ident); // 当前的PID $currentPid = getmypid(); // 将当前的PID写入redis $redis->sAdd($key, $currentPid); // 获取redis中的所有pid $pids = $redis->sMembers($key); // 遍历pid,检查是否有效 foreach ($pids as $index => $pid) { if ($currentPid == $pid) { continue; } // 检查 pid 是否还在运行中 if (isSurvive($pid, $ident)) { continue; } // 若不再运行,则直接删除 unset($pids[$index]); $redis->sRemove($key, $pid); } return count($pids) <= $maxNum;}
关于标识
关于标识,可能我们在运行一些定时脚本的时候,统一的部分可能就是 php 了;或者,拥有相同标识的脚本,我们要归为几类。
为了能够实现这些需求,我们可以通过 php 的内置函数 cli_set_process_title 来实现自定义 COMMAND。
demo.php:
这个时候,我们运行 demo.php,然后通过 ps ax 可以看到如下结果:
PID USER TIME COMMAND 1 root 0:09 php-fpm: master process (/usr/local/etc/php-fpm.conf) 7 root 0:16 php-fpm: pool www 8 root 0:15 php-fpm: pool www 9 root 0:14 php-fpm: pool www 10 root 0:00 sh 663 root 0:00 sh 690 root 0:00 {php} Job Demo 691 root 0:00 ps ax
修改指定脚本的进程标题,我们就可以实现定义某些脚本的标识了。
以上是“PHP怎么限制定时任务的进程数量”这篇文章的所有内容,感谢各位的阅读!希望分享的内容对大家有帮助,更多相关知识,欢迎关注编程网行业资讯频道!
免责声明:
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341