一文帶你入門Go語言中定時任務(wù)庫Cron的使用
前言
在平時的開發(fā)需求中,我們經(jīng)常會有一些重復(fù)執(zhí)行的操作需要觸發(fā)執(zhí)行,和系統(tǒng)約個時間,在幾點幾分幾秒或者每隔幾分鐘跑一個任務(wù),說白了就是定時任務(wù),,想必大家第一反應(yīng)都是linux的Crontab。其實定時任務(wù)不止使用系統(tǒng)自帶的Crontab,在Go語言中也可以使用Cron定時任務(wù)庫, 這篇文章給大家介紹如何在go項目中實現(xiàn)一個crontab功能,感興趣的小伙伴們可以參考借鑒,希望對大家能有所幫助。
golang 實現(xiàn)定時服務(wù)很簡單,只需要簡單幾步代碼便可以完成,不需要配置繁瑣的服務(wù)器,直接在代碼中實現(xiàn)。
使用 github.com/robfig/cron 這個包,robfig/cron是一個第三方開源的任務(wù)調(diào)度庫,也就是我們平時說的定時任務(wù),它實現(xiàn)了 cron 規(guī)范解析器和任務(wù)運行器。
快速開始
安裝
go get github.com/robfig/cron/v3@v3.0.0
導(dǎo)入
import "github.com/robfig/cron/v3"
Demo
package main
import (
"fmt"
"github.com/robfig/cron/v3"
)
func main() {
// 創(chuàng)建一個默認(rèn)的cron對象
c := cron.New()
//添加執(zhí)行任務(wù)
c.AddFunc("30 * * * *", func() { fmt.Println("Every hour on the half hour") })
c.AddFunc("@hourly", func() { fmt.Println("Every hour, starting an hour from now") })
c.AddFunc("@every 1h30m", func() { fmt.Println("Every hour thirty, starting an hour thirty from now") })
//開始執(zhí)行任務(wù)
c.Start()
select {} //阻塞
}Cron表達(dá)式格式
標(biāo)準(zhǔn)格式
一個 cron 表達(dá)式表示一組時間,使用 5 個空格分隔的字段。這是v3版本默認(rèn)支持的格式,沒有Seconds。在v3版本中也支持秒級別的解析,需要自定義解析器。
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 | * / , - ?
預(yù)定義時間表
可以用@yearly、@monthly、@weekly、@weekly、@daily、@hourly來替代cron表達(dá)式。分別表示每年,每月、每星期、每天、每小時。
還可以用@every <duartion>來表示間隔時間,即間隔執(zhí)行一次任務(wù)。只要可以被time.ParseDuration()解析即可。
常用的方法介紹
new()
會根據(jù)本地時間創(chuàng)建一個新(空白)的計劃任務(wù)實例
// 創(chuàng)建一個默認(rèn)的cron對象
cron.New()
// 自定義解析器
cron.New(cron.WithSeconds())
// Seconds field, optional
cron.New(cron.WithParser(cron.NewParser(
cron.SecondOptional | cron.Minute | cron.Hour | cron.Dom | cron.Month | cron.Dow | cron.Descriptor,
)))
AddJob()
// 有兩個參數(shù),第一個參數(shù)可以是cron表達(dá)式或者預(yù)定義時間表,第二個Job
func (c *Cron) AddJob(spec string, cmd Job) (EntryID, error)
// Job是一個接口,有一個Run方法
type Job interface {
Run()
}AddFunc()
會向計劃任務(wù)實例中添加一個回調(diào)函數(shù),按指定時間表執(zhí)行回調(diào)函數(shù)。
// 有兩個參數(shù),第一個參數(shù)可以是cron表達(dá)式或者預(yù)定義時間表,第二個傳入一個函數(shù),就是要執(zhí)行的任務(wù)
// 會返回一個Id和error
// 會把傳入的cmd func轉(zhuǎn)成FuncJob。FuncJob實現(xiàn)了Job接口
func (c *Cron) AddFunc(spec string, cmd func()) (EntryID, error) {
return c.AddJob(spec, FuncJob(cmd))
}Start()
調(diào)用start方法開始執(zhí)行任務(wù)
相關(guān)推薦
Go第三方庫之cronexpr——解析 crontab 表達(dá)式
cronexpr 是一個 crontab 解析表達(dá)式的庫,我們可以根據(jù)當(dāng)前時間獲取到下次執(zhí)行的時間。具體用法如下:
go get github.com/gorhill/cronexpr //下載 import "github.com/gorhill/cronexpr" //導(dǎo)入
demo:
package main
import (
"fmt"
"time"
"github.com/gorhill/cronexpr"
)
func doTask() {
fmt.Println("I am running, time is: ", time.Now())
}
func main() {
// 每隔 5 秒執(zhí)行1次
expr, err := cronexpr.Parse("*/10 * * * * * * ") // 如果表達(dá)式解析錯誤將返回一個錯誤
if err != nil {
fmt.Println(err)
return
}
//獲取下次執(zhí)行時間
nextTime := expr.Next(time.Now())
fmt.Println(nextTime)
time.AfterFunc(time.Until(nextTime), doTask)
//返回當(dāng)前crontab后的5次執(zhí)行,n為次數(shù)
nextTimeList = cronexpr.MustParse("*/10 * * * * * * ").NextN(time.Now(), 5)
for _, v := range nextTimeList {
fmt.Println(v.String())
}
time.Sleep(10 * time.Second)
}總結(jié)
定時任務(wù)很常見,希望你通過本文能夠熟知 Golang 怎么實現(xiàn)一個簡單的定時任務(wù)調(diào)度管理
可以不依賴系統(tǒng)的 Crontab 設(shè)置,指不定哪一天就用上了。
到此這篇關(guān)于一文帶你入門Go語言中定時任務(wù)庫Cron的使用的文章就介紹到這了,更多相關(guān)Go語言定時任務(wù)庫Cron內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Go?for-range?的?value值地址每次都一樣的原因解析
循環(huán)語句是一種常用的控制結(jié)構(gòu),在?Go?語言中,除了?for?關(guān)鍵字以外,還有一個?range?關(guān)鍵字,可以使用?for-range?循環(huán)迭代數(shù)組、切片、字符串、map?和?channel?這些數(shù)據(jù)類型,這篇文章主要介紹了Go?for-range?的?value值地址每次都一樣的原因解析,需要的朋友可以參考下2023-05-05
Golang處理gRPC請求/響應(yīng)元數(shù)據(jù)的示例代碼
前段時間實現(xiàn)內(nèi)部gRPC框架時,為了實現(xiàn)在服務(wù)端攔截器中打印請求及響應(yīng)的頭部信息,便查閱了部分關(guān)于元數(shù)據(jù)的資料,因為中文網(wǎng)絡(luò)上對于該領(lǐng)域的信息較少,于是在這做了一些簡單的總結(jié),需要的朋友可以參考下2024-03-03
Golang結(jié)合ip2region實現(xiàn)ip歸屬地查詢
ip2region - 是一個離線IP地址定位庫和IP定位數(shù)據(jù)管理框架,提供了眾多主流編程語言的 xdb 數(shù)據(jù)生成和查詢客戶端實現(xiàn),下面我們就來看看Golang如何結(jié)合ip2region實現(xiàn)ip歸屬地查詢吧2024-03-03
Go?Error?嵌套實現(xiàn)創(chuàng)建方式
這篇文章主要介紹了Go?Error?嵌套到底是怎么實現(xiàn)的?大家都知道創(chuàng)建error有兩種方式分別是errors.new()另一種是fmt.errorf(),本文通過詳細(xì)例子給大家介紹,需要的朋友可以參考下2022-01-01
Golang AGScheduler動態(tài)持久化任務(wù)調(diào)度的強大庫使用實例
這篇文章主要為大家介紹了Golang AGScheduler動態(tài)持久化任務(wù)調(diào)度的強大庫使用實例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-10-10
詳解如何使用pprof簡單檢測和修復(fù)Go語言中的內(nèi)存泄漏
雖然?Go?有自動垃圾回收(GC),它能回收不再被使用的內(nèi)存,但這并不意味著?Go?程序中不會發(fā)生內(nèi)存泄漏,下面我們就來看看如何使用pprof進(jìn)行檢測和修復(fù)Go語言中的內(nèi)存泄漏吧2025-01-01

