Revel jobs 是轻量级单机异步调度器,非分布式定时框架;启用需在 app.conf 配置 module.jobs 和 jobs.pool;支持 cron 字符串与别名调度;jobs.Now() 无状态、jobs.Every() 易堆积;不持久化、无监控告警、日志无上下文。

Revel 的 jobs 模块不是开箱即用的定时任务“框架”,它本质是一个轻量级、单机进程内的异步任务调度器,不解决分布式重复执行、失败重试、可视化监控等高阶问题。如果你的应用只部署一个实例,且任务逻辑简单、允许偶尔失败或延迟,它够用;否则别硬套,得换 XXL-JOB 或 Quartz。
怎么启用 jobs 模块并配置基础参数
它默认关闭,必须显式启用。在 conf/app.conf 中添加两行:
module.jobs = github.com/robfig/revel/modules/jobs jobs.pool = 5
jobs.pool 控制并发数,默认是 10,但实际中设太高容易压垮数据库连接池;设太低(比如 1)会导致后续任务排队阻塞——尤其当某个 Run() 方法耗时较长时。另外 jobs.selfconcurrent = false 是关键开关:设为 true 允许同一任务的多个实例并行运行,设为 false(默认)则强制串行,避免数据竞争,但要注意这不等于“全局互斥”,只是当前进程内限制。
如何注册 cron 类型的周期任务
Revel 的 jobs.Schedule() 支持两种时间表达:标准六位 cron 字符串(秒 分 时 日 月 周),以及简写别名(如 @every 1h、@midnight)。注意别名底层仍转成 cron,但兼容性不如原生格式稳定。
-
"0 0 * * * ?"表示每小时整点触发(注意末尾?是 Quartz 风格占位符,Revel 支持) -
"0 0/5 * * * ?"表示每 5 分钟一次,比@every 5m更精确(后者可能因前次执行延迟而漂移) - 命名调度器需以
cron.开头,例如cron.cache_warmup = 0 0/15 * * * ?,然后在代码里用jobs.Schedule("cron.cache_warmup", WarmUpJob{})
错误现象:jobs.Schedule("@every 1m", Job{}) 在开发环境跑得好好的,上线后却不再触发——大概率是服务器时区没同步,或者系统时间被 NTP 调整过导致 cron 解析错乱。建议统一用 UTC 时间配置,并在日志里打上 time.Now().UTC() 做校验。
为什么 jobs.Now() 和 jobs.Every() 容易误用
jobs.Now() 立即提交任务到后台线程池执行,不阻塞主线程,但它没有返回值、不提供错误回调、也不记录执行状态。一旦 Run() 抛 panic,整个 goroutine 就静默退出,你根本不知道它失败了。
jobs.Every() 是对 jobs.Schedule() 的封装,底层仍走 cron 解析,但参数是 time.Duration,例如 jobs.Every(5 * time.Minute, Job{})。它的问题在于:如果任务执行时间 > 间隔,下一次调度不会跳过,而是堆积等待——线程池满时直接丢弃新调度,没有任何告警。
- 不要用
jobs.Now()替代初始化逻辑,比如建表、加载配置,应放在revel.OnAppStart回调里直接同步执行 - 不要依赖
jobs.Every()做强实时性任务(如每秒统计),它的最小可靠间隔建议不低于 30 秒 - 所有任务结构体必须实现
Run()方法,且不能有指针接收者(func (j *Job) Run()会导致反射调用失败)
监控页面和常见故障点
启用 module:jobs 路由后,访问 /@jobs 可查看当前运行中的任务、最近执行记录、线程池状态。但这个页面只读,不能手动触发、暂停或重试。
最容易被忽略的是:Revel 的 jobs 不做任何持久化。服务重启后,所有已调度但未执行的任务全部丢失;crontab 表达式重新加载,但历史执行记录清零。这意味着它完全不适合需要“至少执行一次”语义的场景(如发账单、扣费)。
另一个隐性坑是日志上下文丢失。在 Run() 方法里用 revel.INFO.Printf 打日志,你会发现这些日志不带 request ID、trace ID,也进不了结构化日志管道——因为任务脱离 HTTP 请求生命周期运行。建议在任务开始时手动注入 context,或改用独立 logger 实例。


















