Преглед изворни кода

修复执行器启动之后jetty停止的问题;

xuxueli пре 7 година
родитељ
комит
a410b8465f

+ 6 - 6
doc/XXL-JOB官方文档.md Прегледај датотеку

998
 ### 5.12 执行器API服务
998
 ### 5.12 执行器API服务
999
 执行器提供了API服务,供调度中心选择使用,目前提供的API服务有:
999
 执行器提供了API服务,供调度中心选择使用,目前提供的API服务有:
1000
 
1000
 
1001
-    1、心跳检测
1002
-    2、忙碌检测
1003
-    3、触发任务执行
1004
-    4、获取Rolling Log
1005
-    5、终止任务
1001
+    1、心跳检测:调度中心使用
1002
+    2、忙碌检测:调度中心使用
1003
+    3、触发任务执行:调度中心使用;本地进行任务开发时,可使用该API服务模拟触发任务;
1004
+    4、获取Rolling Log:调度中心使用
1005
+    5、终止任务:调度中心使用
1006
     
1006
     
1007
 API服务位置:com.xxl.job.core.biz.ExecutorBiz     
1007
 API服务位置:com.xxl.job.core.biz.ExecutorBiz     
1008
-API服务请求参考代码:com.xxl.executor.test.DemoJobHandlerTest
1008
+API服务请求参考代码:com.xxl.job.executor.ExecutorBizTest
1009
 
1009
 
1010
 ### 5.13 故障转移 & 失败重试
1010
 ### 5.13 故障转移 & 失败重试
1011
 一次完整任务流程包括"调度(调度中心) + 执行(执行器)"两个阶段。
1011
 一次完整任务流程包括"调度(调度中心) + 执行(执行器)"两个阶段。

xxl-job-executor-samples/xxl-job-executor-sample-spring/src/test/java/com/xxl/executor/test/DemoJobHandlerTest.java → xxl-job-admin/src/test/java/com/xxl/job/executor/ExecutorBizTest.java Прегледај датотеку

1
-package com.xxl.executor.test;
1
+package com.xxl.job.executor;
2
 
2
 
3
 import com.xxl.job.core.biz.ExecutorBiz;
3
 import com.xxl.job.core.biz.ExecutorBiz;
4
 import com.xxl.job.core.biz.model.ReturnT;
4
 import com.xxl.job.core.biz.model.ReturnT;
15
  *
15
  *
16
  * Created by xuxueli on 17/5/12.
16
  * Created by xuxueli on 17/5/12.
17
  */
17
  */
18
-public class DemoJobHandlerTest {
18
+public class ExecutorBizTest {
19
 
19
 
20
     public static void main(String[] args) throws Exception {
20
     public static void main(String[] args) throws Exception {
21
 
21
 
23
         String jobHandler = "demoJobHandler";
23
         String jobHandler = "demoJobHandler";
24
         String params = "";
24
         String params = "";
25
 
25
 
26
+        runTest(jobHandler, params);
27
+    }
28
+
29
+    /**
30
+     * run jobhandler
31
+     *
32
+     * @param jobHandler
33
+     * @param params
34
+     */
35
+    private static void runTest(String jobHandler, String params){
26
         // trigger data
36
         // trigger data
27
         TriggerParam triggerParam = new TriggerParam();
37
         TriggerParam triggerParam = new TriggerParam();
28
         triggerParam.setJobId(1);
38
         triggerParam.setJobId(1);