先抛一个核心结论:纯内存方案搞分布式定时调度,基本行不通。原因很简单——内存没法跨节点共享。每个 Go 进程各跑各的 time.NewTicker,哪怕 cron 表达式写得一模一样,10 台机器也会同时在本地触发任务。这哪叫调度?纯粹是广播。

Go 原生确实没给分布式调度开绿灯。time.Ticker 和 time.AfterFunc 都只认单进程。至于“基于内存的分布式任务定时调度框架”,这说法本身就有点矛盾——内存不可共享,强行本地实现分布式,结果只能是重复触发、各自为战。真正落地,必须把协调工作交给外部组件。
为什么不能用纯内存实现分布式定时调度
问题出在哪?一句话:缺乏全局时钟和状态同步机制。每个 Go 进程独立跑 time.NewTicker,哪怕 cron 表达式完全一致,也会在各自机器上同时触发,形成“广播式”执行。这样的结果不是调度,是混乱。
- 各节点系统时钟必然存在偏差(NTP 同步后通常还有 50–200ms 误差),同一时刻在不同机器上会被判定为不同时间点
- 进程重启后,内存中所有
*cron.Cron实例全部丢失,任务直接中断,没有任何恢复能力 - 无法感知其他节点是否存活,故障转移、抢占式重调度根本无从谈起
github.com/robfig/cron的AddFunc是纯内存注册,不提供任何跨进程协商接口
如果坚持用 Go 写,哪些组件必须外置
一个真正可用的“分布式”调度,本质上是把逻辑拆成两层:本地定时器只负责“提醒”,真正的“决策权”落在外部存储里。下面三项东西绝对不能放在内存中:
- 任务元数据:CRON 表达式、参数、启用状态、失败重试次数——必须存到 Redis 或数据库里,否则改个时间就得重新发版部署
- 执行锁:用
SET key value EX 90 NX抢锁,value 设为hostname:pid,TTL 必须大于单次任务的最长执行时间,不然锁提前释放,另一个节点趁虚而入 - 下次触发时间戳:不能让各节点自己算
next := now.Add(...),而应该由中心化服务统一生成并写入共享存储,避免时钟漂移累积误差
用 github.com/go-co-op/gocron 包装分布式锁的典型陷阱
这个库提供了 WithDistributedLocker 接口,但只是预留了钩子,没有默认实现。很多人直接传一个空 locker 或简单封装 redis.Client.SetNX 就上线,结果踩坑不浅:
- 锁未续期:任务执行超时,锁提前过期,另一个节点抢入,导致并发执行
- 锁误删:用
DEL key而非 Lua 脚本校验 value,可能会删掉别人正在持有的锁 - 抢锁时机错:在
Start()时抢一次就不管了,而不是每次func()执行前都重新竞争 - 没处理脑裂:网络分区后,两个节点都认为自己持有锁,同时执行——必须依赖 Redis 的单线程原子性加上合理的 TTL 来规避
最容易被忽略的是:任务的幂等性不是调度框架能保证的。框架只管“谁来跑”,不管“跑得对不对”。就算锁逻辑完全正确,业务代码里一次 db.Exec("INSERT ...") 没加唯一约束,照样会产生脏数据。分布式调度的可靠性,永远是“锁 + 存储 + 业务”三层共同决定的,少一层都不行。