首页 > 语言 > PHP > 正文

PHP多进程并发控制的测试用例

2024-09-04 11:50:12
字体：大 中 小
来源：转载
供稿：网友

　　[文章作者：张宴 本文版本：v1.0 最后修改：2007.11.16 转载请注明出处：http://blog.s135.com]

　　最近遇到一个问题，Linux下的PHP命令行程序作为守护进程，需要从队列文件中读一行数据，通过TCP协议发送给外地的接收服务器，再读下一行数据，再发送。当本地与外地的网络状况不好时，有时候发送一条数据所耗费的时间就较长，累积起来容易造成队列堵塞和延迟。

　　于是，我准备用该PHP命令行程序生成多个子进程，将串行处理变成并行处理。最简单的方法就是在PHP中用exec()或popen()函数将一个shell命令行推到后台去执行，例如：

<?php
exec("/bin/sh /opt/zhangyan.sh &");
?>
　　最后的&表示将shell脚本推到后台去执行。

　　但是这样会有一个问题，如果推到后台的进程太多，可能会导致服务器系统资源耗尽而崩溃，所以必须控制进程数量。


　　我写了一个PHP程序（/opt/zhangyan.php）、一个shell程序（/opt/zhangyan.sh）作为测试用例。

　　程序的逻辑：
　　1、设置/opt/zhangyan.php最多允许生成500个子进程；
　　2、当/opt/zhangyan.php读取到一条数据后，将允许生成的子进程数减1（空闲进程数$p_number=500-1=499），然后将数据交给/opt/zhangyan.sh去后台处理，不等待/opt/zhangyan.sh处理结束，继续读取下一条数据；
　　3、当允许生成的子进程数减至0时（空闲进程数$p_number=0），/opt/zhangyan.php会等待1秒钟，然后检查后台还有多少个/opt/zhangyan.sh子进程尚未处理结束；
　　4、如果1秒钟之后/opt/zhangyan.php发现后台的/opt/zhangyan.sh子进程数还是500（空闲进程数$p_number=0），会继续等待1秒钟，如此反复；
　　5、如果/opt/zhangyan.php发现后台尚未处理结束的/opt/zhangyan.sh子进程数减少到300个了（空闲进程数$p_number=500-300=200），那么/opt/zhangyan.php会再往后台推送200个/opt/zhangyan.sh子进程；


/opt/zhangyan.php代码如下：
  1. <?php   
  2. function run($input)   
  3. {   
  4.     global $p_number;   
  5.     if ($p_number <= 0)   
  6.     {   
  7.         $p_number = worker_processes($p_number);   
  8.     }   
  9.     $p_number = $p_number - 1;   
  10.     $out = popen("/bin/sh /opt/zhangyan.sh ""{$input}"" &", "r");   
  11.     pclose($out);   
  12. }   
  13.   
  14. function worker_processes($p_number)   
  15. {   
  16.     $limit = 500;//允许推到后台的最大进程数   
  17.     while ($p_number <= 0)   
  18.     {   
  19.         $cmd = popen("ps -ef | grep ""/opt/zhangyan.sh"" | grep -v grep | wc -l", "r");   
  20.         $line = fread($cmd, 512);   
  21.         pclose($cmd);   
  22.         $p_number = $limit - $line;   
  23.         if ($p_number <= 0)   
  24.         {   
  25.             sleep(1);//暂停1秒钟   
  26.         }   
  27.     }   
  28.     return $p_number;   
  29. }   
  30.   
  31. $input = "http://blog.s135.com"; //模拟从队列文件中读取到的数据   
  32. for ($i = 1; $i <= 1000; $i++)   
  33. {   
  34.     run($input);   
  35.     echo "Idle process number: " . $p_number . "";   
  36. }   
  37. ?>  
　　（/opt/zhangyan.php程序用来模拟从队列文件中读取1000行数据，交给子进程/opt/zhangyan.sh去处理。）


/opt/zhangyan.sh代码如下：
  1. #!/bin/sh   
  2. echo $(date -d "today" +"%Y-%m-%d %H:%M:%S") $1 >> /opt/zhangyan.log   
  3. sleep_time=$(expr $RANDOM % 4 + 1)   
  4. sleep $sleep_time  
　　（/opt/zhangyan.sh脚本用来模拟向外地接收服务器发送数据。其中的$(expr $RANDOM % 4 + 1)用来生成1～5之间的随机数，用来使程序暂停1～5秒钟。暂停1秒表示网络状况好，发送数据顺畅；暂停2～6秒表示网络状况不好，发送过程需要1～5秒。）


　执行程序：
/usr/local/php/bin/php /opt/zhangyan.php

　（/usr/local/php/bin/php因PHP解析器所在的路径）

　查看/opt/zhangyan.sh打下的日志文件的第一行和最后一行：
head -n 1 /opt/zhangyan.log
　2007-11-16 07:54:13 http://blog.s135.com
tail -n 1 /opt/zhangyan.log
　2007-11-16 07:54:18 http://blog.s135.com

　　可以看出，500进程并发处理这1000条数据只耗费5秒钟。而按照原来的串行模式，处理每条数据即使只耗费最短的1秒钟，也需要1000秒，约合16分钟才能完成。


　PS：将PHP程序作为Linux守护进程的方法：
nohup /usr/local/php/bin/php /opt/zhangyan.php 2>&1 > /dev/null &

　（nohup命令可以在用户退出终端后仍然执行程序，“2>&1 > /dev/null”表示不显示标准输出和错误输出，最后的&表示推到后台执行。）

上一篇：总结下现在我知道的php生成静态页面的办法

下一篇：PHP实现页面GZIP压缩输出

发表评论 共有条评论
用户名: 密码:
验证码: 匿名发表
学习交流
更多

如何查找有故障的配件

如何查找有故障的配件...
热门图片
更多
猜你喜欢的新闻
猜你喜欢的关注

新闻热点

最牛同桌！我考了696分我同桌考了703分
2024-06-26 22:28:41
650分！高二女生考入北大：遗憾不能上高三
2024-06-26 22:26:16
男生估分600只考了397 妈妈：高考虽重要，但不代表所有
2024-06-26 22:23:01
唐尚珺回应是否会直播带货：有人出100万想和他合作！
2024-06-25 19:29:23
名校抢人名场面：清华、北大太拼了！
2024-06-25 19:22:14
男生高考语文满分！网友：第一次听说
2024-06-25 19:19:15

疑难解答

图片精选

网友关注

关于本站 - 网上投稿 - 商务合作 - 隐私政策 - 网站地图
Copyright © 2008 - 2024 VEVB.COM. All Rights Reserved.武林网 版权所有