From 2d55c381c603f4016bbac63d27ecb09927b06343 Mon Sep 17 00:00:00 2001 From: xuxueli <931591021@qq.com> Date: Wed, 20 Dec 2017 20:49:34 +0800 Subject: [PATCH] =?UTF-8?q?JobHandler=E6=8F=90=E4=BE=9Binit/destroy?= =?UTF-8?q?=E6=96=B9=E6=B3=95=EF=BC=8C=E6=94=AF=E6=8C=81=E5=9C=A8JobHandle?= =?UTF-8?q?r=E5=88=9D=E5=A7=8B=E5=8C=96=E5=92=8C=E9=94=80=E6=AF=81?= =?UTF-8?q?=E6=97=B6=E8=BF=9B=E8=A1=8C=E9=99=84=E5=8A=A0=E6=93=8D=E4=BD=9C?= =?UTF-8?q?=EF=BC=9B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- doc/XXL-JOB官方文档.md | 4 ++-- .../com/xxl/job/core/handler/IJobHandler.java | 23 +++++++++++++++++-- 2 files changed, 23 insertions(+), 4 deletions(-) diff --git a/doc/XXL-JOB官方文档.md b/doc/XXL-JOB官方文档.md index 1222ee52..3c546e50 100644 --- a/doc/XXL-JOB官方文档.md +++ b/doc/XXL-JOB官方文档.md @@ -1078,6 +1078,7 @@ Tips: 历史版本(V1.3.x)目前已经Release至稳定版本, 进入维护阶段 - 13、Log组件支持输出异常栈信息,底层实现优化; - 14、失败重试:调度中心调度失败且启用"失败重试"策略时,将会自动重试一次;执行器执行失败且回调失败重试状态时,也将会自动重试一次; - 15、Log地址格式兼容,支持非"/"结尾路径配置; +- 16、JobHandler提供init/destroy方法,支持在JobHandler初始化和销毁时进行附加操作; ### TODO LIST @@ -1097,8 +1098,7 @@ Tips: 历史版本(V1.3.x)目前已经Release至稳定版本, 进入维护阶段 - 14、脚本任务 Shell、Python和Nodejs,如何友好获取分片参数; - 15、Bean模式任务,JobHandler自动从执行器中查询展示为下拉框,选择后自动填充任务名称等属性; - 16、任务告警邮件优化,调整为表格形式; -- 17、JobHandler提供 init/destroy 方法,支持自定义任务线程销毁逻辑; -- 18、执行器回调地址格式兼容,支持非"/"结尾路径配置; +- 17、执行器回调地址格式兼容,支持非"/"结尾路径配置; ## 七、其他 diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/handler/IJobHandler.java b/xxl-job-core/src/main/java/com/xxl/job/core/handler/IJobHandler.java index 4be7a970..64b2f97b 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/handler/IJobHandler.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/handler/IJobHandler.java @@ -9,6 +9,7 @@ import com.xxl.job.core.biz.model.ReturnT; */ public abstract class IJobHandler { + /** success */ public static final ReturnT SUCCESS = new ReturnT(200, null); /** fail */ @@ -18,11 +19,29 @@ public abstract class IJobHandler { /** - * job handler + * execute handler + * * @param params * @return * @throws Exception */ public abstract ReturnT execute(String... params) throws Exception; - + + + /** + * init handler + */ + public void init() { + // TODO + } + + + /** + * destroy handler + */ + public void destroy() { + // TODO + } + + }