Golang 实现基于内存的分布式任务定时调度框架设计

先抛一个核心结论：纯内存方案搞分布式定时调度，基本行不通。原因很简单——内存没法跨节点共享。每个 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 ...") 没加唯一约束，照样会产生脏数据。分布式调度的可靠性，永远是“锁 + 存储 + 业务”三层共同决定的，少一层都不行。