golang定时任务踩坑及终极解决方案

前言

国庆闲来无事，把以前开源的一个定时任务调度中心重构了一下。

期间遇到了一些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] 调度成功 ... ...
复制代码

符合预期