|
|
|
|
@ -196,9 +196,9 @@ XXL-JOB是一个轻量级分布式任务调度框架，其核心设计目标是
|
|
|
|
|
- **步骤一（新建任务）**：
|
|
|
|
|
登陆调度中心，点击下图所示“新建任务”按钮，新建示例任务。然后，参考下面截图中任务的参数配置，点击保存。
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
- **步骤二（GLUE任务开发）**：
|
|
|
|
|
请点击下图中所示“GLUE入口按钮”，进入“GLUE编辑器开发界面”，见下图。GLUE任务默认已经初始化了示例任务代码，即打印Hello World。
|
|
|
|
|
@ -211,18 +211,18 @@ XXL-JOB是一个轻量级分布式任务调度框架，其核心设计目标是
|
|
|
|
|
- **步骤三（触发执行）**：
|
|
|
|
|
点击下图所示“执行”按钮，可手动触发一次任务执行（通常情况下，通过配置Cron表达式进行任务调度出发）。
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
- **步骤四（查看日志）**：
|
|
|
|
|
点击图2.5F所示“日志”按钮，可前往任务日志界面查看任务日志。
|
|
|
|
|
在如图2.5G的任务日志界面中，可查看任务调度状态，执行器接收到调度请求后的执行状态。
|
|
|
|
|
同时，点击如图2.5G中的“执行日志”按钮，可以查看本此调度在执行器端的完整执行日志，完整执行日志如图2.5H。
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
（图2.5F：“调度中心”管理管理界面，任务日志入口）
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
（图2.5G：“调度中心”管理管理界面，任务日志入口）
|
|
|
|
|
|
|
|
|
|
@ -262,7 +262,7 @@ Bean模式任务：任务逻辑以JobHandler的形式存在于“执行器”所
|
|
|
|
|
|
|
|
|
|
参考上文“配置属性详细说明”对新建的任务进行参数配置，需要注意的是“JobHandler + GLUE复选框”任务属性，需要按照“GLUE模式”任务进行配置；
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#### 3.2 GLUE模式任务
|
|
|
|
|
GLUE模式任务：任务逻辑以GLUE代码的形式存储在DB中，支持通过Web IDE在线更新，实时编译和生效，因此不需要指定JobHandler。开发流程如下：
|
|
|
|
|
@ -271,7 +271,7 @@ GLUE模式任务：任务逻辑以GLUE代码的形式存储在DB中，支持通
|
|
|
|
|
|
|
|
|
|
参考上文“配置属性详细说明”对新建的任务进行参数配置，需要注意的是“JobHandler + GLUE复选框”任务属性，需要按照“GLUE模式”任务进行配置；
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
- **步骤二：开发GLUE代码**：
|
|
|
|
|
|
|
|
|
|
@ -282,33 +282,37 @@ GLUE模式任务：任务逻辑以GLUE代码的形式存储在DB中，支持通
|
|
|
|
|
## 四、任务管理
|
|
|
|
|
#### 4.0 配置执行器
|
|
|
|
|
点击进入"执行器管理"界面, 如下图:
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
1、"调度中心OnLine:"右侧显示在线的"调度中心"列表, 任务执行结束后, 将会以failover的模式进行回调调度中心通知执行结果, 避免回调的单点风险;
|
|
|
|
|
2、"执行器列表" 中显示在线的执行器列表, 可通过"OnLine 机器"查看对应执行器的集群机器。
|
|
|
|
|
|
|
|
|
|
点击按钮 "+新增执行器" 弹框如下图, 可新增执行器配置:
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
**执行器属性说明**
|
|
|
|
|
|
|
|
|
|
AppName: 是每个执行器集群的唯一标示AppName, 执行器会周期性以AppName为对象进行自动注册。可通过该配置自动发现注册成功的执行器, 供任务调度时使用;
|
|
|
|
|
名称: 执行器的名称, 因为AppName限制字母数字等组成,可读性不强, 名称为了提高执行器的可读性;
|
|
|
|
|
排序: 执行器的排序, 系统中需要执行器的地方,如任务新增, 将会按照该排序读取可用的执行器列表;
|
|
|
|
|
注册方式：调度中心获取执行器地址的方式；
|
|
|
|
|
自动注册：执行器自动进行执行器注册，调度中心通过底层注册表可以动态发现执行器机器地址；
|
|
|
|
|
手动录入：人工手动录入执行器的地址信息，多地址逗号分隔，供调度中心使用；
|
|
|
|
|
机器地址："注册方式"为"手动录入"时有效，支持人工维护执行器的地址信息；
|
|
|
|
|
|
|
|
|
|
#### 4.1 新建任务
|
|
|
|
|
进入任务管理界面，点击“新增任务”按钮，在弹出的“新增任务”界面配置任务属性后保存即可，可参考下图：
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#### 4.2 编辑任务
|
|
|
|
|
进入任务管理界面，选中指定任务。点击该任务右侧“编辑”按钮，在弹出的“编辑任务”界面更新任务属性后保存即可，可参考下图：
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#### 4.3 编辑GLUE代码
|
|
|
|
|
|
|
|
|
|
@ -338,19 +342,20 @@ GLUE任务开发：进入任务管理界面，选中指定任务。点击该任
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
调度日志，针对单次调度，属性说明如下：
|
|
|
|
|
- 执行器地址：任务执行的机器地址；
|
|
|
|
|
- JobHandler：Bean模式表示任务执行的JobHandler名称；
|
|
|
|
|
- 任务参数：任务执行的入参；
|
|
|
|
|
- 调度时间：调度中心，发起调度的时间；
|
|
|
|
|
- 调度结果：调度中心，发起调度的结果，SUCCESS或FAIL；
|
|
|
|
|
- 调度备注：调度中心，发起调度的备注信息，如地址心跳检测日志等；
|
|
|
|
|
- 执行时间：执行器，任务执行结束后回调的时间；
|
|
|
|
|
- 执行结果：执行器，任务执行的结果，SUCCESS或FAIL；
|
|
|
|
|
- 执行备注：执行器，任务执行的备注信息，如异常日志等；
|
|
|
|
|
- 执行日志：任务执行过程中，业务代码中打印的完整执行日志，见“4.7 查看执行日志”；
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
调度时间："调度中心"触发本次调度并向"执行器"发送任务执行信号的时间；
|
|
|
|
|
调度结果："调度中心"触发本次调度的结果，200表示成功，500或其他表示失败；
|
|
|
|
|
调度备注："调度中心"触发本次调度的日志信息；
|
|
|
|
|
执行器地址：本次任务执行的机器地址
|
|
|
|
|
JobHandler：本地任务执行的JobHandler；Bean模式表示任务执行的JobHandler名称；
|
|
|
|
|
任务参数：本地任务执行的入参
|
|
|
|
|
执行时间："执行器"中本次任务执行结束后回调的时间；
|
|
|
|
|
执行结果："执行器"中本次任务执行的结果，200表示成功，500或其他表示失败；
|
|
|
|
|
执行备注："执行器"中本次任务执行的日志信息；
|
|
|
|
|
操作：
|
|
|
|
|
"执行日志"按钮：点击可查看本地任务执行的详细日志信息；详见“4.7 查看执行日志”；
|
|
|
|
|
"终止任务"按钮：点击可终止本地调度对应执行器上本任务的执行线程，包括未执行的阻塞任务一并被终止；
|
|
|
|
|
|
|
|
|
|
#### 4.7 查看执行日志
|
|
|
|
|
点击执行日志右侧的 “执行日志” 按钮，可跳转至执行日志界面，可以查看业务代码中打印的完整日志，如下图；
|
|
|
|
|
@ -397,14 +402,14 @@ XXL-JOB首先定制了Quartz原生表结构前缀（XXL_JOB_QRTZ_）。
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
然后，在此基础上新增了三张扩展表，如下：
|
|
|
|
|
然后，在此基础上新增了几张张扩展表，如下：
|
|
|
|
|
- XXL_JOB_QRTZ_TRIGGER_GROUP：执行器信息表，维护任务执行器信息；
|
|
|
|
|
- XXL_JOB_QRTZ_TRIGGER_REGISTRY：执行器注册表，维护在线的执行器和调度中心机器地址信息；
|
|
|
|
|
- XXL_JOB_QRTZ_TRIGGER_INFO：调度扩展信息表： 用于保存XXL-JOB调度任务的扩展信息，如任务分组、任务名、机器地址、执行器、执行入参和报警邮件等等；
|
|
|
|
|
- XXL_JOB_QRTZ_TRIGGER_LOG：调度日志表： 用于保存XXL-JOB任务调度的历史信息，如调度结果、执行结果、调度入参、调度机器和执行器等等；
|
|
|
|
|
- XXL_JOB_QRTZ_TRIGGER_LOGGLUE：任务GLUE日志：用于保存GLUE更新历史，用于支持GLUE的版本回溯功能；
|
|
|
|
|
|
|
|
|
|
因此，XXL-JOB调度数据库共计用于14张数据库表。
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
因此，XXL-JOB调度数据库共计用于16张数据库表。
|
|
|
|
|
|
|
|
|
|
#### 5.3 架构设计
|
|
|
|
|
##### 5.3.1 设计思想
|
|
|
|
|
@ -493,9 +498,9 @@ CronTrigger cronTrigger = TriggerBuilder.newTrigger().withIdentity(triggerKey).w
|
|
|
|
|
##### 5.4.7 日志回调服务
|
|
|
|
|
调度模块的“调度中心”作为Web服务单独部署，除此之外，内部嵌入jetty服务器提供日志回调服务。
|
|
|
|
|
|
|
|
|
|
“执行器”在接收到任务执行请求后，执行任务，在执行结束之后会将执行结果回调通知“调度中心”，回调端口如下图所示。
|
|
|
|
|
“执行器”在接收到任务执行请求后，执行任务，在执行结束之后会将执行结果回调通知“调度中心”，回调端口如下图所示（参数：xxl.job.callBackPort）。
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
##### 5.4.8 任务HA（Failover）
|
|
|
|
|
执行器如若集群部署，调度中心将会感知到在线的所有执行器，如“127.0.0.1:9998,127.0.0.1:9999”。
|
|
|
|
|
|
xueli.xue
8 years ago