golang定時任務

1 安裝依賴

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

2 定時任務HelloWorld

package main import ( "fmt" "github.com/robfig/cron/v3" "time" ) func main() { // 新建一個定時任務對象 // 根據cron表達式進行時間調度，cron可以精確到秒，大部分表達式格式也是從秒開始。 //crontab := cron.New() 默認從分開始進行時間調度 crontab := cron.New(cron.WithSeconds()) //精確到秒 //定義定時器調用的任務函數 task := func() { fmt.Println("hello world", time.Now()) } //定時任務 spec := "*/5 * * * * ?" //cron表達式，每五秒一次 // 添加定時任務, crontab.AddFunc(spec, task) // 啟動定時器 crontab.Start() // 定時任務是另起協程執行的,這里使用 select 簡答阻塞.實際開發中需要 // 根據實際情況進行控制 select {} //阻塞主線程停止 } ------------------------------------------輸出結果---------------------------------- hello world 2020-03-18 11:13:00.0241639 +0800 CST m=+3.113746301 hello world 2020-03-18 11:13:05.0007375 +0800 CST m=+8.090319901 hello world 2020-03-18 11:13:10.0004232 +0800 CST m=+13.090005601 hello world 2020-03-18 11:13:15.0003857 +0800 CST m=+18.089968101 hello world 2020-03-18 11:13:20.0003788 +0800 CST m=+23.089961201 

3 Cron 表達式

cron表達式是一個好東西，這個東西不僅Java的quartZ能用到，Go語言和Java中都是可以精確到秒的，但是Linux中不行。cron表達式代表一個時間的集合，使用6個空格分隔的字段表示：

字段名	是否必須	允許的值	允許的特定字符
秒(Seconds)	是	0-59	* / , -
分(Minute)	是	0-59	* / , -
時(Hours)	是	0-23	* / , -
日(Day of month)	是	1-31	* / , - ?
月(Month)	是	1-12 或 JAN-DEC	* / , -
星期(Day of week)	否	0-6 或 SUM-SAT	* / , - ?

3.1 Corn表達式說明

• 月(Month)和星期(Day of week)字段的值不區分大小寫，如：SUN、Sun 和 sun 是一樣的。
• 星期(Day of week)字段如果沒提供，相當於是 *

3.2 Corn表達式示例說明

如果我們使用 crontab := cron.New(cron.WithSeconds()),
比如我們傳遞了一個字符串是："* * * * * *"在crontab.AddFunc()的第一個參數，這六個*是指什么呢？
如果是用crontab := cron.New() 則只需要五個*,如* * * * *

 ┌─────────────second 范圍 (0 - 60) │ ┌───────────── min (0 - 59) │ │ ┌────────────── hour (0 - 23) │ │ │ ┌─────────────── day of month (1 - 31) │ │ │ │ ┌──────────────── month (1 - 12) │ │ │ │ │ ┌───────────────── day of week (0 - 6) (0 to 6 are Sunday to │ │ │ │ │ │ Saturday) │ │ │ │ │ │ │ │ │ │ │ │ * * * * * * 

3.3 cron特定字符說明

符號	說明
(*)	表示 cron 表達式能匹配該字段的所有值。如在第5個字段使用星號(month)，表示每個月
(/)	表示增長間隔，如第1個字段(minutes) 值是 3-59/15，表示每小時的第3分鍾開始執行一次，之后每隔 15 分鍾執行一次（即 3、18、33、48 這些時間點執行），這里也可以表示為：3/15
(,)	用於枚舉值，如第6個字段值是 MON,WED,FRI，表示 星期一、三、五 執行
(-)	表示一個范圍，如第3個字段的值為 9-17 表示 9am 到 5pm 直接每個小時（包括9和17）
(?)	只用於 日(Day of month) 和 星期(Day of week)，表示不指定值，可以用於代替 *

3.4 常用cron舉例

每隔5秒執行一次：*/5 * * * * ? 每隔1分鍾執行一次：0 */1 * * * ? 每天23點執行一次：0 0 23 * * ? 每天凌晨1點執行一次：0 0 1 * * ? 每月1號凌晨1點執行一次：0 0 1 1 * ? 每周一和周三晚上22:30: 00 30 22 * * 1,3 在26分、29分、33分執行一次：0 26,29,33 * * * ? 每天的0點、13點、18點、21點都執行一次：0 0 0,13,18,21 * * ? 每年三月的星期四的下午14:10和14:40: 00 10,40 14 ? 3 4 

3.5 預定義的時間格式

您可以使用幾個預定義的表達式來代替上表的表達式,使用如下

輸入	描述	等式
@yearly (or @annually)	每年1月1日午夜跑步一次	0 0 0 1 1 *
@monthly	每個月第一天的午夜跑一次	0 0 0 1 * *
@weekly	每周周六的午夜運行一次	0 0 0 * * 0
@daily (or @midnight)	每天午夜跑一次	0 0 0 * * *
@hourly	每小時運行一次	0 0 * * * *
@every <duration>	every duration

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

4 多個定時任務

package main import ( "fmt" "github.com/robfig/cron/v3" "time" ) type TestTask struct { Name string } func (t *TestTask) Run() { fmt.Println("TestTask", t.Name) } type Test2Task struct { Name string } func (t *Test2Task) Run() { fmt.Println("Test2Task", t.Name) } func main() { // 新建一個定時任務對象 // 根據cron表達式進行時間調度，cron可以精確到秒，大部分表達式格式也是從秒開始。 //crontab := cron.New() 默認從分開始進行時間調度 crontab := cron.New(cron.WithSeconds()) //精確到秒 //定義定時器調用的任務函數 //定時任務 spec := "*/5 * * * * ?" //cron表達式，每五秒一次 //定義定時器調用的任務函數 task := func() { fmt.Println("hello world", time.Now()) } // 添加定時任務 crontab.AddFunc(spec, task) // 添加多個定時器 crontab.AddJob(spec, &TestTask{Name: "tom"}) crontab.AddJob(spec, &Test2Task{Name: "jeck"}) // 啟動定時器 crontab.Start() //關閉着計划任務, 但是不能關閉已經在執行中的任務. defer crontab.Stop() // 定時任務是另起協程執行的,這里使用 select 簡答阻塞.實際開發中需要 // 根據實際情況進行控制 select {} //阻塞主線程停止 } --------------------------------------輸出結果---------------------------------------- TestTask tom Test2Task jeck hello world 2020-03-18 13:22:10.0245997 +0800 CST m=+2.761856801 TestTask tom Test2Task jeck hello world 2020-03-18 13:22:15.0008245 +0800 CST m=+7.738081601 ……………………………………

 
實際應用

func init() {
   task := cron.New(cron.WithSeconds())
   if _, err := task.AddFunc("*/1 * * * * *", func() {
      service := TaskGyReturnOrder{}
      service.GetReturnOrderResult(1, 10)
      //fmt.Print("6")
   }); err != nil {
      //time.Sleep(time.Second * 60)
   } else {
      task.Start()
   }
}