From fde796526f0356b79fc05661ec0c046c0b37d91e Mon Sep 17 00:00:00 2001 From: bryan31 Date: Thu, 8 Apr 2021 12:10:32 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E8=AF=95=E7=94=A8=E4=BE=8B=E7=BB=9F?= =?UTF-8?q?=E4=B8=80=E5=BD=92=E5=B9=B6=E5=9C=A8=E4=B8=BB=E8=A6=812?= =?UTF-8?q?=E4=B8=AA=E5=B7=A5=E7=A8=8Btest=E7=9B=AE=E5=BD=95=E4=B8=8B?= =?UTF-8?q?=EF=BC=8C=E5=88=A0=E9=99=A4=E5=A4=9A=E4=BD=99=E7=9A=84=E6=B5=8B?= =?UTF-8?q?=E8=AF=95=E7=94=A8=E4=BE=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../flowtest/FlowtestApplicationTests.java | 16 --- .../flowtest/concurrent/ConcurrentCase.java | 130 ------------------ .../flowtest/concurrent/SpringBootApp.java | 20 --- .../flowtest/concurrent/TestGroupIdFlow.java | 49 ------- .../flowtest/concurrent/TestParseFlow.java | 85 ------------ .../flowtest/concurrent/TestRunFlow.java | 90 ------------ .../mock/component/c/C10Component.java | 22 --- .../mock/component/c/C1Component.java | 22 --- .../mock/component/c/C2Component.java | 22 --- .../mock/component/c/C3Component.java | 22 --- .../mock/component/c/C4Component.java | 22 --- .../mock/component/c/C5Component.java | 22 --- .../mock/component/c/C6Component.java | 22 --- .../mock/component/c/C7Component.java | 22 --- .../mock/component/c/C8Component.java | 22 --- .../mock/component/c/C9Component.java | 22 --- .../mock/component/p/P3Component.java | 21 --- .../mock/component/p/P4Component.java | 21 --- .../mock/component/p/P5Component.java | 19 --- .../mock/component/p/P6Component.java | 21 --- .../mock/component/p/P7Component.java | 21 --- .../mock/component/p/P8Component.java | 21 --- .../mock/component/s/S1Component.java | 21 --- .../mock/component/s/S2Component.java | 21 --- .../mock/component/s/S3Component.java | 21 --- .../mock/component/s/S4Component.java | 21 --- .../mock/component/s/S5Component.java | 21 --- .../mock/component/s/S6Component.java | 21 --- .../src/test/resources/application-test.yml | 18 --- .../src/test/resources/config/flow-test.xml | 33 ----- 30 files changed, 911 deletions(-) delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/FlowtestApplicationTests.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/ConcurrentCase.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/SpringBootApp.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/TestGroupIdFlow.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/TestParseFlow.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/TestRunFlow.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C10Component.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C1Component.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C2Component.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C3Component.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C4Component.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C5Component.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C6Component.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C7Component.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C8Component.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C9Component.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/p/P3Component.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/p/P4Component.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/p/P5Component.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/p/P6Component.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/p/P7Component.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/p/P8Component.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/s/S1Component.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/s/S2Component.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/s/S3Component.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/s/S4Component.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/s/S5Component.java delete mode 100644 liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/s/S6Component.java delete mode 100644 liteflow-test-springboot/src/test/resources/application-test.yml delete mode 100644 liteflow-test-springboot/src/test/resources/config/flow-test.xml diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/FlowtestApplicationTests.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/FlowtestApplicationTests.java deleted file mode 100644 index bd48a6c74..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/FlowtestApplicationTests.java +++ /dev/null @@ -1,16 +0,0 @@ -package com.yomahub.flowtest; - -import org.junit.Test; -import org.junit.runner.RunWith; -import org.springframework.boot.test.context.SpringBootTest; -import org.springframework.test.context.junit4.SpringRunner; - -@RunWith(SpringRunner.class) -@SpringBootTest -public class FlowtestApplicationTests { - - @Test - public void contextLoads() { - } - -} diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/ConcurrentCase.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/ConcurrentCase.java deleted file mode 100644 index e50b26fe9..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/ConcurrentCase.java +++ /dev/null @@ -1,130 +0,0 @@ -package com.yomahub.flowtest.concurrent; - -import org.junit.Assert; - -import java.util.AbstractMap; -import java.util.List; -import java.util.Map; -import java.util.Objects; -import java.util.concurrent.ConcurrentHashMap; -import java.util.concurrent.CopyOnWriteArrayList; - -/** - * 流程的顺序执行、并发执行的CASE构造器 - * @author justin.xu - */ -public class ConcurrentCase { - public static final Map, List>> CASES = new ConcurrentHashMap<>(); - - /** - * 初始化一个测试用例的预期 - * @param request - * @param expected - */ - public static void caseInit(String request, List expected) { - CASES.put(request, new AbstractMap.SimpleEntry, List>(expected, new CopyOnWriteArrayList<>())); - } - - /** - * 添加这个测试用例的实际 - * @param request - * @param actual - */ - public static void caseAdd(String request, Routers actual) { - CASES.computeIfPresent(request, (k, v) -> { - v.getValue().add(actual); - return v; - }); - } - - /** - * 测试当前的Expected与Actual是否相同 - * - * @param request - */ - public static void caseAssert(String request) { - AbstractMap.SimpleEntry, List> ca = CASES.get(request); - Assert.assertNotNull(ca); - - Assert.assertEquals(ca.getKey(), ca.getValue()); - - if (ca.getValue().size() > 0) { - Integer expectedIndex = null; - for (Routers actual : ca.getValue()) { - - if (expectedIndex == null) { - expectedIndex = actual.getIndex(); - } else { - Assert.assertEquals(expectedIndex.intValue(), actual.getIndex()); - } - } - } - } - - /** - * 测试当前的Expected与Actual是否相同 - * - * @param request - */ - public static void caseAssertRandom(String request) { - AbstractMap.SimpleEntry, List> ca = CASES.get(request); - Assert.assertNotNull(ca); - - Assert.assertEquals(ca.getKey().size(), ca.getValue().size()); - - if (ca.getValue().size() > 0) { - Integer expectedIndex = null; - for (Routers actual : ca.getValue()) { - boolean find = false; - for(Routers routers : ca.getKey()) { - if (routers.getValue().equals(actual.getValue())) { - find = true; - } - } - Assert.assertTrue(find); - - if (expectedIndex == null) { - expectedIndex = actual.getIndex(); - } else { - Assert.assertEquals(expectedIndex.intValue(), actual.getIndex()); - } - } - } - } - - - public static class Routers { - int index; - String value; - - public Routers(String value) { - this.index = -1; - this.value = value; - } - public Routers(int index, String value) { - this.index = index; - this.value = value; - } - - public int getIndex() { - return index; - } - - public String getValue() { - return value; - } - - @Override - public boolean equals(Object o) { - if (this == o) return true; - if (o == null || getClass() != o.getClass()) return false; - Routers routers = (Routers) o; - return value.equals(routers.value); - } - - @Override - public int hashCode() { - return Objects.hash(value); - } - } -} diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/SpringBootApp.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/SpringBootApp.java deleted file mode 100644 index 9846e2fb5..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/SpringBootApp.java +++ /dev/null @@ -1,20 +0,0 @@ -package com.yomahub.flowtest.concurrent; - -import org.springframework.boot.SpringApplication; -import org.springframework.boot.autoconfigure.SpringBootApplication; -import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration; - -/** - * 启动类 - * @author justin.xu - */ -@SpringBootApplication(exclude={DataSourceAutoConfiguration.class}) -public class SpringBootApp { - /** - * @param args - */ - public static void main(String[] args) { - SpringApplication.run(SpringBootApp.class, args); - } - -} diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/TestGroupIdFlow.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/TestGroupIdFlow.java deleted file mode 100644 index df390d9b5..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/TestGroupIdFlow.java +++ /dev/null @@ -1,49 +0,0 @@ -package com.yomahub.flowtest.concurrent; - -import com.yomahub.liteflow.core.FlowExecutor; -import org.junit.Test; -import org.junit.runner.RunWith; -import org.springframework.boot.test.context.SpringBootTest; -import org.springframework.test.context.ActiveProfiles; -import org.springframework.test.context.junit4.SpringRunner; - -import javax.annotation.Resource; -import java.util.Arrays; -import java.util.List; -import java.util.UUID; -import java.util.stream.Collectors; - -import static com.yomahub.flowtest.concurrent.ConcurrentCase.caseAssertRandom; -import static com.yomahub.flowtest.concurrent.ConcurrentCase.caseInit; - -/** - * 测试流程的顺序执行、并发执行等 - * @author justin.xu - */ -@ActiveProfiles("test") -@RunWith(SpringRunner.class) -@SpringBootTest -public class TestGroupIdFlow { - - @Resource - private FlowExecutor flowExecutor; - - private String init(List steps) { - - String requestId = UUID.randomUUID().toString(); - - caseInit(requestId, steps.stream().map(ConcurrentCase.Routers::new).collect(Collectors.toList())); - - return requestId; - } - - @Test - public void whenConditionGroupTest() throws Exception { - //由于errorResume，即使p5执行失败抛出异常, p7， p8也将会执行 - String requestId = init(Arrays.asList("s1", "s2", "s3", "s4", "s5", "s6", "p3", "p4", "p6", "p7", "p8")); - - flowExecutor.execute("test-groupId", requestId); - - caseAssertRandom(requestId); - } -} diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/TestParseFlow.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/TestParseFlow.java deleted file mode 100644 index ff647fbfb..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/TestParseFlow.java +++ /dev/null @@ -1,85 +0,0 @@ -package com.yomahub.flowtest.concurrent; - - -import com.yomahub.liteflow.entity.flow.Chain; -import com.yomahub.liteflow.entity.flow.Condition; -import com.yomahub.liteflow.entity.flow.ThenCondition; -import com.yomahub.liteflow.entity.flow.WhenCondition; -import com.yomahub.liteflow.flow.FlowBus; -import org.junit.Assert; -import org.junit.Test; -import org.junit.runner.RunWith; -import org.springframework.boot.test.context.SpringBootTest; -import org.springframework.test.context.ActiveProfiles; -import org.springframework.test.context.junit4.SpringRunner; - -import java.util.AbstractMap; -import java.util.Arrays; -import java.util.Collections; -import java.util.List; - - -/** - * 测试流程的解析 - * @author justin.xu - */ -@ActiveProfiles("test") -@RunWith(SpringRunner.class) -@SpringBootTest -public class TestParseFlow { - - private Check caseErrorResume = new Check("test-errorResume", Arrays.asList( - new AbstractMap.SimpleEntry, Boolean>(ThenCondition.class, null), - new AbstractMap.SimpleEntry, Boolean>(WhenCondition.class, true), - new AbstractMap.SimpleEntry, Boolean>(WhenCondition.class, true), - new AbstractMap.SimpleEntry, Boolean>(WhenCondition.class, true) - )); - - private Check caseErrorBreak = new Check("test-errorBreak", Arrays.asList( - new AbstractMap.SimpleEntry, Boolean>(ThenCondition.class, null), - new AbstractMap.SimpleEntry, Boolean>(WhenCondition.class, true), - new AbstractMap.SimpleEntry, Boolean>(WhenCondition.class, false), - new AbstractMap.SimpleEntry, Boolean>(WhenCondition.class, true) - )); - - @Test - public void parseWhen() throws Exception { - assertTrue(caseErrorResume, FlowBus.getChain(caseErrorResume.getChainCode())); - - assertTrue(caseErrorBreak, FlowBus.getChain(caseErrorBreak.getChainCode())); - } - - private void assertTrue(Check check, Chain chain) { - Assert.assertNotNull(chain); - - Assert.assertTrue(null != chain.getConditionList() && !chain.getConditionList().isEmpty()); - for (int i = 0; i < chain.getConditionList().size(); i ++) { - - AbstractMap.SimpleEntry, Boolean> expected = check.getClazzWithFlags().get(i); - Condition actual = chain.getConditionList().get(i); - - Assert.assertEquals(expected.getKey(), actual.getClass()); - if (actual.getClass().equals(WhenCondition.class)) { - Assert.assertEquals(expected.getValue(), ((WhenCondition) actual).isErrorResume()); - } - } - } - - public static class Check { - private String chainCode; - private List, Boolean>> clazzWithFlags; - - public Check(String chainCode, List, Boolean>> clazzWithFlags) { - this.chainCode = chainCode; - this.clazzWithFlags = clazzWithFlags; - } - - public String getChainCode() { - return chainCode; - } - - public List, Boolean>> getClazzWithFlags() { - return clazzWithFlags; - } - } -} diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/TestRunFlow.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/TestRunFlow.java deleted file mode 100644 index fad9ca62c..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/TestRunFlow.java +++ /dev/null @@ -1,90 +0,0 @@ -package com.yomahub.flowtest.concurrent; - -import com.yomahub.liteflow.core.FlowExecutor; -import org.junit.Test; -import org.junit.runner.RunWith; -import org.springframework.boot.test.context.SpringBootTest; -import org.springframework.test.context.ActiveProfiles; -import org.springframework.test.context.junit4.SpringRunner; - -import javax.annotation.Resource; -import java.util.Arrays; -import java.util.List; -import java.util.UUID; -import java.util.stream.Collectors; - -import static com.yomahub.flowtest.concurrent.ConcurrentCase.caseAssertRandom; -import static com.yomahub.flowtest.concurrent.ConcurrentCase.caseInit; - -/** - * 测试流程的顺序执行、并发执行等 - * @author justin.xu - */ -@ActiveProfiles("test") -@RunWith(SpringRunner.class) -@SpringBootTest -public class TestRunFlow { - - @Resource - private FlowExecutor flowExecutor; - - private String init(List steps) { - - String requestId = UUID.randomUUID().toString(); - - caseInit(requestId, steps.stream().map(ConcurrentCase.Routers::new).collect(Collectors.toList())); - - return requestId; - } - - @Test - public void mixedRunByErrorResumeTest() throws Exception { - //由于errorResume，即使p5执行失败抛出异常, p7， p8也将会执行 - String requestId = init(Arrays.asList("s1", "s2", "s3", "s4", "s5", "s6", "p3", "p4", "p6", "p7", "p8")); - - flowExecutor.execute("test-errorResume", requestId); - - caseAssertRandom(requestId); - } - - - @Test - public void mixedRunByErrorBreakTest() throws Exception { - //由于errorBreak，p5执行失败抛出异常, p7， p8将不会执行 - String requestId = init(Arrays.asList("s1", "s2", "s3", "s4", "s5", "s6", "p3", "p4", "p6")); - - flowExecutor.execute("test-errorBreak", requestId); - - caseAssertRandom(requestId); - } - - @Test - public void parallelTest() throws InterruptedException { - //测试2个线程并发时，所执行的序列是正常的，线程安全的（slotIndex在每个执行序列chain中都是不变的） - String requestId1 = init(Arrays.asList("c1", "c2", "c3", "c4", "c5")); - String requestId2 = init(Arrays.asList("c6", "c7", "c8", "c9", "c10")); - - List ts = Arrays.asList( - newExecutor("async-concurrent1", requestId1), - newExecutor("async-concurrent2", requestId2) - ); - ts.forEach(Thread::start); - - for (Thread t : ts) { - t.join(); - } - - caseAssertRandom(requestId1); - caseAssertRandom(requestId2); - } - - private Thread newExecutor(String chain, String requestId) { - return new Thread(() -> { - try { - flowExecutor.execute(chain, requestId); - } catch (Exception e) { - e.printStackTrace(); - } - }); - } -} diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C10Component.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C10Component.java deleted file mode 100644 index 360878450..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C10Component.java +++ /dev/null @@ -1,22 +0,0 @@ -package com.yomahub.flowtest.concurrent.mock.component.c; - -import com.yomahub.flowtest.concurrent.ConcurrentCase; -import com.yomahub.liteflow.core.NodeComponent; -import org.springframework.stereotype.Component; - -/** - * 测试mock component - * @author justin.xu - */ -@Component("c10") -public class C10Component extends NodeComponent { - - private static final String name = "c10"; - - @Override - public void process() throws Exception { - Thread.sleep(1_000); - ConcurrentCase.caseAdd((String) getSlot().getRequestData(), new ConcurrentCase.Routers(getSlotIndex(), name)); - System.out.println(String.format("[%s] component executed, index[%d].", name, getSlotIndex())); - } -} \ No newline at end of file diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C1Component.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C1Component.java deleted file mode 100644 index 641a67629..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C1Component.java +++ /dev/null @@ -1,22 +0,0 @@ -package com.yomahub.flowtest.concurrent.mock.component.c; - -import com.yomahub.flowtest.concurrent.ConcurrentCase; -import com.yomahub.liteflow.core.NodeComponent; -import org.springframework.stereotype.Component; - -/** - * 测试mock component - * @author justin.xu - */ -@Component("c1") -public class C1Component extends NodeComponent { - - private static final String name = "c1"; - - @Override - public void process() throws Exception { - Thread.sleep(1_000); - ConcurrentCase.caseAdd((String) getSlot().getRequestData(), new ConcurrentCase.Routers(getSlotIndex(), name)); - System.out.println(String.format("[%s] component executed, index[%d].", name, getSlotIndex())); - } -} diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C2Component.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C2Component.java deleted file mode 100644 index 7aa9ea9ab..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C2Component.java +++ /dev/null @@ -1,22 +0,0 @@ -package com.yomahub.flowtest.concurrent.mock.component.c; - -import com.yomahub.flowtest.concurrent.ConcurrentCase; -import com.yomahub.liteflow.core.NodeComponent; -import org.springframework.stereotype.Component; - -/** - * 测试mock component - * @author justin.xu - */ -@Component("c2") -public class C2Component extends NodeComponent { - - private static final String name = "c2"; - - @Override - public void process() throws Exception { - Thread.sleep(1_000); - ConcurrentCase.caseAdd((String) getSlot().getRequestData(), new ConcurrentCase.Routers(getSlotIndex(), name)); - System.out.println(String.format("[%s] component executed, index[%d].", name, getSlotIndex())); - } -} diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C3Component.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C3Component.java deleted file mode 100644 index 104d2e1fd..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C3Component.java +++ /dev/null @@ -1,22 +0,0 @@ -package com.yomahub.flowtest.concurrent.mock.component.c; - -import com.yomahub.flowtest.concurrent.ConcurrentCase; -import com.yomahub.liteflow.core.NodeComponent; -import org.springframework.stereotype.Component; - -/** - * 测试mock component - * @author justin.xu - */ -@Component("c3") -public class C3Component extends NodeComponent { - - private static final String name = "c3"; - - @Override - public void process() throws Exception { - Thread.sleep(1_000); - ConcurrentCase.caseAdd((String) getSlot().getRequestData(), new ConcurrentCase.Routers(getSlotIndex(), name)); - System.out.println(String.format("[%s] component executed, index[%d].", name, getSlotIndex())); - } -} diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C4Component.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C4Component.java deleted file mode 100644 index 207b20309..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C4Component.java +++ /dev/null @@ -1,22 +0,0 @@ -package com.yomahub.flowtest.concurrent.mock.component.c; - -import com.yomahub.flowtest.concurrent.ConcurrentCase; -import com.yomahub.liteflow.core.NodeComponent; -import org.springframework.stereotype.Component; - -/** - * 测试mock component - * @author justin.xu - */ -@Component("c4") -public class C4Component extends NodeComponent { - - private static final String name = "c4"; - - @Override - public void process() throws Exception { - Thread.sleep(1_000); - ConcurrentCase.caseAdd((String) getSlot().getRequestData(), new ConcurrentCase.Routers(getSlotIndex(), name)); - System.out.println(String.format("[%s] component executed, index[%d].", name, getSlotIndex())); - } -} \ No newline at end of file diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C5Component.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C5Component.java deleted file mode 100644 index a5877c041..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C5Component.java +++ /dev/null @@ -1,22 +0,0 @@ -package com.yomahub.flowtest.concurrent.mock.component.c; - -import com.yomahub.flowtest.concurrent.ConcurrentCase; -import com.yomahub.liteflow.core.NodeComponent; -import org.springframework.stereotype.Component; - -/** - * 测试mock component - * @author justin.xu - */ -@Component("c5") -public class C5Component extends NodeComponent { - - private static final String name = "c5"; - - @Override - public void process() throws Exception { - Thread.sleep(1_000); - ConcurrentCase.caseAdd((String) getSlot().getRequestData(), new ConcurrentCase.Routers(getSlotIndex(), name)); - System.out.println(String.format("[%s] component executed, index[%d].", name, getSlotIndex())); - } -} \ No newline at end of file diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C6Component.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C6Component.java deleted file mode 100644 index af3bca011..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C6Component.java +++ /dev/null @@ -1,22 +0,0 @@ -package com.yomahub.flowtest.concurrent.mock.component.c; - -import com.yomahub.flowtest.concurrent.ConcurrentCase; -import com.yomahub.liteflow.core.NodeComponent; -import org.springframework.stereotype.Component; - -/** - * 测试mock component - * @author justin.xu - */ -@Component("c6") -public class C6Component extends NodeComponent { - - private static final String name = "c6"; - - @Override - public void process() throws Exception { - Thread.sleep(1_000); - ConcurrentCase.caseAdd((String) getSlot().getRequestData(), new ConcurrentCase.Routers(getSlotIndex(), name)); - System.out.println(String.format("[%s] component executed, index[%d].", name, getSlotIndex())); - } -} diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C7Component.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C7Component.java deleted file mode 100644 index 30f47d0d1..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C7Component.java +++ /dev/null @@ -1,22 +0,0 @@ -package com.yomahub.flowtest.concurrent.mock.component.c; - -import com.yomahub.flowtest.concurrent.ConcurrentCase; -import com.yomahub.liteflow.core.NodeComponent; -import org.springframework.stereotype.Component; - -/** - * 测试mock component - * @author justin.xu - */ -@Component("c7") -public class C7Component extends NodeComponent { - - private static final String name = "c7"; - - @Override - public void process() throws Exception { - Thread.sleep(1_000); - ConcurrentCase.caseAdd((String) getSlot().getRequestData(), new ConcurrentCase.Routers(getSlotIndex(), name)); - System.out.println(String.format("[%s] component executed, index[%d].", name, getSlotIndex())); - } -} diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C8Component.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C8Component.java deleted file mode 100644 index ce9bb91e2..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C8Component.java +++ /dev/null @@ -1,22 +0,0 @@ -package com.yomahub.flowtest.concurrent.mock.component.c; - -import com.yomahub.flowtest.concurrent.ConcurrentCase; -import com.yomahub.liteflow.core.NodeComponent; -import org.springframework.stereotype.Component; - -/** - * 测试mock component - * @author justin.xu - */ -@Component("c8") -public class C8Component extends NodeComponent { - - private static final String name = "c8"; - - @Override - public void process() throws Exception { - Thread.sleep(1_000); - ConcurrentCase.caseAdd((String) getSlot().getRequestData(), new ConcurrentCase.Routers(getSlotIndex(), name)); - System.out.println(String.format("[%s] component executed, index[%d].", name, getSlotIndex())); - } -} diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C9Component.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C9Component.java deleted file mode 100644 index f770ac294..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/c/C9Component.java +++ /dev/null @@ -1,22 +0,0 @@ -package com.yomahub.flowtest.concurrent.mock.component.c; - -import com.yomahub.flowtest.concurrent.ConcurrentCase; -import com.yomahub.liteflow.core.NodeComponent; -import org.springframework.stereotype.Component; - -/** - * 测试mock component - * @author justin.xu - */ -@Component("c9") -public class C9Component extends NodeComponent { - - private static final String name = "c9"; - - @Override - public void process() throws Exception { - Thread.sleep(1_000); - ConcurrentCase.caseAdd((String) getSlot().getRequestData(), new ConcurrentCase.Routers(getSlotIndex(), name)); - System.out.println(String.format("[%s] component executed, index[%d].", name, getSlotIndex())); - } -} diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/p/P3Component.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/p/P3Component.java deleted file mode 100644 index eaaa96423..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/p/P3Component.java +++ /dev/null @@ -1,21 +0,0 @@ -package com.yomahub.flowtest.concurrent.mock.component.p; - -import com.yomahub.flowtest.concurrent.ConcurrentCase; -import com.yomahub.liteflow.core.NodeComponent; -import org.springframework.stereotype.Component; - -/** - * 测试mock component - * @author justin.xu - */ -@Component("p3") -public class P3Component extends NodeComponent { - - private static final String name = "p3"; - - @Override - public void process() throws Exception { - ConcurrentCase.caseAdd((String) getSlot().getRequestData(), new ConcurrentCase.Routers(getSlotIndex(), name)); - System.out.println(String.format("[%s] component executed, index[%d].", name, getSlotIndex())); - } -} diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/p/P4Component.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/p/P4Component.java deleted file mode 100644 index 4b22bb1ad..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/p/P4Component.java +++ /dev/null @@ -1,21 +0,0 @@ -package com.yomahub.flowtest.concurrent.mock.component.p; - -import com.yomahub.flowtest.concurrent.ConcurrentCase; -import com.yomahub.liteflow.core.NodeComponent; -import org.springframework.stereotype.Component; - -/** - * 测试mock component - * @author justin.xu - */ -@Component("p4") -public class P4Component extends NodeComponent { - - private static final String name = "p4"; - - @Override - public void process() throws Exception { - ConcurrentCase.caseAdd((String) getSlot().getRequestData(), new ConcurrentCase.Routers(getSlotIndex(), name)); - System.out.println(String.format("[%s] component executed, index[%d].", name, getSlotIndex())); - } -} diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/p/P5Component.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/p/P5Component.java deleted file mode 100644 index c4463fc26..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/p/P5Component.java +++ /dev/null @@ -1,19 +0,0 @@ -package com.yomahub.flowtest.concurrent.mock.component.p; - -import com.yomahub.liteflow.core.NodeComponent; -import org.springframework.stereotype.Component; - -/** - * 测试mock component - * @author justin.xu - */ -@Component("p5") -public class P5Component extends NodeComponent { - - private static final String name = "p5"; - - @Override - public void process() throws Exception { - throw new RuntimeException(String.format("test mock error [%s]", name)); - } -} \ No newline at end of file diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/p/P6Component.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/p/P6Component.java deleted file mode 100644 index a17f1ffcd..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/p/P6Component.java +++ /dev/null @@ -1,21 +0,0 @@ -package com.yomahub.flowtest.concurrent.mock.component.p; - -import com.yomahub.flowtest.concurrent.ConcurrentCase; -import com.yomahub.liteflow.core.NodeComponent; -import org.springframework.stereotype.Component; - -/** - * 测试mock component - * @author justin.xu - */ -@Component("p6") -public class P6Component extends NodeComponent { - - private static final String name = "p6"; - - @Override - public void process() throws Exception { - ConcurrentCase.caseAdd((String) getSlot().getRequestData(), new ConcurrentCase.Routers(getSlotIndex(), name)); - System.out.println(String.format("[%s] component executed, index[%d].", name, getSlotIndex())); - } -} diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/p/P7Component.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/p/P7Component.java deleted file mode 100644 index da1bfa819..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/p/P7Component.java +++ /dev/null @@ -1,21 +0,0 @@ -package com.yomahub.flowtest.concurrent.mock.component.p; - -import com.yomahub.flowtest.concurrent.ConcurrentCase; -import com.yomahub.liteflow.core.NodeComponent; -import org.springframework.stereotype.Component; - -/** - * 测试mock component - * @author justin.xu - */ -@Component("p7") -public class P7Component extends NodeComponent { - - private static final String name = "p7"; - - @Override - public void process() throws Exception { - ConcurrentCase.caseAdd((String) getSlot().getRequestData(), new ConcurrentCase.Routers(getSlotIndex(), name)); - System.out.println(String.format("[%s] component executed, index[%d].", name, getSlotIndex())); - } -} diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/p/P8Component.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/p/P8Component.java deleted file mode 100644 index 12f612e95..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/p/P8Component.java +++ /dev/null @@ -1,21 +0,0 @@ -package com.yomahub.flowtest.concurrent.mock.component.p; - -import com.yomahub.flowtest.concurrent.ConcurrentCase; -import com.yomahub.liteflow.core.NodeComponent; -import org.springframework.stereotype.Component; - -/** - * 测试mock component - * @author justin.xu - */ -@Component("p8") -public class P8Component extends NodeComponent { - - private static final String name = "p8"; - - @Override - public void process() throws Exception { - ConcurrentCase.caseAdd((String) getSlot().getRequestData(), new ConcurrentCase.Routers(getSlotIndex(), name)); - System.out.println(String.format("[%s] component executed, index[%d].", name, getSlotIndex())); - } -} \ No newline at end of file diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/s/S1Component.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/s/S1Component.java deleted file mode 100644 index e78c15f35..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/s/S1Component.java +++ /dev/null @@ -1,21 +0,0 @@ -package com.yomahub.flowtest.concurrent.mock.component.s; - -import com.yomahub.flowtest.concurrent.ConcurrentCase; -import com.yomahub.liteflow.core.NodeComponent; -import org.springframework.stereotype.Component; - -/** - * 测试mock component - * @author justin.xu - */ -@Component("s1") -public class S1Component extends NodeComponent { - - private static final String name = "s1"; - - @Override - public void process() throws Exception { - ConcurrentCase.caseAdd((String) getSlot().getRequestData(), new ConcurrentCase.Routers(getSlotIndex(), name)); - System.out.println(String.format("[%s] component executed, index[%d].", name, getSlotIndex())); - } -} diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/s/S2Component.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/s/S2Component.java deleted file mode 100644 index 5d67adea1..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/s/S2Component.java +++ /dev/null @@ -1,21 +0,0 @@ -package com.yomahub.flowtest.concurrent.mock.component.s; - -import com.yomahub.flowtest.concurrent.ConcurrentCase; -import com.yomahub.liteflow.core.NodeComponent; -import org.springframework.stereotype.Component; - -/** - * 测试mock component - * @author justin.xu - */ -@Component("s2") -public class S2Component extends NodeComponent { - - private static final String name = "s2"; - - @Override - public void process() throws Exception { - ConcurrentCase.caseAdd((String) getSlot().getRequestData(), new ConcurrentCase.Routers(getSlotIndex(), name)); - System.out.println(String.format("[%s] component executed, index[%d].", name, getSlotIndex())); - } -} diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/s/S3Component.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/s/S3Component.java deleted file mode 100644 index d85ca5822..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/s/S3Component.java +++ /dev/null @@ -1,21 +0,0 @@ -package com.yomahub.flowtest.concurrent.mock.component.s; - -import com.yomahub.flowtest.concurrent.ConcurrentCase; -import com.yomahub.liteflow.core.NodeComponent; -import org.springframework.stereotype.Component; - -/** - * 测试mock component - * @author justin.xu - */ -@Component("s3") -public class S3Component extends NodeComponent { - - private static final String name = "s3"; - - @Override - public void process() throws Exception { - ConcurrentCase.caseAdd((String) getSlot().getRequestData(), new ConcurrentCase.Routers(getSlotIndex(), name)); - System.out.println(String.format("[%s] component executed, index[%d].", name, getSlotIndex())); - } -} \ No newline at end of file diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/s/S4Component.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/s/S4Component.java deleted file mode 100644 index 47bec234d..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/s/S4Component.java +++ /dev/null @@ -1,21 +0,0 @@ -package com.yomahub.flowtest.concurrent.mock.component.s; - -import com.yomahub.flowtest.concurrent.ConcurrentCase; -import com.yomahub.liteflow.core.NodeComponent; -import org.springframework.stereotype.Component; - -/** - * 测试mock component - * @author justin.xu - */ -@Component("s4") -public class S4Component extends NodeComponent { - - private static final String name = "s4"; - - @Override - public void process() throws Exception { - ConcurrentCase.caseAdd((String) getSlot().getRequestData(), new ConcurrentCase.Routers(getSlotIndex(), name)); - System.out.println(String.format("[%s] component executed, index[%d].", name, getSlotIndex())); - } -} diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/s/S5Component.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/s/S5Component.java deleted file mode 100644 index 4c20855dc..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/s/S5Component.java +++ /dev/null @@ -1,21 +0,0 @@ -package com.yomahub.flowtest.concurrent.mock.component.s; - -import com.yomahub.flowtest.concurrent.ConcurrentCase; -import com.yomahub.liteflow.core.NodeComponent; -import org.springframework.stereotype.Component; - -/** - * 测试mock component - * @author justin.xu - */ -@Component("s5") -public class S5Component extends NodeComponent { - - private static final String name = "s5"; - - @Override - public void process() throws Exception { - ConcurrentCase.caseAdd((String) getSlot().getRequestData(), new ConcurrentCase.Routers(getSlotIndex(), name)); - System.out.println(String.format("[%s] component executed, index[%d].", name, getSlotIndex())); - } -} \ No newline at end of file diff --git a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/s/S6Component.java b/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/s/S6Component.java deleted file mode 100644 index ee2578b6c..000000000 --- a/liteflow-test-springboot/src/test/java/com/yomahub/flowtest/concurrent/mock/component/s/S6Component.java +++ /dev/null @@ -1,21 +0,0 @@ -package com.yomahub.flowtest.concurrent.mock.component.s; - -import com.yomahub.flowtest.concurrent.ConcurrentCase; -import com.yomahub.liteflow.core.NodeComponent; -import org.springframework.stereotype.Component; - -/** - * 测试mock component - * @author justin.xu - */ -@Component("s6") -public class S6Component extends NodeComponent { - - private static final String name = "s6"; - - @Override - public void process() throws Exception { - ConcurrentCase.caseAdd((String) getSlot().getRequestData(), new ConcurrentCase.Routers(getSlotIndex(), name)); - System.out.println(String.format("[%s] component executed, index[%d].", name, getSlotIndex())); - } -} diff --git a/liteflow-test-springboot/src/test/resources/application-test.yml b/liteflow-test-springboot/src/test/resources/application-test.yml deleted file mode 100644 index a98fcc5ea..000000000 --- a/liteflow-test-springboot/src/test/resources/application-test.yml +++ /dev/null @@ -1,18 +0,0 @@ -logging: - level: - root: debug - io: - lettuce: info - pattern: - console: "%d{yyyy-MM-dd} %d{hhh:mm:ss},%red(%d{SSS}) %green(%-5level) [%thread] %cyan(%logger{36}) : %msg%n" - -server: - port: 8086 - -liteflow: - rule-source: "config/flow-test.xml" - -threadPool: - parallel: - worker: 3 - queue: 512 diff --git a/liteflow-test-springboot/src/test/resources/config/flow-test.xml b/liteflow-test-springboot/src/test/resources/config/flow-test.xml deleted file mode 100644 index 575a6da5b..000000000 --- a/liteflow-test-springboot/src/test/resources/config/flow-test.xml +++ /dev/null @@ -1,33 +0,0 @@ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -