From 9aeb10d40f90e0c5351db92ecf4667814aedb4fb Mon Sep 17 00:00:00 2001
From: bryan31 <weenyc31@163.com>
Date: Sat, 5 Mar 2022 23:56:25 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A1=A5=E5=85=85=E6=B5=8B=E8=AF=95=E7=94=A8?=
 =?UTF-8?q?=E4=BE=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../CustomerDefaultNodeExecutor.java          | 19 ++++++
 .../nodeExecutor/CustomerNodeExecutor.java    | 20 ++++++
 .../CustomerNodeExecutorAndCustomRetry.java   | 29 ++++++++
 .../LiteflowNodeExecutorTest.java             | 66 +++++++++++++++++++
 .../liteflow/test/nodeExecutor/cmp/ACmp.java  | 20 ++++++
 .../liteflow/test/nodeExecutor/cmp/BCmp.java  | 25 +++++++
 .../liteflow/test/nodeExecutor/cmp/CCmp.java  | 27 ++++++++
 .../liteflow/test/nodeExecutor/cmp/DCmp.java  | 29 ++++++++
 .../src/test/resources/nodeExecutor/flow.xml  | 25 +++++++
 9 files changed, 260 insertions(+)
 create mode 100644 liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/CustomerDefaultNodeExecutor.java
 create mode 100644 liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/CustomerNodeExecutor.java
 create mode 100644 liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/CustomerNodeExecutorAndCustomRetry.java
 create mode 100644 liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/LiteflowNodeExecutorTest.java
 create mode 100644 liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/cmp/ACmp.java
 create mode 100644 liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/cmp/BCmp.java
 create mode 100644 liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/cmp/CCmp.java
 create mode 100644 liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/cmp/DCmp.java
 create mode 100644 liteflow-testcase-nospring/src/test/resources/nodeExecutor/flow.xml

diff --git a/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/CustomerDefaultNodeExecutor.java b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/CustomerDefaultNodeExecutor.java
new file mode 100644
index 000000000..84b60247a
--- /dev/null
+++ b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/CustomerDefaultNodeExecutor.java
@@ -0,0 +1,19 @@
+package com.yomahub.liteflow.test.nodeExecutor;
+
+import com.yomahub.liteflow.core.NodeComponent;
+import com.yomahub.liteflow.entity.data.DataBus;
+import com.yomahub.liteflow.entity.data.Slot;
+import com.yomahub.liteflow.entity.executor.NodeExecutor;
+
+/**
+ * 自定义默认的节点执行器
+ */
+public class CustomerDefaultNodeExecutor extends NodeExecutor {
+    @Override
+    public void execute(NodeComponent instance) throws Exception {
+        Slot slot = DataBus.getSlot(instance.getSlotIndex());
+        LOG.info("使用customerDefaultNodeExecutor进行执行");
+        slot.setData("customerDefaultNodeExecutor", this.getClass());
+        super.execute(instance);
+    }
+}
diff --git a/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/CustomerNodeExecutor.java b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/CustomerNodeExecutor.java
new file mode 100644
index 000000000..247bc3d47
--- /dev/null
+++ b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/CustomerNodeExecutor.java
@@ -0,0 +1,20 @@
+package com.yomahub.liteflow.test.nodeExecutor;
+
+import com.yomahub.liteflow.core.NodeComponent;
+import com.yomahub.liteflow.entity.data.DataBus;
+import com.yomahub.liteflow.entity.data.Slot;
+import com.yomahub.liteflow.entity.executor.NodeExecutor;
+
+/**
+ * 自定义节点执行器
+ */
+public class CustomerNodeExecutor extends NodeExecutor {
+    @Override
+    public void execute(NodeComponent instance) throws Exception {
+        Slot slot = DataBus.getSlot(instance.getSlotIndex());
+        LOG.info("使用customerNodeExecutor进行执行");
+        slot.setData("customerNodeExecutor", this.getClass());
+        super.execute(instance);
+    }
+
+}
diff --git a/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/CustomerNodeExecutorAndCustomRetry.java b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/CustomerNodeExecutorAndCustomRetry.java
new file mode 100644
index 000000000..46792852a
--- /dev/null
+++ b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/CustomerNodeExecutorAndCustomRetry.java
@@ -0,0 +1,29 @@
+package com.yomahub.liteflow.test.nodeExecutor;
+
+import com.yomahub.liteflow.core.NodeComponent;
+import com.yomahub.liteflow.entity.data.DataBus;
+import com.yomahub.liteflow.entity.data.Slot;
+import com.yomahub.liteflow.entity.executor.NodeExecutor;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * 自定义节点执行器
+ */
+public class CustomerNodeExecutorAndCustomRetry extends NodeExecutor {
+    @Override
+    public void execute(NodeComponent instance) throws Exception {
+        Slot slot = DataBus.getSlot(instance.getSlotIndex());
+        LOG.info("使用customerNodeExecutorAndCustomRetry进行执行");
+        slot.setData("customerNodeExecutorAndCustomRetry", this.getClass());
+        super.execute(instance);
+    }
+
+    @Override
+    protected void retry(NodeComponent instance, int currentRetryCount) throws Exception {
+        TimeUnit.MICROSECONDS.sleep(20L);
+        Slot slot = DataBus.getSlot(instance.getSlotIndex());
+        slot.setData("retryLogic", this.getClass());
+        super.retry(instance, currentRetryCount);
+    }
+}
diff --git a/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/LiteflowNodeExecutorTest.java b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/LiteflowNodeExecutorTest.java
new file mode 100644
index 000000000..60153647c
--- /dev/null
+++ b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/LiteflowNodeExecutorTest.java
@@ -0,0 +1,66 @@
+package com.yomahub.liteflow.test.nodeExecutor;
+
+import com.yomahub.liteflow.core.FlowExecutor;
+import com.yomahub.liteflow.entity.data.DefaultSlot;
+import com.yomahub.liteflow.entity.data.LiteflowResponse;
+import com.yomahub.liteflow.property.LiteflowConfig;
+import com.yomahub.liteflow.test.BaseTest;
+import org.junit.Assert;
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+
+/**
+ * 测试非spring环境下的自定义组件执行器
+ * @author Bryan.Zhang
+ * @since 2.5.10
+ */
+public class LiteflowNodeExecutorTest extends BaseTest {
+
+    private static FlowExecutor flowExecutor;
+
+    @BeforeClass
+    public static void init(){
+        LiteflowConfig config = new LiteflowConfig();
+        config.setRuleSource("nodeExecutor/flow.xml");
+        config.setRetryCount(3);
+        config.setSlotSize(512);
+        config.setNodeExecutorClass("com.yomahub.liteflow.test.nodeExecutor.CustomerDefaultNodeExecutor");
+        flowExecutor = FlowExecutor.loadInstance(config);
+    }
+
+    // 默认执行器测试
+    @Test
+    public void testCustomerDefaultNodeExecutor() {
+        LiteflowResponse<DefaultSlot> response = flowExecutor.execute2Resp("chain1", "arg");
+        Assert.assertTrue(response.isSuccess());
+        Assert.assertEquals(CustomerDefaultNodeExecutor.class, response.getSlot().getData("customerDefaultNodeExecutor"));
+        Assert.assertEquals("a", response.getSlot().getExecuteStepStr());
+    }
+
+    //默认执行器测试+全局重试配置测试
+    @Test
+    public void testDefaultExecutorForRetry() {
+        LiteflowResponse<DefaultSlot> response = flowExecutor.execute2Resp("chain2", "arg");
+        Assert.assertTrue(response.isSuccess());
+        Assert.assertEquals(CustomerDefaultNodeExecutor.class, response.getSlot().getData("customerDefaultNodeExecutor"));
+        Assert.assertEquals("b==>b==>b", response.getSlot().getExecuteStepStr());
+    }
+
+    //自定义执行器测试
+    @Test
+    public void testCustomerExecutor() {
+        LiteflowResponse<DefaultSlot> response = flowExecutor.execute2Resp("chain3", "arg");
+        Assert.assertTrue(response.isSuccess());
+        Assert.assertEquals("c", response.getSlot().getExecuteStepStr());
+    }
+
+    //自定义执行器测试+全局重试配置测试
+    @Test
+    public void testCustomExecutorForRetry() {
+        LiteflowResponse<DefaultSlot> response = flowExecutor.execute2Resp("chain4", "arg");
+        Assert.assertFalse(response.isSuccess());
+        Assert.assertEquals(CustomerNodeExecutorAndCustomRetry.class, response.getSlot().getData("retryLogic"));
+        Assert.assertEquals("d==>d==>d==>d==>d==>d", response.getSlot().getExecuteStepStr());
+    }
+}
diff --git a/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/cmp/ACmp.java b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/cmp/ACmp.java
new file mode 100644
index 000000000..1396310b8
--- /dev/null
+++ b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/cmp/ACmp.java
@@ -0,0 +1,20 @@
+/**
+ * <p>Title: liteflow</p>
+ * <p>Description: 轻量级的组件式流程框架</p>
+ *
+ * @author Bryan.Zhang
+ * @email weenyc31@163.com
+ * @Date 2020/4/1
+ */
+package com.yomahub.liteflow.test.nodeExecutor.cmp;
+
+import com.yomahub.liteflow.core.NodeComponent;
+
+public class ACmp extends NodeComponent {
+
+    @Override
+    public void process() {
+        System.out.println("ACmp executed!");
+    }
+
+}
diff --git a/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/cmp/BCmp.java b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/cmp/BCmp.java
new file mode 100644
index 000000000..4ab073c46
--- /dev/null
+++ b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/cmp/BCmp.java
@@ -0,0 +1,25 @@
+/**
+ * <p>Title: liteflow</p>
+ * <p>Description: 轻量级的组件式流程框架</p>
+ * @author Bryan.Zhang
+ * @email weenyc31@163.com
+ * @Date 2020/4/1
+ */
+package com.yomahub.liteflow.test.nodeExecutor.cmp;
+
+import com.yomahub.liteflow.core.NodeComponent;
+
+public class BCmp extends NodeComponent {
+
+	private int flag = 0;
+
+	@Override
+	public void process() {
+		System.out.println("BCmp executed!");
+		if (flag < 2){
+			flag++;
+			throw new RuntimeException("demo exception");
+		}
+	}
+
+}
diff --git a/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/cmp/CCmp.java b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/cmp/CCmp.java
new file mode 100644
index 000000000..084d6e9d4
--- /dev/null
+++ b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/cmp/CCmp.java
@@ -0,0 +1,27 @@
+/**
+ * <p>Title: liteflow</p>
+ * <p>Description: 轻量级的组件式流程框架</p>
+ * @author Bryan.Zhang
+ * @email weenyc31@163.com
+ * @Date 2020/4/1
+ */
+package com.yomahub.liteflow.test.nodeExecutor.cmp;
+
+import com.yomahub.liteflow.annotation.LiteflowRetry;
+import com.yomahub.liteflow.core.NodeComponent;
+import com.yomahub.liteflow.entity.executor.NodeExecutor;
+import com.yomahub.liteflow.test.nodeExecutor.CustomerNodeExecutor;
+
+@LiteflowRetry(5)
+public class CCmp extends NodeComponent {
+
+	@Override
+	public void process() {
+		System.out.println("CCmp executed!");
+	}
+
+	@Override
+	public  Class<? extends NodeExecutor> getNodeExecutorClass() {
+		return CustomerNodeExecutor.class;
+	}
+}
diff --git a/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/cmp/DCmp.java b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/cmp/DCmp.java
new file mode 100644
index 000000000..a5ccc27ea
--- /dev/null
+++ b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/nodeExecutor/cmp/DCmp.java
@@ -0,0 +1,29 @@
+/**
+ * <p>Title: liteflow</p>
+ * <p>Description: 轻量级的组件式流程框架</p>
+ *
+ * @author Bryan.Zhang
+ * @email weenyc31@163.com
+ * @Date 2020/4/1
+ */
+package com.yomahub.liteflow.test.nodeExecutor.cmp;
+
+import com.yomahub.liteflow.annotation.LiteflowRetry;
+import com.yomahub.liteflow.core.NodeComponent;
+import com.yomahub.liteflow.entity.executor.NodeExecutor;
+import com.yomahub.liteflow.test.nodeExecutor.CustomerNodeExecutorAndCustomRetry;
+
+@LiteflowRetry(retry = 5, forExceptions = {NullPointerException.class})
+public class DCmp extends NodeComponent {
+
+    @Override
+    public void process() {
+        System.out.println("DCmp executed!");
+        throw new NullPointerException("demo exception");
+    }
+
+    @Override
+    public Class<? extends NodeExecutor> getNodeExecutorClass() {
+        return CustomerNodeExecutorAndCustomRetry.class;
+    }
+}
diff --git a/liteflow-testcase-nospring/src/test/resources/nodeExecutor/flow.xml b/liteflow-testcase-nospring/src/test/resources/nodeExecutor/flow.xml
new file mode 100644
index 000000000..5a4010a28
--- /dev/null
+++ b/liteflow-testcase-nospring/src/test/resources/nodeExecutor/flow.xml
@@ -0,0 +1,25 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<flow>
+    <nodes>
+        <node id="a" class="com.yomahub.liteflow.test.nodeExecutor.cmp.ACmp"/>
+        <node id="b" class="com.yomahub.liteflow.test.nodeExecutor.cmp.BCmp"/>
+        <node id="c" class="com.yomahub.liteflow.test.nodeExecutor.cmp.CCmp"/>
+        <node id="d" class="com.yomahub.liteflow.test.nodeExecutor.cmp.DCmp"/>
+    </nodes>
+
+    <chain name="chain1">
+        <then value="a"/>
+    </chain>
+
+    <chain name="chain2">
+        <then value="b"/>
+    </chain>
+
+    <chain name="chain3">
+        <then value="c"/>
+    </chain>
+
+    <chain name="chain4">
+        <then value="d"/>
+    </chain>
+</flow>
\ No newline at end of file