Go (Golang) 任务调度器：cron、gocron、asynq

Go (Golang) 任务调度器：从 cron 到 asynq

在现代 Go (Golang) 服务器端开发中，经常需要按计划或延迟执行代码。缓存清理、通知推送、报告生成——所有这些都需要一个可靠的任务调度器。在本文中，我们将详细分析三种流行的方法：标准包 cron、轻量级库 gocron 和分布式队列 asynq。您将了解如何为您的 PythonLib 项目选择合适的工具。

1. Go 的标准 cron

github.com/robfig/cron/v3 库是 Go 中调度重复任务的事实标准。它使用熟悉的 cron 表达式语法（5 个字段），并支持秒、时区和从 panic 中恢复。

安装和基本示例

go get github.com/robfig/cron/v3

一个每 30 秒运行一次任务的调度器示例：

package main

import (    "fmt"    "github.com/robfig/cron/v3")

func main() {    c := cron.New()        // 使用 cron 表达式添加任务：每 30 秒    _, err := c.AddFunc("*/30 * * * * *", func() {        fmt.Println("任务已执行:", time.Now())    })    if err != nil {        panic(err)    }        c.Start()        // 阻塞主 goroutine    select {}}

主要特点：

支持标准 cron 表达式（5 或 6 个字段，含秒）
任务 panic 后自动恢复
可通过 cron.WithLocation() 设置时区
通过 cron.WithLogger() 进行日志记录

高级用法：链式任务

c := cron.New(cron.WithSeconds())

// 带名称的任务，便于管理id, _ := c.AddFunc("@every 5m", func() {    fmt.Println("每 5 分钟执行一次")})

// 根据 ID 删除任务c.Remove(id)

// 停止调度器c.Stop()

该库非常适合单个进程内的简单周期性任务。然而，对于分布式系统（多个 Go 服务器副本），则需要外部锁来防止任务在所有节点上同时执行。

2. Gocron — 带链式调用的轻量级调度器

github.com/go-co-op/gocron 提供了更现代的 API，无需 cron 表达式。您可以使用方法链代替字符串。这对初学者尤其方便。

gocron 示例

package main

import (    "fmt"    "time"    "github.com/go-co-op/gocron")

func main() {    s := gocron.NewScheduler(time.UTC)        // 每 2 分钟执行一次的任务    _, _ = s.Every(2).Minutes().Do(func() {        fmt.Println("已过 2 分钟")    })        // 启动后延迟执行的任务    _, _ = s.Every(1).Day().At("10:30").Do(func() {        fmt.Println("每天 10:30 执行")    })        s.StartBlocking()}

gocron 的优势：