Hyperf 中实现按分钟循环的多进程定时任务,需结合 Swoole 多进程与 Hyperf Timer 组件,通过 Process 启动多个守护进程,各进程内用 Timer::add(60, [$this, 'execute']) 注册定时器,并配置 processes 数量实现负载分散;为避免时间漂移,应首次计算对齐整分钟的延迟并用 Timer::after 精确调度,配合 Redis 分布式锁防止多实例重复执行;需独立日志、异常捕获及异步 I/O 处理,进程数应根据 CPU 与 IO 密度合理设置。

Hyperf 中实现按分钟循环的多进程定时任务,核心在于结合 Swoole 的多进程管理能力 与 Hyperf 的定时器组件,避免单进程阻塞、提升并发执行稳定性。不推荐直接用 PHP 原生 sleep() 或简单 while 循环,而应利用 Hyperf 提供的 Timer + Process 组合方案。
使用 Process + Timer 实现分钟级多进程任务
Hyperf 的 Process 组件可独立启动守护进程,每个进程内用 Timer::add() 设置每分钟触发一次的任务,多个进程互不干扰:
- 在
app/Process/MinuteTaskProcess.php中定义进程类,继承AbstractProcess - 重写
handle()方法,在其中注册分钟级定时器:Timer::add(60, [$this, 'execute']); - 确保
enableCoroutine => true(默认开启),避免阻塞协程调度 - 通过配置
processes数量(如 3 个)启动多个相同逻辑的进程,实现负载分散
避免重复执行与时间漂移
单纯设 60 秒间隔可能因任务耗时导致实际执行间隔 > 60 秒(即“漂移”)。若需严格对齐整点分钟(如每小时第 0、1、2... 分钟执行),建议:
- 首次启动时计算到下一个整分钟的等待时间(如当前是 10:23:45,则等待 15 秒)
- 后续每次执行后,重新计算下一次目标时间戳,用
Timer::after($delay, ...)精确对齐 - 加 Redis 分布式锁(如
lock('minute_task_0'))防止多实例部署时重复触发(尤其跨机器场景)
配置与启动方式
在 config/autoload/processes.php 中注册进程:
'App\Process\MinuteTaskProcess' => [
'enable' => true,
'num' => 2, // 启动 2 个并行进程
],
启动命令:php bin/hyperf.php start。可通过 ps aux | grep MinuteTaskProcess 查看运行中的进程数。
日志与错误隔离建议
每个进程独立记录日志,避免混杂:
- 在
handle()中初始化独立 Logger:$logger = $this->container->get(LoggerInterface::class)->withContext('MinuteTask'); - 捕获异常并记录完整堆栈,不抛出到进程顶层(否则会导致进程退出)
- 任务体中避免长时间 I/O 操作;如需 HTTP 请求,用
Co\Http\Client或GuzzleHttp\Promise\Promise异步处理
不复杂但容易忽略细节:进程数不是越多越好,需结合 CPU 核心数与任务 IO 密度合理设置;定时器回调函数必须是可序列化对象方法或闭包(Hyperf 会自动处理);重启服务时进程自动拉起,无需额外守护脚本。


















