在workerman中定时任务需注册到onworkerstart回调内才能执行,避免多进程重复需设count=1或用redis锁,重启后自动恢复依赖onworkerstart重注册,验证需查看日志输出。

在Workerman中让定时任务自动执行,关键不是写完Timer::add就完事,而是必须把它注册到Worker进程的生命周期里——否则进程一启动就退出,任务根本没机会触发。
把定时任务塞进onWorkerStart回调
第一步:确保Timer::add()调用发生在Worker进程真正进入事件循环之后。最稳妥的位置是$worker->onWorkerStart回调内部,因为此时Worker已初始化完毕、事件循环即将启动。
第二步:直接在回调里调用Timer::add,传入间隔秒数和回调函数。例如每3秒打印一次时间:Timer::add(3, function() { echo date('H:i:s') . "\n"; });
第三步:注意不要在Worker::runAll()之前调用Timer::add——那只是往空队列里塞一条无效指令,主进程还没开始轮询,任务永远不会被执行。
避免多进程重复执行同一任务
Workerman默认启动多个子进程(由$worker->count控制),每个子进程都会独立运行自己注册的定时任务。如果你写了$worker->count = 4,又在onWorkerStart里调用Timer::add(5, $cb),那么每5秒会触发4次,而不是1次。
方法一:强制单进程运行
在Worker实例上设置$worker->count = 1,这样整个定时逻辑只在一个进程中执行,简单直接。
方法二:用Redis分布式锁保证唯一性
在定时任务回调开头加锁判断:if (redis()->set('task_lock', 1, ['NX', 'EX' => 10])) { /* 执行任务 */ }。锁过期时间要比任务间隔长,否则可能漏执行。
【切勿用Worker::$pid === Worker::$masterPid做判断】因为主进程不跑事件循环,定时器根本无法在主进程中注册生效,这个条件永远为假。
让定时任务随进程重启自动恢复
第一步:定时任务本身不持久化,Worker进程重启后所有Timer::add注册的任务自动失效。
第二步:把Timer::add逻辑全部放在onWorkerStart里——每次子进程启动时都会重新注册,天然实现“自动恢复”。
第三步:如果任务配置来自数据库或配置文件,务必在onWorkerStart中读取并动态生成Timer::add调用,不能把配置硬编码在外部。
第四步:不要在回调函数里再嵌套Timer::add——这会导致任务注册次数随执行次数指数增长,几轮下来进程就会卡死。
验证定时任务是否真正在跑
打开终端,执行php start.php start -d启动服务。
用tail -f storage/logs/workerman.log(或你自定义的日志路径)实时查看输出,确认时间戳按预期间隔出现。
如果日志完全没动静,先检查是否漏写了Worker::runAll();再确认onWorkerStart是否被正确赋值——常见错误是把等号写成双等号==,导致回调根本没绑定。











