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

相关推荐

  1. golang开源定时任务调度框架

    2024-02-06 07:18:04       55 阅读
  2. linux定时调度任务

    2024-02-06 07:18:04       34 阅读
  3. 定时任务框架

    2024-02-06 07:18:04       44 阅读
  4. SpringTask定时任务框架

    2024-02-06 07:18:04       58 阅读

最近更新

  1. docker php8.1+nginx base 镜像 dockerfile 配置

    2024-02-06 07:18:04       98 阅读
  2. Could not load dynamic library ‘cudart64_100.dll‘

    2024-02-06 07:18:04       106 阅读
  3. 在Django里面运行非项目文件

    2024-02-06 07:18:04       87 阅读
  4. Python语言-面向对象

    2024-02-06 07:18:04       96 阅读

热门阅读

  1. 这是为什么啊!

    2024-02-06 07:18:04       55 阅读
  2. Rust消费kafka

    2024-02-06 07:18:04       48 阅读
  3. Spring boot 集成redis

    2024-02-06 07:18:04       47 阅读
  4. 【案例】--分布式”雪花算法案例

    2024-02-06 07:18:04       48 阅读
  5. Springboot使用kafka的两种方式

    2024-02-06 07:18:04       57 阅读
  6. 百度语音合成API

    2024-02-06 07:18:04       49 阅读
  7. Vue 本地存储

    2024-02-06 07:18:04       56 阅读
  8. C语言:公式求和

    2024-02-06 07:18:04       57 阅读
  9. go c 通过内存原始二进制内容直接传递结构体

    2024-02-06 07:18:04       54 阅读