前言
国庆闲来无事,把之前开源的一个定时任务调度中心重构了一下。
期间遇到了一些crontab的坑
CronTab
我们来看一下crontab的时间格式,
Spec参考beego toolbox模块下的crontab的组成格式:
//前6个字段分别表示:
// 秒钟:0-59
// 分钟:0-59
// 小时:1-23
// 日期:1-31
// 月份:1-12
// 星期:0-6(0 表示周日)
//还可以用一些特殊符号:
// *: 表示任何时刻
// ,: 表示分割,如第三段里:2,4,表示 2 点和 4 点执行
// -:表示一个段,如第三端里: 1-5,就表示 1 到 5 点
// /n : 表示每个n的单位执行一次,如第三段里,*/1, 就表示每隔 1 个小时执行一次命令。也可以写成1-23/1.
/////////////////////////////////////////////////////////
// 0/30 * * * * * 每 30 秒 执行
// 0 43 21 * * * 21:43 执行
// 0 15 05 * * * 05:15 执行
// 0 0 17 * * * 17:00 执行
// 0 0 17 * * 1 每周一的 17:00 执行
// 0 0,10 17 * * 0,2,3 每周日,周二,周三的 17:00和 17:10 执行
// 0 0-10 17 1 * * 毎月1日从 17:00 到 7:10 毎隔 1 分钟 执行
// 0 0 0 1,15 * 1 毎月1日和 15 日和 一日的 0:00 执行
// 0 42 4 1 * * 毎月1日的 4:42 分 执行
// 0 0 21 * * 1-6 周一到周六 21:00 执行
// 0 0,10,20,30,40,50 * * * * 每隔 10 分 执行
// 0 */10 * * * * 每隔 10 分 执行
// 0 * 1 * * * 从 1:0 到 1:59 每隔 1 分钟 执行
// 0 0 1 * * * 1:00 执行
// 0 0 */1 * * * 毎时 0 分 每隔 1 小时 执行
// 0 0 * * * * 毎时 0 分 每隔 1 小时 执行
// 0 2 8-20/3 * * * 8:02,11:02,14:02,17:02,20:02 执行
// 0 30 5 1,15 * * 1 日 和 15 日的 5:30 执行
复制代码
PS:beego的定时模块比较强大,支持了秒级别的定时任务
现在假设当前时间为21:11:05, 如何定义一个每隔5分钟循环运行的定时任务?
网上搜索,大部分都是这样的方案:
0 */5 * * * *
复制代码
ok,我们运行下该定时任务,看看会发生什么情况:
2019/10/05 21:11:05:087825 local [INFO] ------ 定时任务: [Test] 加载成功 ------ cron.go:155
2019/10/05 21:12:00:007810 local [DEBUG] 定时任务: [Test] 成功获取Redis分布式锁, 开始执行调度任务 delivery.go:90
2019/10/05 21:12:00:036411 local [DEBUG] 定时任务: [Test] 调度成功 ... ...
2019/10/05 21:17:00:004286 local [DEBUG] 定时任务: [Test] 成功获取Redis分布式锁, 开始执行调度任务 delivery.go:90
2019/10/05 21:17:00:010506 local [DEBUG] 定时任务: [Test] 调度成功 ... ...
复制代码
很奇怪,为什么任务不是21:16:05运行,而是21:12:00就开始运行了
网上大致的解释为:
设置的N应该被60整除才行”的意思是:如果N能被60整除,则会相当于每隔N分钟执行一次,一个小时正好执行60/N次;如果N不能被60整除,则在能整除和整点(除完余数为0)的时候都会执行。
如何解决?
-
秒
秒(第一位):替换为 当前秒/60,当前秒之后每隔60秒执行一次;
-
分(只替换如下格式的):
*/?
分(第二位):替换为当前分/每隔多少分,当前分之后每隔多少分执行一次;
-
小时(只替换如下格式的):
*/?
小时(第三位):替换为当前小时/每隔多少小时,当前小时之后每隔多少小时执行一次;
举例:每隔7分钟、每隔9分钟、每隔14分钟、每隔27分钟
以21:16:05为例
0 */7 * * * * 替换为: 5/60 16/7 * * * *
0 */9 * * * * 替换为: 5/60 16/9 * * * *
0 */14 * * * * 替换为: 5/60 16/14 * * * *
0 */27 * * * * 替换为: 5/60 16/27 * * * *
复制代码
代码解决方案:
func ConvertSecond(spec string) string {
if spec != "" {
_spec := strings.Split(spec, " ")
hour, minute, second := time.Now().Clock()
// second处理
_second := strconv.FormatInt(int64(second), 10) + "/60"
spec = strings.Replace(spec, _spec[0], _second, 1)
// minute处理(类似: */5)
if strings.HasPrefix(_spec[1], "*/") {
_minute := strconv.FormatInt(int64(minute), 10) + "/" + strings.Trim(_spec[1], "*/")
spec = strings.Replace(spec, _spec[1], _minute, 1)
}
// hour处理(类似: */5)
if strings.HasPrefix(_spec[2], "*/") {
_hour := strconv.FormatInt(int64(hour), 10) + "/" + strings.Trim(_spec[2], "*/")
spec = strings.Replace(spec, _spec[2], _hour, 1)
}
return spec
}
return ""
}
复制代码
ok,我们再次运行下该定时任务,查看结果:
2019/10/05 21:18:38:333458 local [INFO] ------ 定时任务: [Test] 加载成功 ------ cron.go:155
2019/10/05 21:23:38:002390 local [DEBUG] 定时任务: [Test] 成功获取Redis分布式锁, 开始执行调度任务 delivery.go:90
2019/10/05 21:23:38:009905 local [DEBUG] 定时任务: [Test] 调度成功 ... ...
2019/10/05 21:28:38:008273 local [DEBUG] 定时任务: [Test] 成功获取Redis分布式锁, 开始执行调度任务 delivery.go:90
2019/10/05 21:28:38:011781 local [DEBUG] 定时任务: [Test] 调度成功 ... ...
复制代码
符合预期
有疑问加站长微信联系(非本文作者)