Go实战--golang中执行cron job定时任务(robfig/cron和jasonlvhit/gocron)

生命不止,继续 go go go !!!

今天,跟大家分享的是在golang中执行定时任务,主要介绍两个github上的开源库的使用。

Linux下crontab

crontab 命令常见于Unix和类Unix的操作系统之中,用于设置周期性被执行的指令。 该命令从标准输入设备读取指令,并将其存放于"crontab"文件中,以供之后读取和执行。 该词来源于希腊语chronos(χρόνος),原意是时间。

通常,crontab储存的指令被守护进程激活,crond常常在后台运行,每一分钟检查是否有预定的作业需要执行。这类作业一般称为cron jobs。

crontab文件包含送交cron守护进程的一系列作业和指令。每个用户可以拥有自己的crontab文件;同时,操作系统保存一个针对整个系统的crontab文件,该文件通常存放于/etc或者/etc之下的子目录中,而这个文件只能由系统管理员来修改。
crontab文件的每一行均遵守特定的格式,由空格或tab分隔为数个领域,每个领域可以放置单一或多个数值。

命令
安装crontab:

yum install crontabs

启动:

service crond start

关闭:

service crond stop

重启:

service crond restart

重载:

service crond reload

查看状态:

service crond status

编辑任务:

crontab -e

查看任务:

crontab -l

删除:

crontab -r

格式
分 时 日 月 星期 要运行的命令

操作符号
在一个区域里填写多个数值的方法:
逗号(’,’)分开的值,例如:"1,3,4,7,8"
连词符(’-‘)指定值的范围,例如:"1-6",意思等同于"1,2,3,4,5,6"
星号(’*’)代表任何可能的值。例如,在"小时域"里的星号等于是"每一个小时",等等
某些cron程序的扩展版本也支持斜线(’/’)操作符,用于表示跳过某些给定的数。例如,"*/3"在小时域中等于"0,3,6,9,12,15,18,21"等被3整除的数;

实例
每分钟执行一次命令:

* * * * * yourCommand

每小时的第2和第10分钟执行:

2,10 * * * * yourCommand

每天上午9点到12点的第2和第10分钟执行:

2,10 9-12 * * * yourCommand

每隔两天的上午9点到12点的第2和第10分钟执行:

2,10 9-12 */2 * * yourCommand

每周一上午9点到12点的第2和第10分钟执行:

2,10 9-12 * * 1 yourCommand

robfig/cron

安装:

go get -u github.com/robfig/cron

应用:
每分钟执行一次:

package main
import (
 "log"
 "github.com/robfig/cron"
)
func main() {
 i := 0
 c := cron.New()
 spec := "0 */1 * * * *"
 c.AddFunc(spec, func() {
 i++
 log.Println("execute per second", i)
 })
 c.Start()
 select {}
}

其中注意select的用法:
golang 的 select 的功能和 select, poll, epoll 相似, 就是监听 IO 操作,当 IO 操作发生时,触发相应的动作。

每天上午9点到12点的第2和第10分钟执行:

package main
import (
 "fmt"
 "github.com/robfig/cron"
)
func main() {
 spec := "2,10 9-12 * * *" // 每天上午9点到12点的第2和第10分钟执行
 c := cron.New()
 c.AddFunc(spec, myFunc)
 c.Start()
 select {}
}
func myFunc() {
 fmt.Println("execute")
}

jasonlvhit/gocron

安装:

go get -u github.com/jasonlvhit/gocron

每隔1秒执行一个任务,每隔4秒执行另一个任务:

package main
import (
 "fmt"
 "time"
 "github.com/jasonlvhit/gocron"
)
func task() {
 fmt.Println("I am runnning task.", time.Now())
}
func superWang() {
 fmt.Println("I am runnning superWang.", time.Now())
}
func main() {
 s := gocron.NewScheduler()
 s.Every(1).Seconds().Do(task)
 s.Every(4).Seconds().Do(superWang)
 sc := s.Start() // keep the channel
 go test(s, sc) // wait
 <-sc // it will happens if the channel is closed
}
func test(s *gocron.Scheduler, sc chan bool) {
 time.Sleep(8 * time.Second)
 s.Remove(task) //remove task
 time.Sleep(8 * time.Second)
 s.Clear()
 fmt.Println("All task removed")
 close(sc) // close the channel
}

这里写图片描述

有疑问加站长微信联系(非本文作者)

• 请尽量让自己的回复能够对别人有帮助
• 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
• 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
• 图片支持拖拽、截图粘贴等方式上传