拿什么守護你-PHP程序級守護進程的實現與優化


首先需要解釋的是什么是守護進程。

守護進程就是在后台一直運行的進程。比如我們啟動的httpd,mysqld等進程都是常駐內存內運行的程序。

針對需求進行分析:

需求:有一個常駐隊列messageQueue(假設在redis內存中),這個隊列會有可能有請求不定期的往隊列中增加元素。同時我們要求在隊列中有元素的時候,按照隊列順序將元素pop出來,並進行處理(假設這個處理只是echo ‘test’);

解決方法:

現在假設已經有了兩個函數

function oPopMessageQueue(){ …} //獲取隊列最后一個元素;

function vDealElement($element) { …} 處理元素;

要求寫出一個守護程序,完成上面的需求。

程序:

好了,這個程序很容易想到,可以使用while循環來做

while(true)
{
	if( $element  = oPopMessageQueue())
	{
		vDealElement($element);
	}	
}

考慮1 : 這個程序如果一直跑的話已經可以滿足上面的需求了.

但是考慮到:1 用php進程跑有可能會由於各種情況(比如運行時間過長),進程掛了,這樣程序就無法自動重連了.

方法:使用cron

我們在定時腳本中每10分鍾起一個進程跑這個程序。

然后設置這個程序的運行時間為10分鍾,10分鍾后自動取消,於是代碼變成

while(true)
{
	if($element = oPopMessageQueue())
	{
		vCheckTimeLimit();
		vDealElement($elemnt);
	}
}

$timeStart = 0;
function vCheckTimeLimit()
{
	global $timeStart;
	if(empty($timeStart))
	{
		$timeStart = time();
	}	
	
	if(time() - $timeStart > 60*10)
	{
		exit;
	}
}
 
考慮2,可能會有這種需求: 需要有隨時讓腳本暫停的功能:
於是考慮使用文件來增加暫停功能
while(true)
{
	if($element = oPopMessageQueue())
	{
		vCheckTimeLimit();
		vCheckEnd();
		vDealElement($elemnt);
	}
}


function vCheckEnd()
{
	if(file_exists("/home/JesephYe/end"))
	{
		exit;
	}
}
考慮3, 是否可以改成多線程的程序,讓運行的效率更高?
這個只要把cron的10分鍾起一個進程的限制改成每1分鍾起一個進程就好了
這樣能保證有10個線程在運行程序
但是有一個基本要求是:oPopMessageQueue()是一個原子操作

    ----------------------

作者:yjf512(軒脈刃)

出處:http://www.cnblogs.com/yjf512/

本文版權歸yjf512和cnBlog共有,歡迎轉載,但未經作者同意必須保留此段聲明


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM