From ea5b3541e46e21501a6deb7fcd80ce1b95820dea Mon Sep 17 00:00:00 2001 From: xuxueli <931591021@qq.com> Date: Sat, 28 Apr 2018 18:39:59 +0800 Subject: [PATCH] =?UTF-8?q?Glue(Shell)=20=E7=AD=89=E8=84=9A=E6=9C=AC?= =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E6=94=AF=E6=8C=81=E5=A4=B1=E8=B4=A5=E9=87=8D?= =?UTF-8?q?=E8=AF=95=EF=BC=9B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- doc/XXL-JOB官方文档.md | 16 +++++++++++++--- .../job/core/handler/impl/ScriptJobHandler.java | 11 +++++++++-- 2 files changed, 22 insertions(+), 5 deletions(-) diff --git a/doc/XXL-JOB官方文档.md b/doc/XXL-JOB官方文档.md index 6620fe0b..66029efb 100644 --- a/doc/XXL-JOB官方文档.md +++ b/doc/XXL-JOB官方文档.md @@ -785,14 +785,15 @@ xxl-job-admin#com.xxl.job.admin.controller.JobApiController.callback #### 5.5.3 GLUE模式(Shell) + GLUE模式(Python) + GLUE模式(NodeJS) 开发步骤：可参考 "章节三" ； -原理：脚本任务的源码托管在调度中心，脚本逻辑在执行器运行。当触发脚本任务时，执行器会加载脚本源码在执行器机器上生成一份脚本文件，然后通过Java代码调用该脚本；并且实时将脚本输出日志写到任务日志文件中，从而在调度中心可以实时监控脚本运行情况；脚本返回码为0时表示执行成功，其他标示执行失败。 +原理：脚本任务的源码托管在调度中心，脚本逻辑在执行器运行。当触发脚本任务时，执行器会加载脚本源码在执行器机器上生成一份脚本文件，然后通过Java代码调用该脚本；并且实时将脚本输出日志写到任务日志文件中，从而在调度中心可以实时监控脚本运行情况； 目前支持的脚本类型如下： - shell脚本：任务运行模式选择为 "GLUE模式(Shell)"时支持 "shell" 脚本任务； - python脚本：任务运行模式选择为 "GLUE模式(Python)"时支持 "python" 脚本任务； - nodejs脚本：务运行模式选择为 "GLUE模式(NodeJS)"时支持 "nodejs" 脚本任务； - + +脚本任务通过 Exit Code 判断任务执行结果，状态码可参考章节 "5.15 任务执行结果说明"； #### 5.5.4 执行器 执行器实际上是一个内嵌的Jetty服务器，默认端口9999（配置项：xxl.job.executor.port）。 @@ -917,6 +918,15 @@ echo "分片总数 total = $3" - 3、等待B组机器任务运行结束并编译上线；执行器注册地址替换为A组+B组； 操作结束； +### 5.15 任务执行结果说明 +系统根据以下标准判断任务执行结果，可参考之。 + +-- | Bean/Glue(Java) | Glue(Shell) 等脚本任务 +--- | --- | --- +成功 | IJobHandler.SUCCESS | 0 +失败 | IJobHandler.FAIL | -1（其他） +失败重试 | IJobHandler.FAIL_RETRY | 501 + ## 六、版本更新日志 ### 6.1 版本 V1.1.x，新特性[2015-12-05] @@ -1181,7 +1191,7 @@ Tips: 历史版本(V1.3.x)目前已经Release至稳定版本, 进入维护阶段 - 3、[迭代中]任务超时设置，超时任务主动终止； - 4、任务属性枚举 "任务模式、阻塞策略" 国际化优化； - 5、任务日志表状态字段类型优化； -- 6、[迭代中]脚本任务支持失败重试； +- 6、Glue(Shell) 等脚本任务支持失败重试； - 7、告警邮箱支持SSL配置； - 8、Window机器下File.separator不兼容问题修复； diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/handler/impl/ScriptJobHandler.java b/xxl-job-core/src/main/java/com/xxl/job/core/handler/impl/ScriptJobHandler.java index 9adf1242..b6e017ec 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/handler/impl/ScriptJobHandler.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/handler/impl/ScriptJobHandler.java @@ -63,8 +63,15 @@ public class ScriptJobHandler extends IJobHandler { // invoke XxlJobLogger.log("----------- script file:"+ scriptFileName +" -----------"); int exitValue = ScriptUtil.execToFile(cmd, scriptFileName, logFileName, scriptParams); - ReturnT result = (exitValue==0)?IJobHandler.SUCCESS:new ReturnT(IJobHandler.FAIL.getCode(), "script exit value("+exitValue+") is failed"); - return result; + + if (exitValue == 0) { + return IJobHandler.SUCCESS; + } else if (exitValue == 501) { + return IJobHandler.FAIL_RETRY; + } else { + return new ReturnT(IJobHandler.FAIL.getCode(), "script exit value("+exitValue+") is failed"); + } + } }