sqlserver暂停在执行的job_XXLJOB轻量级分布式任务调度框架文档

1.1 概述

XXL-JOB是一个轻量级分布式任务调度框架&＃xff0c;其核心设计目标是开发迅速、学习简单、轻量级、易扩展。现已开放源代码并接入多家公司线上产品线&＃xff0c;开箱即用。

1.2 特性

1、简单&＃xff1a;支持通过Web页面对任务进行CRUD操作&＃xff0c;操作简单&＃xff0c;一分钟上手&＃xff1b;

2、动态&＃xff1a;支持动态修改任务状态、暂停/恢复任务&＃xff0c;以及终止运行中任务&＃xff0c;即时生效&＃xff1b;

3、调度中心HA(中心式)&＃xff1a;调度采用中心式设计&＃xff0c;“调度中心”基于集群Quartz实现&＃xff0c;可保证调度中心HA&＃xff1b;

4、执行器HA(分布式)&＃xff1a;任务分布式执行&＃xff0c;任务"执行器"支持集群部署&＃xff0c;可保证任务执行HA&＃xff1b;

5、任务Failover&＃xff1a;执行器集群部署时&＃xff0c;任务路由策略选择"故障转移"情况下调度失败时将会平滑切换执行器进行Failover&＃xff1b;

6、一致性&＃xff1a;“调度中心”通过DB锁保证集群分布式调度的一致性, 一次任务调度只会触发一次执行&＃xff1b;

7、自定义任务参数&＃xff1a;支持在线配置调度任务入参&＃xff0c;即时生效&＃xff1b;

8、调度线程池&＃xff1a;调度系统多线程触发调度运行&＃xff0c;确保调度精确执行&＃xff0c;不被堵塞&＃xff1b;

9、弹性扩容缩容&＃xff1a;一旦有新执行器机器上线或者下线&＃xff0c;下次调度时将会重新分配任务&＃xff1b;

10、邮件报警&＃xff1a;任务失败时支持邮件报警&＃xff0c;支持配置多邮件地址群发报警邮件&＃xff1b;

11、状态监控&＃xff1a;支持实时监控任务进度&＃xff1b;

12、Rolling执行日志&＃xff1a;支持在线查看调度结果&＃xff0c;并且支持以Rolling方式实时查看执行器输出的完整的执行日志&＃xff1b;

13、GLUE&＃xff1a;提供Web IDE&＃xff0c;支持在线开发任务逻辑代码&＃xff0c;动态发布&＃xff0c;实时编译生效&＃xff0c;省略部署上线的过程。支持30个版本的历史版本回溯。

14、数据加密&＃xff1a;调度中心和执行器之间的通讯进行数据加密&＃xff0c;提升调度信息安全性&＃xff1b;

15、任务依赖&＃xff1a;支持配置子任务依赖&＃xff0c;当父任务执行结束且执行成功后将会主动触发一次子任务的执行, 多个子任务用逗号分隔&＃xff1b;

16、推送maven中央仓库: 将会把最新稳定版推送到maven中央仓库, 方便用户接入和使用;

17、任务注册: 执行器会周期性自动注册任务, 调度中心将会自动发现注册的任务并触发执行。同时&＃xff0c;也支持手动录入执行器地址&＃xff1b;

18、路由策略&＃xff1a;执行器集群部署时提供丰富的路由策略&＃xff0c;包括&＃xff1a;第一个、最后一个、轮询、随机、一致性HASH、最不经常使用、最近最久未使用、故障转移、忙碌转移等&＃xff1b;

19、运行报表&＃xff1a;支持实时查看运行数据&＃xff0c;如任务数量、调度次数、执行器数量等&＃xff1b;以及调度报表&＃xff0c;如调度日期分布图&＃xff0c;调度成功分布图等&＃xff1b;

20、脚本任务&＃xff1a;支持以GLUE模式开发和运行脚本任务&＃xff0c;包括Shell、Python等类型脚本;

21、阻塞处理策略&＃xff1a;调度过于密集执行器来不及处理时的处理策略&＃xff0c;策略包括&＃xff1a;单机串行(默认)、丢弃后续调度、覆盖之前调度&＃xff1b;

22、失败处理策略&＃xff1b;调度失败时的处理策略&＃xff0c;策略包括&＃xff1a;失败告警(默认)、失败重试&＃xff1b;

23、分片广播任务&＃xff1a;执行器集群部署时&＃xff0c;任务路由策略选择"分片广播"情况下&＃xff0c;一次任务调度将会广播触发集群中所有执行器执行一次任务&＃xff0c;可根据分片参数开发分片任务&＃xff1b;

24、动态分片&＃xff1a;分片广播任务以执行器为维度进行分片&＃xff0c;支持动态扩容执行器集群从而动态增加分片数量&＃xff0c;协同进行业务处理&＃xff1b;在进行大数据量业务操作时可显著提升任务处理能力和速度。

25、事件触发&＃xff1a;除了"Cron方式"和"任务依赖方式"触发任务执行之外&＃xff0c;支持基于事件的触发任务方式。调度中心提供触发任务单次执行的API服务&＃xff0c;可根据业务事件灵活触发。

1.3 发展

于2015年中&＃xff0c;github上创建XXL-JOB项目仓库并提交第一个commit&＃xff0c;随之进行系统结构设计&＃xff0c;UI选型&＃xff0c;交互设计……

于2015-11月&＃xff0c;XXL-JOB终于RELEASE了第一个大版本V1.0&＃xff0c; 随后我将之发布到OSCHINA&＃xff0c;XXL-JOB在OSCHINA上获得了&＃64;红薯的热门推荐&＃xff0c;同期分别达到了OSCHINA的“热门动弹”排行第一和git.oschina的开源软件月热度排行第一&＃xff0c;在此特别感谢红薯&＃xff0c;感谢大家的关注和支持。

于2015-12月&＃xff0c;我将XXL-JOB发表到我司内部知识库&＃xff0c;并且得到内部同事认可。

于2016-01月&＃xff0c;我司展开XXL-JOB的内部接入和定制工作&＃xff0c;在此感谢袁某和尹某两位同事的贡献&＃xff0c;同时也感谢内部其他给与关注与支持的同事。

于2017-05-13&＃xff0c;在上海举办的 “第62期开源中国源创会” 的 “放码过来” 环节&＃xff0c;我登台对XXL-JOB做了演讲&＃xff0c;台下五百位在场观众反响热烈(图文回顾 )。

我司大众点评目前已接入XXL-JOB&＃xff0c;内部别名《Ferrari》(Ferrari基于XXL-JOB的V1.1版本定制而成&＃xff0c;新接入应用推荐升级最新版本)。 据最新统计, 自2016-01-21接入至2017-07-07期间&＃xff0c;该系统已调度约60万余次&＃xff0c;表现优异。新接入应用推荐使用最新版本&＃xff0c;因为经过数个大版本的更新&＃xff0c;系统的任务模型、UI交互模型以及底层调度通讯模型都有了较大的优化和提升&＃xff0c;核心功能更加稳定高效。

至今&＃xff0c;XXL-JOB已接入多家公司的线上产品线&＃xff0c;接入场景如电商业务&＃xff0c;O2O业务和大数据作业等。

1.4 下载

文档地址

中文文档

English Documentation

源码仓库地址

English Documentation

源码仓库地址

源码仓库地址Release Download

https://github.com/xuxueli/xxl-jobDownload

http://git.oschina.net/xuxueli0323/xxl-jobDownload

中央仓库地址

com.xuxueli xxl-job-core 1.8.2

1.5 环境

JDK&＃xff1a;1.7&＃43;

Servlet/JSP Spec&＃xff1a;3.1/2.3

Tomcat&＃xff1a;8.5.x/Jetty9.2.x

Spring-boot&＃xff1a;1.5.x/Spring4.x

Mysql&＃xff1a;5.6&＃43;

Maven&＃xff1a;3&＃43;

2.1 初始化“调度数据库”

请下载项目源码并解压&＃xff0c;获取 “调度数据库初始化SQL脚本” 并执行即可&＃xff0c;正常情况下应该生成16张表。

“调度数据库初始化SQL脚本” 位置为:

/xxl-job/doc/db/tables_xxl_job.sql

调度中心支持集群部署&＃xff0c;集群情况下各节点务必连接同一个mysql实例;

如果mysql做主从,调度中心集群节点务必强制走主库;

2.2 编译源码

解压源码,按照maven格式将源码导入IDE, 使用maven进行编译即可&＃xff0c;源码结构如下&＃xff1a;

xxl-job-admin&＃xff1a;调度中心

xxl-job-core&＃xff1a;公共依赖

xxl-job-executor&＃xff1a;执行器Sample示例(选择合适的版本执行器&＃xff0c;可直接使用&＃xff0c;也可以参考其并将现有项目改造成执行器)

&＃xff1a;xxl-job-executor-sample-spring&＃xff1a;Spring版本&＃xff0c;通过Spring容器管理执行器&＃xff0c;比较通用&＃xff0c;推荐这种方式&＃xff1b;

&＃xff1a;xxl-job-executor-sample-springboot&＃xff1a;Springboot版本&＃xff0c;通过Springboot管理执行器&＃xff1b;

&＃xff1a;xxl-job-executor-sample-jfinal&＃xff1a;JFinal版本&＃xff0c;通过JFinal管理执行器&＃xff1b;

2.3 配置部署“调度中心”

调度中心项目&＃xff1a;xxl-job-admin

作用&＃xff1a;统一管理任务调度平台上调度任务&＃xff0c;负责触发调度执行&＃xff0c;并且提供任务管理平台。

步骤一&＃xff1a;调度中心配置&＃xff1a;

调度中心配置文件地址&＃xff1a;

/xxl-job/xxl-job-admin/src/main/resources/xxl-job-admin.properties

调度中心配置内容说明&＃xff1a;

### 调度中心JDBC链接&＃xff1a;链接地址请保持和 2.1章节 所创建的调度数据库的地址一致xxl.job.db.driverClass&＃61;com.mysql.jdbc.Driverxxl.job.db.url&＃61;jdbc:mysql://localhost:3306/xxl-job?useUnicode&＃61;true&characterEncoding&＃61;UTF-8xxl.job.db.user&＃61;rootxxl.job.db.password&＃61;root_pwd### 报警邮箱xxl.job.mail.host&＃61;smtp.163.comxxl.job.mail.port&＃61;25xxl.job.mail.username&＃61;ovono802302&＃64;163.comxxl.job.mail.password&＃61;asdfzxcvxxl.job.mail.sendFrom&＃61;ovono802302&＃64;163.comxxl.job.mail.sendNick&＃61;《任务调度平台XXL-JOB》### 登录账号xxl.job.login.username&＃61;adminxxl.job.login.password&＃61;123456### 调度中心通讯TOKEN&＃xff0c;非空时启用xxl.job.accessToken&＃61;

步骤二&＃xff1a;部署项目&＃xff1a;

如果已经正确进行上述配置&＃xff0c;可将项目编译打war包并部署到tomcat中。 调度中心访问地址&＃xff1a;http://localhost:8080/xxl-job-admin (该地址执行器将会使用到&＃xff0c;作为回调地址)&＃xff0c;登录后运行界面如下图所示

至此“调度中心”项目已经部署成功。

步骤三&＃xff1a;调度中心集群(可选)&＃xff1a;

调度中心支持集群部署&＃xff0c;提升调度系统可用性。

集群部署唯一要求为&＃xff1a;保证每个集群节点配置(db和登陆账号等)保持一致。调度中心通过db配置区分不同集群。

调度中心在集群部署时可通过nginx负载均衡&＃xff0c;此时可以为集群分配一个域名。该域名一方面可以用于访问&＃xff0c;另一方面也可以用于配置执行器回调地址。

2.4 配置部署“执行器项目”

“执行器”项目&＃xff1a;xxl-job-executor-sample-spring (如新建执行器项目&＃xff0c;可参考该Sample示例执行器项目的配置步骤&＃xff1b;)

作用&＃xff1a;负责接收“调度中心”的调度并执行&＃xff1b;可直接部署执行器&＃xff0c;也可以将执行器集成到现有业务项目中。

步骤一&＃xff1a;maven依赖

确认pom文件中引入了 “xxl-job-core” 的maven依赖&＃xff1b;

步骤二&＃xff1a;执行器配置

执行器配置&＃xff0c;配置文件地址&＃xff1a;

/xxl-job/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/resources/xxl-job-executor.properties

执行器配置&＃xff0c;配置内容说明&＃xff1a;

### xxl-job admin address list&＃xff1a;调度中心部署跟地址&＃xff1a;如调度中心集群部署存在多个地址则用逗号分隔。执行器将会使用该地址进行"执行器心跳注册"和"任务结果回调"。xxl.job.admin.addresses&＃61;http://127.0.0.1:8080/xxl-job-admin### xxl-job executor address&＃xff1a;执行器"AppName"和地址信息配置&＃xff1a;AppName执行器心跳注册分组依据&＃xff1b;地址信息用于"调度中心请求并触发任务"和"执行器注册"。执行器默认端口为9999&＃xff0c;执行器IP默认为空表示自动获取IP&＃xff0c;多网卡时可手动设置指定IP&＃xff0c;手动设置IP时将会绑定Host。单机部署多个执行器时&＃xff0c;注意要配置不同执行器端口&＃xff1b;xxl.job.executor.appname&＃61;xxl-job-executor-samplexxl.job.executor.ip&＃61;xxl.job.executor.port&＃61;9999### xxl-job log path&＃xff1a;执行器运行日志文件存储的磁盘位置&＃xff0c;需要对该路径拥有读写权限xxl.job.executor.logpath&＃61;/data/applogs/xxl-job/jobhandler/### xxl-job, access token&＃xff1a;执行器通讯TOKEN&＃xff0c;非空时启用xxl.job.accessToken&＃61;

步骤三&＃xff1a;执行器组件配置

执行器组件&＃xff0c;配置文件地址&＃xff1a;

/xxl-job/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/resources/applicationcontext-xxl-job.xml

执行器组件&＃xff0c;配置内容说明&＃xff1a;

步骤四&＃xff1a;部署执行器项目&＃xff1a;

如果已经正确进行上述配置&＃xff0c;可将执行器项目编译打部署&＃xff0c;系统提供三个执行器Sample示例项目&＃xff0c;选择其中一个即可&＃xff0c;各自的部署方式如下。

xxl-job-executor-sample-spring&＃xff1a;项目编译打包成WAR包&＃xff0c;并部署到tomcat中。xxl-job-executor-sample-springboot&＃xff1a;项目编译打包成springboot类型的可执行JAR包&＃xff0c;命令启动即可&＃xff1b;

至此“执行器”项目已经部署结束。

步骤五&＃xff1a;执行器集群(可选)&＃xff1a;

执行器支持集群部署&＃xff0c;提升调度系统可用性&＃xff0c;同时提升任务处理能力。

集群部署唯一要求为&＃xff1a;保证集群中每个执行器的配置项 “xxl.job.admin.addresses/调度中心地址” 保持一致&＃xff0c;执行器根据该配置进行执行器自动注册等操作。

2.5 开发第一个任务“Hello World”

本示例以新建一个 “GLUE模式(Java)” 运行模式的任务为例。更多有关任务的详细配置&＃xff0c;请查看“章节三&＃xff1a;任务详解”。 ( “GLUE模式(Java)”的执行代码托管到调度中心在线维护&＃xff0c;相比“Bean模式任务”需要在执行器项目开发部署上线&＃xff0c;更加简便轻量)

前提&＃xff1a;请确认“调度中心”和“执行器”项目已经成功部署并启动&＃xff1b;

步骤一&＃xff1a;新建任务&＃xff1a;

登录调度中心&＃xff0c;点击下图所示“新建任务”按钮&＃xff0c;新建示例任务。然后&＃xff0c;参考下面截图中任务的参数配置&＃xff0c;点击保存。

步骤二&＃xff1a;“GLUE模式(Java)” 任务开发&＃xff1a;

请点击任务右侧 “GLUE” 按钮&＃xff0c;进入 “GLUE编辑器开发界面” &＃xff0c;见下图。“GLUE模式(Java)” 运行模式的任务默认已经初始化了示例任务代码&＃xff0c;即打印Hello World。 ( “GLUE模式(Java)” 运行模式的任务实际上是一段继承自IJobHandler的Java类代码&＃xff0c;它在执行器项目中运行&＃xff0c;可使用&＃64;Resource/&＃64;Autowire注入执行器里中的其他服务&＃xff0c;详细介绍请查看第三章节)

步骤三&＃xff1a;触发执行&＃xff1a;

请点击任务右侧 “执行” 按钮&＃xff0c;可手动触发一次任务执行(通常情况下&＃xff0c;通过配置Cron表达式进行任务调度出发)。

步骤四&＃xff1a;查看日志&＃xff1a;

请点击任务右侧 “日志” 按钮&＃xff0c;可前往任务日志界面查看任务日志。 在任务日志界面中&＃xff0c;可查看该任务的历史调度记录以及每一次调度的任务调度信息、执行参数和执行信息。运行中的任务点击右侧的“执行日志”按钮&＃xff0c;可进入日志控制台查看实时执行日志。

在日志控制台&＃xff0c;可以Rolling方式实时查看任务在执行器一侧运行输出的日志信息&＃xff0c;实时监控任务进度&＃xff1b;

配置属性详细说明&＃xff1a;

• 执行器&＃xff1a;任务的绑定的执行器&＃xff0c;任务触发调度时将会自动发现注册成功的执行器, 实现任务自动发现功能; 另一方面也可以方便的进行任务分组。每个任务必须绑定一个执行器, 可在 “执行器管理” 进行设置;
• 描述&＃xff1a;任务的描述信息&＃xff0c;便于任务管理&＃xff1b;
• 路由策略&＃xff1a;当执行器集群部署时&＃xff0c;提供丰富的路由策略&＃xff0c;包括&＃xff1b;
• FIRST(第一个)&＃xff1a;固定选择第一个执行器&＃xff1b;
• LAST(最后一个)&＃xff1a;固定选择最后一个执行器&＃xff1b;
• ROUND(轮询)&＃xff1a;&＃xff1b;
• RANDOM(随机)&＃xff1a;随机选择在线的执行器&＃xff1b;
• CONSISTENT_HASH(一致性HASH)&＃xff1a;分组下机器地址相同&＃xff0c;不同JOB均匀散列在不同机器上&＃xff0c;保证分组下机器分配JOB平均&＃xff1b;且每个JOB固定调度其中一台机器&＃xff1b;
• LEAST_FREQUENTLY_USED(最不经常使用)&＃xff1a;单个JOB对应的每个执行器&＃xff0c;使用频率最低的优先被选举&＃xff1b;
• LEAST_RECENTLY_USED(最近最久未使用)&＃xff1a;单个JOB对应的每个执行器&＃xff0c;最久为使用的优先被选举&＃xff1b;
• FAILOVER(故障转移)&＃xff1a;按照顺序依次进行心跳检测&＃xff0c;第一个心跳检测成功的机器选定为目标执行器并发起调度&＃xff1b;
• BUSYOVER(忙碌转移)&＃xff1a;按照顺序依次进行空闲检测&＃xff0c;第一个空闲检测成功的机器选定为目标执行器并发起调度&＃xff1b;
• SHARDING_BROADCAST(分片广播)&＃xff1a;广播触发对应集群中所有执行器执行一次任务&＃xff0c;同时传递分片参数&＃xff1b;可根据分片参数开发分片任务&＃xff1b;
• Cron&＃xff1a;触发任务执行的Cron表达式&＃xff1b;
• 运行模式&＃xff1a;
• BEAN模式&＃xff1a;任务以JobHandler方式维护在执行器端&＃xff1b;需要结合 “JobHandler” 属性匹配执行器中任务&＃xff1b;
• GLUE模式(Java)&＃xff1a;任务以源码方式维护在调度中心&＃xff1b;该模式的任务实际上是一段继承自IJobHandler的Java类代码并 “groovy” 源码方式维护&＃xff0c;它在执行器项目中运行&＃xff0c;可使用&＃64;Resource/&＃64;Autowire注入执行器里中的其他服务&＃xff1b;
• GLUE模式(Shell)&＃xff1a;任务以源码方式维护在调度中心&＃xff1b;该模式的任务实际上是一段 “shell” 脚本&＃xff1b;
• GLUE模式(Python)&＃xff1a;任务以源码方式维护在调度中心&＃xff1b;该模式的任务实际上是一段 “python” 脚本&＃xff1b;
• GLUE模式(NodeJS)&＃xff1a;任务以源码方式维护在调度中心&＃xff1b;该模式的任务实际上是一段 “nodejs” 脚本&＃xff1b;
• JobHandler&＃xff1a;运行模式为 “BEAN模式” 时生效&＃xff0c;对应执行器中新开发的JobHandler类“&＃64;JobHander”注解自定义的value值&＃xff1b;
• 子任务Key&＃xff1a;每个任务都拥有一个唯一的任务Key(任务Key可以从任务列表获取)&＃xff0c;当本任务执行结束并且执行成功时&＃xff0c;将会触发子任务Key所对应的任务的一次主动调度。
• 阻塞处理策略&＃xff1a;调度过于密集执行器来不及处理时的处理策略&＃xff1b;
• 单机串行(默认)&＃xff1a;调度请求进入单机执行器后&＃xff0c;调度请求进入FIFO队列并以串行方式运行&＃xff1b;
• 丢弃后续调度&＃xff1a;调度请求进入单机执行器后&＃xff0c;发现执行器存在运行的调度任务&＃xff0c;本次请求将会被丢弃并标记为失败&＃xff1b;
• 覆盖之前调度&＃xff1a;调度请求进入单机执行器后&＃xff0c;发现执行器存在运行的调度任务&＃xff0c;将会终止运行中的调度任务并清空队列&＃xff0c;然后运行本地调度任务&＃xff1b;
• 失败处理策略&＃xff1b;调度失败时的处理策略&＃xff1b;
• 失败告警(默认)&＃xff1a;调度失败时&＃xff0c;将会触发失败报警&＃xff0c;如发送报警邮件&＃xff1b;
• 失败重试&＃xff1a;调度失败时&＃xff0c;将会主动进行一次失败重试调度&＃xff0c;重试调度后仍然失败将会触发一失败告警。注意当任务以failover方式路由时&＃xff0c;每次失败重试将会触发新一轮路由。
• 执行参数&＃xff1a;任务执行所需的参数&＃xff0c;多个参数时用逗号分隔&＃xff0c;任务执行时将会把多个参数转换成数组传入&＃xff1b;
• 报警邮件&＃xff1a;任务调度失败时邮件通知的邮箱地址&＃xff0c;支持配置多邮箱地址&＃xff0c;配置多个邮箱地址时用逗号分隔&＃xff1b;
• 负责人&＃xff1a;任务的负责人&＃xff1b;

- 3.1 BEAN模式

任务逻辑以JobHandler的形式存在于“执行器”所在项目中&＃xff0c;开发流程如下&＃xff1a;

步骤一&＃xff1a;执行器项目中&＃xff0c;开发JobHandler&＃xff1a;

- 1、 新建一个继承com.xxl.job.core.handler.IJobHandler的Java类&＃xff1b;- 2、 该类被Spring容器扫描为Bean实例&＃xff0c;如加“&＃64;Component”注解&＃xff1b;- 3、 添加 “&＃64;JobHander(value&＃61;"自定义jobhandler名称")”注解&＃xff0c;注解的value值为自定义的JobHandler名称&＃xff0c;该名称对应的是调度中心新建任务的JobHandler属性的值。(可参考Sample示例执行器中的DemoJobHandler&＃xff0c;见下图)

步骤二&＃xff1a;调度中心&＃xff0c;新建调度任务

参考上文“配置属性详细说明”对新建的任务进行参数配置&＃xff0c;运行模式选中 “BEAN模式”&＃xff0c;JobHandler属性填写任务注解&＃64;JobHander中定义的值&＃xff1b;

3.2 GLUE模式(Java)

任务以源码方式维护在调度中心&＃xff0c;支持通过Web IDE在线更新&＃xff0c;实时编译和生效&＃xff0c;因此不需要指定JobHandler。开发流程如下&＃xff1a;

步骤一&＃xff1a;调度中心&＃xff0c;新建调度任务&＃xff1a;

参考上文“配置属性详细说明”对新建的任务进行参数配置&＃xff0c;运行模式选中 “GLUE模式(Java)”&＃xff1b;

步骤二&＃xff1a;开发任务代码&＃xff1a;

选中指定任务&＃xff0c;点击该任务右侧“GLUE”按钮&＃xff0c;将会前往GLUE任务的Web IDE界面&＃xff0c;在该界面支持对任务代码进行开发(也可以在IDE中开发完成后&＃xff0c;复制粘贴到编辑中)。

版本回溯功能(支持30个版本的版本回溯)&＃xff1a;在GLUE任务的Web IDE界面&＃xff0c;选择右上角下拉框“版本回溯”&＃xff0c;会列出该GLUE的更新历史&＃xff0c;选择相应版本即可显示该版本代码&＃xff0c;保存后GLUE代码即回退到对应的历史版本&＃xff1b;

3.3 GLUE模式(Shell)

步骤一&＃xff1a;调度中心&＃xff0c;新建调度任务

参考上文“配置属性详细说明”对新建的任务进行参数配置&＃xff0c;运行模式选中 “GLUE模式(Shell)”&＃xff1b;

步骤二&＃xff1a;开发任务代码&＃xff1a;

选中指定任务&＃xff0c;点击该任务右侧“GLUE”按钮&＃xff0c;将会前往GLUE任务的Web IDE界面&＃xff0c;在该界面支持对任务代码进行开发(也可以在IDE中开发完成后&＃xff0c;复制粘贴到编辑中)。

该模式的任务实际上是一段 “shell” 脚本&＃xff1b;

3.4 GLUE模式(Python)

步骤一&＃xff1a;调度中心&＃xff0c;新建调度任务

参考上文“配置属性详细说明”对新建的任务进行参数配置&＃xff0c;运行模式选中 “GLUE模式(Python)”&＃xff1b;

步骤二&＃xff1a;开发任务代码&＃xff1a;

选中指定任务&＃xff0c;点击该任务右侧“GLUE”按钮&＃xff0c;将会前往GLUE任务的Web IDE界面&＃xff0c;在该界面支持对任务代码进行开发(也可以在IDE中开发完成后&＃xff0c;复制粘贴到编辑中)。

该模式的任务实际上是一段 “python” 脚本&＃xff1b;

3.5 GLUE模式(NodeJS)

步骤一&＃xff1a;调度中心&＃xff0c;新建调度任务

参考上文“配置属性详细说明”对新建的任务进行参数配置&＃xff0c;运行模式选中 “GLUE模式(NodeJS)”&＃xff1b;

步骤二&＃xff1a;开发任务代码&＃xff1a;

选中指定任务&＃xff0c;点击该任务右侧“GLUE”按钮&＃xff0c;将会前往GLUE任务的Web IDE界面&＃xff0c;在该界面支持对任务代码进行开发(也可以在IDE中开发完成后&＃xff0c;复制粘贴到编辑中)。

该模式的任务实际上是一段 “nodejS” 脚本&＃xff1b;

4.0 配置执行器

点击进入"执行器管理"界面, 如下图:

1、"调度中心OnLine:"右侧显示在线的"调度中心"列表, 任务执行结束后, 将会以failover的模式进行回调调度中心通知执行结果, 避免回调的单点风险;

2、“执行器列表” 中显示在线的执行器列表, 可通过"OnLine 机器"查看对应执行器的集群机器。

点击按钮 “&＃43;新增执行器” 弹框如下图, 可新增执行器配置:

执行器属性说明

AppName: 是每个执行器集群的唯一标示AppName, 执行器会周期性以AppName为对象进行自动注册。可通过该配置自动发现注册成功的执行器, 供任务调度时使用;

名称: 执行器的名称, 因为AppName限制字母数字等组成,可读性不强, 名称为了提高执行器的可读性;

排序: 执行器的排序, 系统中需要执行器的地方,如任务新增, 将会按照该排序读取可用的执行器列表;

注册方式&＃xff1a;调度中心获取执行器地址的方式&＃xff1b;

自动注册&＃xff1a;执行器自动进行执行器注册&＃xff0c;调度中心通过底层注册表可以动态发现执行器机器地址&＃xff1b;

手动录入&＃xff1a;人工手动录入执行器的地址信息&＃xff0c;多地址逗号分隔&＃xff0c;供调度中心使用&＃xff1b;

机器地址&＃xff1a;"注册方式"为"手动录入"时有效&＃xff0c;支持人工维护执行器的地址信息&＃xff1b;

4.1 新建任务

进入任务管理界面&＃xff0c;点击“新增任务”按钮&＃xff0c;在弹出的“新增任务”界面配置任务属性后保存即可。详情页参考章节 “三、任务详解”。

4.2 编辑任务

进入任务管理界面&＃xff0c;选中指定任务。点击该任务右侧“编辑”按钮&＃xff0c;在弹出的“编辑任务”界面更新任务属性后保存即可&＃xff0c;可以修改设置的任务属性信息&＃xff1a;

4.3 编辑GLUE代码

该操作仅针对GLUE任务。

选中指定任务&＃xff0c;点击该任务右侧“GLUE”按钮&＃xff0c;将会前往GLUE任务的Web IDE界面&＃xff0c;在该界面支持对任务代码进行开发。可参考章节 “3.2 GLUE模式(Java)”。

4.4 暂停/恢复任务

可对任务进行“暂停”和“恢复”操作。 需要注意的是&＃xff0c;此处的暂停/恢复仅针对任务的后续调度触发行为&＃xff0c;不会影响到已经触发的调度任务&＃xff0c;如需终止已经触发的调度任务&＃xff0c;可查看“4.8 终止运行中的任务”

4.5 手动触发一次调度

点击“执行”按钮&＃xff0c;可手动触发一次任务调度&＃xff0c;不影响原有调度规则。

4.6 查看调度日志

点击“日志”按钮&＃xff0c;可以查看任务历史调度日志。在历史调入日志界面可查看每次任务调度的调度结果、执行结果等&＃xff0c;点击“执行日志”按钮可查看执行器完整日志。

调度时间&＃xff1a;"调度中心"触发本次调度并向"执行器"发送任务执行信号的时间&＃xff1b;

调度结果&＃xff1a;"调度中心"触发本次调度的结果&＃xff0c;200表示成功&＃xff0c;500或其他表示失败&＃xff1b;

调度备注&＃xff1a;"调度中心"触发本次调度的日志信息&＃xff1b;

执行器地址&＃xff1a;本次任务执行的机器地址

运行模式&＃xff1a;触发调度时任务的运行模式&＃xff0c;运行模式可参考章节 “三、任务详解”&＃xff1b;

任务参数&＃xff1a;本地任务执行的入参

执行时间&＃xff1a;"执行器"中本次任务执行结束后回调的时间&＃xff1b;

执行结果&＃xff1a;"执行器"中本次任务执行的结果&＃xff0c;200表示成功&＃xff0c;500或其他表示失败&＃xff1b;

执行备注&＃xff1a;"执行器"中本次任务执行的日志信息&＃xff1b;

操作&＃xff1a;

"执行日志"按钮&＃xff1a;点击可查看本地任务执行的详细日志信息&＃xff1b;详见“4.7 查看执行日志”&＃xff1b;

"终止任务"按钮&＃xff1a;点击可终止本地调度对应执行器上本任务的执行线程&＃xff0c;包括未执行的阻塞任务一并被终止&＃xff1b;

4.7 查看执行日志

点击执行日志右侧的 “执行日志” 按钮&＃xff0c;可跳转至执行日志界面&＃xff0c;可以查看业务代码中打印的完整日志&＃xff0c;如下图&＃xff1b;

4.8 终止运行中的任务

仅针对执行中的任务。 在任务日志界面&＃xff0c;点击右侧的“终止任务”按钮&＃xff0c;将会向本次任务对应的执行器发送任务终止请求&＃xff0c;将会终止掉本次任务&＃xff0c;同时会清空掉整个任务执行队列。

任务终止时通过 “interrupt” 执行线程的方式实现, 将会触发 “InterruptedException” 异常。因此如果JobHandler内部catch到了该异常并消化掉的话, 任务终止功能将不可用。

因此, 如果遇到上述任务终止不可用的情况, 需要在JobHandler中应该针对 “InterruptedException” 异常进行特殊处理 (向上抛出) , 正确逻辑如下:

try{ // TODO} catch (Exception e) { if (e instanceof InterruptedException) { throw e; } logger.warn("{}