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] 調度成功 ... ...
複製代碼

符合預期