From b7fa39bd513b4b94ffdd805da44200d45768e9d1 Mon Sep 17 00:00:00 2001 From: "xueli.xue" Date: Mon, 3 Oct 2016 19:20:51 +0800 Subject: [PATCH] =?UTF-8?q?=E6=89=A7=E8=A1=8C=E5=99=A8=E6=A0=8F=E7=9B=AE,?= =?UTF-8?q?=E6=94=AF=E6=8C=81=E6=9F=A5=E7=9C=8B=E5=9C=A8=E7=BA=BF=E9=A2=9D?= =?UTF-8?q?=E6=89=A7=E8=A1=8C=E5=99=A8=E5=88=97=E8=A1=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- README.md | 27 ++++++++++--------- .../admin/controller/JobGroupController.java | 7 ++++- .../template/jobgroup/jobgroup.index.ftl | 2 ++ 3 files changed, 22 insertions(+), 14 deletions(-) diff --git a/README.md b/README.md index 1c1fa01a..5b63ed21 100644 --- a/README.md +++ b/README.md @@ -8,9 +8,9 @@ XXL-JOB是一个轻量级分布式任务调度框架，其核心设计目标是 - 1、简单：支持通过Web页面对任务进行CRUD操作，操作简单，一分钟上手； - 2、动态：支持动态修改任务状态、暂停/恢复任务，以及终止运行中任务，即时生效； - 3、调度HA：“调度中心”基于集群Quartz实现，可保证调度中心HA； -- 4、任务HA：任务支持多地址配置，可保证任务执行HA； -- 5、任务Failover：多地址配置时，调度失败时将会平滑切换执行器进行Failover； -- 6、一致性：“调度中心”通过DB锁保证集群分布式调度的一致性； +- 4、任务HA：任务"执行器"支持集群部署，可保证任务执行HA； +- 5、任务Failover：执行器集群部署时，调度失败时将会平滑切换执行器进行Failover； +- 6、一致性：“调度中心”通过DB锁保证集群分布式调度的一致性, 一次任务调度只会触发一次执行； - 7、自定义任务参数：支持在线配置调度任务入参，即时生效； - 8、调度线程池：调度系统多线程触发调度运行，确保调度精确执行，不被堵塞； - 9、执行日志：支持在线查看调度结果，并且查看完整的执行日志； @@ -20,6 +20,7 @@ XXL-JOB是一个轻量级分布式任务调度框架，其核心设计目标是 - 13、数据加密：调度中心和执行器之间的通讯进行数据加密，提升调度信息安全性； - 14、任务依赖：支持配置子任务依赖，当父任务执行结束且执行成功后将会主动触发一次子任务的执行, 多个子任务用逗号分隔； - 15、推送maven中央仓库: 将会把最新稳定版推送到maven中央仓库, 方便用户接入和使用; +- 16、任务注册: 执行器会周期性自动注册任务, 调度中心将会自动发现注册的任务并触发执行。 #### 1.3 发展 于2015年中，我在github上创建XXL-JOB项目仓库并提交第一个commit，随之进行系统结构设计，UI选型，交互设计…… @@ -652,12 +653,14 @@ Tips: 历史版本(V1.3.x)目前已经Release至稳定版本, 进入维护阶段 - 5、因catch异常,导致任务不可终止的问题,给出解决方案, 见文档; #### 6.9 版本 V1.5.0 特性 -- 1、调度中心回调逻辑优化, 过滤非法请求; -- 2、公共依赖中新增DBGlueLoader,基于原生jdbc实现GLUE源码的加载器,减少第三方依赖(mybatis,spring-orm等); -- 3、精简和优化执行器测配置(针对GLUE任务),降低上手难度 -- 4、(调度中心, 注册发现线程, 5min清空一次过期appName, 懒加载查询appName注册, 放入缓存, 存活10s, 30s内认为有效, 注册间隔15s) -- 5、(DB字段优化) -- 6、(调度中心, 也自动注册, 调度时, 传输调度中心地址列表) +- 1、任务注册: 执行器会周期性自动注册任务, 调度中心将会自动发现注册的任务并触发执行。 +- 2、"执行器" 新增参数 "AppName" : 是每个执行器集群的唯一标示AppName, 并周期性以AppName为对象进行自动注册。 +- 3、调度中心新增栏目 "执行器管理" : 管理在线的执行器, 通过属性AppName自动发现注册的执行器。只有被管理的执行器才允许被使用; +- 4、"任务组"属性改为"执行器": 每个任务需要绑定指定的执行器, 调度地址通过绑定的执行器获取; +- 5、抛弃"任务机器"属性: 通过任务绑定的执行器, 自动发现注册的远程执行器地址并触发调度请求。 +- 6、"公共依赖"中新增DBGlueLoader,基于原生jdbc实现GLUE源码的加载器,减少第三方依赖(mybatis,spring-orm等);精简和优化执行器测配置(针对GLUE任务),降低上手难度; +- 7、表结构调整,底层重构优化; +- 8、"调度中心"自动注册和发现,failover: 调度中心周期性自动注册, 任务回调时可以感知在线的所有调度中心地址, 通过failover的方式进行任务回调,避免回调单点风险。 #### 规划中 - 1、任务执行规则自定义：假如前一个任务正在执行，后续调度执行规则支持自定义； @@ -665,10 +668,8 @@ Tips: 历史版本(V1.3.x)目前已经Release至稳定版本, 进入维护阶段 并行：后续调度并行执行； Pass：后续调度被Pass； - 2、兼容oracle； -- 3、执行器JobHandler自动注册发现: 执行器中JobHandler自动上报到注册中心,调度中心自动发现注册中心的JobHandler并触发对应的执行器执行任务逻辑; 一方面省略了人工指定器地址的流程,另一方面可以方便的进行执行器机器扩充;(但是,XXL-JOB的定位是轻量级作业调度系统,目前而言使用非常方便,担心引入注册机器会增加运维和学习成本,权衡得失中...) -- 4、后续优化：在线维护分组，在线修改密码，回调多地址+重试， -- 5、支持脚本JOB, 即shell/python/php等, glue实现; -- 6、通过数据库实现JobHandler自动发现: 每个执行器指定appname, 执行器15注册一次粒度为appname和ip, 调度中心15秒加载一次注册表, 超时记录则心跳检测, 调度未配置执行地址,则使用注册表; +- 3、后续优化：在线修改密码， +- 4、支持脚本JOB, 即shell/python/php等, glue实现; ## 七、其他 diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobGroupController.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobGroupController.java index fa92fd04..dd0e6c3f 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobGroupController.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobGroupController.java @@ -26,12 +26,16 @@ public class JobGroupController { @Resource public IXxlJobInfoDao xxlJobInfoDao; - @Resource public IXxlJobGroupDao xxlJobGroupDao; @RequestMapping public String index(Model model) { + + // job admin + List adminAddressList = JobRegistryHelper.discover(RegistHelper.RegistType.ADMIN.name(), RegistHelper.RegistType.ADMIN.name()); + + // job group (executor) List list = xxlJobGroupDao.findAll(); if (CollectionUtils.isNotEmpty(list)) { @@ -41,6 +45,7 @@ public class JobGroupController { } } + model.addAttribute("adminAddressList", adminAddressList); model.addAttribute("list", list); return "jobgroup/jobgroup.index"; } diff --git a/xxl-job-admin/src/main/webapp/WEB-INF/template/jobgroup/jobgroup.index.ftl b/xxl-job-admin/src/main/webapp/WEB-INF/template/jobgroup/jobgroup.index.ftl index 08fe335e..5e1aa863 100644 --- a/xxl-job-admin/src/main/webapp/WEB-INF/template/jobgroup/jobgroup.index.ftl +++ b/xxl-job-admin/src/main/webapp/WEB-INF/template/jobgroup/jobgroup.index.ftl @@ -32,6 +32,8 @@

执行器列表

   +      + 调度中心OnLine:<#if adminAddressList?exists><#list adminAddressList as item>${item}