電子發(fā)燒友App
PHP是一種易于學習和使用的服務器端腳本語言。只需要很少的編程知識你就能使用PHP建立一個真正交互的WEB站點。 PHP是能讓你生成動態(tài)網(wǎng)頁的工具之一。PHP網(wǎng)頁文件被當作一般HTML網(wǎng)頁文件來處理并且在編輯時你可以用編輯HTML的常規(guī)方法編寫PHP。本文為大家介紹php實現(xiàn)定時器任務方法。
基礎知識
此程序在Linux下開發(fā)，以cli模式運行，一下是基本知識的簡要介紹。
CLI：PHP的命令行模式，常見的WEB應用使用的是fpm；
進程：進程是程序運行的基本單元，進程之間是獨立運行且互不干擾的，有獨立的運行空間，每個進程都有一個進程控制塊；
進程間通信：既然進程是獨立運行，我們需要一種機制保證不同進程信息的交換，進程間通信主要包括：管道，IPC（共享內(nèi)存，信號，消息隊列），套接字；
PCNTL擴展：PHP的一個進程擴展，主要用到pcntl_alarm（）函數(shù)，詳細介紹請查閱官網(wǎng)。
實現(xiàn)原理
用一個三維數(shù)組保存所有需要執(zhí)行的任務，一級索引為時間戳，值為執(zhí)行任務的方法、回調(diào)參數(shù)等，具體數(shù)組形式如下：
array（
‘1438156396’ => array（
array（1，array（‘Class’，‘Func’）， array（）， true），
）
）
說明：
1438156396 時間戳
array（1，array（‘Class’，‘Func’）， array（）， true）
參數(shù)依次表示： 執(zhí)行時間間隔，回調(diào)函數(shù)，傳遞給回調(diào)函數(shù)的參數(shù)，是否持久化（ture則一直保存在數(shù)據(jù)中，否則執(zhí)行一次后刪除）
這些任務可以是任意類的方法。既然是定時任務，我們需要一個類似計時的東東，此方案采用信號量去做，每一秒向當前進程發(fā)送SIGALRM信號，并捕獲該信號，觸發(fā)信號處理函數(shù)，循環(huán)遍歷數(shù)據(jù)，判斷是否有當前時間需要執(zhí)行的任務。如果有則采用回調(diào)方式觸發(fā)，并把參數(shù)傳遞給該方法。
［php］ view plain copy<？php
/**
*定時器
*/
class Timer
{
//保存所有定時任務
public static $task = array（）;
//定時間隔
public static $time = 1;
/**
*開啟服務
*@param $time int
*/
public static function run（$time = null）
{
if（$time）
{
self：：$time = $time;
}
self：：installHandler（）;
pcntl_alarm（1）;
}
/**
*注冊信號處理函數(shù)
*/
public static function installHandler（）
{
pcntl_signal（SIGALRM， array（‘Timer’，‘signalHandler’））;
}
/**
*信號處理函數(shù)
*/
public static function signalHandler（）
{
self：：task（）;
//一次信號事件執(zhí)行完成后，再觸發(fā)下一次
pcntl_alarm（self：：$time）;
}
/**
*執(zhí)行回調(diào)
*/
public static function task（）
{
if（empty（self：：$task））
{//沒有任務，返回
return ;
}
foreach（self：：$task as $time => $arr）
{
$current = time（）;
foreach（$arr as $k => $job）
{//遍歷每一個任務
$func = $job［‘func’］; /*回調(diào)函數(shù)*/
$argv = $job［‘a(chǎn)rgv’］; /*回調(diào)函數(shù)參數(shù)*/
$interval = $job［‘interval’］; /*時間間隔*/
$persist = $job［‘persist’］; /*持久化*/
if（$current == $time）
{//當前時間有執(zhí)行任務
//調(diào)用回調(diào)函數(shù)，并傳遞參數(shù)
call_user_func_array（$func， $argv）;
//刪除該任務
unset（self：：$task［$time］［$k］）;
}
if（$persist）
{//如果做持久化，則寫入數(shù)組，等待下次喚醒
self：：$task［$current+$interval］［］ = $job;
}
}
if（empty（self：：$task［$time］））
{
unset（self：：$task［$time］）;
}
}
}
/**
*添加任務
*/
public static function add（$interval， $func， $argv = array（）， $persist = false）
{
if（is_null（$interval））
{
return;
}
$time = time（）+$interval;
//寫入定時任務
self：：$task［$time］［］ = array（‘func’=>$func， ‘a(chǎn)rgv’=>$argv， ‘interval’=>$interval， ‘persist’=>$persist）;
}
/**
*刪除所有定時器任務
*/
public function dellAll（）
{
self：：$task = array（）;
}
}
這是定時器類核心部分，有一個靜態(tài)變量保存有所有需要執(zhí)行的任務，這里為什么是靜態(tài)的呢？大家自行思考。當進程接受到 SIGALRM 信號后，觸發(fā) signalHandler 函數(shù)，隨后循序遍歷數(shù)組查看是否有當前時間需要執(zhí)行的任務，有則回調(diào)，并傳遞參數(shù)，刪除當前job，隨后檢查是否要做持久化任務，是則繼續(xù)將當前job寫入事件數(shù)組等待下次觸發(fā)，最后再為當前進程設置一個鬧鐘信號。可以看出這個定時器，只要觸發(fā)一次就會從內(nèi)部再次觸發(fā)，得到自循環(huán)目的。
［php］ view plain copy<？php
class DoJob
{
public function job（ $param = array（） ）
{
$time = time（）;
echo “Time： {$time}， Func： ”.get_class（）。“：：”.__FUNCTION__.“（”.json_encode（$param）。“）\n”;
}
}
這是回調(diào)類及函數(shù)，為方便說明，加入不少調(diào)試信息.Timer類及回調(diào)都有了，我們看看使用場景是怎么樣的。［php］ view plain copy<？php
require_once（__DIR__.“/Timer.php”）;
require_once（__DIR__.“/DoJob.php”）;
Timer：：dellAll（）;
Timer：：add（ 1， array（‘DoJob’，‘job’）， array（），true）;
Timer：：add（ 3， array（‘DoJob’，‘job’），array（‘a(chǎn)’=>1）， false）;
echo “Time start： ”.time（）。“\n”;
Timer：：run（）;
while（1）
{
sleep（1）;
pcntl_signal_dispatch（）;
}
代碼非常短，這里注冊了兩個job，隨后運行定時器，在一個無限循環(huán)里捕捉信號觸發(fā)動作，如果不捕獲將無法觸發(fā)事先注冊的處理函數(shù)。這樣一個自循環(huán)的定時器開發(fā)完成。運行結果如下：
如我們場景類添加的任務一樣，在90的時候執(zhí)行了兩個任務，一個為持久化的不帶參數(shù)的job，一個為非持久化帶參數(shù)的job，隨后非持久化job不再執(zhí)行。
總結
1、在收到信號前，當前進程不能退出。這里我使用了條件永遠為真的循環(huán)。在我們實際生產(chǎn)環(huán)境中，需要創(chuàng)造這么一個先決條件，比如說，我們有一組服務，這些服務都是一直運行的，不管是IO訪問，等待socket鏈接等等，當前服務都不會終止，即使進程阻塞也不會有問題，這種場景，也就是有一個一直運行的服務中使用。
2、目前PHP只支持以秒為單位的觸發(fā)，不支持更小時間單位，對位定時任務而言基本足夠
工商網(wǎng)監(jiān)
評論