Golang使用cron调度定时任务

本文介绍如何使用cron v3在一定时间间隔调度job任务执行。采用cron运行后端进程非常有用，如定期从第三方服务器拉去数据、两个服务器间同步数据、在一定时间间隔时发送通知邮件等。

介绍Cron v3

cron v3是非常流行的包，它实现了cron规范，包括解析器和执行器。我们利用它调度任务在特定时间间隔执行。

运行下面命令下载包：

go get github.com/robfig/cron/v3@v3.0.0

使用需在程序导入包：

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

因为使用Go Modules，需要Go 1.11以上版本。v3版本是最新版本，修复之前版本的大量bug。

cron表达式

注意：月份和星期字段值是不区分大小写的，“SUN”, “Sun”, 和 “sun” 三者等效。

星号(*) : 星号表示匹配该字段所有值，举例：第五个字段（月份）表示每个月

斜杠（/）：描述增加范围。举例第一个字段(分钟）值为:3-59/15,表示第三分钟之后，每十五分钟执行一次。

逗号（,）：逗号用于分隔多个值项。例如，在第5个字段(星期)中使用“MON,WED,FRI”表示星期一、星期三和星期五。

连字符(-)：连字符用于定义范围。例如，9-17表示上午9点到下午5点之间的每小时。

问号(?)：问号可以用来代替“*”，以便将月中的哪一天或星期中的哪一天空出来。

预定义表达式

处理cron表达式，cron-v3还预定义了一些快捷调度表达式：

示例

c := cron.New()
c.AddFunc("0 30 * * * *", func() { fmt.Println("Every hour on the half hour") })
c.AddFunc("@hourly",      func() { fmt.Println("Every hour") })
c.AddFunc("@every 1h30m", func() { fmt.Println("Every hour thirty") })
c.Start()
..
// Funcs are invoked in their own goroutine, asynchronously.
...
// Funcs may also be added to a running Cron
c.AddFunc("@daily", func() { fmt.Println("Every day") })
..
// Inspect the cron job entries' next and previous run times.
inspect(c.Entries())
..
c.Stop()  // Stop the scheduler (does not stop any jobs already running).

完整实例

package main

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

func main() {
	c := cron.New()、
    // 在协程中异步执行
	c.AddFunc("@every 1s", SendMail)
	c.Start()
	defer c.Stop()

    // 防止程序提前结束
	var ch = make(chan int)
	<-ch
}

func SendMail() {
	fmt.Println("Successfully! Mail has been sent!.")
}


 

  
 

执行程序，每秒输出输出一次"Successfully! Mail has been sent!."

更多信息参考官方文档：https://pkg.go.dev/github.com/robfig/cron#hdr-Usage。

转载：https://blog.csdn.net/neweastsun/article/details/128781679