From eb9a3f0e699f6119eeefadacf4ddad8fd60e4317 Mon Sep 17 00:00:00 2001 From: "xueli.xue" Date: Fri, 30 Oct 2020 20:36:53 +0800 Subject: [PATCH] =?UTF-8?q?-=2021=E3=80=81=E8=B0=83=E5=BA=A6=E8=BF=87?= =?UTF-8?q?=E6=9C=9F=E7=AD=96=E7=95=A5=EF=BC=9A=E8=B0=83=E5=BA=A6=E4=B8=AD?= =?UTF-8?q?=E5=BF=83=E9=94=99=E8=AF=AF=E8=B0=83=E5=BA=A6=E6=97=B6=E9=97=B4?= =?UTF-8?q?=E7=9A=84=E8=A1=A5=E5=81=BF=E5=A4=84=E7=90=86=E7=AD=96=E7=95=A5?= =?UTF-8?q?=EF=BC=8C=E5=8C=85=E6=8B=AC=EF=BC=9A=E5=BF=BD=E7=95=A5=E3=80=81?= =?UTF-8?q?=E7=AB=8B=E5=8D=B3=E8=A1=A5=E5=81=BF=E8=A7=A6=E5=8F=91=E4=B8=80?= =?UTF-8?q?=E6=AC=A1=E7=AD=89=EF=BC=9B=20-=2022=E3=80=81=E8=A7=A6=E5=8F=91?= =?UTF-8?q?=E7=AD=96=E7=95=A5=E5=BC=BA=E5=8C=96=EF=BC=9A=E9=99=A4=E4=BA=86?= =?UTF-8?q?=E5=B8=B8=E8=A7=84Cron=E3=80=81API=E3=80=81=E7=88=B6=E5=AD=90?= =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E8=A7=A6=E5=8F=91=E6=96=B9=E5=BC=8F=E5=A4=96?= =?UTF-8?q?=EF=BC=8C=E6=96=B0=E5=A2=9E=E6=8F=90=E4=BE=9B=20"=E5=9B=BA?= =?UTF-8?q?=E5=AE=9A=E9=97=B4=E9=9A=94=E8=A7=A6=E5=8F=91=E3=80=81=E5=9B=BA?= =?UTF-8?q?=E5=AE=9A=E5=BB=B6=E6=97=B6=E8=A7=A6=E5=8F=91"=20=E4=B8=A4?= =?UTF-8?q?=E7=A7=8D=E6=96=B0=E8=A7=A6=E5=8F=91=E6=96=B9=E5=BC=8F=EF=BC=9B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- README.md | 51 ++-- doc/XXL-JOB官方文档.md | 140 +++++----- doc/db/tables_xxl_job.sql | 3 +- .../xxl/job/admin/core/model/XxlJobInfo.java | 37 ++- .../core/scheduler/MisfireStrategyEnum.java | 4 +- .../core/scheduler/ScheduleTypeEnum.java | 6 +- .../admin/core/thread/JobScheduleHelper.java | 29 +- .../admin/core/trigger/TriggerTypeEnum.java | 3 +- .../admin/service/impl/XxlJobServiceImpl.java | 119 ++++++-- .../main/resources/i18n/message_en.properties | 6 + .../resources/i18n/message_zh_CN.properties | 6 + .../resources/i18n/message_zh_TC.properties | 6 + .../mybatis-mapper/XxlJobInfoMapper.xml | 21 +- .../resources/static/js/jobinfo.index.1.js | 176 +++++++----- .../templates/jobinfo/jobinfo.index.ftl | 254 ++++++++++++------ .../xxl/job/admin/dao/XxlJobInfoDaoTest.java | 10 +- 16 files changed, 592 insertions(+), 279 deletions(-) diff --git a/README.md b/README.md index 81cace18..55379cb0 100644 --- a/README.md +++ b/README.md @@ -56,35 +56,36 @@ XXL-JOB是一个分布式任务调度平台，其核心设计目标是开发迅 - 4、执行器HA（分布式）：任务分布式执行，任务"执行器"支持集群部署，可保证任务执行HA； - 5、注册中心: 执行器会周期性自动注册任务, 调度中心将会自动发现注册的任务并触发执行。同时，也支持手动录入执行器地址； - 6、弹性扩容缩容：一旦有新执行器机器上线或者下线，下次调度时将会重新分配任务； -- 7、路由策略：执行器集群部署时提供丰富的路由策略，包括：第一个、最后一个、轮询、随机、一致性HASH、最不经常使用、最近最久未使用、故障转移、忙碌转移等； -- 8、故障转移：任务路由策略选择"故障转移"情况下，如果执行器集群中某一台机器故障，将会自动Failover切换到一台正常的执行器发送调度请求。 +- 7、触发策略：提供丰富的任务触发策略，包括：Cron触发、固定间隔触发、固定延时触发、API（事件）触发、人工触发、父子任务触发； +- 8、调度过期策略：调度中心错误调度时间的补偿处理策略，包括：忽略、立即补偿触发一次等； - 9、阻塞处理策略：调度过于密集执行器来不及处理时的处理策略，策略包括：单机串行（默认）、丢弃后续调度、覆盖之前调度； - 10、任务超时控制：支持自定义任务超时时间，任务运行超时将会主动中断任务； - 11、任务失败重试：支持自定义任务失败重试次数，当任务失败时将会按照预设的失败重试次数主动进行重试；其中分片任务支持分片粒度的失败重试； - 12、任务失败告警；默认提供邮件方式失败告警，同时预留扩展接口，可方便的扩展短信、钉钉等告警方式； -- 13、分片广播任务：执行器集群部署时，任务路由策略选择"分片广播"情况下，一次任务调度将会广播触发集群中所有执行器执行一次任务，可根据分片参数开发分片任务； -- 14、动态分片：分片广播任务以执行器为维度进行分片，支持动态扩容执行器集群从而动态增加分片数量，协同进行业务处理；在进行大数据量业务操作时可显著提升任务处理能力和速度。 -- 15、事件触发：除了"Cron方式"和"任务依赖方式"触发任务执行之外，支持基于事件的触发任务方式。调度中心提供触发任务单次执行的API服务，可根据业务事件灵活触发。 -- 16、任务进度监控：支持实时监控任务进度； -- 17、Rolling实时日志：支持在线查看调度结果，并且支持以Rolling方式实时查看执行器输出的完整的执行日志； -- 18、GLUE：提供Web IDE，支持在线开发任务逻辑代码，动态发布，实时编译生效，省略部署上线的过程。支持30个版本的历史版本回溯。 -- 19、脚本任务：支持以GLUE模式开发和运行脚本任务，包括Shell、Python、NodeJS、PHP、PowerShell等类型脚本; -- 20、命令行任务：原生提供通用命令行任务Handler（Bean任务，"CommandJobHandler"）；业务方只需要提供命令行即可； -- 21、任务依赖：支持配置子任务依赖，当父任务执行结束且执行成功后将会主动触发一次子任务的执行, 多个子任务用逗号分隔； -- 22、一致性：“调度中心”通过DB锁保证集群分布式调度的一致性, 一次任务调度只会触发一次执行； -- 23、自定义任务参数：支持在线配置调度任务入参，即时生效； -- 24、调度线程池：调度系统多线程触发调度运行，确保调度精确执行，不被堵塞； -- 25、数据加密：调度中心和执行器之间的通讯进行数据加密，提升调度信息安全性； -- 26、邮件报警：任务失败时支持邮件报警，支持配置多邮件地址群发报警邮件； -- 27、推送maven中央仓库: 将会把最新稳定版推送到maven中央仓库, 方便用户接入和使用; -- 28、运行报表：支持实时查看运行数据，如任务数量、调度次数、执行器数量等；以及调度报表，如调度日期分布图，调度成功分布图等； -- 29、全异步：任务调度流程全异步化设计实现，如异步调度、异步运行、异步回调等，有效对密集调度进行流量削峰，理论上支持任意时长任务的运行； -- 30、跨语言：调度中心与执行器提供语言无关的 RESTful API 服务，第三方任意语言可据此对接调度中心或者实现执行器。除此之外，还提供了 “多任务模式”和“httpJobHandler”等其他跨语言方案； -- 31、国际化：调度中心支持国际化设置，提供中文、英文两种可选语言，默认为中文； -- 32、容器化：提供官方docker镜像，并实时更新推送dockerhub，进一步实现产品开箱即用； -- 33、线程池隔离：调度线程池进行隔离拆分，慢任务自动降级进入"Slow"线程池，避免耗尽调度线程，提高系统稳定性； -- 34、用户管理：支持在线管理系统用户，存在管理员、普通用户两种角色； -- 35、权限控制：执行器维度进行权限控制，管理员拥有全量权限，普通用户需要分配执行器权限后才允许相关操作； +- 13、路由策略：执行器集群部署时提供丰富的路由策略，包括：第一个、最后一个、轮询、随机、一致性HASH、最不经常使用、最近最久未使用、故障转移、忙碌转移等； +- 14、分片广播任务：执行器集群部署时，任务路由策略选择"分片广播"情况下，一次任务调度将会广播触发集群中所有执行器执行一次任务，可根据分片参数开发分片任务； +- 15、动态分片：分片广播任务以执行器为维度进行分片，支持动态扩容执行器集群从而动态增加分片数量，协同进行业务处理；在进行大数据量业务操作时可显著提升任务处理能力和速度。 +- 16、故障转移：任务路由策略选择"故障转移"情况下，如果执行器集群中某一台机器故障，将会自动Failover切换到一台正常的执行器发送调度请求。 +- 17、任务进度监控：支持实时监控任务进度； +- 18、Rolling实时日志：支持在线查看调度结果，并且支持以Rolling方式实时查看执行器输出的完整的执行日志； +- 19、GLUE：提供Web IDE，支持在线开发任务逻辑代码，动态发布，实时编译生效，省略部署上线的过程。支持30个版本的历史版本回溯。 +- 20、脚本任务：支持以GLUE模式开发和运行脚本任务，包括Shell、Python、NodeJS、PHP、PowerShell等类型脚本; +- 21、命令行任务：原生提供通用命令行任务Handler（Bean任务，"CommandJobHandler"）；业务方只需要提供命令行即可； +- 22、任务依赖：支持配置子任务依赖，当父任务执行结束且执行成功后将会主动触发一次子任务的执行, 多个子任务用逗号分隔； +- 23、一致性：“调度中心”通过DB锁保证集群分布式调度的一致性, 一次任务调度只会触发一次执行； +- 24、自定义任务参数：支持在线配置调度任务入参，即时生效； +- 25、调度线程池：调度系统多线程触发调度运行，确保调度精确执行，不被堵塞； +- 26、数据加密：调度中心和执行器之间的通讯进行数据加密，提升调度信息安全性； +- 27、邮件报警：任务失败时支持邮件报警，支持配置多邮件地址群发报警邮件； +- 28、推送maven中央仓库: 将会把最新稳定版推送到maven中央仓库, 方便用户接入和使用; +- 29、运行报表：支持实时查看运行数据，如任务数量、调度次数、执行器数量等；以及调度报表，如调度日期分布图，调度成功分布图等； +- 30、全异步：任务调度流程全异步化设计实现，如异步调度、异步运行、异步回调等，有效对密集调度进行流量削峰，理论上支持任意时长任务的运行； +- 31、跨语言：调度中心与执行器提供语言无关的 RESTful API 服务，第三方任意语言可据此对接调度中心或者实现执行器。除此之外，还提供了 “多任务模式”和“httpJobHandler”等其他跨语言方案； +- 32、国际化：调度中心支持国际化设置，提供中文、英文两种可选语言，默认为中文； +- 33、容器化：提供官方docker镜像，并实时更新推送dockerhub，进一步实现产品开箱即用； +- 34、线程池隔离：调度线程池进行隔离拆分，慢任务自动降级进入"Slow"线程池，避免耗尽调度线程，提高系统稳定性； +- 35、用户管理：支持在线管理系统用户，存在管理员、普通用户两种角色； +- 36、权限控制：执行器维度进行权限控制，管理员拥有全量权限，普通用户需要分配执行器权限后才允许相关操作； ## Development diff --git a/doc/XXL-JOB官方文档.md b/doc/XXL-JOB官方文档.md index a4630956..165d6029 100644 --- a/doc/XXL-JOB官方文档.md +++ b/doc/XXL-JOB官方文档.md @@ -27,35 +27,36 @@ XXL-JOB是一个分布式任务调度平台，其核心设计目标是开发迅 - 4、执行器HA（分布式）：任务分布式执行，任务"执行器"支持集群部署，可保证任务执行HA； - 5、注册中心: 执行器会周期性自动注册任务, 调度中心将会自动发现注册的任务并触发执行。同时，也支持手动录入执行器地址； - 6、弹性扩容缩容：一旦有新执行器机器上线或者下线，下次调度时将会重新分配任务； -- 7、路由策略：执行器集群部署时提供丰富的路由策略，包括：第一个、最后一个、轮询、随机、一致性HASH、最不经常使用、最近最久未使用、故障转移、忙碌转移等； -- 8、故障转移：任务路由策略选择"故障转移"情况下，如果执行器集群中某一台机器故障，将会自动Failover切换到一台正常的执行器发送调度请求。 +- 7、触发策略：提供丰富的任务触发策略，包括：Cron触发、固定间隔触发、固定延时触发、API（事件）触发、人工触发、父子任务触发； +- 8、调度过期策略：调度中心错误调度时间的补偿处理策略，包括：忽略、立即补偿触发一次等； - 9、阻塞处理策略：调度过于密集执行器来不及处理时的处理策略，策略包括：单机串行（默认）、丢弃后续调度、覆盖之前调度； - 10、任务超时控制：支持自定义任务超时时间，任务运行超时将会主动中断任务； - 11、任务失败重试：支持自定义任务失败重试次数，当任务失败时将会按照预设的失败重试次数主动进行重试；其中分片任务支持分片粒度的失败重试； - 12、任务失败告警；默认提供邮件方式失败告警，同时预留扩展接口，可方便的扩展短信、钉钉等告警方式； -- 13、分片广播任务：执行器集群部署时，任务路由策略选择"分片广播"情况下，一次任务调度将会广播触发集群中所有执行器执行一次任务，可根据分片参数开发分片任务； -- 14、动态分片：分片广播任务以执行器为维度进行分片，支持动态扩容执行器集群从而动态增加分片数量，协同进行业务处理；在进行大数据量业务操作时可显著提升任务处理能力和速度。 -- 15、事件触发：除了"Cron方式"和"任务依赖方式"触发任务执行之外，支持基于事件的触发任务方式。调度中心提供触发任务单次执行的API服务，可根据业务事件灵活触发。 -- 16、任务进度监控：支持实时监控任务进度； -- 17、Rolling实时日志：支持在线查看调度结果，并且支持以Rolling方式实时查看执行器输出的完整的执行日志； -- 18、GLUE：提供Web IDE，支持在线开发任务逻辑代码，动态发布，实时编译生效，省略部署上线的过程。支持30个版本的历史版本回溯。 -- 19、脚本任务：支持以GLUE模式开发和运行脚本任务，包括Shell、Python、NodeJS、PHP、PowerShell等类型脚本; -- 20、命令行任务：原生提供通用命令行任务Handler（Bean任务，"CommandJobHandler"）；业务方只需要提供命令行即可； -- 21、任务依赖：支持配置子任务依赖，当父任务执行结束且执行成功后将会主动触发一次子任务的执行, 多个子任务用逗号分隔； -- 22、一致性：“调度中心”通过DB锁保证集群分布式调度的一致性, 一次任务调度只会触发一次执行； -- 23、自定义任务参数：支持在线配置调度任务入参，即时生效； -- 24、调度线程池：调度系统多线程触发调度运行，确保调度精确执行，不被堵塞； -- 25、数据加密：调度中心和执行器之间的通讯进行数据加密，提升调度信息安全性； -- 26、邮件报警：任务失败时支持邮件报警，支持配置多邮件地址群发报警邮件； -- 27、推送maven中央仓库: 将会把最新稳定版推送到maven中央仓库, 方便用户接入和使用; -- 28、运行报表：支持实时查看运行数据，如任务数量、调度次数、执行器数量等；以及调度报表，如调度日期分布图，调度成功分布图等； -- 29、全异步：任务调度流程全异步化设计实现，如异步调度、异步运行、异步回调等，有效对密集调度进行流量削峰，理论上支持任意时长任务的运行； -- 30、跨语言：调度中心与执行器提供语言无关的 RESTful API 服务，第三方任意语言可据此对接调度中心或者实现执行器。除此之外，还提供了 “多任务模式”和“httpJobHandler”等其他跨语言方案； -- 31、国际化：调度中心支持国际化设置，提供中文、英文两种可选语言，默认为中文； -- 32、容器化：提供官方docker镜像，并实时更新推送dockerhub，进一步实现产品开箱即用； -- 33、线程池隔离：调度线程池进行隔离拆分，慢任务自动降级进入"Slow"线程池，避免耗尽调度线程，提高系统稳定性； -- 34、用户管理：支持在线管理系统用户，存在管理员、普通用户两种角色； -- 35、权限控制：执行器维度进行权限控制，管理员拥有全量权限，普通用户需要分配执行器权限后才允许相关操作； +- 13、路由策略：执行器集群部署时提供丰富的路由策略，包括：第一个、最后一个、轮询、随机、一致性HASH、最不经常使用、最近最久未使用、故障转移、忙碌转移等； +- 14、分片广播任务：执行器集群部署时，任务路由策略选择"分片广播"情况下，一次任务调度将会广播触发集群中所有执行器执行一次任务，可根据分片参数开发分片任务； +- 15、动态分片：分片广播任务以执行器为维度进行分片，支持动态扩容执行器集群从而动态增加分片数量，协同进行业务处理；在进行大数据量业务操作时可显著提升任务处理能力和速度。 +- 16、故障转移：任务路由策略选择"故障转移"情况下，如果执行器集群中某一台机器故障，将会自动Failover切换到一台正常的执行器发送调度请求。 +- 17、任务进度监控：支持实时监控任务进度； +- 18、Rolling实时日志：支持在线查看调度结果，并且支持以Rolling方式实时查看执行器输出的完整的执行日志； +- 19、GLUE：提供Web IDE，支持在线开发任务逻辑代码，动态发布，实时编译生效，省略部署上线的过程。支持30个版本的历史版本回溯。 +- 20、脚本任务：支持以GLUE模式开发和运行脚本任务，包括Shell、Python、NodeJS、PHP、PowerShell等类型脚本; +- 21、命令行任务：原生提供通用命令行任务Handler（Bean任务，"CommandJobHandler"）；业务方只需要提供命令行即可； +- 22、任务依赖：支持配置子任务依赖，当父任务执行结束且执行成功后将会主动触发一次子任务的执行, 多个子任务用逗号分隔； +- 23、一致性：“调度中心”通过DB锁保证集群分布式调度的一致性, 一次任务调度只会触发一次执行； +- 24、自定义任务参数：支持在线配置调度任务入参，即时生效； +- 25、调度线程池：调度系统多线程触发调度运行，确保调度精确执行，不被堵塞； +- 26、数据加密：调度中心和执行器之间的通讯进行数据加密，提升调度信息安全性； +- 27、邮件报警：任务失败时支持邮件报警，支持配置多邮件地址群发报警邮件； +- 28、推送maven中央仓库: 将会把最新稳定版推送到maven中央仓库, 方便用户接入和使用; +- 29、运行报表：支持实时查看运行数据，如任务数量、调度次数、执行器数量等；以及调度报表，如调度日期分布图，调度成功分布图等； +- 30、全异步：任务调度流程全异步化设计实现，如异步调度、异步运行、异步回调等，有效对密集调度进行流量削峰，理论上支持任意时长任务的运行； +- 31、跨语言：调度中心与执行器提供语言无关的 RESTful API 服务，第三方任意语言可据此对接调度中心或者实现执行器。除此之外，还提供了 “多任务模式”和“httpJobHandler”等其他跨语言方案； +- 32、国际化：调度中心支持国际化设置，提供中文、英文两种可选语言，默认为中文； +- 33、容器化：提供官方docker镜像，并实时更新推送dockerhub，进一步实现产品开箱即用； +- 34、线程池隔离：调度线程池进行隔离拆分，慢任务自动降级进入"Slow"线程池，避免耗尽调度线程，提高系统稳定性； +- 35、用户管理：支持在线管理系统用户，存在管理员、普通用户两种角色； +- 36、权限控制：执行器维度进行权限控制，管理员拥有全量权限，普通用户需要分配执行器权限后才允许相关操作； ### 1.4 发展 于2015年中，我在github上创建XXL-JOB项目仓库并提交第一个commit，随之进行系统结构设计，UI选型，交互设计…… @@ -765,40 +766,59 @@ public XxlJobSpringExecutor xxlJobExecutor() { ### 配置属性详细说明： - - 执行器：任务的绑定的执行器，任务触发调度时将会自动发现注册成功的执行器, 实现任务自动发现功能; 另一方面也可以方便的进行任务分组。每个任务必须绑定一个执行器, 可在 "执行器管理" 进行设置; - - 任务描述：任务的描述信息，便于任务管理； - - 路由策略：当执行器集群部署时，提供丰富的路由策略，包括； - FIRST（第一个）：固定选择第一个机器； - LAST（最后一个）：固定选择最后一个机器； - ROUND（轮询）：； - RANDOM（随机）：随机选择在线的机器； - CONSISTENT_HASH（一致性HASH）：每个任务按照Hash算法固定选择某一台机器，且所有任务均匀散列在不同机器上。 - LEAST_FREQUENTLY_USED（最不经常使用）：使用频率最低的机器优先被选举； - LEAST_RECENTLY_USED（最近最久未使用）：最久未使用的机器优先被选举； - FAILOVER（故障转移）：按照顺序依次进行心跳检测，第一个心跳检测成功的机器选定为目标执行器并发起调度； - BUSYOVER（忙碌转移）：按照顺序依次进行空闲检测，第一个空闲检测成功的机器选定为目标执行器并发起调度； - SHARDING_BROADCAST(分片广播)：广播触发对应集群中所有机器执行一次任务，同时系统自动传递分片参数；可根据分片参数开发分片任务； + 基础配置： + - 执行器：任务的绑定的执行器，任务触发调度时将会自动发现注册成功的执行器, 实现任务自动发现功能; 另一方面也可以方便的进行任务分组。每个任务必须绑定一个执行器, 可在 "执行器管理" 进行设置; + - 任务描述：任务的描述信息，便于任务管理； + - 负责人：任务的负责人； + - 报警邮件：任务调度失败时邮件通知的邮箱地址，支持配置多邮箱地址，配置多个邮箱地址时用逗号分隔； - - Cron：触发任务执行的Cron表达式； - - 运行模式： - BEAN模式：任务以JobHandler方式维护在执行器端；需要结合 "JobHandler" 属性匹配执行器中任务； - GLUE模式(Java)：任务以源码方式维护在调度中心；该模式的任务实际上是一段继承自IJobHandler的Java类代码并 "groovy" 源码方式维护，它在执行器项目中运行，可使用@Resource/@Autowire注入执行器里中的其他服务； - GLUE模式(Shell)：任务以源码方式维护在调度中心；该模式的任务实际上是一段 "shell" 脚本； - GLUE模式(Python)：任务以源码方式维护在调度中心；该模式的任务实际上是一段 "python" 脚本； - GLUE模式(PHP)：任务以源码方式维护在调度中心；该模式的任务实际上是一段 "php" 脚本； - GLUE模式(NodeJS)：任务以源码方式维护在调度中心；该模式的任务实际上是一段 "nodejs" 脚本； - GLUE模式(PowerShell)：任务以源码方式维护在调度中心；该模式的任务实际上是一段 "PowerShell" 脚本； - - JobHandler：运行模式为 "BEAN模式" 时生效，对应执行器中新开发的JobHandler类“@JobHandler”注解自定义的value值； - - 阻塞处理策略：调度过于密集执行器来不及处理时的处理策略； - 单机串行（默认）：调度请求进入单机执行器后，调度请求进入FIFO队列并以串行方式运行； - 丢弃后续调度：调度请求进入单机执行器后，发现执行器存在运行的调度任务，本次请求将会被丢弃并标记为失败； - 覆盖之前调度：调度请求进入单机执行器后，发现执行器存在运行的调度任务，将会终止运行中的调度任务并清空队列，然后运行本地调度任务； - - 子任务：每个任务都拥有一个唯一的任务ID(任务ID可以从任务列表获取)，当本任务执行结束并且执行成功时，将会触发子任务ID所对应的任务的一次主动调度。 - - 任务超时时间：支持自定义任务超时时间，任务运行超时将会主动中断任务； - - 失败重试次数；支持自定义任务失败重试次数，当任务失败时将会按照预设的失败重试次数主动进行重试； - - 报警邮件：任务调度失败时邮件通知的邮箱地址，支持配置多邮箱地址，配置多个邮箱地址时用逗号分隔； - - 负责人：任务的负责人； - - 执行参数：任务执行所需的参数； + 触发配置： + - 调度类型： + 无：该类型不会主动触发调度； + CRON：该类型将会通过CRON，触发任务调度； + 固定速度：该类型将会以固定速度，触发任务调度；按照固定的间隔时间，周期性触发； + 固定延迟：该类型将会以固定延迟，触发任务调度；按照固定的延迟时间，从上次调度结束后开始计算延迟时间，到达延迟时间后触发下次调度； + - CRON：触发任务执行的Cron表达式； + - 固定速度：固件速度的时间间隔，单位为秒； + - 固定延迟：固件延迟的时间间隔，单位为秒； + + 任务配置： + - 运行模式： + BEAN模式：任务以JobHandler方式维护在执行器端；需要结合 "JobHandler" 属性匹配执行器中任务； + GLUE模式(Java)：任务以源码方式维护在调度中心；该模式的任务实际上是一段继承自IJobHandler的Java类代码并 "groovy" 源码方式维护，它在执行器项目中运行，可使用@Resource/@Autowire注入执行器里中的其他服务； + GLUE模式(Shell)：任务以源码方式维护在调度中心；该模式的任务实际上是一段 "shell" 脚本； + GLUE模式(Python)：任务以源码方式维护在调度中心；该模式的任务实际上是一段 "python" 脚本； + GLUE模式(PHP)：任务以源码方式维护在调度中心；该模式的任务实际上是一段 "php" 脚本； + GLUE模式(NodeJS)：任务以源码方式维护在调度中心；该模式的任务实际上是一段 "nodejs" 脚本； + GLUE模式(PowerShell)：任务以源码方式维护在调度中心；该模式的任务实际上是一段 "PowerShell" 脚本； + - JobHandler：运行模式为 "BEAN模式" 时生效，对应执行器中新开发的JobHandler类“@JobHandler”注解自定义的value值； + - 执行参数：任务执行所需的参数； + + 高级配置： + - 路由策略：当执行器集群部署时，提供丰富的路由策略，包括； + FIRST（第一个）：固定选择第一个机器； + LAST（最后一个）：固定选择最后一个机器； + ROUND（轮询）：； + RANDOM（随机）：随机选择在线的机器； + CONSISTENT_HASH（一致性HASH）：每个任务按照Hash算法固定选择某一台机器，且所有任务均匀散列在不同机器上。 + LEAST_FREQUENTLY_USED（最不经常使用）：使用频率最低的机器优先被选举； + LEAST_RECENTLY_USED（最近最久未使用）：最久未使用的机器优先被选举； + FAILOVER（故障转移）：按照顺序依次进行心跳检测，第一个心跳检测成功的机器选定为目标执行器并发起调度； + BUSYOVER（忙碌转移）：按照顺序依次进行空闲检测，第一个空闲检测成功的机器选定为目标执行器并发起调度； + SHARDING_BROADCAST(分片广播)：广播触发对应集群中所有机器执行一次任务，同时系统自动传递分片参数；可根据分片参数开发分片任务； + - 子任务：每个任务都拥有一个唯一的任务ID(任务ID可以从任务列表获取)，当本任务执行结束并且执行成功时，将会触发子任务ID所对应的任务的一次主动调度。 + - 调度过期策略： + - 忽略：调度过期后，忽略过期的任务，从当前时间开始重新计算下次触发时间； + - 立即执行一次：调度过期后，立即执行一次，并从当前时间开始重新计算下次触发时间； + - 阻塞处理策略：调度过于密集执行器来不及处理时的处理策略； + 单机串行（默认）：调度请求进入单机执行器后，调度请求进入FIFO队列并以串行方式运行； + 丢弃后续调度：调度请求进入单机执行器后，发现执行器存在运行的调度任务，本次请求将会被丢弃并标记为失败； + 覆盖之前调度：调度请求进入单机执行器后，发现执行器存在运行的调度任务，将会终止运行中的调度任务并清空队列，然后运行本地调度任务； + - 任务超时时间：支持自定义任务超时时间，任务运行超时将会主动中断任务； + - 失败重试次数；支持自定义任务失败重试次数，当任务失败时将会按照预设的失败重试次数主动进行重试； + + + ### 3.1 BEAN模式（类形式） @@ -2064,8 +2084,8 @@ data: post-data - 18、执行器Commandhandler示例任务优化，修复极端情况下脚本进程挂起问题； - 19、调度中心页面交互优化：用户管理模块密码列取消；多处表达autocomplete取消；执行器管理模块XSS拦截校验等； - 20、执行器注册组件优化：注册逻辑调整为异步方式，提高注册性能； -- 21、[ING]任务触发参数优化：支持选择 "无（API/人工）"，"Cron触发"、"固定间隔"、"固定延时"等； -- 22、[ING]任务 misfire 策略：忽略、补偿一次等； +- 21、调度过期策略：调度中心错误调度时间的补偿处理策略，包括：忽略、立即补偿触发一次等； +- 22、触发策略强化：除了常规Cron、API、父子任务触发方式外，新增提供 "固定间隔触发、固定延时触发" 两种新触发方式； ### 7.32 版本 v2.3.0 Release Notes[规划中] diff --git a/doc/db/tables_xxl_job.sql b/doc/db/tables_xxl_job.sql index 3660cbd6..a1717c81 100644 --- a/doc/db/tables_xxl_job.sql +++ b/doc/db/tables_xxl_job.sql @@ -10,7 +10,6 @@ SET NAMES utf8mb4; CREATE TABLE `xxl_job_info` ( `id` int(11) NOT NULL AUTO_INCREMENT, `job_group` int(11) NOT NULL COMMENT '执行器主键ID', - `job_cron` varchar(128) NOT NULL COMMENT '任务执行CRON', `job_desc` varchar(255) NOT NULL, `add_time` datetime DEFAULT NULL, `update_time` datetime DEFAULT NULL, @@ -115,7 +114,7 @@ CREATE TABLE `xxl_job_lock` ( ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4; INSERT INTO `xxl_job_group`(`id`, `app_name`, `title`, `address_type`, `address_list`, `update_time`) VALUES (1, 'xxl-job-executor-sample', '示例执行器', 0, NULL, '2018-11-03 22:21:31' ); -INSERT INTO `xxl_job_info`(`id`, `job_group`, `job_cron`, `job_desc`, `add_time`, `update_time`, `author`, `alarm_email`, `schedule_type`, `schedule_conf`, `misfire_strategy`, `executor_route_strategy`, `executor_handler`, `executor_param`, `executor_block_strategy`, `executor_timeout`, `executor_fail_retry_count`, `glue_type`, `glue_source`, `glue_remark`, `glue_updatetime`, `child_jobid`) VALUES (1, 1, '0 0 0 * * ? *', '测试任务1', '2018-11-03 22:21:31', '2018-11-03 22:21:31', 'XXL', '', 'CRON', '0 0 0 * * ? *', 'DO_NOTHING', 'FIRST', 'demoJobHandler', '', 'SERIAL_EXECUTION', 0, 0, 'BEAN', '', 'GLUE代码初始化', '2018-11-03 22:21:31', ''); +INSERT INTO `xxl_job_info`(`id`, `job_group`, `job_desc`, `add_time`, `update_time`, `author`, `alarm_email`, `schedule_type`, `schedule_conf`, `misfire_strategy`, `executor_route_strategy`, `executor_handler`, `executor_param`, `executor_block_strategy`, `executor_timeout`, `executor_fail_retry_count`, `glue_type`, `glue_source`, `glue_remark`, `glue_updatetime`, `child_jobid`) VALUES (1, 1, '测试任务1', '2018-11-03 22:21:31', '2018-11-03 22:21:31', 'XXL', '', 'CRON', '0 0 0 * * ? *', 'DO_NOTHING', 'FIRST', 'demoJobHandler', '', 'SERIAL_EXECUTION', 0, 0, 'BEAN', '', 'GLUE代码初始化', '2018-11-03 22:21:31', ''); INSERT INTO `xxl_job_user`(`id`, `username`, `password`, `role`, `permission`) VALUES (1, 'admin', 'e10adc3949ba59abbe56e057f20f883e', 1, NULL); INSERT INTO `xxl_job_lock` ( `lock_name`) VALUES ( 'schedule_lock'); diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/model/XxlJobInfo.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/model/XxlJobInfo.java index 1e4a74b1..e47b6dc6 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/model/XxlJobInfo.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/model/XxlJobInfo.java @@ -12,7 +12,6 @@ public class XxlJobInfo { private int id; // 主键ID private int jobGroup; // 执行器主键ID - private String jobCron; // 任务执行CRON表达式 private String jobDesc; private Date addTime; @@ -21,6 +20,10 @@ public class XxlJobInfo { private String author; // 负责人 private String alarmEmail; // 报警邮件 + private String scheduleType; // 调度类型 + private String scheduleConf; // 调度配置，值含义取决于调度类型 + private String misfireStrategy; // 调度过期策略 + private String executorRouteStrategy; // 执行器路由策略 private String executorHandler; // 执行器，任务Handler名称 private String executorParam; // 执行器，任务参数 @@ -56,14 +59,6 @@ public class XxlJobInfo { this.jobGroup = jobGroup; } - public String getJobCron() { - return jobCron; - } - - public void setJobCron(String jobCron) { - this.jobCron = jobCron; - } - public String getJobDesc() { return jobDesc; } @@ -104,6 +99,30 @@ public class XxlJobInfo { this.alarmEmail = alarmEmail; } + public String getScheduleType() { + return scheduleType; + } + + public void setScheduleType(String scheduleType) { + this.scheduleType = scheduleType; + } + + public String getScheduleConf() { + return scheduleConf; + } + + public void setScheduleConf(String scheduleConf) { + this.scheduleConf = scheduleConf; + } + + public String getMisfireStrategy() { + return misfireStrategy; + } + + public void setMisfireStrategy(String misfireStrategy) { + this.misfireStrategy = misfireStrategy; + } + public String getExecutorRouteStrategy() { return executorRouteStrategy; } diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/scheduler/MisfireStrategyEnum.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/scheduler/MisfireStrategyEnum.java index 52c03ae7..0b9b4a9c 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/scheduler/MisfireStrategyEnum.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/scheduler/MisfireStrategyEnum.java @@ -27,13 +27,13 @@ public enum MisfireStrategyEnum { return title; } - public static MisfireStrategyEnum match(String name){ + public static MisfireStrategyEnum match(String name, MisfireStrategyEnum defaultItem){ for (MisfireStrategyEnum item: MisfireStrategyEnum.values()) { if (item.name().equals(name)) { return item; } } - return DO_NOTHING; + return defaultItem; } } diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/scheduler/ScheduleTypeEnum.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/scheduler/ScheduleTypeEnum.java index 7c1d9bb3..efe7b6f0 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/scheduler/ScheduleTypeEnum.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/scheduler/ScheduleTypeEnum.java @@ -34,13 +34,13 @@ public enum ScheduleTypeEnum { return title; } - public static ScheduleTypeEnum match(String name){ + public static ScheduleTypeEnum match(String name, ScheduleTypeEnum defaultItem){ for (ScheduleTypeEnum item: ScheduleTypeEnum.values()) { - if (item.equals(name)) { + if (item.name().equals(name)) { return item; } } - return NONE; + return defaultItem; } } diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobScheduleHelper.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobScheduleHelper.java index e425b323..d3ca6fe0 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobScheduleHelper.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobScheduleHelper.java @@ -3,6 +3,8 @@ package com.xxl.job.admin.core.thread; import com.xxl.job.admin.core.conf.XxlJobAdminConfig; import com.xxl.job.admin.core.cron.CronExpression; import com.xxl.job.admin.core.model.XxlJobInfo; +import com.xxl.job.admin.core.scheduler.MisfireStrategyEnum; +import com.xxl.job.admin.core.scheduler.ScheduleTypeEnum; import com.xxl.job.admin.core.trigger.TriggerTypeEnum; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -86,7 +88,15 @@ public class JobScheduleHelper { // 2.1、trigger-expire > 5s：pass && make next-trigger-time logger.warn(">>>>>>>>>>> xxl-job, schedule misfire, jobId = " + jobInfo.getId()); - // fresh next + // 1、misfire match + MisfireStrategyEnum misfireStrategyEnum = MisfireStrategyEnum.match(jobInfo.getMisfireStrategy(), MisfireStrategyEnum.DO_NOTHING); + if (MisfireStrategyEnum.FIRE_ONCE_NOW == misfireStrategyEnum) { + // FIRE_ONCE_NOW 》 trigger + JobTriggerPoolHelper.trigger(jobInfo.getId(), TriggerTypeEnum.MISFIRE, -1, null, null, null); + logger.debug(">>>>>>>>>>> xxl-job, schedule push trigger : jobId = " + jobInfo.getId() ); + } + + // 2、fresh next refreshNextValidTime(jobInfo, new Date()); } else if (nowTime > jobInfo.getTriggerNextTime()) { @@ -270,7 +280,7 @@ public class JobScheduleHelper { } private void refreshNextValidTime(XxlJobInfo jobInfo, Date fromTime) throws ParseException { - Date nextValidTime = new CronExpression(jobInfo.getJobCron()).getNextValidTimeAfter(fromTime); + Date nextValidTime = generateNextValidTime(jobInfo, fromTime); if (nextValidTime != null) { jobInfo.setTriggerLastTime(jobInfo.getTriggerNextTime()); jobInfo.setTriggerNextTime(nextValidTime.getTime()); @@ -278,6 +288,8 @@ public class JobScheduleHelper { jobInfo.setTriggerStatus(0); jobInfo.setTriggerLastTime(0); jobInfo.setTriggerNextTime(0); + logger.warn(">>>>>>>>>>> xxl-job, refreshNextValidTime fail for job: jobId={}, scheduleType={}, scheduleConf={}", + jobInfo.getId(), jobInfo.getScheduleType(), jobInfo.getScheduleConf()); } } @@ -351,4 +363,17 @@ public class JobScheduleHelper { logger.info(">>>>>>>>>>> xxl-job, JobScheduleHelper stop"); } + + // ---------------------- tools ---------------------- + public static Date generateNextValidTime(XxlJobInfo jobInfo, Date fromTime) throws ParseException { + ScheduleTypeEnum scheduleTypeEnum = ScheduleTypeEnum.match(jobInfo.getScheduleType(), null); + if (ScheduleTypeEnum.CRON == scheduleTypeEnum) { + Date nextValidTime = new CronExpression(jobInfo.getScheduleConf()).getNextValidTimeAfter(fromTime); + return nextValidTime; + } else if (ScheduleTypeEnum.FIX_RATE == scheduleTypeEnum || ScheduleTypeEnum.FIX_DELAY == scheduleTypeEnum) { + return new Date(fromTime.getTime() + Integer.valueOf(jobInfo.getScheduleConf())*1000 ); + } + return null; + } + } diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/trigger/TriggerTypeEnum.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/trigger/TriggerTypeEnum.java index bfb66d05..446c90e9 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/trigger/TriggerTypeEnum.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/trigger/TriggerTypeEnum.java @@ -13,7 +13,8 @@ public enum TriggerTypeEnum { CRON(I18nUtil.getString("jobconf_trigger_type_cron")), RETRY(I18nUtil.getString("jobconf_trigger_type_retry")), PARENT(I18nUtil.getString("jobconf_trigger_type_parent")), - API(I18nUtil.getString("jobconf_trigger_type_api")); + API(I18nUtil.getString("jobconf_trigger_type_api")), + MISFIRE(I18nUtil.getString("jobconf_trigger_type_misfire")); private TriggerTypeEnum(String title){ this.title = title; diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/service/impl/XxlJobServiceImpl.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/service/impl/XxlJobServiceImpl.java index 526c43b3..60354f64 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/service/impl/XxlJobServiceImpl.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/service/impl/XxlJobServiceImpl.java @@ -1,10 +1,12 @@ package com.xxl.job.admin.service.impl; +import com.xxl.job.admin.core.cron.CronExpression; import com.xxl.job.admin.core.model.XxlJobGroup; import com.xxl.job.admin.core.model.XxlJobInfo; -import com.xxl.job.admin.core.cron.CronExpression; import com.xxl.job.admin.core.model.XxlJobLogReport; import com.xxl.job.admin.core.route.ExecutorRouteStrategyEnum; +import com.xxl.job.admin.core.scheduler.MisfireStrategyEnum; +import com.xxl.job.admin.core.scheduler.ScheduleTypeEnum; import com.xxl.job.admin.core.thread.JobScheduleHelper; import com.xxl.job.admin.core.util.I18nUtil; import com.xxl.job.admin.dao.*; @@ -58,40 +60,67 @@ public class XxlJobServiceImpl implements XxlJobService { @Override public ReturnT add(XxlJobInfo jobInfo) { - // valid + + // valid base XxlJobGroup group = xxlJobGroupDao.load(jobInfo.getJobGroup()); if (group == null) { return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("system_please_choose")+I18nUtil.getString("jobinfo_field_jobgroup")) ); } - if (!CronExpression.isValidExpression(jobInfo.getJobCron())) { - return new ReturnT(ReturnT.FAIL_CODE, I18nUtil.getString("jobinfo_field_cron_unvalid") ); - } if (jobInfo.getJobDesc()==null || jobInfo.getJobDesc().trim().length()==0) { return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("system_please_input")+I18nUtil.getString("jobinfo_field_jobdesc")) ); } if (jobInfo.getAuthor()==null || jobInfo.getAuthor().trim().length()==0) { return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("system_please_input")+I18nUtil.getString("jobinfo_field_author")) ); } - if (ExecutorRouteStrategyEnum.match(jobInfo.getExecutorRouteStrategy(), null) == null) { - return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("jobinfo_field_executorRouteStrategy")+I18nUtil.getString("system_unvalid")) ); + + // valid trigger + ScheduleTypeEnum scheduleTypeEnum = ScheduleTypeEnum.match(jobInfo.getScheduleType(), null); + if (scheduleTypeEnum == null) { + return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type")+I18nUtil.getString("system_unvalid")) ); } - if (ExecutorBlockStrategyEnum.match(jobInfo.getExecutorBlockStrategy(), null) == null) { - return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("jobinfo_field_executorBlockStrategy")+I18nUtil.getString("system_unvalid")) ); + if (scheduleTypeEnum == ScheduleTypeEnum.CRON) { + if (jobInfo.getScheduleConf()==null || !CronExpression.isValidExpression(jobInfo.getScheduleConf())) { + return new ReturnT(ReturnT.FAIL_CODE, I18nUtil.getString("jobinfo_field_cron_unvalid") ); + } + } else if (scheduleTypeEnum == ScheduleTypeEnum.FIX_RATE || scheduleTypeEnum == ScheduleTypeEnum.FIX_DELAY) { + if (jobInfo.getScheduleConf() == null) { + return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type")+I18nUtil.getString("system_unvalid")) ); + } + try { + int fixSecond = Integer.valueOf(jobInfo.getScheduleConf()); + if (fixSecond < 1) { + return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type")+I18nUtil.getString("system_unvalid")) ); + } + } catch (Exception e) { + return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type")+I18nUtil.getString("system_unvalid")) ); + } } + + // valid job if (GlueTypeEnum.match(jobInfo.getGlueType()) == null) { return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("jobinfo_field_gluetype")+I18nUtil.getString("system_unvalid")) ); } if (GlueTypeEnum.BEAN==GlueTypeEnum.match(jobInfo.getGlueType()) && (jobInfo.getExecutorHandler()==null || jobInfo.getExecutorHandler().trim().length()==0) ) { return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("system_please_input")+"JobHandler") ); } - - // fix "\r" in shell + // 》fix "\r" in shell if (GlueTypeEnum.GLUE_SHELL==GlueTypeEnum.match(jobInfo.getGlueType()) && jobInfo.getGlueSource()!=null) { jobInfo.setGlueSource(jobInfo.getGlueSource().replaceAll("\r", "")); } - // ChildJobId valid - if (jobInfo.getChildJobId()!=null && jobInfo.getChildJobId().trim().length()>0) { + // valid advanced + if (ExecutorRouteStrategyEnum.match(jobInfo.getExecutorRouteStrategy(), null) == null) { + return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("jobinfo_field_executorRouteStrategy")+I18nUtil.getString("system_unvalid")) ); + } + if (MisfireStrategyEnum.match(jobInfo.getMisfireStrategy(), null) == null) { + return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("misfire_strategy")+I18nUtil.getString("system_unvalid")) ); + } + if (ExecutorBlockStrategyEnum.match(jobInfo.getExecutorBlockStrategy(), null) == null) { + return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("jobinfo_field_executorBlockStrategy")+I18nUtil.getString("system_unvalid")) ); + } + + // 》ChildJobId valid + if (jobInfo.getChildJobId()!=null && jobInfo.getChildJobId().trim().length()>0) { String[] childJobIds = jobInfo.getChildJobId().split(","); for (String childJobIdItem: childJobIds) { if (childJobIdItem!=null && childJobIdItem.trim().length()>0 && isNumeric(childJobIdItem)) { @@ -140,25 +169,50 @@ public class XxlJobServiceImpl implements XxlJobService { @Override public ReturnT update(XxlJobInfo jobInfo) { - // valid - if (!CronExpression.isValidExpression(jobInfo.getJobCron())) { - return new ReturnT(ReturnT.FAIL_CODE, I18nUtil.getString("jobinfo_field_cron_unvalid") ); - } + // valid base if (jobInfo.getJobDesc()==null || jobInfo.getJobDesc().trim().length()==0) { return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("system_please_input")+I18nUtil.getString("jobinfo_field_jobdesc")) ); } if (jobInfo.getAuthor()==null || jobInfo.getAuthor().trim().length()==0) { return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("system_please_input")+I18nUtil.getString("jobinfo_field_author")) ); } + + // valid trigger + ScheduleTypeEnum scheduleTypeEnum = ScheduleTypeEnum.match(jobInfo.getScheduleType(), null); + if (scheduleTypeEnum == null) { + return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type")+I18nUtil.getString("system_unvalid")) ); + } + if (scheduleTypeEnum == ScheduleTypeEnum.CRON) { + if (jobInfo.getScheduleConf()==null || !CronExpression.isValidExpression(jobInfo.getScheduleConf())) { + return new ReturnT(ReturnT.FAIL_CODE, I18nUtil.getString("jobinfo_field_cron_unvalid") ); + } + } else if (scheduleTypeEnum == ScheduleTypeEnum.FIX_RATE || scheduleTypeEnum == ScheduleTypeEnum.FIX_DELAY) { + if (jobInfo.getScheduleConf() == null) { + return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type")+I18nUtil.getString("system_unvalid")) ); + } + try { + int fixSecond = Integer.valueOf(jobInfo.getScheduleConf()); + if (fixSecond < 1) { + return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type")+I18nUtil.getString("system_unvalid")) ); + } + } catch (Exception e) { + return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type")+I18nUtil.getString("system_unvalid")) ); + } + } + + // valid advanced if (ExecutorRouteStrategyEnum.match(jobInfo.getExecutorRouteStrategy(), null) == null) { return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("jobinfo_field_executorRouteStrategy")+I18nUtil.getString("system_unvalid")) ); } + if (MisfireStrategyEnum.match(jobInfo.getMisfireStrategy(), null) == null) { + return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("misfire_strategy")+I18nUtil.getString("system_unvalid")) ); + } if (ExecutorBlockStrategyEnum.match(jobInfo.getExecutorBlockStrategy(), null) == null) { return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("jobinfo_field_executorBlockStrategy")+I18nUtil.getString("system_unvalid")) ); } - // ChildJobId valid - if (jobInfo.getChildJobId()!=null && jobInfo.getChildJobId().trim().length()>0) { + // 》ChildJobId valid + if (jobInfo.getChildJobId()!=null && jobInfo.getChildJobId().trim().length()>0) { String[] childJobIds = jobInfo.getChildJobId().split(","); for (String childJobIdItem: childJobIds) { if (childJobIdItem!=null && childJobIdItem.trim().length()>0 && isNumeric(childJobIdItem)) { @@ -197,24 +251,27 @@ public class XxlJobServiceImpl implements XxlJobService { // next trigger time (5s后生效，避开预读周期) long nextTriggerTime = exists_jobInfo.getTriggerNextTime(); - if (exists_jobInfo.getTriggerStatus() == 1 && !jobInfo.getJobCron().equals(exists_jobInfo.getJobCron()) ) { + boolean scheduleDataNotChanged = jobInfo.getScheduleType().equals(exists_jobInfo.getScheduleType()) && jobInfo.getScheduleConf().equals(exists_jobInfo.getScheduleConf()); + if (exists_jobInfo.getTriggerStatus() == 1 && !scheduleDataNotChanged) { try { - Date nextValidTime = new CronExpression(jobInfo.getJobCron()).getNextValidTimeAfter(new Date(System.currentTimeMillis() + JobScheduleHelper.PRE_READ_MS)); + Date nextValidTime = JobScheduleHelper.generateNextValidTime(jobInfo, new Date(System.currentTimeMillis() + JobScheduleHelper.PRE_READ_MS)); if (nextValidTime == null) { - return new ReturnT(ReturnT.FAIL_CODE, I18nUtil.getString("jobinfo_field_cron_never_fire")); + return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type")+I18nUtil.getString("system_unvalid")) ); } nextTriggerTime = nextValidTime.getTime(); - } catch (ParseException e) { + } catch (Exception e) { logger.error(e.getMessage(), e); - return new ReturnT(ReturnT.FAIL_CODE, I18nUtil.getString("jobinfo_field_cron_unvalid")+" | "+ e.getMessage()); + return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type")+I18nUtil.getString("system_unvalid")) ); } } exists_jobInfo.setJobGroup(jobInfo.getJobGroup()); - exists_jobInfo.setJobCron(jobInfo.getJobCron()); exists_jobInfo.setJobDesc(jobInfo.getJobDesc()); exists_jobInfo.setAuthor(jobInfo.getAuthor()); exists_jobInfo.setAlarmEmail(jobInfo.getAlarmEmail()); + exists_jobInfo.setScheduleType(jobInfo.getScheduleType()); + exists_jobInfo.setScheduleConf(jobInfo.getScheduleConf()); + exists_jobInfo.setMisfireStrategy(jobInfo.getMisfireStrategy()); exists_jobInfo.setExecutorRouteStrategy(jobInfo.getExecutorRouteStrategy()); exists_jobInfo.setExecutorHandler(jobInfo.getExecutorHandler()); exists_jobInfo.setExecutorParam(jobInfo.getExecutorParam()); @@ -248,17 +305,23 @@ public class XxlJobServiceImpl implements XxlJobService { public ReturnT start(int id) { XxlJobInfo xxlJobInfo = xxlJobInfoDao.loadById(id); + // valid + ScheduleTypeEnum scheduleTypeEnum = ScheduleTypeEnum.match(xxlJobInfo.getScheduleType(), ScheduleTypeEnum.NONE); + if (ScheduleTypeEnum.NONE == scheduleTypeEnum) { + return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type_none_limit_start")) ); + } + // next trigger time (5s后生效，避开预读周期) long nextTriggerTime = 0; try { - Date nextValidTime = new CronExpression(xxlJobInfo.getJobCron()).getNextValidTimeAfter(new Date(System.currentTimeMillis() + JobScheduleHelper.PRE_READ_MS)); + Date nextValidTime = JobScheduleHelper.generateNextValidTime(xxlJobInfo, new Date(System.currentTimeMillis() + JobScheduleHelper.PRE_READ_MS)); if (nextValidTime == null) { - return new ReturnT(ReturnT.FAIL_CODE, I18nUtil.getString("jobinfo_field_cron_never_fire")); + return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type")+I18nUtil.getString("system_unvalid")) ); } nextTriggerTime = nextValidTime.getTime(); } catch (ParseException e) { logger.error(e.getMessage(), e); - return new ReturnT(ReturnT.FAIL_CODE, I18nUtil.getString("jobinfo_field_cron_unvalid")+" | "+ e.getMessage()); + return new ReturnT(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type")+I18nUtil.getString("system_unvalid")) ); } xxlJobInfo.setTriggerStatus(1); diff --git a/xxl-job-admin/src/main/resources/i18n/message_en.properties b/xxl-job-admin/src/main/resources/i18n/message_en.properties index 68b9b6e5..9605916a 100644 --- a/xxl-job-admin/src/main/resources/i18n/message_en.properties +++ b/xxl-job-admin/src/main/resources/i18n/message_en.properties @@ -149,9 +149,14 @@ schedule_type_none=None schedule_type_cron=Cron schedule_type_fix_rate=Fix rate schedule_type_fix_delay=Fix delay +schedule_type_none_limit_start=The current schedule type disables startup misfire_strategy=Misfire strategy misfire_strategy_do_nothing=Do nothing misfire_strategy_fire_once_now=Fire once now +jobinfo_conf_base=Base configuration +jobinfo_conf_trigger=Trigger configuration +jobinfo_conf_job=Job configuration +jobinfo_conf_advanced=Advanced configuration ## job log joblog_name=Trigger Log @@ -251,6 +256,7 @@ jobconf_trigger_type_manual=Manual trigger jobconf_trigger_type_parent=Parent job trigger jobconf_trigger_type_api=Api trigger jobconf_trigger_type_retry=Fail retry trigger +jobconf_trigger_type_misfire=Misfire compensation trigger ## user user_manage=User Manage diff --git a/xxl-job-admin/src/main/resources/i18n/message_zh_CN.properties b/xxl-job-admin/src/main/resources/i18n/message_zh_CN.properties index d7ceb34d..fc3f65b6 100644 --- a/xxl-job-admin/src/main/resources/i18n/message_zh_CN.properties +++ b/xxl-job-admin/src/main/resources/i18n/message_zh_CN.properties @@ -149,9 +149,14 @@ schedule_type_none=无 schedule_type_cron=CRON schedule_type_fix_rate=固定速度 schedule_type_fix_delay=固定延迟 +schedule_type_none_limit_start=当前调度类型禁止启动 misfire_strategy=调度过期策略 misfire_strategy_do_nothing=忽略 misfire_strategy_fire_once_now=立即执行一次 +jobinfo_conf_base=基础配置 +jobinfo_conf_trigger=触发配置 +jobinfo_conf_job=任务配置 +jobinfo_conf_advanced=高级信息 ## job log joblog_name=调度日志 @@ -251,6 +256,7 @@ jobconf_trigger_type_manual=手动触发 jobconf_trigger_type_parent=父任务触发 jobconf_trigger_type_api=API触发 jobconf_trigger_type_retry=失败重试触发 +jobconf_trigger_type_misfire=调度过期补偿 ## user user_manage=用户管理 diff --git a/xxl-job-admin/src/main/resources/i18n/message_zh_TC.properties b/xxl-job-admin/src/main/resources/i18n/message_zh_TC.properties index 9a6bffa0..947c748f 100755 --- a/xxl-job-admin/src/main/resources/i18n/message_zh_TC.properties +++ b/xxl-job-admin/src/main/resources/i18n/message_zh_TC.properties @@ -149,9 +149,14 @@ schedule_type_none=無 schedule_type_cron=CRON schedule_type_fix_rate=固定速度 schedule_type_fix_delay=固定延遲 +schedule_type_none_limit_start=當前調度類型禁止啟動 misfire_strategy=調度過期策略 misfire_strategy_do_nothing=忽略 misfire_strategy_fire_once_now=立即執行壹次 +jobinfo_conf_base=基礎配置 +jobinfo_conf_trigger=觸發配置 +jobinfo_conf_job=任務配置 +jobinfo_conf_advanced=高級信息 ## job log joblog_name=調度日誌 @@ -251,6 +256,7 @@ jobconf_trigger_type_manual=手動觸發 jobconf_trigger_type_parent=父任務觸發 jobconf_trigger_type_api=API觸發 jobconf_trigger_type_retry=失敗重試觸發 +jobconf_trigger_type_misfire=調度過期補償 ## user user_manage=用户管理 diff --git a/xxl-job-admin/src/main/resources/mybatis-mapper/XxlJobInfoMapper.xml b/xxl-job-admin/src/main/resources/mybatis-mapper/XxlJobInfoMapper.xml index cb9048d2..7b3c3a3e 100644 --- a/xxl-job-admin/src/main/resources/mybatis-mapper/XxlJobInfoMapper.xml +++ b/xxl-job-admin/src/main/resources/mybatis-mapper/XxlJobInfoMapper.xml @@ -7,7 +7,6 @@ - @@ -16,6 +15,10 @@ + + + + @@ -38,12 +41,14 @@ t.id, t.job_group, - t.job_cron, t.job_desc, t.add_time, t.update_time, t.author, t.alarm_email, + t.schedule_type, + t.schedule_conf, + t.misfire_strategy, t.executor_route_strategy, t.executor_handler, t.executor_param, @@ -109,12 +114,14 @@ INSERT INTO xxl_job_info ( job_group, - job_cron, job_desc, add_time, update_time, author, alarm_email, + schedule_type, + schedule_conf, + misfire_strategy, executor_route_strategy, executor_handler, executor_param, @@ -131,12 +138,14 @@ trigger_next_time ) VALUES ( #{jobGroup}, - #{jobCron}, #{jobDesc}, #{addTime}, #{updateTime}, #{author}, #{alarmEmail}, + #{scheduleType}, + #{scheduleConf}, + #{misfireStrategy}, #{executorRouteStrategy}, #{executorHandler}, #{executorParam}, @@ -168,11 +177,13 @@ UPDATE xxl_job_info SET job_group = #{jobGroup}, - job_cron = #{jobCron}, job_desc = #{jobDesc}, update_time = #{updateTime}, author = #{author}, alarm_email = #{alarmEmail}, + schedule_type = #{scheduleType}, + schedule_conf = #{scheduleConf}, + misfire_strategy = #{misfireStrategy}, executor_route_strategy = #{executorRouteStrategy}, executor_handler = #{executorHandler}, executor_param = #{executorParam}, diff --git a/xxl-job-admin/src/main/resources/static/js/jobinfo.index.1.js b/xxl-job-admin/src/main/resources/static/js/jobinfo.index.1.js index c8e76e9e..833e621a 100644 --- a/xxl-job-admin/src/main/resources/static/js/jobinfo.index.1.js +++ b/xxl-job-admin/src/main/resources/static/js/jobinfo.index.1.js @@ -48,6 +48,18 @@ $(function() { "visible" : true, "width":'25%' }, + { + "data": 'scheduleType', + "visible" : true, + "width":'13%', + "render": function ( data, type, row ) { + if (row.scheduleConf) { + return row.scheduleType + '：'+ row.scheduleConf; + } else { + return row.scheduleType; + } + } + }, { "data": 'glueType', "width":'25%', @@ -62,11 +74,6 @@ $(function() { } }, { "data": 'executorParam', "visible" : false}, - { - "data": 'jobCron', - "visible" : true, - "width":'13%' - }, { "data": 'addTime', "visible" : false, @@ -364,8 +371,8 @@ $(function() { $(".add").click(function(){ // init-cronGen - $("#addModal .form input[name='jobCron']").show().siblings().remove(); - $("#addModal .form input[name='jobCron']").cronGen({}); + $("#addModal .form input[name='schedule_conf_CRON']").show().siblings().remove(); + $("#addModal .form input[name='schedule_conf_CRON']").cronGen({}); $('#addModal').modal({backdrop: false, keyboard: false}).modal('show'); }); @@ -378,35 +385,29 @@ $(function() { required : true, maxlength: 50 }, - jobCron : { - required : true - }, author : { required : true - }, + }/*, executorTimeout : { digits:true }, executorFailRetryCount : { digits:true - } + }*/ }, messages : { jobDesc : { required : I18n.system_please_input + I18n.jobinfo_field_jobdesc }, - jobCron : { - required : I18n.system_please_input + "Cron" - }, author : { required : I18n.system_please_input + I18n.jobinfo_field_author - }, + }/*, executorTimeout : { digits: I18n.system_please_input + I18n.system_digits }, executorFailRetryCount : { digits: I18n.system_please_input + I18n.system_digits - } + }*/ }, highlight : function(element) { $(element).closest('.form-group').addClass('has-error'); @@ -420,7 +421,7 @@ $(function() { }, submitHandler : function(form) { - // process + // process executorTimeout+executorFailRetryCount var executorTimeout = $("#addModal .form input[name='executorTimeout']").val(); if(!/^\d+$/.test(executorTimeout)) { executorTimeout = 0; @@ -432,8 +433,17 @@ $(function() { } $("#addModal .form input[name='executorFailRetryCount']").val(executorFailRetryCount); - // process-cronGen - $("#addModal .form input[name='jobCron']").val( $("#addModal .form input[name='cronGen_display']").val() ); + // process schedule_conf + var scheduleType = $("#addModal .form select[name='scheduleType']").val(); + var scheduleConf; + if (scheduleType == 'CRON') { + scheduleConf = $("#addModal .form input[name='cronGen_display']").val(); + } else if (scheduleType == 'FIX_RATE') { + scheduleConf = $("#addModal .form input[name='schedule_conf_FIX_RATE']").val(); + } else if (scheduleType == 'FIX_DELAY') { + scheduleConf = $("#addModal .form input[name='schedule_conf_FIX_DELAY']").val(); + } + $("#addModal .form input[name='scheduleConf']").val( scheduleConf ); $.post(base_url + "/jobinfo/add", $("#addModal .form").serialize(), function(data, status) { if (data.code == "200") { @@ -468,6 +478,13 @@ $(function() { $("#addModal .form input[name='executorHandler']").removeAttr("readonly"); }); + // scheduleType change + $(".scheduleType").change(function(){ + var scheduleType = $(this).val(); + $(this).parents("form").find(".schedule_conf").hide(); + $(this).parents("form").find(".schedule_conf_" + scheduleType).show(); + + }); // glueType change $(".glueType").change(function(){ @@ -508,27 +525,46 @@ $(function() { var id = $(this).parents('ul').attr("_id"); var row = tableData['key'+id]; - // base data + // fill base $("#updateModal .form input[name='id']").val( row.id ); $('#updateModal .form select[name=jobGroup] option[value='+ row.jobGroup +']').prop('selected', true); $("#updateModal .form input[name='jobDesc']").val( row.jobDesc ); - $("#updateModal .form input[name='jobCron']").val( row.jobCron ); $("#updateModal .form input[name='author']").val( row.author ); $("#updateModal .form input[name='alarmEmail']").val( row.alarmEmail ); - $("#updateModal .form input[name='executorTimeout']").val( row.executorTimeout ); - $("#updateModal .form input[name='executorFailRetryCount']").val( row.executorFailRetryCount ); - $('#updateModal .form select[name=executorRouteStrategy] option[value='+ row.executorRouteStrategy +']').prop('selected', true); + + // fill trigger + $('#updateModal .form select[name=scheduleType] option[value='+ row.scheduleType +']').prop('selected', true); + $("#updateModal .form input[name='scheduleConf']").val( row.scheduleConf ); + if (row.scheduleType == 'CRON') { + $("#updateModal .form input[name='schedule_conf_CRON']").val( row.scheduleConf ); + } else if (row.scheduleType == 'FIX_RATE') { + $("#updateModal .form input[name='schedule_conf_FIX_RATE']").val( row.scheduleConf ); + } else if (row.scheduleType == 'FIX_DELAY') { + $("#updateModal .form input[name='schedule_conf_FIX_DELAY']").val( row.scheduleConf ); + } + + // 》init scheduleType + $("#updateModal .form select[name=scheduleType]").change(); + + // fill job + $('#updateModal .form select[name=glueType] option[value='+ row.glueType +']').prop('selected', true); $("#updateModal .form input[name='executorHandler']").val( row.executorHandler ); $("#updateModal .form textarea[name='executorParam']").val( row.executorParam ); - $("#updateModal .form input[name='childJobId']").val( row.childJobId ); + + // 》init glueType + $("#updateModal .form select[name=glueType]").change(); + + // 》init-cronGen + $("#updateModal .form input[name='schedule_conf_CRON']").show().siblings().remove(); + $("#updateModal .form input[name='schedule_conf_CRON']").cronGen({}); + + // fill advanced + $('#updateModal .form select[name=executorRouteStrategy] option[value='+ row.executorRouteStrategy +']').prop('selected', true); + $("#updateModal .form input[name='childJobId']").val( row.childJobId ); + $('#updateModal .form select[name=misfireStrategy] option[value='+ row.misfireStrategy +']').prop('selected', true); $('#updateModal .form select[name=executorBlockStrategy] option[value='+ row.executorBlockStrategy +']').prop('selected', true); - $('#updateModal .form select[name=glueType] option[value='+ row.glueType +']').prop('selected', true); - - $("#updateModal .form select[name=glueType]").change(); - - // init-cronGen - $("#updateModal .form input[name='jobCron']").show().siblings().remove(); - $("#updateModal .form input[name='jobCron']").cronGen({}); + $("#updateModal .form input[name='executorTimeout']").val( row.executorTimeout ); + $("#updateModal .form input[name='executorFailRetryCount']").val( row.executorFailRetryCount ); // show $('#updateModal').modal({backdrop: false, keyboard: false}).modal('show'); @@ -548,13 +584,7 @@ $(function() { }, author : { required : true - }, - executorTimeout : { - digits:true - }, - executorFailRetryCount : { - digits:true - } + } }, messages : { jobDesc : { @@ -565,13 +595,7 @@ $(function() { }, author : { required : I18n.system_please_input + I18n.jobinfo_field_author - }, - executorTimeout : { - digits: I18n.system_please_input + I18n.system_digits - }, - executorFailRetryCount : { - digits: I18n.system_please_input + I18n.system_digits - } + } }, highlight : function(element) { $(element).closest('.form-group').addClass('has-error'); @@ -585,7 +609,7 @@ $(function() { }, submitHandler : function(form) { - // process + // process executorTimeout + executorFailRetryCount var executorTimeout = $("#updateModal .form input[name='executorTimeout']").val(); if(!/^\d+$/.test(executorTimeout)) { executorTimeout = 0; @@ -597,8 +621,18 @@ $(function() { } $("#updateModal .form input[name='executorFailRetryCount']").val(executorFailRetryCount); - // process-cronGen - $("#updateModal .form input[name='jobCron']").val( $("#updateModal .form input[name='cronGen_display']").val() ); + + // process schedule_conf + var scheduleType = $("#updateModal .form select[name='scheduleType']").val(); + var scheduleConf; + if (scheduleType == 'CRON') { + scheduleConf = $("#updateModal .form input[name='cronGen_display']").val(); + } else if (scheduleType == 'FIX_RATE') { + scheduleConf = $("#updateModal .form input[name='schedule_conf_FIX_RATE']").val(); + } else if (scheduleType == 'FIX_DELAY') { + scheduleConf = $("#updateModal .form input[name='schedule_conf_FIX_DELAY']").val(); + } + $("#updateModal .form input[name='scheduleConf']").val( scheduleConf ); // post $.post(base_url + "/jobinfo/update", $("#updateModal .form").serialize(), function(data, status) { @@ -653,27 +687,45 @@ $(function() { var id = $(this).parents('ul').attr("_id"); var row = tableData['key'+id]; - // base data - //$("#addModal .form input[name='id']").val( row.id ); + // fill base $('#addModal .form select[name=jobGroup] option[value='+ row.jobGroup +']').prop('selected', true); $("#addModal .form input[name='jobDesc']").val( row.jobDesc ); - $("#addModal .form input[name='jobCron']").val( row.jobCron ); $("#addModal .form input[name='author']").val( row.author ); $("#addModal .form input[name='alarmEmail']").val( row.alarmEmail ); - $("#addModal .form input[name='executorTimeout']").val( row.executorTimeout ); - $("#addModal .form input[name='executorFailRetryCount']").val( row.executorFailRetryCount ); - $('#addModal .form select[name=executorRouteStrategy] option[value='+ row.executorRouteStrategy +']').prop('selected', true); + + // fill trigger + $('#addModal .form select[name=scheduleType] option[value='+ row.scheduleType +']').prop('selected', true); + $("#addModal .form input[name='scheduleConf']").val( row.scheduleConf ); + if (row.scheduleType == 'CRON') { + $("#addModal .form input[name='schedule_conf_CRON']").val( row.scheduleConf ); + } else if (row.scheduleType == 'FIX_RATE') { + $("#addModal .form input[name='schedule_conf_FIX_RATE']").val( row.scheduleConf ); + } else if (row.scheduleType == 'FIX_DELAY') { + $("#addModal .form input[name='schedule_conf_FIX_DELAY']").val( row.scheduleConf ); + } + + // 》init scheduleType + $("#addModal .form select[name=scheduleType]").change(); + + // fill job + $('#addModal .form select[name=glueType] option[value='+ row.glueType +']').prop('selected', true); $("#addModal .form input[name='executorHandler']").val( row.executorHandler ); $("#addModal .form textarea[name='executorParam']").val( row.executorParam ); - $("#addModal .form input[name='childJobId']").val( row.childJobId ); - $('#addModal .form select[name=executorBlockStrategy] option[value='+ row.executorBlockStrategy +']').prop('selected', true); - $('#addModal .form select[name=glueType] option[value='+ row.glueType +']').prop('selected', true); + // 》init glueType $("#addModal .form select[name=glueType]").change(); - // init-cronGen - $("#addModal .form input[name='jobCron']").show().siblings().remove(); - $("#addModal .form input[name='jobCron']").cronGen({}); + // 》init-cronGen + $("#addModal .form input[name='schedule_conf_CRON']").show().siblings().remove(); + $("#addModal .form input[name='schedule_conf_CRON']").cronGen({}); + + // fill advanced + $('#addModal .form select[name=executorRouteStrategy] option[value='+ row.executorRouteStrategy +']').prop('selected', true); + $("#addModal .form input[name='childJobId']").val( row.childJobId ); + $('#addModal .form select[name=misfireStrategy] option[value='+ row.misfireStrategy +']').prop('selected', true); + $('#addModal .form select[name=executorBlockStrategy] option[value='+ row.executorBlockStrategy +']').prop('selected', true); + $("#addModal .form input[name='executorTimeout']").val( row.executorTimeout ); + $("#addModal .form input[name='executorFailRetryCount']").val( row.executorFailRetryCount ); // show $('#addModal').modal({backdrop: false, keyboard: false}).modal('show'); diff --git a/xxl-job-admin/src/main/resources/templates/jobinfo/jobinfo.index.ftl b/xxl-job-admin/src/main/resources/templates/jobinfo/jobinfo.index.ftl index 0e39c2a6..f4d4d359 100644 --- a/xxl-job-admin/src/main/resources/templates/jobinfo/jobinfo.index.ftl +++ b/xxl-job-admin/src/main/resources/templates/jobinfo/jobinfo.index.ftl @@ -81,8 +81,8 @@ ${I18n.jobinfo_field_jobgroup} ${I18n.jobinfo_field_jobdesc} ${I18n.jobinfo_field_gluetype} - ${I18n.jobinfo_field_executorparam} - Cron + ${I18n.schedule_type} + ${I18n.jobinfo_field_executorparam} addTime updateTime ${I18n.jobinfo_field_author} @@ -114,6 +114,8 @@
+ +

- ${I18n.jobinfo_conf_base} -

<#-- 基础信息 -->
@@ -123,11 +125,71 @@
+
- + +
+ +
+
+ +

- ${I18n.jobinfo_conf_trigger} -

<#-- 触发配置 --> +
+ +
+ +
+ + + +
+ +
+
+ + +
+ +

- ${I18n.jobinfo_conf_job} -

<#-- 任务配置 --> + +
+ +
+ +
+ +
+
+ +
+ +
+ +
+
+ +

- ${I18n.jobinfo_conf_advanced} -

<#-- 高级配置 --> + +
+
- -
+ + +
+
- +
- + <#list MisfireStrategyEnum as item> + +
- -
-
-
- + +
- -
+
-
+
-
-
-
- -
- -
-
-
- -
- -
+
@@ -310,71 +358,121 @@ exit 0
-
+ + + +

- ${I18n.jobinfo_conf_base} -

<#-- 基础信息 --> +
+
-
- -
- -
- -
-
-
- -
- -
- -
-
-
- -
- -
- -
-
-
- -
- -
-
+ +

- ${I18n.jobinfo_conf_trigger} -

<#-- 触发配置 --> +
+ +
+ +
+ + + +
+ +
+
+ + +
+ +

- ${I18n.jobinfo_conf_job} -

<#-- 任务配置 --> + +
+ +
+ +
+ +
+
+
-
+
+
+ +

- ${I18n.jobinfo_conf_advanced} -

<#-- 高级配置 --> + +
+ +
+ +
+ + +
+
+ +
+ +
+ +
+ + +
+ +
+
+ +
+ +
+ +
diff --git a/xxl-job-admin/src/test/java/com/xxl/job/admin/dao/XxlJobInfoDaoTest.java b/xxl-job-admin/src/test/java/com/xxl/job/admin/dao/XxlJobInfoDaoTest.java index 1a27ab47..273ef46e 100644 --- a/xxl-job-admin/src/test/java/com/xxl/job/admin/dao/XxlJobInfoDaoTest.java +++ b/xxl-job-admin/src/test/java/com/xxl/job/admin/dao/XxlJobInfoDaoTest.java @@ -1,6 +1,8 @@ package com.xxl.job.admin.dao; import com.xxl.job.admin.core.model.XxlJobInfo; +import com.xxl.job.admin.core.scheduler.MisfireStrategyEnum; +import com.xxl.job.admin.core.scheduler.ScheduleTypeEnum; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.boot.test.context.SpringBootTest; @@ -32,10 +34,12 @@ public class XxlJobInfoDaoTest { public void save_load(){ XxlJobInfo info = new XxlJobInfo(); info.setJobGroup(1); - info.setJobCron("jobCron"); info.setJobDesc("desc"); info.setAuthor("setAuthor"); info.setAlarmEmail("setAlarmEmail"); + info.setScheduleType(ScheduleTypeEnum.FIX_RATE.name()); + info.setScheduleConf(String.valueOf(33)); + info.setMisfireStrategy(MisfireStrategyEnum.DO_NOTHING.name()); info.setExecutorRouteStrategy("setExecutorRouteStrategy"); info.setExecutorHandler("setExecutorHandler"); info.setExecutorParam("setExecutorParam"); @@ -52,7 +56,9 @@ public class XxlJobInfoDaoTest { int count = xxlJobInfoDao.save(info); XxlJobInfo info2 = xxlJobInfoDao.loadById(info.getId()); - info2.setJobCron("jobCron2"); + info.setScheduleType(ScheduleTypeEnum.FIX_DELAY.name()); + info.setScheduleConf(String.valueOf(44)); + info.setMisfireStrategy(MisfireStrategyEnum.FIRE_ONCE_NOW.name()); info2.setJobDesc("desc2"); info2.setAuthor("setAuthor2"); info2.setAlarmEmail("setAlarmEmail2");