<p>使用robfig/cron库可轻松实现go语言中的定时任务。1. 安装:执行go get github.com/robfig/cron/v3。2. 创建任务:通过cron.New()创建调度器,AddFunc添加任务,支持6位(含秒)或5位cron表达式,如”0 “表示每分钟执行。3. 多任务支持:可添加多个任务,如”0 0 12 “每天中午执行,”@every 1h”每隔一小时执行。4. 特殊语法:支持@daily、@weekly等便捷表达式。5. 停止任务:调用c.Stop()关闭调度器,确保正在运行的任务完成。</p>
在go语言中实现定时执行任务的计划程序(cron job),最常用的方式是使用第三方库 robfig/cron。它功能强大、使用简单,支持标准的cron表达式语法。
1. 安装 cron 库
打开终端,执行以下命令安装 cron 包:
go get github.com/robfig/cron/v3
2. 编写一个简单的定时任务
下面是一个每分钟执行一次打印任务的示例:
package main <p>import ( "fmt" "time" "github.com/robfig/cron/v3" )</p><p>func main() { c := cron.New()</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">// 添加一个每分钟执行的任务 c.AddFunc("0 * * * * *", func() { fmt.Println("每分钟执行一次:", time.Now()) }) // 启动cron调度器 c.Start() // 阻塞主线程,防止程序退出 select {}
}
说明:
- “0 * * * * *” 是扩展格式的cron表达式,表示每分钟的第0秒执行(Go的cron支持6位格式:秒、分、时、日、月、周)。
- 你也可以使用标准5位格式(不包含秒),需调用
cron.New(cron.WithSeconds())
来启用秒级精度。
3. 使用标准cron表达式(5位)
如果你习惯使用标准的5位cron表达式(分 时 日 月 周),可以这样写:
c := cron.New() // 每分钟执行一次(标准格式,不包含秒) c.AddFunc("*/1 * * * *", func() { fmt.Println("标准cron格式执行:", time.Now()) }) c.Start()
4. 添加多个任务
你可以添加多个不同的定时任务:
c.AddFunc("0 0 12 * * *", func() { fmt.Println("每天中午12点执行") }) <p>c.AddFunc("0 0 0 <em> </em> 0", func() { fmt.Println("每周日凌晨0点执行") })</p><p>c.AddFunc("@every 1h", func() { fmt.Println("每隔一小时执行:", time.Now()) })
支持的特殊语法:
- @every 1h:每隔1小时执行一次
- @daily 或 @midnight:每天凌晨执行
- @weekly:每周执行一次
- @monthly:每月执行一次
- @yearly:每年执行一次
5. 停止cron任务
如果需要在某个时刻关闭cron(比如在服务关闭时),可以调用
Stop()
方法:
stop := c.Stop() // stop 是一个channel,关闭后会等待正在运行的任务完成 <-stop fmt.Println("Cron已停止")
6. 实际项目中的建议
- 将cron任务封装成独立的服务或模块,便于测试和管理。
- 在Go的Web服务中,可以在启动时开启cron,在服务关闭(如收到SIGINT)时优雅停止。
- 避免在cron函数中执行阻塞时间过长的操作,必要时使用goroutine。
基本上就这些。robfig/cron 是Go中最成熟的定时任务库,适合大多数场景。
评论(已关闭)
评论已关闭