【Golang】定时任务Cron指南-毫秒级任务支持

2024-02-09 08:04
文章标签 golang 支持 指南 定时 任务 cron 毫秒 级任务

本文主要是介绍【Golang】定时任务Cron指南-毫秒级任务支持，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

文章目录

  • Cron
    • Cron快速使用
    • 时间表达式
      • 最小分钟级任务
      • 最小秒级任务
      • 预定义的时间表
    • 时区
    • Job
    • 选项
      • Job 包装器
      • WithLogger
    • 支持毫秒级任务

Cron

版本：v3.0.0
仓库：https://github.com/robfig/cron

cron是golang实现定时任务比较好的库, 这个库提供了一个简单而强大的接口，用于创建和管理基于cron表达式的定时任务。cron库的主要特点有：

  • 基于cron表达式的任务调度
  • 多任务支持
  • 容错和错误处理
  • 可靠性
  • 易用的API
  • 灵活性
  • 并发安全

Cron快速使用

package mainimport ("fmt""github.com/robfig/cron/v3"
)func main() {job := cron.New()job.AddFunc("@every 1s", func() {fmt.Println("hello world")})job.Start()select {}
}

上述简单的示例表示，每秒钟执行一次hello world打印。其中容易让人产生困惑的是"@every 1s"的含义，这是一条描述定时任务执行的时间表达式，下面将会具体介绍。

时间表达式

cron库支持用 6 个空格分隔的域来表示时间（在v3版本中新增了对秒级任务的支持）：

# ┌────────────── second (0–59)
# │ ┌───────────── minute (0–59)
# │ │ ┌───────────── hour (0–23)
# │ │ │ ┌───────────── day of the month (1–31)
# │ │ │ │ ┌───────────── month (1–12)
# │ │ │ │ │ ┌───────────── day of the week (0–6) (Sunday to Saturday;
# │ │ │ │ │ │                                   7 is also Sunday on some systems)
# │ │ │ │ │ │
# │ │ │ │ │ │
# * * * * * * <command to execute>

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  | * / , - ?
  • 星号 (*)：星号表示 cron 表达式将匹配该字段的所有值；例如，在第 5 个字段（月份）中使用星号将表示每个月。
  • 斜杠 (/)：斜杠用于描述范围的步长。例如，第2个字段（分钟）中的 3-59/15 表示该小时的第 3 分钟以及此后每 15 分钟一次。
  • 逗号 (,)：逗号用于分隔列表中的项目。例如，在第 6 个字段（星期几）中使用“MON,WED,FRI”将表示星期一、星期三和星期五。
  • 连字符 (-)：连字符用于定义范围。例如，在第 3 个字段（小时）9-17 表示上午 9 点到下午 5 点之间的每小时（含）。
  • 问号(?)：只能用在月和周的域中，用来代替*，表示每月/周的任意一天。

最小分钟级任务

使用这种以空格分隔的域来表示时间的方式默认情况下只能支持到分钟级任务：

package mainimport ("fmt""github.com/robfig/cron/v3"
)func main() {job := cron.New()job.AddFunc("* * * * *", func() {fmt.Println("hello world")})job.Start()select {}
}

表示每分钟执行一次
注意：实测在v3.0.1版本6个*是不会执行任务的。
查看表达是是否正确：https://crontab.guru/

最小秒级任务

如果想要支持秒级任务，则需添加cron.WithSeconds选项：

package mainimport ("fmt""github.com/robfig/cron/v3"
)func main() {job := cron.New()job.AddFunc("* * * * * *", func() {fmt.Println("hello world")})job.Start()select {}
}

表示每秒执行一次
注意：添加了cron.WithSeconds后6个*可以正确执行。

预定义的时间表

可以使用几个预定义计划之一来代替 cron 表达式。

Entry                  | Description                                | Equivalent To
-----                  | -----------                                | -------------
@yearly (or @annually) | Run once a year, midnight, Jan. 1st        | 0 0 0 1 1 *
@monthly               | Run once a month, midnight, first of month | 0 0 0 1 * *
@weekly                | Run once a week, midnight between Sat/Sun  | 0 0 0 * * 0
@daily (or @midnight)  | Run once a day, midnight                   | 0 0 0 * * *
@hourly                | Run once an hour, beginning of hour        | 0 0 * * * *

还可以安排作业以固定的时间间隔执行，从添加作业或运行 cron 时开始。这是通过格式化 cron 规范来支持的，如下所示：

@every <duration>

其中“duration”是 time.ParseDuration 接受的字符串（http://golang.org/pkg/time/#ParseDuration）
例子：

c := cron.New()
c.AddFunc("@hourly",      func() { fmt.Println("Every hour") })
c.AddFunc("@every 1h30m", func() { fmt.Println("Every hour thirty") })
c.AddFunc("@every 1s", func() { fmt.Println("Every seconds") })
c.Start()

cron还提供了cron.Every方法，用于直接接收time.Duration来设置任务间隔：

package mainimport ("fmt""time""github.com/robfig/cron/v3"
)func main() {job := cron.New(cron.WithSeconds())job.Schedule(cron.Every(1*time.Second), cron.FuncJob(func() {fmt.Println("hello world")}))job.Start()select {}
}

时区

默认情况下任务是基于当前时区的，cron也可以设置不同的时区:

loLosAngeles, _ := time.LoadLocation("America/Los_Angeles")
job := cron.New(cron.WithLocation(loLosAngeles))
job.AddFunc("0 6 * * ?", func() {fmt.Println("Every 6 o'clock at Los Angeles")
})

或者：

job.AddFunc("CRON_TZ=Asia/Tokyo 0 6 * * ?", func() {fmt.Println("Every 6 o'clock at Tokyo")
})

Job

除了使用无参的回调方式，cron还提供了实现job接口的方式：

type Job interface {Run()
}

实现job接口

package mainimport ("fmt""time""github.com/robfig/cron/v3"
)func main() {job := cron.New(cron.WithSeconds())j := &myJob{}job.AddJob("@every 1s", j)job.Start()select {}
}type myJob struct {i int
}func (j *myJob) Run() {j.i++fmt.Println("hello world:", j.i)
}

执行结果：

hello world: 1
hello world: 2
hello world: 3
hello world: 4
hello world: 5
hello world: 6

选项

  • WithLocation：指定时区
  • WithParser：使用自定义的解析器
  • WithSeconds：让时间格式支持秒
  • WithLogger：自定义日志
  • WithChain：Job 包装器

Job 包装器

Job 包装器可以在执行实际的Job前后添加一些逻辑

cron库提供了一些常用的包装器：

  • cron.DelayIfStillRunning: 如果上周期的任务还在执行，则延迟此次并产生一条Info日志
  • cron.SkipIfStillRunning：如果上周期的任务还在执行，则跳过此次并产生一条Info日志
  • cron.Recover：捕获任务异常，并产生error日志

WithLogger

cron提供默认的标准输出日志打印cron.DefaultLogger和丢弃日志cron.DiscardLogger两种：

// DefaultLogger is used by Cron if none is specified.
var DefaultLogger Logger = PrintfLogger(log.New(os.Stdout, "cron: ", log.LstdFlags))// DiscardLogger can be used by callers to discard all log messages.
var DiscardLogger Logger = PrintfLogger(log.New(ioutil.Discard, "", 0))

也可是使用cron.PrintfLogger和cron.VerbosePrintfLogger包装：

  • cron.PrintfLogger: 只打印错误日志
  • cron.VerbosePrintfLogger：打印详细日志
package mainimport ("fmt""github.com/robfig/cron/v3"
)func main() {job := cron.New(cron.WithLogger(cron.VerbosePrintfLogger(log.New(os.Stdout, "cron: ", log.LstdFlags),)),)job.AddFunc("@every 1s", func() {fmt.Println("hello world")})job.Start()select {}
}

支持毫秒级任务

cron库给出的方法最小只能支持到秒级任务，如果想要精确到毫秒级任务，则需要重新实现Schedule接口

// Schedule describes a job's duty cycle.
type Schedule interface {// Next returns the next activation time, later than the given time.// Next is invoked initially, and then each time the job is run.Next(time.Time) time.Time
}

自定义一个ConstantDelaySchedule结构体，并给出Every方法（这边我限制最小到200ms）

package cronimport "time"// ConstantDelaySchedule represents a simple recurring duty cycle, e.g. "Every 5 minutes".
// It does not support jobs more frequent than once a second.
type ConstantDelaySchedule struct {Delay time.Duration
}// Every returns a crontab Schedule that activates once every duration.
// Delays of less than a second are not supported (will round up to 1 second).
// Any fields less than a Second are truncated.
func Every(duration time.Duration) ConstantDelaySchedule {min := 200 * time.Millisecondif duration < min {duration = min}return ConstantDelaySchedule{Delay: duration,}
}// Next returns the next time this should be run.
// This rounds so that the next activation time will be on the second.
func (schedule ConstantDelaySchedule) Next(t time.Time) time.Time {return t.Add(schedule.Delay)
}

调用：

package mainimport ("fmt""time""github.com/robfig/cron/v3"
)func main() {job := cron.New(cron.WithSeconds())j := &myJob{t: time.Now(),}job.Schedule(Every(200*time.Millisecond), j)job.Start()select {}
}type myJob struct {i intt time.Time
}func (j *myJob) Run() {j.i++now := time.Now()sub := now.Sub(j.t)j.t = nowfmt.Printf("hello world: %d, duraction : %d ms \n", j.i, sub.Milliseconds())
}

结果：

hello world: 1, duraction : 201 ms 
hello world: 2, duraction : 201 ms 
hello world: 3, duraction : 201 ms 
hello world: 4, duraction : 201 ms 
hello world: 5, duraction : 201 ms 
hello world: 6, duraction : 200 ms 
hello world: 7, duraction : 201 ms 
hello world: 8, duraction : 201 ms 
hello world: 9, duraction : 201 ms

这篇关于【Golang】定时任务Cron指南-毫秒级任务支持的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/693637。

相关文章

Golang中拼接字符串的6种方式性能对比

Golang中拼接字符串的6种方式性能对比

《Golang中拼接字符串的6种方式性能对比》golang的string类型是不可修改的,对于拼接字符串来说,本质上还是创建一个新的对象将数据放进去,主要有6种拼接方式,下面小编就来为大家详细讲讲吧... 目录拼接方式介绍性能对比测试代码测试结果源码分析golang的string类型是不可修改的，对于拼接字
阅读更多...
Java使用Mail构建邮件功能的完整指南

Java使用Mail构建邮件功能的完整指南

《Java使用Mail构建邮件功能的完整指南》JavaMailAPI是一个功能强大的工具,它可以帮助开发者轻松实现邮件的发送与接收功能,本文将介绍如何使用JavaMail发送和接收邮件,希望对大家有所... 目录1、简述2、主要特点3、发送样例3.1 发送纯文本邮件3.2 发送 html 邮件3.3 发送带
阅读更多...
IDEA连接达梦数据库的详细配置指南

IDEA连接达梦数据库的详细配置指南

《IDEA连接达梦数据库的详细配置指南》达梦数据库（DMDatabase）作为国产关系型数据库的代表,广泛应用于企业级系统开发,本文将详细介绍如何在IntelliJIDEA中配置并连接达梦数据库,助力... 目录准备工作1. 下载达梦JDBC驱动配置步骤1. 将驱动添加到IDEA2. 创建数据库连接连接参数
阅读更多...
一文教你解决Python不支持中文路径的问题

一文教你解决Python不支持中文路径的问题

《一文教你解决Python不支持中文路径的问题》Python是一种广泛使用的高级编程语言,然而在处理包含中文字符的文件路径时,Python有时会表现出一些不友好的行为,下面小编就来为大家介绍一下具体的... 目录问题背景解决方案1. 设置正确的文件编码2. 使用pathlib模块3. 转换路径为Unicod
阅读更多...
如何通过Golang的container/list实现LRU缓存算法

如何通过Golang的container/list实现LRU缓存算法

《如何通过Golang的container/list实现LRU缓存算法》文章介绍了Go语言中container/list包实现的双向链表,并探讨了如何使用链表实现LRU缓存,LRU缓存通过维护一个双向... 目录力扣：146. LRU 缓存主要结构 List 和 Element常用方法1. 初始化链表2.
阅读更多...
JavaScript中的Map用法完全指南

JavaScript中的Map用法完全指南

《JavaScript中的Map用法完全指南》：本文主要介绍JavaScript中Map用法的相关资料,通过实例讲解了Map的创建、常用方法和迭代方式,还探讨了Map与对象的区别,并通过一个例子展... 目录引言1. 创建 Map2. Map 和对象的对比3. Map 的常用方法3.1 set(key, v
阅读更多...
Java中使用注解校验手机号格式的详细指南

Java中使用注解校验手机号格式的详细指南

《Java中使用注解校验手机号格式的详细指南》在现代的Web应用开发中,数据校验是一个非常重要的环节,本文将详细介绍如何在Java中使用注解对手机号格式进行校验,感兴趣的小伙伴可以了解下... 目录1. 引言2. 数据校验的重要性3. Java中的数据校验框架4. 使用注解校验手机号格式4.1 @NotBl
阅读更多...
使用Java发送邮件到QQ邮箱的完整指南

使用Java发送邮件到QQ邮箱的完整指南

《使用Java发送邮件到QQ邮箱的完整指南》在现代软件开发中,邮件发送功能是一个常见的需求,无论是用户注册验证、密码重置,还是系统通知,邮件都是一种重要的通信方式,本文将详细介绍如何使用Java编写程... 目录引言1. 准备工作1.1 获取QQ邮箱的SMTP授权码1.2 添加JavaMail依赖2. 实现
阅读更多...
Golang基于内存的键值存储缓存库go-cache

Golang基于内存的键值存储缓存库go-cache

《Golang基于内存的键值存储缓存库go-cache》go-cache是一个内存中的key:valuestore/cache库,适用于单机应用程序,本文主要介绍了Golang基于内存的键值存储缓存库... 目录文档安装方法示例1示例2使用注意点优点缺点go-cache 和 Redis 缓存对比1）功能特性
阅读更多...
Golang中map缩容的实现

Golang中map缩容的实现

《Golang中map缩容的实现》本文主要介绍了Go语言中map的扩缩容机制,包括grow和hashGrow方法的处理,具有一定的参考价值,感兴趣的可以了解一下... 目录基本分析带来的隐患为什么不支持缩容基本分析在 Go 底层源码 src/runtime/map.go 中，扩缩容的处理方法是 grow
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2