Workerman怎么实现定时任务_Timer类add方法使用教程【教程】

5次阅读

timer::add 不返回定时器对象而是全局单例调度器,仅返回整数 id 用于 timer::del;所有任务由主进程统一轮询触发,不支持单独生命周期控制、回调中修改执行时间或销毁停止;多进程下每个子进程独立执行,需用分布式锁确保单次运行;最小精度约 0.1 秒,非毫秒级;禁止阻塞操作和未捕获异常。

Workerman 怎么实现定时任务_Timer 类 add 方法使用教程【教程】

Workerman 的 Timer::add 不是「定时器对象」,而是全局单例调度器

很多人以为 Timer::add 会返回一个可管理的定时器实例(比如能 cancel()reset()),实际它只是往 Workerman 内部的静态任务队列里塞一条调度指令,没有句柄、不返回对象。所有定时任务都由 Worker 主进程统一轮询触发,底层靠 pcntl_signal + usleep 驱动,不是基于 event loop 的异步定时器。

这意味着:你无法单独控制某个定时任务的生命周期;不能在回调里直接修改它下次执行时间;也不能靠“销毁对象”来停止——只能用 Timer::del 配合 ID 手动清除。

  • Timer::add 返回的是一个整数 ID,仅用于后续 Timer::del($id),别指望它有方法或属性
  • 回调函数必须是可调用类型(function[$obj, 'method']fn() => ……),不能是字符串函数名(如 'test_func')——PHP 8.1+ 会报 TypeError
  • 如果 Worker 进程重启(比如 reload),所有未 del 的定时任务自动失效,不会跨进程持久化

定时任务在多进程下执行几次?看 Worker::$processCount

Workerman 默认启动一个主进程 + 多个子 Worker 进程(取决于 Worker::$processCount)。每个子进程都会独立运行自己那一份 Timer::add 注册的任务——也就是说,如果你在 Worker::runAll() 前写了 Timer::add(1, fn() => echo "tickn"),且 $processCount = 4,那每秒会输出 4 行 "tick",而不是 1 行。

  • 想让任务只执行一次?必须加进程判断:if (Worker::$pid === Worker::$masterPid) ——但注意,$masterPid 是主进程 PID,而定时器不能在主进程中运行(主进程不跑事件循环),所以这行其实无效
  • 真正可靠的做法:用文件锁、Redis 分布式锁,或把定时逻辑移到单独的「守护型 Worker」中,并设 $processCount = 1
  • 误在 onWorkerStart 里反复 Timer::add,会导致每个子进程都注册一遍,最终任务执行频次翻 N 倍

Timer::add 的间隔参数单位是「秒」,但最小精度约 0.1s

文档写“支持浮点数”,但底层依赖 usleep 和主循环调度频率,实际达不到毫秒级稳定精度。例如 Timer::add(0.01, $cb) 并不会每 10ms 触发,大概率变成每 100~200ms 一次,甚至更不规律——尤其在高负载或大量并发连接时。

  • 需要亚秒级调度(如 500ms 心跳),建议用 Timer::add(0.5, $cb),别写 0.499500e-3,没意义
  • 如果业务强依赖精确时间(比如金融对账),别用 Timer,改用系统 cron + HTTP/CLI 调用接口,或引入 reactphp/event-loop 等更精细的调度器
  • 间隔设为 0 是非法的,会触发 warning 并跳过注册;设为负数则直接静默失败

回调里不能用阻塞操作,否则整个 Worker 进程卡住

Timer::add 的回调是在 Worker 进程的事件循环中同步执行的。一旦你在里面调用 sleep()file_get_contents()(无超时)、mysqli_query()(同步)等阻塞操作,当前进程立刻停摆,既无法处理新连接,也无法触发其他定时任务,直到阻塞结束。

  • 数据库操作务必用异步客户端(如 workerman/mysql)或丢到 Worker::sendToWorkerProcess() 子进程里做
  • HTTP 请求推荐 WorkermanHttpClient,它内部是非阻塞的;别用 curl_execfile_get_contents
  • 日志写入也需注意:如果用 file_put_contents(……, FILE_APPEND) 且磁盘慢,同样会卡——建议走 Monolog + StreamHandler 异步刷盘,或先写内存再批量 flush

最常被忽略的一点:Timer 回调里抛出的未捕获异常,不会打印错误日志,也不会终止进程,而是被 Workerman 吞掉——你得手动 try/catch 并写日志,否则定时任务某天突然不跑了,连线索都没有。

text=ZqhQzanResources