golang开源定时任务调度框架

时间：2025-02-26 08:46:13

golang开源定时任务调度框架

Go语言中有很多开源的定时任务调度框架，以下几个是比较流行常用的：

golang开源定时任务框架介绍

  • cron

一个基于Cron表达式的定时任务库，可以精确到秒级。它提供了简单易用的API来定义和管理定时任务，支持任务暂停、恢复、删除等操作，同时还能够在多个节点之间共享状态信息。
目前在github中的star最多，最为流行。
官方网站地址：/robfig/cron

  • go-crontab

一个轻量级的定时调度库，也是基于Cron表达式的。它支持多种调度方式，包括分布式调度、集群调度，同时还提供了Web控制台和RESTful API接口，非常方便使用。
一个定时任务管理器，基于Go语言和beego框架开发。用于统一管理项目中的定时任务，提供可视化配置界面、执行日志记录、邮件通知等功能，无需依赖*unix下的crontab服务。
官方网站地址：/lisijie/webcron

  • jobrunner

一个简单易用的定时任务库，它支持按照时间周期或按照固定时间点执行任务。除此之外，还支持异步任务、任务重试、延迟任务等功能。
官方网站地址：/bamzi/jobrunner

  • gocron

另一个基于Cron表达式的定时任务库，它可以让你以链式调用的方式定义任务，并且支持任务组、任务优先级等功能。
官方网站地址：/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使用

官方地址：/robfig/cron

下载依赖包

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

cron的封装如下示例：

import "/robfig/cron/v3"

var C *
// 记录启动的任务EntryId
var TaskEntryIdMap map[string]

func TaskInit() {
	TaskEntryIdMap = make(map[string])

	//创建一个定时任务对象,根据cron表达式进行时间调度，cron可以精确到秒，大部分表达式格式也是从秒开始
	// 默认从分开始进行时间调度
	//C = ()
	//精确到秒
	C = (())
	
	// 这里可以查询数据库里的定时任务，加载进来。
	
	//启动
	()
}

// 添加定时任务
func AddFuncTask(taskId, name, desc, cron string, param map[string]interface{}, cmd func(map[string]interface{})) bool {
	entryId, err := (cron, func() {
		cmd(param)
	})
	if err != nil {
		("task AddFuncTask start error:", err)
		return false
	}

	//这里可以把定时任务保存到数据库，重启程序时，可以从数据库加载定时任务
	
	addEntryId(taskId, entryId)
	return true
}

// 删除定时任务
func DeleteTask(taskId string) {
	(TaskEntryIdMap[taskId])
	deleteEntryId(taskId)
	
	//从数据库删除任务
}

func addEntryId(taskId string, entryId ) {
	TaskEntryIdMap[taskId] = entryId
}

func deleteEntryId(taskId string) {
	delete(TaskEntryIdMap, taskId)
}

func TaskClose() {
	//关闭cron
	()
}

func main() {
	//初始化定时任务
	TaskInit()
	
	//其他业务初始化
	
	//关闭定时任务
	TaskClose()
}

以上示例根据业务动态调整，可以把定时任务保存到数据库，当程序重启的时候从数据库把定时任务查询出来，在启动执行。

基于cron表达式定时监控，支持任务的总体启动暂停和单个任务的启动暂停
/dhjz/dwatch

参考链接：
/u013421629/article/details/129981594

相关文章