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