PHP定时任务扩展包EasyTask使用教程


EasyTask是一个PHP驻留内存定时器作曲器包,与workerman定时器效果相同,多个定时器同时在多个进程中运行,可以使用它来完成需要重复的任务(如自动取消订单超时,异步推送短信邮件,队列/消费者/频道订阅者等),甚至处理Crontab定时任务(如每天凌晨1点到凌晨3点同步DB数据, 每月1号生成月度统一报表,每晚10点重启nginx服务器等);内置任务异常上报功能,可自定义异常错误处理(如异常错误自动短信通知);它还支持异常任务退出的自动重启,使您的任务运行更加稳定,并且该工具包支持Windows,Linux和Mac环境的操作。

这个包在我们做定时任务或者需要任务调度系统时特别实用,这是一个composer包,你可以把它安装在你需要的地方,下面说一下这个包吧。

首先我们必须明白PHP的定时器只能基于CLI命令行形式运行,由于FPM形式用完即走,内存立即释放,无法做到常驻,当然我们也可以让FPM常驻起来,但是内存开销过大。因此FPM本身就是官方用来提供给我们做网站CURD的,而CLI模式才是后端核心,大量的PHP服务都是基于PHP_CLI模式,因此高级程序员更必须了解CLI模式。但凡大点的公司都是用FPM处理网页,CLI处理服务队列。

下面的定时任务也是基于CLI执行。

我们使用的定时任务包是EasyTask,先安装它(参考官方文档,没有必要安装event扩展):

1
composer require easy-task/easy-task

使用实例
我们创建一个console.php简单使用它:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
// 加载Composer代码
require './vendor/autoload.php';

//初始化
$task = new Task();

// 设置非常驻内存
$task->setDaemon(false);

// 设置项目名称
$task->setPrefix('EasyTask');

// 设置记录运行时目录(日志或缓存目录)
$task->setRunTimePath('./Application/Runtime/');

// 1.添加闭包函数类型定时任务(开启2个进程,每隔10秒执行1次你写闭包方法中的代码)
$task->addFunc(function () {
$url = 'https://www.viphper.com';
@file_get_contents($url);
}, 'request', 10, 1);

// 启动任务
$task->start();

我们执行这个脚本:

1
php console.php start

如果是windows系统,我们看到启动了2个cmd窗口,1个窗口是守护进程,1个是执行上面的每隔10s访问网站的定时任务的进程,测试成功。

那么我们如果不显示cmd执行呢,只需要修改为常驻运行:

1
2
// 设置常驻内存
$task->setDaemon(true);

那我们如何添加多个定时任务呢?只需要多调用addFunc方法添加任务进去即可,下面再添加1个15秒的定时任务

1
2
3
4
$task->addFunc(function () {
$url = 'https://www.viphper.com';
@file_get_contents($url);
}, 'request2', 15, 1);

上面只是说添加任务,那么如何去管理呢?官方给了一个基础的命令整合命令:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
// 获取命令
$force = empty($_SERVER['argv']['2']) ? '' : $_SERVER['argv']['2'];
$command = empty($_SERVER['argv']['1']) ? '' : $_SERVER['argv']['1'];

// 配置任务
$task = new Task();
$task->setRunTimePath('./Application/Runtime/');
$task->addFunc(function () {
$url = 'https://www.viphper.com';
@file_get_contents($url);
}, 'request', 10, 2);;

// 根据命令执行
if ($command == 'start')
{
$task->start();
}
elseif ($command == 'status')
{
$task->status();
}
elseif ($command == 'stop')
{
$force = ($force == 'force'); //是否强制停止
$task->stop($force);
}
else
{
exit('Command is not exist');
}
1
2
3
4
5
6
7
启动任务: php console.php start

查询任务: php console.php status

普通关闭: php console.php stop

强制关闭: php console.php stop force

当然你可可以在任务管理中找到所有进程进行关闭。事实上EasyTask还支持addClass方式添加定时器去执行类的方法,也支持addCommand方法添加定时器去执行cmd或者shell命令,也支持crontab格式的指令。

项目地址:https://gitee.com/392223903/EasyTask

原文链接:https://xiaohost.com/11599.html,转载请注明出处。
0