登录
首页 >  Golang >  Go教程

一文带你入门Go语言中定时任务库Cron的使用

来源:脚本之家

时间:2023-01-07 11:58:53 250浏览 收藏

在Golang实战开发的过程中,我们经常会遇到一些这样那样的问题,然后要卡好半天,等问题解决了才发现原来一些细节知识点还是没有掌握好。今天golang学习网就整理分享《一文带你入门Go语言中定时任务库Cron的使用》,聊聊cron、定时、任务,希望可以帮助到正在努力赚钱的你。

golang 实现定时服务很简单,只需要简单几步代码便可以完成,不需要配置繁琐的服务器,直接在代码中实现。

使用 github.com/robfig/cron 这个包,robfig/cron是一个第三方开源的任务调度库,也就是我们平时说的定时任务,它实现了 cron 规范解析器和任务运行器。

快速开始

安装

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

导入

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

Demo

package main

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

func main() {
	// 创建一个默认的cron对象
    c := cron.New()
    
    //添加执行任务
	c.AddFunc("30 * * * *", func() { fmt.Println("Every hour on the half hour") })
	c.AddFunc("@hourly", func() { fmt.Println("Every hour, starting an hour from now") })
	c.AddFunc("@every 1h30m", func() { fmt.Println("Every hour thirty, starting an hour thirty from now") })
	
    //开始执行任务
    c.Start()
	select {} //阻塞
}

Cron表达式格式

标准格式

一个 cron 表达式表示一组时间,使用 5 个空格分隔的字段。这是v3版本默认支持的格式,没有Seconds。在v3版本中也支持秒级别的解析,需要自定义解析器。

Field name   | Mandatory? | Allowed values  | Allowed special characters
----------   | ---------- | --------------  | --------------------------
Seconds      | Yes        | 0-59            | * / , -
Minutes      | Yes        | 0-59            | * / , -
Hours        | Yes        | 0-23            | * / , -
Day of month | Yes        | 1-31            | * / , - ?
Month        | Yes        | 1-12 or JAN-DEC | * / , -
Day of week  | Yes        | 0-6 or SUN-SAT  | * / , - ?

预定义时间表

可以用@yearly@monthly@weekly@weekly@daily@hourly来替代cron表达式。分别表示每年,每月、每星期、每天、每小时。

还可以用@every 来表示间隔时间,即间隔执行一次任务。只要可以被time.ParseDuration()解析即可。

常用的方法介绍

new()

会根据本地时间创建一个新(空白)的计划任务实例

// 创建一个默认的cron对象
cron.New()

// 自定义解析器
cron.New(cron.WithSeconds())

// Seconds field, optional
cron.New(cron.WithParser(cron.NewParser(
    cron.SecondOptional | cron.Minute | cron.Hour | cron.Dom | cron.Month | cron.Dow | cron.Descriptor,
)))

AddJob()

// 有两个参数,第一个参数可以是cron表达式或者预定义时间表,第二个Job
func (c *Cron) AddJob(spec string, cmd Job) (EntryID, error)

// Job是一个接口,有一个Run方法
type Job interface {
	Run()
}

AddFunc()

会向计划任务实例中添加一个回调函数,按指定时间表执行回调函数。

// 有两个参数,第一个参数可以是cron表达式或者预定义时间表,第二个传入一个函数,就是要执行的任务
// 会返回一个Id和error
// 会把传入的cmd func转成FuncJob。FuncJob实现了Job接口
func (c *Cron) AddFunc(spec string, cmd func()) (EntryID, error) {
	return c.AddJob(spec, FuncJob(cmd))
}

Start()

调用start方法开始执行任务

相关推荐

Go第三方库之cronexpr——解析 crontab 表达式

cronexpr 是一个 crontab 解析表达式的库,我们可以根据当前时间获取到下次执行的时间。具体用法如下:

go get github.com/gorhill/cronexpr //下载
import "github.com/gorhill/cronexpr" //导入

demo:

package main

import (
	"fmt"
	"time"

	"github.com/gorhill/cronexpr"
)

func doTask() {
	fmt.Println("I am running, time is: ", time.Now())
}
func main() {

	// 每隔 5 秒执行1次
	expr, err := cronexpr.Parse("*/10 * * * * * * ") // 如果表达式解析错误将返回一个错误
	if err != nil {
		fmt.Println(err)
		return
	}
    
    //获取下次执行时间
	nextTime := expr.Next(time.Now()) 
	fmt.Println(nextTime)

	time.AfterFunc(time.Until(nextTime), doTask)
    
    //返回当前crontab后的5次执行,n为次数
    nextTimeList = cronexpr.MustParse("*/10 * * * * * * ").NextN(time.Now(), 5)
    for _, v := range nextTimeList {
        fmt.Println(v.String())
    } 
    
	time.Sleep(10 * time.Second)

}

总结

定时任务很常见,希望你通过本文能够熟知 Golang 怎么实现一个简单的定时任务调度管理

可以不依赖系统的 Crontab 设置,指不定哪一天就用上了。

文中关于golang的知识介绍,希望对你的学习有所帮助!若是受益匪浅,那就动动鼠标收藏这篇《一文带你入门Go语言中定时任务库Cron的使用》文章吧,也可关注golang学习网公众号了解相关技术文章。

声明:本文转载于:脚本之家 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>