日本免费高清视频-国产福利视频导航-黄色在线播放国产-天天操天天操天天操天天操|www.shdianci.com

學無先后，達者為師

網站首頁 編程語言 正文

一文帶你入門Go語言中定時任務庫Cron的使用_Golang

作者：yi個俗人 ? 更新時間： 2022-10-21 編程語言

前言

在平時的開發需求中，我們經常會有一些重復執行的操作需要觸發執行，和系統約個時間，在幾點幾分幾秒或者每隔幾分鐘跑一個任務，說白了就是定時任務，，想必大家第一反應都是linux的Crontab。其實定時任務不止使用系統自帶的Crontab，在Go語言中也可以使用Cron定時任務庫, 這篇文章給大家介紹如何在go項目中實現一個crontab功能，感興趣的小伙伴們可以參考借鑒，希望對大家能有所幫助。

golang 實現定時服務很簡單，只需要簡單幾步代碼便可以完成，不需要配置繁瑣的服務器，直接在代碼中實現。

使用 github.com/robfig/cron 這個包，robfig/cron是一個第三方開源的任務調度庫，也就是我們平時說的定時任務，它實現了 cron 規范解析器和任務運行器。

快速開始

安裝

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

導入

import "github.com/robfig/cron/v3"

Demo

package main

import (
	"fmt"
	"github.com/robfig/cron/v3"
)

func main() {
	// 創建一個默認的cron對象
    c := cron.New()
    
    //添加執行任務
	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") })
	
    //開始執行任務
    c.Start()
	select {} //阻塞
}

Cron表達式格式

標準格式

一個 cron 表達式表示一組時間，使用 5 個空格分隔的字段。這是v3版本默認支持的格式，沒有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  | * / , - ?

預定義時間表

可以用@yearly、@monthly、@weekly、@weekly、@daily、@hourly來替代cron表達式。分別表示每年，每月、每星期、每天、每小時。

還可以用@every <duartion>來表示間隔時間，即間隔執行一次任務。只要可以被time.ParseDuration()解析即可。

常用的方法介紹

new()

會根據本地時間創建一個新（空白）的計劃任務實例

// 創建一個默認的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()

// 有兩個參數，第一個參數可以是cron表達式或者預定義時間表，第二個Job
func (c *Cron) AddJob(spec string, cmd Job) (EntryID, error)

// Job是一個接口，有一個Run方法
type Job interface {
	Run()
}

AddFunc()

會向計劃任務實例中添加一個回調函數，按指定時間表執行回調函數。

// 有兩個參數，第一個參數可以是cron表達式或者預定義時間表，第二個傳入一個函數，就是要執行的任務
// 會返回一個Id和error
// 會把傳入的cmd func轉成FuncJob。FuncJob實現了Job接口
func (c *Cron) AddFunc(spec string, cmd func()) (EntryID, error) {
	return c.AddJob(spec, FuncJob(cmd))
}

Start()

調用start方法開始執行任務

相關推薦

Go第三方庫之cronexpr——解析 crontab 表達式

cronexpr 是一個 crontab 解析表達式的庫，我們可以根據當前時間獲取到下次執行的時間。具體用法如下：

go get github.com/gorhill/cronexpr //下載
import "github.com/gorhill/cronexpr" //導入

demo：

package main

import (
	"fmt"
	"time"

	"github.com/gorhill/cronexpr"
)

func doTask() {
	fmt.Println("I am running, time is: ", time.Now())
}
func main() {

	// 每隔 5 秒執行1次
	expr, err := cronexpr.Parse("*/10 * * * * * * ") // 如果表達式解析錯誤將返回一個錯誤
	if err != nil {
		fmt.Println(err)
		return
	}
    
    //獲取下次執行時間
	nextTime := expr.Next(time.Now()) 
	fmt.Println(nextTime)

	time.AfterFunc(time.Until(nextTime), doTask)
    
    //返回當前crontab后的5次執行,n為次數
    nextTimeList = cronexpr.MustParse("*/10 * * * * * * ").NextN(time.Now(), 5)
    for _, v := range nextTimeList {
        fmt.Println(v.String())
    } 
    
	time.Sleep(10 * time.Second)

}

總結

定時任務很常見，希望你通過本文能夠熟知 Golang 怎么實現一個簡單的定時任務調度管理

可以不依賴系統的 Crontab 設置，指不定哪一天就用上了。

原文鏈接：https://juejin.cn/post/7133086081822441509

欄目分類
最近更新