Hyperf定时任务通过CrontabDispatcherProcess进程统一调度,配合$singleton=true和$mutex=['type'=>'redis']实现多进程安全执行;需安装hyperf/crontab、定义继承AbstractCrontab的任务类、在processes.php中注册调度器进程。

Hyperf 新建多进程定时任务,本身不靠“命令行创建”来实现多进程——定时任务默认由 CrontabDispatcherProcess 进程统一调度,它本身就是个常驻的独立进程;而“多进程”指的是整个 Hyperf 应用启动时启用多个 Worker 进程(如通过 Swoole 配置 worker_num),或你主动注册额外的自定义进程(如 @Process)。所谓“新建多进程定时任务”,实际是两件事的组合:1)定义定时任务;2)确保它在多进程环境下安全、不重复执行。下面直接说清楚怎么写、怎么配:
一、先装好定时任务组件
确保已安装:composer require hyperf/crontab
组件会自动注册,无需手动启用。
二、定义定时任务类(支持多进程安全)
在 app/Crontab/ 下新建类,继承 AbstractCrontab,关键点是开启单例 + 分布式锁:
-
必须设置
$singleton = true:防止多个 Worker 同时触发同一任务 -
推荐加 Redis 锁:
$mutex = ['type' => 'redis']:跨进程防重,需已配置 Redis -
$rule支持标准 cron(如"0 * * * *"每小时)或秒级(如"*/5 * * * * *"每5秒)
示例:
namespace App\Crontab;
<p>use Hyperf\Crontab\AbstractCrontab;
use Hyperf\Crontab\Annotation\Crontab;</p><h1>[Crontab]</h1><p>class DailyCleanupTask extends AbstractCrontab
{
public string $name = 'daily_cleanup';
public string $rule = '0 2 <em> </em> *'; // 每天凌晨2点
public array $singleton = true;
public array $mutex = ['type' => 'redis'];</p><pre class="brush:php;toolbar:false;">public function execute(): void
{
// 清理过期日志、缓存等业务逻辑
\Hyperf\Utils\Coroutine::sleep(0.1);
echo "[DailyCleanup] executed at " . date('Y-m-d H:i:s') . "\n";
}
}
三、注册调度器进程(让定时任务真正多进程运行)
定时任务不是靠命令行启动的,而是随服务一起跑。你需要在 config/autoload/processes.php 中显式注册调度进程:
return [
// 必须加上这一行,否则定时任务不会运行
\Hyperf\Crontab\Process\CrontabDispatcherProcess::class,
];
这个 CrontabDispatcherProcess 是一个独立协程进程,负责解析规则、触发任务,它本身不占用 Worker 进程,但能协调所有 Worker 共同参与执行(配合 $singleton 和 $mutex 保证只执行一次)。
四、命令行相关操作(仅用于调试或手动触发)
Hyperf 不提供“新建多进程定时任务”的命令行指令,但你可以:
- 用命令生成普通命令类(非定时任务):
php bin/hyperf.php gen:command Task\ManualSync - 手动触发该命令:
php bin/hyperf.php task:manual-sync - 若想用系统 crontab 触发(绕过 Hyperf 调度):
0 3 * * * cd /path/to/project && php bin/hyperf.php task:manual-sync >> /dev/null 2>&1
注意:这种方式脱离了 Hyperf 的协程调度和锁机制,需自行处理并发安全。
五、验证是否多进程生效
启动服务后观察日志:
- 看到
[INFO] Crontab manager started with X tasks表示调度器已就绪 - 多个 Worker 日志中,同一时刻只有一条
DailyCleanup输出,说明singleton + mutex生效 - 若关闭
$singleton且无$mutex,多个 Worker 会同时打印,即出现重复执行
不复杂但容易忽略:定时任务不是“新建进程”,而是靠调度器进程 + 多 Worker 协同 + 锁机制共同实现“多进程环境下的安全定时执行”。











