PHP多進(jìn)程并發(fā)控制的測(cè)試用例

2024-09-04 11:50:12

字體：大中小

供稿：網(wǎng)友

　　[文章作者：張宴本文版本：v1.0 最后修改：2007.11.16 轉(zhuǎn)載請(qǐng)注明出處：http://blog.s135.com]

　　最近遇到一個(gè)問題，Linux下的PHP命令行程序作為守護(hù)進(jìn)程，需要從隊(duì)列文件中讀一行數(shù)據(jù)，通過TCP協(xié)議發(fā)送給外地的接收服務(wù)器，再讀下一行數(shù)據(jù)，再發(fā)送。當(dāng)本地與外地的網(wǎng)絡(luò)狀況不好時(shí)，有時(shí)候發(fā)送一條數(shù)據(jù)所耗費(fèi)的時(shí)間就較長(zhǎng)，累積起來容易造成隊(duì)列堵塞和延遲。

　　于是，我準(zhǔn)備用該P(yáng)HP命令行程序生成多個(gè)子進(jìn)程，將串行處理變成并行處理。最簡(jiǎn)單的方法就是在PHP中用exec()或popen()函數(shù)將一個(gè)shell命令行推到后臺(tái)去執(zhí)行，例如：

<?php
exec("/bin/sh /opt/zhangyan.sh &");
?>

　　最后的&表示將shell腳本推到后臺(tái)去執(zhí)行。

　　但是這樣會(huì)有一個(gè)問題，如果推到后臺(tái)的進(jìn)程太多，可能會(huì)導(dǎo)致服務(wù)器系統(tǒng)資源耗盡而崩潰，所以必須控制進(jìn)程數(shù)量。

　　我寫了一個(gè)PHP程序（/opt/zhangyan.php）、一個(gè)shell程序（/opt/zhangyan.sh）作為測(cè)試用例。

　　程序的邏輯：
　　1、設(shè)置/opt/zhangyan.php最多允許生成500個(gè)子進(jìn)程；
　　2、當(dāng)/opt/zhangyan.php讀取到一條數(shù)據(jù)后，將允許生成的子進(jìn)程數(shù)減1（空閑進(jìn)程數(shù)$p_number=500-1=499），然后將數(shù)據(jù)交給/opt/zhangyan.sh去后臺(tái)處理，不等待/opt/zhangyan.sh處理結(jié)束，繼續(xù)讀取下一條數(shù)據(jù)；
　　3、當(dāng)允許生成的子進(jìn)程數(shù)減至0時(shí)（空閑進(jìn)程數(shù)$p_number=0），/opt/zhangyan.php會(huì)等待1秒鐘，然后檢查后臺(tái)還有多少個(gè)/opt/zhangyan.sh子進(jìn)程尚未處理結(jié)束；
　　4、如果1秒鐘之后/opt/zhangyan.php發(fā)現(xiàn)后臺(tái)的/opt/zhangyan.sh子進(jìn)程數(shù)還是500（空閑進(jìn)程數(shù)$p_number=0），會(huì)繼續(xù)等待1秒鐘，如此反復(fù)；
　　5、如果/opt/zhangyan.php發(fā)現(xiàn)后臺(tái)尚未處理結(jié)束的/opt/zhangyan.sh子進(jìn)程數(shù)減少到300個(gè)了（空閑進(jìn)程數(shù)$p_number=500-300=200），那么/opt/zhangyan.php會(huì)再往后臺(tái)推送200個(gè)/opt/zhangyan.sh子進(jìn)程；

/opt/zhangyan.php代碼如下：

<?php
function run($input)
{
global $p_number;
if ($p_number <= 0)
{
$p_number = worker_processes($p_number);
}
$p_number = $p_number - 1;
$out = popen("/bin/sh /opt/zhangyan.sh ""{$input}"" &", "r");
pclose($out);
}
function worker_processes($p_number)
{
$limit = 500;//允許推到后臺(tái)的最大進(jìn)程數(shù)
while ($p_number <= 0)
{
$cmd = popen("ps -ef | grep ""/opt/zhangyan.sh"" | grep -v grep | wc -l", "r");
$line = fread($cmd, 512);
pclose($cmd);
$p_number = $limit - $line;
if ($p_number <= 0)
{
sleep(1);//暫停1秒鐘
}
}
return $p_number;
}
$input = "http://blog.s135.com"; //模擬從隊(duì)列文件中讀取到的數(shù)據(jù)
for ($i = 1; $i <= 1000; $i++)
{
run($input);
echo "Idle process number: " . $p_number . "";
}
?>

　　（/opt/zhangyan.php程序用來模擬從隊(duì)列文件中讀取1000行數(shù)據(jù)，交給子進(jìn)程/opt/zhangyan.sh去處理。）

/opt/zhangyan.sh代碼如下：

#!/bin/sh
echo $(date -d "today" +"%Y-%m-%d %H:%M:%S") $1 >> /opt/zhangyan.log
sleep_time=$(expr $RANDOM % 4 + 1)
sleep $sleep_time

　　（/opt/zhangyan.sh腳本用來模擬向外地接收服務(wù)器發(fā)送數(shù)據(jù)。其中的$(expr $RANDOM % 4 + 1)用來生成1～5之間的隨機(jī)數(shù)，用來使程序暫停1～5秒鐘。暫停1秒表示網(wǎng)絡(luò)狀況好，發(fā)送數(shù)據(jù)順暢；暫停2～6秒表示網(wǎng)絡(luò)狀況不好，發(fā)送過程需要1～5秒。）

　執(zhí)行程序：

/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進(jìn)程并發(fā)處理這1000條數(shù)據(jù)只耗費(fèi)5秒鐘。而按照原來的串行模式，處理每條數(shù)據(jù)即使只耗費(fèi)最短的1秒鐘，也需要1000秒，約合16分鐘才能完成。

　PS：將PHP程序作為L(zhǎng)inux守護(hù)進(jìn)程的方法：

nohup /usr/local/php/bin/php /opt/zhangyan.php 2>&1 > /dev/null &

　（nohup命令可以在用戶退出終端后仍然執(zhí)行程序，“2>&1 > /dev/null”表示不顯示標(biāo)準(zhǔn)輸出和錯(cuò)誤輸出，最后的&表示推到后臺(tái)執(zhí)行。）

上一篇：總結(jié)下現(xiàn)在我知道的php生成靜態(tài)頁面的辦法

下一篇：PHP實(shí)現(xiàn)頁面GZIP壓縮輸出