Go实战--golang中执行cron job定时任务(robfig/cron和jasonlvhit
生命不止,继续 go go go !!! 今天,跟大家分享的是在golang中执行定时任务,主要介绍两个github上的开源库的使用。 Linux下crontabcrontab 命令常见于Unix和类Unix的操作系统之中,用于设置周期性被执行的指令。 该命令从标准输入设备读取指令,并将其存放于“crontab”文件中,以供之后读取和执行。 该词来源于希腊语chronos(χρ?νο?),原意是时间。 通常,crontab储存的指令被守护进程激活,crond常常在后台运行,每一分钟检查是否有预定的作业需要执行。这类作业一般称为cron jobs。 crontab文件包含送交cron守护进程的一系列作业和指令。每个用户可以拥有自己的crontab文件;同时,操作系统保存一个针对整个系统的crontab文件,该文件通常存放于/etc或者/etc之下的子目录中,而这个文件只能由系统管理员来修改。 命令 yum install crontabs
启动: service crond start
关闭: service crond stop
重启: service crond restart 重载: service crond reload 查看状态: service crond status 编辑任务: crontab -e
查看任务: crontab -l
删除: crontab -r
格式 操作符号 实例 * * * * * 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的用法: 每天上午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
}
(编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |