使用go-cron多服务同时启动时任务重复执行问题及单次执行方案咨询

问题解答：多服务启动会导致任务同时执行吗？ #

是的。如果同时启动多个go-cron服务实例，每个实例都会独立解析并执行0 2 */1 * *（每天凌晨2点执行）这个定时任务，完全不受其他实例影响，必然会出现同一时间多个任务实例并行运行的情况。

确保任务仅执行一次的解决方案 #

1. 分布式锁方案 #

借助Redis、etcd这类分布式存储实现全局锁，任务触发时只有成功获取锁的实例才能执行任务，其他实例直接跳过。以Redis为例，可使用redsync库实现分布式锁：

package main

import (
    "github.com/go-redsync/redsync/v4"
    "github.com/go-redsync/redsync/v4/redis/goredis/v9"
    "github.com/redis/go-redis/v9"
    "time"
)

func main() {
    // 初始化Redis客户端
    client := redis.NewClient(&redis.Options{Addr: "localhost:6379"})
    pool := goredis.NewPool(client)
    rs := redsync.New(pool)

    // 创建针对该定时任务的分布式锁，设置过期时间（需长于任务执行耗时）
    mutex := rs.NewMutex("daily-task-lock", redsync.WithExpiry(10*time.Minute))

    // 尝试获取锁
    if err := mutex.Lock(); err != nil {
        // 未获取到锁，直接退出
        return
    }
    defer func() {
        // 任务完成后释放锁
        if ok, err := mutex.Unlock(); !ok || err != nil {
            // 处理锁释放失败的异常情况
        }
    }()

    // 执行定时任务逻辑
    runDailyTask()
}

func runDailyTask() {
    // 你的任务具体实现
}

2. 主节点选举机制 #

让多个服务实例通过选举产生主节点，仅主节点执行定时任务，其他节点处于待命状态。当主节点故障时，剩余节点会自动重新选举新主，保证任务始终有且仅有一个实例执行。可基于etcd的leader选举功能实现该机制。

3. 独立任务调度中心 #

将定时任务从业务服务中剥离，单独部署一个单点的任务调度中心（基于go-cron封装即可），所有业务服务不再内置cron逻辑，统一由调度中心触发任务执行。这种方式从根源上避免了多实例冲突，架构更清晰。

4. 数据库锁机制 #

如果没有分布式存储，可利用数据库实现锁逻辑：创建任务执行记录表，每次任务触发时检查上次执行时间和当前状态，只有满足执行条件且能更新状态为"运行中"的实例才执行任务。伪代码示例：

func checkAndRunTask() {
    db := getDBInstance()
    var taskRecord TaskRecord
    db.Where("task_id = ?", "daily-2am-task").First(&taskRecord)

    now := time.Now()
    // 验证距离上次执行已超过24小时，且无正在执行的任务
    if now.Sub(taskRecord.LastExecTime) > 24*time.Hour && taskRecord.Status != "running" {
        // 原子更新任务状态为运行中
        if err := db.Model(&taskRecord).Updates(map[string]interface{}{
            "Status":       "running",
            "LastExecTime": now,
        }).Error; err != nil {
            return
        }
        defer func() {
            // 任务完成后更新状态为已完成
            db.Model(&taskRecord).Update("Status", "completed")
        }()
        runDailyTask()
    }
}

注意需通过数据库事务或乐观锁（如版本号）避免并发更新冲突。

内容的提问来源于stack exchange，提问作者Jayleonc