README.md

Author: sizegang1

gobrs-async-example/src/main/java/com/jd/gobrs/async/example/service/AService.java

@@ -24,7 +24,7 @@ public class AService implements AsyncTask<DataContext, DataContext>, ParaExecto
     @Override
     public void callback(boolean success, DataContext param, TaskResult<DataContext> workResult) {
         if (success) {
-            System.out.println("AService 成功");
+//            System.out.println("AService 成功");
         } else {
             System.out.println("AService 失败");
         }
@@ -33,16 +33,15 @@ public void callback(boolean success, DataContext param, TaskResult<DataContext>
     @Override
     public DataContext task(DataContext params, GobrsAsyncSupport support) {
         try {
-//            System.out.println(1/0);
             Thread.sleep(1000);
-            System.out.println("AService 执行完了");
+//            System.out.println("AService 执行完了");
 
         } catch (InterruptedException e) {
             e.printStackTrace();
         }
-        byte[] result  = new byte[1024*1024];
+//        byte[] result  = new byte[1024*1024];
         Map h = new HashMap();
-        h.put("result", result);
+        h.put("result", h);
         params.setResult(h);
         return params;
     }

gobrs-async-example/src/main/java/com/jd/gobrs/async/example/service/BService.java

@@ -26,7 +26,7 @@ public class BService implements AsyncTask<DataContext, Map>, SerExector {
     @Override
     public void callback(boolean success, DataContext param, TaskResult<Map> workResult) {
         if (success) {
-            System.out.println("BService 成功");
+//            System.out.println("BService 成功");
         } else {
             System.out.println("BService 失败");
         }

gobrs-async-example/src/main/java/com/jd/gobrs/async/example/service/EService.java

@@ -24,15 +24,26 @@ public class EService implements AsyncTask<DataContext, DataContext>, ParaExecto
     @Override
     public void callback(boolean success, DataContext param, TaskResult<DataContext> workResult) {
         if (success) {
-            System.out.println("EService 成功");
+//            System.out.println("EService 成功");
         } else {
             System.out.println("EService 失败");
         }
     }
 
     @Override
     public DataContext task(DataContext params, GobrsAsyncSupport support) {
-        stopTaskFlow(support, 100);
+        try {
+//            System.out.println(1/0);
+            Thread.sleep(500);
+
+
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+//        byte[] result = new byte[1024 * 1024];
+        Map h = new HashMap();
+        h.put("result", "我是EService 的 结果 恭喜你拿到");
+        params.setResult(h);
         return params;
     }
 

gobrs-async-example/src/main/java/com/jd/gobrs/async/example/service/FService.java

@@ -23,7 +23,7 @@ public class FService implements AsyncTask<DataContext, Map>, SerExector {
     @Override
     public void callback(boolean success, DataContext param, TaskResult<Map> workResult) {
         if (success) {
-            System.out.println("FService 成功");
+//            System.out.println("FService 成功");
         } else {
             System.out.println("FService 失败");
         }
@@ -32,8 +32,8 @@ public void callback(boolean success, DataContext param, TaskResult<Map> workRes
     @Override
     public Map task(DataContext params, GobrsAsyncSupport support) {
         try {
-            DataContext result = getResult(support, EService.class, DataContext.class);
-            System.out.println(JSONObject.toJSONString(result.getResult()));
+//            DataContext result = getResult(support, EService.class, DataContext.class);
+//            System.out.println(JSONObject.toJSONString(result.getResult()));
             Thread.sleep(1000);
         } catch (InterruptedException e) {
             e.printStackTrace();

gobrs-async-example/src/main/java/com/jd/gobrs/async/example/service/GobrsService.java

@@ -51,13 +51,6 @@ public void testGobrs(HttpServletRequest httpServletRequest) {
         DataContext dataContext = new DataContext();
         dataContext.setHttpServletRequest(httpServletRequest);
         AsyncResult asyncResult = taskFlow.taskFlow("test", dataContext, 100000);
-
-        if(asyncResult.getExpCode().equals(100)){
-            // 业务一
-        }else if(asyncResult.getExpCode().equals(200)){
-            // 业务二
-        }
-
     }
 
 

gobrs-async-example/src/main/resources/application.yml

@@ -3,6 +3,6 @@ server:
 spring:
   gobrs:
     async:
-      rules: '[{name: "test", content: "AService->BService,CService,GService,DService, FService:not;EService->FService"}]'
+      rules: '[{name: "test", content: "AService->BService;EService->FService"}]'
       #      rules: '[{name: "test", content: "BService->CService->EService->DService:not;AService->DService:not"}]'
       task-interrupt: true #局部异常是否打断主流程