舊版(3.5.x版本之前)定時任務(wù)
開發(fā)者執(zhí)行定時任務(wù)會通過 Linux 的 Crontab 去實現(xiàn),不方便去管理。EasySwoole 提供了根據(jù) Linux 下 Crontab 規(guī)則的定時任務(wù),最小粒度為1分鐘。
創(chuàng)建一個定時任務(wù)
需要定義一個定時任務(wù)類繼承 \EasySwoole\EasySwoole\Crontab\AbstractCronTask。
定義執(zhí)行規(guī)則
public static function getRule(): string
{
// 定義執(zhí)行規(guī)則 根據(jù)Crontab來定義
return '*/1 * * * *';
}
定義 Crontab 名稱
public static function getTaskName(): string
{
// 定時任務(wù)的名稱
return 'custom crontab';
}
定義執(zhí)行邏輯
public function run(int $taskId, int $workerIndex)
{
// 定時任務(wù)的執(zhí)行邏輯
// 開發(fā)者可投遞給task異步處理
TaskManager::getInstance()->async(function (){
// todo some thing
});
}
定義異常捕獲
public function onException(\Throwable $throwable, int $taskId, int $workerIndex)
{
// 捕獲run方法內(nèi)所拋出的異常
}
注冊 Crontab
在 EasySwoole 框架全局的 mainServerCreate 事件(即項目根目錄的 EasySwooleEvent.php 文件)中進行定時任務(wù)注冊
Crontab::getInstance()->addTask(CustomCrontab::class);
完整示例代碼
<?php
namespace App\Crontab;
use EasySwoole\EasySwoole\Crontab\AbstractCronTask;
use EasySwoole\EasySwoole\Task\TaskManager;
class CustomCrontab extends AbstractCronTask
{
public static function getRule(): string
{
// 定義執(zhí)行規(guī)則 根據(jù)Crontab來定義
return '*/1 * * * *';
}
public static function getTaskName(): string
{
// 定時任務(wù)的名稱
return 'CustomCrontab';
}
public function run(int $taskId, int $workerIndex)
{
// 定時任務(wù)的執(zhí)行邏輯
// 例如:每隔1分鐘打印當前時間
echo date('Y-m-d H:i:s') . PHP_EOL;
}
public function onException(\Throwable $throwable, int $taskId, int $workerIndex)
{
// 捕獲run方法內(nèi)所拋出的異常
}
}
Crontab表達式
通用表達式:
* * * * *
- - - - -
| | | | |
| | | | |
| | | | +----- day of week (0 - 7) (Sunday=0 or 7)
| | | +---------- month (1 - 12)
| | +--------------- day of month (1 - 31)
| +-------------------- hour (0 - 23)
+------------------------- min (0 - 59)
特殊表達式:
@yearly 每年一次 等同于(0 0 1 1 *)
@annually 每年一次 等同于(0 0 1 1 *)
@monthly 每月一次 等同于(0 0 1 * *)
@weekly 每周一次 等同于(0 0 * * 0)
@daily 每日一次 等同于(0 0 * * *)
@hourly 每小時一次 等同于(0 * * * *)
Crontab 管理
EasySwoole 內(nèi)置對于 Crontab 的命令行操作,方便開發(fā)者友好的去管理 Crontab。
可執(zhí)行 php easyswoole.php crontab -h 來查看具體操作。
查看所有注冊的Crontab
php easyswoole.php crontab show
停止指定的Crontab
php easyswoole.php crontab stop --name=TASK_NAME
恢復指定的Crontab
php easyswoole.php crontab resume --name=TASK_NAME
立即跑一次指定的Crontab
php easyswoole.php crontab run --name=TASK_NAME
版本強調(diào)
EasySwoole 3.3.0 版本如何定義:
<?php
namespace App\Crontab;
use EasySwoole\EasySwoole\Crontab\AbstractCronTask;
class TaskOne extends AbstractCronTask
{
public static function getRule(): string
{
// TODO: Implement getRule() method.
// 定時周期 (每小時)
return '@hourly';
}
public static function getTaskName(): string
{
// TODO: Implement getTaskName() method.
// 定時任務(wù)名稱
return 'taskOne';
}
static function run(\swoole_server $server, int $taskId, int $fromWorkerId,$flags=null)
{
// TODO: Implement run() method.
// 定時任務(wù)處理邏輯
var_dump('run once per hour');
}
}