PowerJob 3.2.2 发布,强大的任务调度中间件
PowerJob是全新一代任务调度中间件,能让您轻松完成作业的调度与繁杂任务的分布式计算,其主要功能特性如下:
- 使用简单:提供前端Web界面,允许开发者可视化地完成调度任务的管理(增、删、改、查)、任务运行状态监控和运行日志查看等功能。
- 定时策略完善:支持CRON表达式、固定频率、固定延迟和API四种定时调度策略,同时提供延迟执行策略
- 执行模式丰富:支持单机、广播、Map、MapReduce四种执行模式,其中Map/MapReduce处理器能使开发者寥寥数行代码便获得集群分布式计算的能力。
- 工作流支持:支持在线配置任务依赖关系(DAG),可视化得对任务进行编排,同时还支持上下游任务间的数据传递。
- 执行器支持广泛:支持Spring Bean、内置/外置Java类、Shell、Python等处理器,应用范围广。
- 系统易扩展:提供 OpenAPI 允许开发者自由地扩展系统原有功能,轻松完成定制
- 运维便捷:支持在线日志功能,执行器产生的日志可以在前端控制台页面实时显示,降低debug成本,极大地提高开发效率。
- 依赖精简:最小仅依赖关系型数据库(MySQL/PostgreSQL/Oracle/MS SQLServer...)
- 高可用&高性能:调度服务器经过精心设计,一改其他调度框架基于数据库锁的策略,实现了无锁化调度。部署多个调度服务器可以同时实现高可用和性能的提升(支持无限的水平扩展)。
- 故障转移与恢复:任务执行失败后,可根据配置的重试策略完成重试,只要执行器集群有足够的计算节点,任务就能顺利完成。
适用场景
- 有定时执行需求的业务场景:如每天凌晨全量同步数据、生成业务报表等。
- 有需要全部机器一同执行的业务场景:如使用广播执行模式清理集群日志。
- 有需要分布式处理的业务场景:比如需要更新一大批数据,单机执行耗时非常长,可以使用Map/MapReduce处理器完成任务的分发,调动整个集群加速计算。
- 有需要延迟执行某些任务的业务场景:比如订单过期处理等。
在线试用
试用地址:try.powerjob.tech 试用应用名称:powerjob-agent-test 控制台密码:123
新版本包含了大量的改进,主要更新内容如下:
Features 🚀
- 新增任务重跑功能(群友需求)
- 支持本机启动多个 server & worker #40
- 支持查看任务的历史运行记录 #35
- 优化报警通知信息,加强可读性
- 美化了前端页面
- 优化了 server 与 worker 的部分实现,会带来些许的性能提升
BugFix 🐛
- 修复了某些操作系统下 H2 数据库 table not found 的问题 #41
- 修复了前端控制台 no appId 的报错 #26
- 修复了 worker 机器配置无法准确生效的 bug (感谢 群友@追忆 的反馈)
- 修复了 server 不使用 MongoDB 也会出现报错的问题
PowerJob 目前已被多家企业正式接入,稳定运行,欢迎各位使用!

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
-
上一篇
Akka 2.6.8 发布,修复 v2.6.7 集群分片严重回退
Akka 2.6.8 发布了,这主要是 2.6.7 中引入的一个回退的修复版本,一共修复了 9 个问题。Akka 是一个用 Scala 编写的库,用于简化编写容错的、高可伸缩性的 Java 和 Scala 的 Actor 模型应用。 Akka 集群分片中出现了一个相对严重的回退bug #29383,使用 Akka 集群分片时将被触发,并且实体将在没有进行passivate 的情况下终止,这将导致完整的分片崩溃,并且分片中的其它实体将被停止,直到它们收到下一条消息,继而导致重新启动。 不过启用了“记住实体(Remember Entities)”功能的用户不受此错误影响。 完整的变更记录见:https://github.com/akka/akka/milestone/168?closed=1 更新说明:https://akka.io/blog/news/2020/07/16/akka-2.6.8-released
-
下一篇
gout v0.1.2 发布,Golang 实现的 http 客户端
项目地址 https://gitee.com/guonaihong/gout https://github.com/guonaihong/gout changlog #241上传进度(在v0.0.4版本中间件里面实现https://github.com/antlabs/gout-middleware) #248调整FormFile和FormType的优先级 #250新增关闭301中间件 上传进度条 currBytes是已经上传数据,totalBytes是数据总大小. currBytes/totalBytes就是上传进度百分比 package main import ( "bytes" "github.com/antlabs/gout-middleware/request" "github.com/guonaihong/gout" ) func main() { gout.POST(":8080").RequestUse(request.ProgressBar(func(currBytes, totalBytes int) { fmt.Printf("%...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- MySQL8.0.19开启GTID主从同步CentOS8
- SpringBoot2编写第一个Controller,响应你的http请求并返回结果
- SpringBoot2配置默认Tomcat设置,开启更多高级功能
- Springboot2将连接池hikari替换为druid,体验最强大的数据库连接池
- MySQL数据库在高并发下的优化方案
- Docker使用Oracle官方镜像安装(12C,18C,19C)
- Docker快速安装Oracle11G,搭建oracle11g学习环境
- CentOS7,8上快速安装Gitea,搭建Git服务器
- SpringBoot2全家桶,快速入门学习开发网站教程
- Dcoker安装(在线仓库),最新的服务器搭配容器使用