golang-cron定时任务

golang-cron定时任务

cron.New创建一个定时器管理器
c.AddFunc添加一个定时任务，第一个参数是cron时间表达式，第二个参数是要触发执行的函数
go c.Start()新启一个协程，运行定时任务
c.Stop是等待停止信号结束任务

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

var Parser cron.Parser

func init() {
	Parser = cron.NewParser(
		cron.Second | cron.Minute | cron.Hour | cron.Dom | cron.Month | cron.Dow,
	)

    c := cron.New(cron.WithParser(Parser))

    //添加定时任务 schedule 为cron表达式
    schedule := "0 30 * * * *"
    c.AddFunc(schedule, func() {
         // 处理业务
    }

    	c.Start()
	defer c.Stop()

	select {}
}

Beego任务实现

1.)获取beego task

go get github.com/beego/beego/v2/task

2.)代码示例

tk1 := task.NewTask("tk1", "0 12 * * * *", func(ctx context.Context) error {
	fmt.Println("tk1")
	return nil
})

task.AddTask("tk1", tk1)
task.StartTask()
defer task.StopTask()

相关链接

https://github.com/robfig/cron
https://pkg.go.dev/github.com/robfig/cron
https://github.com/ouqiang/gocron
https://www.lsdcloud.com/go/middleware/go-timer.html#_6-2-成员方法