Go常用包(二十七):定时任务管理Cron

1.介绍

在Linux
中，通过crontab
命令使任务在约定的时间执行已经计划好的工作，而Go
由于语言的特性，不适合直接使用crontab
来管理计划任务，cron (目前 Star8.3k)是一个用Go
实现的定时任务库，支持秒级定时任务，可以满足绝大多数工作场景需求。

2. 安装

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

复制

3. 快速使用

package main

import (
 "fmt"
 "github.com/robfig/cron/v3"
 "time"
)
func main() {
 // 开启秒字段支持
 c := cron.New(cron.WithSeconds())
 // 传统表达式写法: 每秒执行一次
 _, _ = c.AddFunc("0/1 * * * * *", func() {
  fmt.Println("传统表达式: ",time.Now().Format("2006-01-02 15:04:05"))
 })
 // 预定义表达式
 _,_ = c.AddFunc("@every 1s", func() {
  fmt.Println("预定义表达式: ",time.Now().Format("2006-01-02 15:04:05"))
 })
 // 启动
 c.Start()
 // 防止程序直接退出
 time.Sleep(time.Second * 3)
}
/**输出
预定义表达式:  2021-07-18 10:44:52
传统表达式:   2021-07-18 10:44:52
传统表达式:   2021-07-18 10:44:53
预定义表达式:  2021-07-18 10:44:53
传统表达式:    2021-07-18 10:44:54
预定义表达式:  2021-07-18 10:44:54
*/

复制

4. 添加任务方式

4.1 通过AddFunc

具体使用，参见上面的快速使用案例

4.2 通过AddJob

1. 使用步骤

• 第一步：定义类型
• 第二步：实现cron.Job
  接口，即给自定义类型添加方法Run()
  
• 第三步：通过AddJob
  方法添加到定时任务

2. 使用示例

package main

import (
 "fmt"
 "github.com/robfig/cron/v3"
 "time"
)
// 定义类型
type city struct {
 Name string
}
// 实现cron.Job接口
func (s city) Run()  {
 fmt.Printf("%s时间:%v\n",s.Name,time.Now().Format("2006-01-02 15:04:05"))
}

func main() {
 // 开启秒级别支持,默认支持最小粒度是分钟
 c := cron.New(cron.WithSeconds())
 // 添加定时任务
 _, _ = c.AddJob("@every 1s", city{
  Name: "北京",
 })
 // 启动
 c.Start()
 // 防止程序直接退出
 for {}
}

/**输出
北京时间:2021-07-18 11:21:50
北京时间:2021-07-18 11:21:51
北京时间:2021-07-18 11:21:52
...
*/

复制

5. 执行频率

5.1 cron时间表达式

@注意: cron默认支持最小粒度是分钟，若要支持秒级别,需要传入cron.WithSeconds()
来开启,开启后的cron时间表达式和Linux中的crontab时间表达式会有区别。

1. 开启秒级别后

2. 示例

@注意：下面表格示例，是在开启秒级级别支持情况下的写法。

5.2 预定义时间

1. 预表达式

上面通过表达式写，很容易会写错，还好cron
提供了预表达式，可以很方便各种场景的示例,具体如下:

2. 固定间隔(@every
)

@every duration
含义为每隔duration
触发一次。<duration>
会调用time.ParseDuration()
函数解析，所以ParseDuration
支持的格式都可以。单位为h(小时)、m(分钟)、s(秒)