
Go-Cron 本身不支持分布式,直接用会重复执行任务
Go-Cron 是单进程定时器,没做节点间协调。你在 3 台机器上都跑同一个 gocron.NewScheduler(),每台都会独立触发任务——不是“分布式调度”,是“分布式重复执行”。想靠它实现跨节点调度,等于没锁就并发写文件。
- 典型现象:
task executed 3 times per minute(日志里同一任务高频重复) - 适用场景:单机服务、后台小工具、开发环境模拟
- 真实分布式必须引入外部协调机制,比如 Redis、Etcd 或数据库的分布式锁
用 Redis 实现调度节点选举 + 任务锁最轻量
不用改任务逻辑,只在执行前加一层“抢锁”判断。核心是两个原子操作:谁先用 SET key value NX EX 30 成功,谁获得本轮调度权;任务执行中再用 SET task:lock:<code>jobID 1 NX EX 60 防重入。
- 选主锁(scheduler leader):所有节点竞争
redis:set scheduler:leader nodeA NX EX 10,成功者负责拉取待执行任务列表 - 任务粒度锁:执行前尝试
redis:set task:lock:send_email_20240501 1 NX EX 120,失败则跳过 - 注意
EX时间要大于任务最长耗时,否则锁提前释放导致重复;但也不能设太长,否则故障节点无法及时释放锁
Go-Cron 可以保留,但只做“本地触发器”,别让它管分发
把 Go-Cron 当成一个精准的本地闹钟,只负责在本机某个时间点调用一个函数;真正的任务分发、去重、状态更新全交给业务层和 Redis 协作完成。
- 示例结构:
s := gocron.NewScheduler(time.UTC) s.Every(30).Seconds().Do(func() { // 不在这里处理业务逻辑 // 只做:从 Redis 拉取「该由我执行」的任务列表(比如用 nodeID 做前缀筛选) // 然后逐个尝试加锁并执行 }) s.Start() - 避免在
Do()里写耗时操作或阻塞调用,否则会拖慢整个调度周期 - 如果任务需要动态增删,别依赖 Go-Cron 的
AddJob/RemoveJob,统一走 Redis + 定期 reload 机制
Etcd 比 Redis 更适合强一致性场景,但复杂度明显上升
如果你的任务不能容忍哪怕一次重复(比如金融扣款),且已有 Etcd 集群,用 etcd/client/v3 的 CompareAndSwap(CAS)比 Redis 的 SET NX 更可靠——它能保证锁的租约与 session 绑定,自动续期/失效。
立即学习“go语言免费学习笔记(深入)”;
- 关键差异:
redis:SET是纯超时控制,网络分区时可能多个节点同时认为自己持锁;etcd:Grant + Put with Lease支持心跳保活,故障节点锁会真实释放 - 代价:需要维护
*clientv3.Client连接池,处理context.DeadlineExceeded等网络错误,代码量多 3–4 倍 - 除非你已经在用 Etcd 做服务发现或配置中心,否则没必要为调度单独上 Etcd
EX 值很容易引发误释放或假死锁。










