用Golang实现轻量可靠任务调度器，推荐robfig/cron/v3+log/slog（或log+lumberjack），支持秒级调度、结构化日志、超时控制、并发限制与优雅关闭。
用 Golang 实现一个轻量、可靠的任务调度器，核心在于：选对库、合理设计任务结构、分离执行逻辑与日志记录。不需要引入重量级框架，标准库 + robfig/cron/v3 就能搞定定时任务，再配合 log/slog（Go 1.21+）或 log + 文件轮转（如 lumberjack），就能完成带日志的生产级调度。
选择并初始化 cron 调度器
推荐使用 github.com/robfig/cron/v3，它支持秒级精度、任务唯一性控制、错误回调等特性，比标准库 time/ticker 更适合复杂调度场景。
安装：
go get github.com/robfig/cron/v3基础用法示例：
立即学习“go语言免费学习笔记（深入）”；
import "github.com/robfig/cron/v3"
<p>c := cron.New(cron.WithSeconds()) // 启用秒级（格式为 "0/5 <em> </em> <em> </em> ?" 表示每5秒）
c.AddFunc("0/30 <em> </em> <em> </em> ?", func() {
fmt.Println("每30秒执行一次")
})
c.Start()
defer c.Stop() // 程序退出前停止
封装可注册的任务类型（支持日志与错误处理）
避免所有任务都写成匿名函数。定义统一接口，让每个任务自带名称、描述、执行逻辑和日志能力：
type Task struct {
Name string
Description string
Fn func() error
Logger *slog.Logger // 或 *log.Logger
}
<p>func (t *Task) Run() {
t.Logger.Info("任务开始", "name", t.Name)
if err := t.Fn(); err != nil {
t.Logger.Error("任务失败", "name", t.Name, "error", err)
return
}
t.Logger.Info("任务完成", "name", t.Name)
}
注册时直接传入封装好的 Task：
c := cron.New(cron.WithSeconds())
logger := slog.With("component", "scheduler")
<p>task := &Task{
Name: "sync-user-data",
Description: "同步用户数据到缓存",
Logger: logger,
Fn: func() error {
// 实际业务逻辑，例如 HTTP 请求、DB 查询
_, err := http.Get("<a href="https://www.php.cn/link/93a819cbd635bd1505ef0f804c21cc2a">https://www.php.cn/link/93a819cbd635bd1505ef0f804c21cc2a</a>")
return err
},
}</p><p>c.AddFunc("0 <em> </em> <em> </em> ?", func() { task.Run() })
c.Start()
添加结构化日志与文件输出（支持轮转）
默认 slog 只输出到 stdout。若需写入文件并自动轮转（防止单文件过大），推荐搭配 lumberjack：
安装：
go get gopkg.in/natefinch/lumberjack.v2配置日志输出：
import (
"gopkg.in/natefinch/lumberjack.v2"
"log/slog"
)
<p>logWriter := &lumberjack.Logger{
Filename: "./logs/scheduler.log",
MaxSize: 50, // MB
MaxBackups: 7,
MaxAge: 28, // 天
Compress: true,
}</p><p>logger := slog.New(slog.NewJSONHandler(logWriter, &slog.HandlerOptions{
AddSource: true,
Level: slog.LevelInfo,
}))
这样每条日志会包含时间、级别、源码位置、结构化字段（如 "name":"sync-user-data"），方便后续采集与分析。
增强健壮性：任务超时、并发控制与恢复机制
cron 默认并发执行同一任务（若上一周期未结束，下一周期仍会触发）。可通过以下方式控制：
-
使用
cron.WithChain(cron.Recover(cron.DefaultLogger))自动捕获 panic，避免单个任务崩溃导致整个调度器停止 - 用
cron.WithChain(cron.SkipIfStillRunning(cron.DefaultLogger)) -
为任务加 context 超时：在
Fn中使用context.WithTimeout，防止某个任务卡死拖垮调度
示例：
Fn: func() error {
ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
defer cancel()
<pre class="brush:php;toolbar:false;">req, _ := http.NewRequestWithContext(ctx, "GET", url, nil)
resp, err := http.DefaultClient.Do(req)
if err != nil {
return fmt.Errorf("http call failed: %w", err)
}
defer resp.Body.Close()
return nil},
不复杂但容易忽略：调度器本身应作为长期运行的服务，建议用 signal.Notify 监听 SIGINT/SIGTERM，优雅关闭 cron 和日志 writer。
