dcron分布式定时任务库 分布式定时任务库 dcron分布式定时任务库

LibiChai • 8567 次点击    
这是一个分享于 的项目,其中的信息可能已经有所发展或是发生改变。
## dcron 分布式定时任务库 ### 原理 基于redis同步节点数据,模拟服务注册。然后将任务名 根据一致性hash 选举出执行该任务的节点。 ### 流程图 ![dcron流程图](https://github.com/LibiChai/dcron/raw/master/dcron.png) ### 特性 - 负载均衡:根据任务数据和节点数据均衡分发任务。 - 无缝扩容:如果任务节点负载过大,直接启动新的服务器后部分任务会自动迁移至新服务实现无缝扩容。 - 故障转移:单个节点故障,10s后会自动将任务自动转移至其他正常节点。 - 任务唯一:同一个服务内同一个任务只会启动单个运行实例,不会重复执行。 - 自定义存储:通过实现driver接口来增加节点数据存储方式。 ### 使用说明 1.创建redisDriver实例,指定服务名并初始化dcron。服务名为执行相同任务的单元。 ```golang drv, _ := redis.NewDriver(&redis.Conf{ Host: "127.0.0.1", Port: 6379, }) dcron := NewDcron("server1", drv) ``` 2.使用cron语法添加任务,需要指定任务名。任务名作为任务的唯一标识,必须保证唯一。 ```golang dcron.AddFunc("test1","*/3 * * * *",func(){ fmt.Println("执行 test1 任务",time.Now().Format("15:04:05")) }) ``` 3.开始任务。 ```golang dcron.Start() ``` ### 关于服务名的说明 服务名只是为了定义相同一组任务,节点在启动时会产生一个uuid,然后绑定到这个服务内,不会存在多个节点使用同一个服务明出现冲突的问题。 比如有个服务叫【课堂服务】里面包含了 【上课】【下课】 等各类定时任务,那么就可以有n个不同的服务节点(可以在同一台或者不同机器上),服务都叫课堂服务。 ### 其他 注意:一般定时如果和http服务在一起时不用特殊处理;但如果程序内只有该定时任务,需要阻塞主进程以防止主线程直接退出。
授权协议:
MIT
开发语言:
Go 查看源码»
操作系统:
linux,windows,osx
8567 次点击  ∙  1 赞  
加入收藏 微博
1 回复  |  直到
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传