如何在 Go 中使用 cron 持续执行定时任务

心靈之曲 2026-01-26 00:00:00 次阅读

本文详解如何正确使用 robfig/cron 在 go 程序中实现长期运行的定时方法调用，解决因主 goroutine 过早退出导致任务不执行的问题，并提供可立即运行的完整示例。

在 Go 中使用 robfig/cron（现维护版本为 github.com/robfig/cron/v3）实现定时任务时，一个常见误区是：调用 c.Start() 后未保持主 goroutine 活跃，导致程序立即退出，定时器根本来不及触发。你的原始代码正是如此——c.Start() 启动了调度器，但 main() 函数随即结束，整个进程终止。

此外，原 cron 表达式 "1 * * * * *" 表示「秒字段为 1 时执行」（即每分钟第 1 秒），而非「每秒执行」；若需每秒触发，请使用 "* * * * * *"（6 字段格式，对应秒分时日月周）。

以下是修正后的完整、健壮的实现：

package main

import (
    "fmt"
    "os"
    "os/signal"
    "syscall"
    "time"

    "github.com/robfig/cron/v3"
)

func main() {
    // 创建 cron 调度器（v3 版本推荐使用 cron.New() 或 cron.New(cron.WithSeconds())）
    c := cron.New(cron.WithSeconds())

    // 添加每秒执行的任务（6 字段：* * * * * *）
    _, err := c.AddFunc("* * * * * *", RunEverySecond)
    if err != nil {
        panic(err)
    }

    // 启动调度器（非阻塞，需在后台运行）
    c.Start()
    defer c.Stop() // 确保优雅关闭

    fmt.Println("Cron job started. Press Ctrl+C to exit.")

    // 阻塞主 goroutine，等待系统中断信号（如 Ctrl+C）
    sigChan := make(chan os.Signal, 1)
    signal.Notify(sigChan, syscall.SIGINT, syscall.SIGTERM)
    <-sigChan // 阻塞直至收到信号

    fmt.Println("Shutting down...")
}

func RunEverySecond() {
    fmt.Printf("[%s] Task executed\n", time.Now().Format("15:04:05"))
}

✅ 关键要点说明：

✅ 必须显式阻塞 main()：使用 signal.Notify 监听 SIGINT（Ctrl+C）或 SIGTERM，避免进程闪退；
✅ 正确使用 cron v3 的秒级支持：通过 cron.WithSeconds() 启用 6 字段语法，"* * * * * *" 表示每秒执行；
✅ 调用 c.Start() 后无需 go 关键字：v3 的 Start() 本身已启动 goroutine，手动 go c.Start() 是冗余且易引发竞态；
✅ 务必调用 c.Stop()：在退出前清理资源（如关闭内部 ticker），避免 goroutine 泄漏；
⚠️ 注意：旧版 github.com/robfig/cron（v2）默认不支持秒级，需升级至 v3 并启用 WithSeconds() 选项。

运行该程序后，你将看到每秒打印一条带时间戳的日志，直到手动中断（Ctrl+C）。此模式适用于后台服务、健康检查、定时同步等长期运行场景。