golang开源定时任务调度框架
golang开源定时任务调度框架
Go语言中有很多开源的定时任务调度框架，以下几个是比较流行常用的：
golang开源定时任务框架介绍
- cron
一个基于Cron表达式的定时任务库，可以精确到秒级。它提供了简单易用的API来定义和管理定时任务，支持任务暂停、恢复、删除等操作，同时还能够在多个节点之间共享状态信息。
目前在github中的star最多，最为流行。
官方网站地址：https://github.com/robfig/cron
- go-crontab
一个轻量级的定时调度库，也是基于Cron表达式的。它支持多种调度方式，包括分布式调度、集群调度，同时还提供了Web控制台和RESTful API接口，非常方便使用。
一个定时任务管理器，基于Go语言和beego框架开发。用于统一管理项目中的定时任务，提供可视化配置界面、执行日志记录、邮件通知等功能，无需依赖*unix下的crontab服务。
官方网站地址：https://github.com/lisijie/webcron
- jobrunner
一个简单易用的定时任务库，它支持按照时间周期或按照固定时间点执行任务。除此之外，还支持异步任务、任务重试、延迟任务等功能。
官方网站地址：https://github.com/bamzi/jobrunner
- gocron
另一个基于Cron表达式的定时任务库，它可以让你以链式调用的方式定义任务，并且支持任务组、任务优先级等功能。
官方网站地址：https://github.com/go-co-op/gocron
总之，这些库使用起来都比较简单，你可以根据自己的需求和喜好选择其中一个来使用。因为每个定时框架都有其自身的优点和适用场景。以下是每个框架的一些特点仅供参考：
golang开源定时任务框架对比
-
cron
目前在github中的star最多，得到广泛的使用和测试。评测结果表明，与其他相比，它拥有最高的调度准确性，尤其在较高负载下。它也有宽松的开源许可证，允许你做任何你想做的事情。 -
go-crontab
基于Go语言和beego框架开发，可以运行多个实例（master/扇脸ave）并支持分布式部署。易于集成，并提供了控制台和API接口。在Go语言中编写，易于维护和扩展。 -
jobrunner
拥有丰富的功能，包括异步任务、任务重试、延迟任务等。具有充分的单元测试和文档支持。代码简单而直观。 -
gocron
支持链式调用，非常易于使用。可以定义任务组、任务优先级等。在调度方面表现良好，但没有经过广泛测试。
总结：因此，选择哪个库主要取决于您的需求和偏好。如果你需要更高的调度准确性和稳定性，那么cron可能是一个不错的选择；
如果你需要分布式调度和控制台支持，那么go-crontab可能更适合你。而如果你需要更多的功能和灵活性，那么jobrunner可能更适合你。
我目前选择的是：cron，因为在github中的star最多，最为流行，能得到广泛的使用和测试，而且它的性能比较好。
cron使用
官方地址：https://github.com/robfig/cron
下载依赖包
go get github.com/robfig/cron/v3@v3.0.0
cron的封装如下示例：
import "github.com/robfig/cron/v3"
var C *cron.Cron
// 记录启动的任务EntryId
var TaskEntryIdMap map[string]cron.EntryID
func TaskInit() {
TaskEntryIdMap = make(map[string]cron.EntryID)
//创建一个定时任务对象,根据cron表达式进行时间调度，cron可以精确到秒，大部分表达式格式也是从秒开始
// 默认从分开始进行时间调度
//C = cron.New()
//精确到秒
C = cron.New(cron.WithSeconds())
// 这里可以查询数据库里的定时任务，加载进来。
//启动
C.Start()
}
// 添加定时任务
func AddFuncTask(taskId, name, desc, cron string, param map[string]interface{}, cmd func(map[string]interface{})) bool {
entryId, err := C.AddFunc(cron, func() {
cmd(param)
})
if err != nil {
Log.Error("task AddFuncTask start error:", err)
return false
}
//这里可以把定时任务保存到数据库，重启程序时，可以从数据库加载定时任务
addEntryId(taskId, entryId)
return true
}
// 删除定时任务
func DeleteTask(taskId string) {
C.Remove(TaskEntryIdMap[taskId])
deleteEntryId(taskId)
//从数据库删除任务
}
func addEntryId(taskId string, entryId cron.EntryID) {
TaskEntryIdMap[taskId] = entryId
}
func deleteEntryId(taskId string) {
delete(TaskEntryIdMap, taskId)
}
func TaskClose() {
//关闭cron
C.Stop()
}
func main() {
//初始化定时任务
TaskInit()
//其他业务初始化
//关闭定时任务
TaskClose()
}
以上示例根据业务动态调整，可以把定时任务保存到数据库，当程序重启的时候从数据库把定时任务查询出来，在启动执行。
基于cron表达式定时监控，支持任务的总体启动暂停和单个任务的启动暂停
https://github.com/dhjz/dwatch
参考链接：
https://blog.csdn.net/u013421629/article/details/129981594