电子发烧友App
PHP是一种易于学习和使用的服务器端脚本语言。只需要很少的编程知识你就能使用PHP建立一个真正交互的WEB站点。 PHP是能让你生成动态网页的工具之一。PHP网页文件被当作一般HTML网页文件来处理并且在编辑时你可以用编辑HTML的常规方法编写PHP。本文为大家介绍php实现定时器任务方法。
基础知识
此程序在Linux下开发，以cli模式运行，一下是基本知识的简要介绍。
CLI：PHP的命令行模式，常见的WEB应用使用的是fpm；
进程：进程是程序运行的基本单元，进程之间是独立运行且互不干扰的，有独立的运行空间，每个进程都有一个进程控制块；
进程间通信：既然进程是独立运行，我们需要一种机制保证不同进程信息的交换，进程间通信主要包括：管道，IPC（共享内存，信号，消息队列），套接字；
PCNTL扩展：PHP的一个进程扩展，主要用到pcntl_alarm（）函数，详细介绍请查阅官网。
实现原理
用一个三维数组保存所有需要执行的任务，一级索引为时间戳，值为执行任务的方法、回调参数等，具体数组形式如下：
array（
‘1438156396’ => array（
array（1，array（‘Class’，‘Func’）， array（）， true），
）
）
说明：
1438156396 时间戳
array（1，array（‘Class’，‘Func’）， array（）， true）
参数依次表示： 执行时间间隔，回调函数，传递给回调函数的参数，是否持久化（ture则一直保存在数据中，否则执行一次后删除）
这些任务可以是任意类的方法。既然是定时任务，我们需要一个类似计时的东东，此方案采用信号量去做，每一秒向当前进程发送SIGALRM信号，并捕获该信号，触发信号处理函数，循环遍历数据，判断是否有当前时间需要执行的任务。如果有则采用回调方式触发，并把参数传递给该方法。
［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）;
}
/**
*注册信号处理函数
*/
public static function installHandler（）
{
pcntl_signal（SIGALRM， array（‘Timer’，‘signalHandler’））;
}
/**
*信号处理函数
*/
public static function signalHandler（）
{
self：：task（）;
//一次信号事件执行完成后，再触发下一次
pcntl_alarm（self：：$time）;
}
/**
*执行回调
*/
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’］; /*回调函数*/
$argv = $job［‘argv’］; /*回调函数参数*/
$interval = $job［‘interval’］; /*时间间隔*/
$persist = $job［‘persist’］; /*持久化*/
if（$current == $time）
{//当前时间有执行任务
//调用回调函数，并传递参数
call_user_func_array（$func， $argv）;
//删除该任务
unset（self：：$task［$time］［$k］）;
}
if（$persist）
{//如果做持久化，则写入数组，等待下次唤醒
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， ‘argv’=>$argv， ‘interval’=>$interval， ‘persist’=>$persist）;
}
/**
*删除所有定时器任务
*/
public function dellAll（）
{
self：：$task = array（）;
}
}
这是定时器类核心部分，有一个静态变量保存有所有需要执行的任务，这里为什么是静态的呢？大家自行思考。当进程接受到 SIGALRM 信号后，触发 signalHandler 函数，随后循序遍历数组查看是否有当前时间需要执行的任务，有则回调，并传递参数，删除当前job，随后检查是否要做持久化任务，是则继续将当前job写入事件数组等待下次触发，最后再为当前进程设置一个闹钟信号。可以看出这个定时器，只要触发一次就会从内部再次触发，得到自循环目的。
［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”;
}
}
这是回调类及函数，为方便说明，加入不少调试信息.Timer类及回调都有了，我们看看使用场景是怎么样的。［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’=>1）， false）;
echo “Time start： ”.time（）。“\n”;
Timer：：run（）;
while（1）
{
sleep（1）;
pcntl_signal_dispatch（）;
}
代码非常短，这里注册了两个job，随后运行定时器，在一个无限循环里捕捉信号触发动作，如果不捕获将无法触发事先注册的处理函数。这样一个自循环的定时器开发完成。运行结果如下：
如我们场景类添加的任务一样，在90的时候执行了两个任务，一个为持久化的不带参数的job，一个为非持久化带参数的job，随后非持久化job不再执行。
总结
1、在收到信号前，当前进程不能退出。这里我使用了条件永远为真的循环。在我们实际生产环境中，需要创造这么一个先决条件，比如说，我们有一组服务，这些服务都是一直运行的，不管是IO访问，等待socket链接等等，当前服务都不会终止，即使进程阻塞也不会有问题，这种场景，也就是有一个一直运行的服务中使用。
2、目前PHP只支持以秒为单位的触发，不支持更小时间单位，对位定时任务而言基本足够
工商网监
评论