diff --git a/liteflow-core/src/main/java/com/yomahub/liteflow/core/NodeComponent.java b/liteflow-core/src/main/java/com/yomahub/liteflow/core/NodeComponent.java
index 55fe2e5282249b310b2b73fb90a7bdf4a9df403a..7fcdd1d796842fdb8aec5fa2e2afa84fc5a4f35c 100644
--- a/liteflow-core/src/main/java/com/yomahub/liteflow/core/NodeComponent.java
+++ b/liteflow-core/src/main/java/com/yomahub/liteflow/core/NodeComponent.java
@@ -7,6 +7,7 @@
  */
 package com.yomahub.liteflow.core;
 
+import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.date.StopWatch;
 import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.StrUtil;
@@ -32,6 +33,7 @@ import com.yomahub.liteflow.monitor.CompStatistics;
 import com.yomahub.liteflow.monitor.MonitorBus;
 
 import java.lang.reflect.Method;
+import java.util.Deque;
 import java.util.Map;
 
 /**
@@ -156,10 +158,17 @@ public abstract class NodeComponent {
 
 	public void doRollback() throws Exception {
 		Slot slot = this.getSlot();
-
+		Deque<CmpStep> rollbackSteps = slot.getRollbackSteps();
+		if(!CollUtil.isEmpty(rollbackSteps)) {
+			for (CmpStep rollbackStep : rollbackSteps) {
+				Node refNode = rollbackStep.getRefNode();
+				if(refNode == this.getRefNode()) return;
+			}
+		}
 		CmpStep cmpStep = new CmpStep(nodeId, name, CmpStepTypeEnum.SINGLE);
 		cmpStep.setTag(this.getTag());
 		cmpStep.setInstance(this);
+		cmpStep.setRefNode(this.getRefNode());
 		slot.addRollbackStep(cmpStep);
 
 		StopWatch stopWatch = new StopWatch();
diff --git a/liteflow-testcase-el/liteflow-testcase-el-declare-multi-springboot/src/test/java/com/yomahub/liteflow/test/rollback/RollbackELDeclMultiSpringbootTest.java b/liteflow-testcase-el/liteflow-testcase-el-declare-multi-springboot/src/test/java/com/yomahub/liteflow/test/rollback/RollbackELDeclMultiSpringbootTest.java
index 022dc9aece4ce5e9843f9fb698b3f18992f8985d..8fcc1c34bfc1ff25a848741038308bea69d07d34 100644
--- a/liteflow-testcase-el/liteflow-testcase-el-declare-multi-springboot/src/test/java/com/yomahub/liteflow/test/rollback/RollbackELDeclMultiSpringbootTest.java
+++ b/liteflow-testcase-el/liteflow-testcase-el-declare-multi-springboot/src/test/java/com/yomahub/liteflow/test/rollback/RollbackELDeclMultiSpringbootTest.java
@@ -100,4 +100,12 @@ public class RollbackELDeclMultiSpringbootTest extends BaseTest {
 		Assertions.assertEquals("321", context.getData("test"));
 	}
 
+	@Test
+	// 对重试的测试
+	public void testRetry() throws Exception {
+		LiteflowResponse response = flowExecutor.execute2Resp("chain10", "arg");
+		Assertions.assertFalse(response.isSuccess());
+		Assertions.assertEquals("n==>m", response.getRollbackStepStr());
+	}
+
 }
diff --git a/liteflow-testcase-el/liteflow-testcase-el-declare-multi-springboot/src/test/java/com/yomahub/liteflow/test/rollback/cmp/CmpConfig.java b/liteflow-testcase-el/liteflow-testcase-el-declare-multi-springboot/src/test/java/com/yomahub/liteflow/test/rollback/cmp/CmpConfig.java
index 1c1e43ad8217ea36f21a1a156953a0dd9b530508..b88545014434dd045487b115306300da03b34d25 100644
--- a/liteflow-testcase-el/liteflow-testcase-el-declare-multi-springboot/src/test/java/com/yomahub/liteflow/test/rollback/cmp/CmpConfig.java
+++ b/liteflow-testcase-el/liteflow-testcase-el-declare-multi-springboot/src/test/java/com/yomahub/liteflow/test/rollback/cmp/CmpConfig.java
@@ -3,6 +3,7 @@ package com.yomahub.liteflow.test.rollback.cmp;
 import cn.hutool.core.collection.ListUtil;
 import com.yomahub.liteflow.annotation.LiteflowComponent;
 import com.yomahub.liteflow.annotation.LiteflowMethod;
+import com.yomahub.liteflow.annotation.LiteflowRetry;
 import com.yomahub.liteflow.core.NodeComponent;
 import com.yomahub.liteflow.enums.LiteFlowMethodEnum;
 import com.yomahub.liteflow.enums.NodeTypeEnum;
@@ -145,4 +146,32 @@ public class CmpConfig {
         System.out.println("XCmp rollback!");
     }
 
+    private int flag = 0;
+    @LiteflowRetry(5)
+    @LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "m")
+    public void processM(NodeComponent bindCmp) {
+        if(flag < 2) {
+            flag ++;
+            throw new RuntimeException();
+        }
+        System.out.println("MCmp executed!");
+    }
+
+    @LiteflowMethod(value = LiteFlowMethodEnum.ROLLBACK, nodeId = "m")
+    public void rollbackM() throws Exception {
+        System.out.println("MCmp rollback!");
+    }
+
+    @LiteflowRetry(3)
+    @LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "n")
+    public void processN(NodeComponent bindCmp) {
+        System.out.println("NCmp executed!");
+        throw new RuntimeException();
+    }
+
+    @LiteflowMethod(value = LiteFlowMethodEnum.ROLLBACK, nodeId = "n")
+    public void rollbackN() throws Exception {
+        System.out.println("NCmp rollback!");
+    }
+
 }
diff --git a/liteflow-testcase-el/liteflow-testcase-el-declare-multi-springboot/src/test/resources/rollback/flow.el.xml b/liteflow-testcase-el/liteflow-testcase-el-declare-multi-springboot/src/test/resources/rollback/flow.el.xml
index 887403167b90e4d6dcc8acab021df379b7b915e7..a6db91b4882542d89239bbbde9a777fd34e77954 100644
--- a/liteflow-testcase-el/liteflow-testcase-el-declare-multi-springboot/src/test/resources/rollback/flow.el.xml
+++ b/liteflow-testcase-el/liteflow-testcase-el-declare-multi-springboot/src/test/resources/rollback/flow.el.xml
@@ -35,4 +35,8 @@
     <chain name="chain9">
         THEN(a.tag("1"), a.tag("2"), a.tag("3"), d);
     </chain>
+
+    <chain name="chain10">
+        THEN( m, n );
+    </chain>
 </flow>
\ No newline at end of file
diff --git a/liteflow-testcase-el/liteflow-testcase-el-declare-springboot/src/test/java/com/yomahub/liteflow/test/rollback/RollbackELDeclSpringbootTest.java b/liteflow-testcase-el/liteflow-testcase-el-declare-springboot/src/test/java/com/yomahub/liteflow/test/rollback/RollbackELDeclSpringbootTest.java
index c89f3c72c6e859d72f6449013309d7d16ff3cfde..952c8567e9d732967fa9c53c23b3480eb423adaf 100644
--- a/liteflow-testcase-el/liteflow-testcase-el-declare-springboot/src/test/java/com/yomahub/liteflow/test/rollback/RollbackELDeclSpringbootTest.java
+++ b/liteflow-testcase-el/liteflow-testcase-el-declare-springboot/src/test/java/com/yomahub/liteflow/test/rollback/RollbackELDeclSpringbootTest.java
@@ -102,4 +102,12 @@ public class RollbackELDeclSpringbootTest extends BaseTest {
 		Assertions.assertEquals("321", context.getData("test"));
 	}
 
+	@Test
+	// 对重试的测试
+	public void testRetry() throws Exception {
+		LiteflowResponse response = flowExecutor.execute2Resp("chain10", "arg");
+		Assertions.assertFalse(response.isSuccess());
+		Assertions.assertEquals("n==>m", response.getRollbackStepStr());
+	}
+
 }
diff --git a/liteflow-testcase-el/liteflow-testcase-el-declare-springboot/src/test/resources/rollback/flow.el.xml b/liteflow-testcase-el/liteflow-testcase-el-declare-springboot/src/test/resources/rollback/flow.el.xml
index 2e46ba7aff8434371efd1e95947ce57ac2614269..8ab1a1403d28af0c11efee532dabc1887e0efee9 100644
--- a/liteflow-testcase-el/liteflow-testcase-el-declare-springboot/src/test/resources/rollback/flow.el.xml
+++ b/liteflow-testcase-el/liteflow-testcase-el-declare-springboot/src/test/resources/rollback/flow.el.xml
@@ -35,4 +35,8 @@
     <chain name="chain9">
         THEN(a.tag("1"), a.tag("2"), a.tag("3"), d);
     </chain>
+
+    <chain name="chain10">
+        THEN( m, n );
+    </chain>
 </flow>
\ No newline at end of file
diff --git a/liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/java/com/yomahub/liteflow/test/rollback/RollbackTest.java b/liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/java/com/yomahub/liteflow/test/rollback/RollbackTest.java
index f8d58918e9a2ad906edcd8ede1833cc0c3992e4d..97498e070d6f382b8ed4f1b23cdd31d0dae92d3e 100644
--- a/liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/java/com/yomahub/liteflow/test/rollback/RollbackTest.java
+++ b/liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/java/com/yomahub/liteflow/test/rollback/RollbackTest.java
@@ -99,4 +99,12 @@ public class RollbackTest extends BaseTest {
 		Assertions.assertEquals("321", context.getData("test"));
 	}
 
+	@Test
+	// 对重试的测试
+	public void testRetry() throws Exception {
+		LiteflowResponse response = flowExecutor.execute2Resp("chain10", "arg");
+		Assertions.assertFalse(response.isSuccess());
+		Assertions.assertEquals("n==>m", response.getRollbackStepStr());
+	}
+
 }
diff --git a/liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/resources/rollback/flow.el.xml b/liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/resources/rollback/flow.el.xml
index 7072cf2b9ddc73aaa7b60a39a6fc6d48f8b07032..da327932dc6433f347fdb5e0c8769b3aead5740b 100644
--- a/liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/resources/rollback/flow.el.xml
+++ b/liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/resources/rollback/flow.el.xml
@@ -12,6 +12,8 @@
         <node id="i" class="com.yomahub.liteflow.test.rollback.cmp.ICmp"/>
         <node id="w" class="com.yomahub.liteflow.test.rollback.cmp.WCmp"/>
         <node id="x" class="com.yomahub.liteflow.test.rollback.cmp.XCmp"/>
+        <node id="m" class="com.yomahub.liteflow.test.rollback.cmp.MCmp"/>
+        <node id="n" class="com.yomahub.liteflow.test.rollback.cmp.NCmp"/>
     </nodes>
     <chain name="chain1">
         THEN( a, b, WHEN(c, d).ignoreError(true), CATCH(e) );
@@ -48,4 +50,8 @@
     <chain name="chain9">
         THEN(a.tag("1"), a.tag("2"), a.tag("3"), d);
     </chain>
+
+    <chain name="chain10">
+        THEN( m, n );
+    </chain>
 </flow>
\ No newline at end of file
diff --git a/liteflow-testcase-el/liteflow-testcase-el-solon/src/test/java/com/yomahub/liteflow/test/rollback/RollbackSpringbootTest.java b/liteflow-testcase-el/liteflow-testcase-el-solon/src/test/java/com/yomahub/liteflow/test/rollback/RollbackSpringbootTest.java
index 07d7486f64c7cb2484123637d0a06fcda41446a5..fdaa63d621bcd3425cb94eed347250a972392fa2 100644
--- a/liteflow-testcase-el/liteflow-testcase-el-solon/src/test/java/com/yomahub/liteflow/test/rollback/RollbackSpringbootTest.java
+++ b/liteflow-testcase-el/liteflow-testcase-el-solon/src/test/java/com/yomahub/liteflow/test/rollback/RollbackSpringbootTest.java
@@ -94,4 +94,12 @@ public class RollbackSpringbootTest extends BaseTest {
 		Assertions.assertEquals("321", context.getData("test"));
 	}
 
+	@Test
+	// 对重试的测试
+	public void testRetry() throws Exception {
+		LiteflowResponse response = flowExecutor.execute2Resp("chain10", "arg");
+		Assertions.assertFalse(response.isSuccess());
+		Assertions.assertEquals("n==>m", response.getRollbackStepStr());
+	}
+
 }
diff --git a/liteflow-testcase-el/liteflow-testcase-el-solon/src/test/resources/rollback/flow.el.xml b/liteflow-testcase-el/liteflow-testcase-el-solon/src/test/resources/rollback/flow.el.xml
index 2e46ba7aff8434371efd1e95947ce57ac2614269..8ab1a1403d28af0c11efee532dabc1887e0efee9 100644
--- a/liteflow-testcase-el/liteflow-testcase-el-solon/src/test/resources/rollback/flow.el.xml
+++ b/liteflow-testcase-el/liteflow-testcase-el-solon/src/test/resources/rollback/flow.el.xml
@@ -35,4 +35,8 @@
     <chain name="chain9">
         THEN(a.tag("1"), a.tag("2"), a.tag("3"), d);
     </chain>
+
+    <chain name="chain10">
+        THEN( m, n );
+    </chain>
 </flow>
\ No newline at end of file
diff --git a/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/rollback/RollbackSpringbootTest.java b/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/rollback/RollbackSpringbootTest.java
index 8e230f7fa3983aac7c3144bba40f6acda67e7fca..133806e92423e94723b6bfad6d5c7d2d03287352 100644
--- a/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/rollback/RollbackSpringbootTest.java
+++ b/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/rollback/RollbackSpringbootTest.java
@@ -2,6 +2,8 @@ package com.yomahub.liteflow.test.rollback;
 
 import com.yomahub.liteflow.core.FlowExecutor;
 import com.yomahub.liteflow.flow.LiteflowResponse;
+import com.yomahub.liteflow.property.LiteflowConfig;
+import com.yomahub.liteflow.property.LiteflowConfigGetter;
 import com.yomahub.liteflow.slot.DefaultContext;
 import com.yomahub.liteflow.test.BaseTest;
 import org.junit.jupiter.api.Assertions;
@@ -97,4 +99,12 @@ public class RollbackSpringbootTest extends BaseTest {
 		Assertions.assertFalse(response.isSuccess());
 		Assertions.assertEquals("321", context.getData("test"));
 	}
+
+	@Test
+	// 对重试的测试
+	public void testRetry() throws Exception {
+		LiteflowResponse response = flowExecutor.execute2Resp("chain10", "arg");
+		Assertions.assertFalse(response.isSuccess());
+		Assertions.assertEquals("n==>m", response.getRollbackStepStr());
+	}
 }
diff --git a/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/rollback/cmp/MCmp.java b/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/rollback/cmp/MCmp.java
new file mode 100644
index 0000000000000000000000000000000000000000..975de743ccdbcd60555a0ae6fb6d68a546d0d975
--- /dev/null
+++ b/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/rollback/cmp/MCmp.java
@@ -0,0 +1,25 @@
+package com.yomahub.liteflow.test.rollback.cmp;
+
+import com.yomahub.liteflow.annotation.LiteflowRetry;
+import com.yomahub.liteflow.core.NodeComponent;
+import org.springframework.stereotype.Component;
+
+@Component("m")
+@LiteflowRetry(5)
+public class MCmp extends NodeComponent {
+
+    private int flag = 0;
+    @Override
+    public void process() {
+        if(flag < 2) {
+            flag ++;
+            throw new RuntimeException();
+        }
+        System.out.println("MCmp executed!");
+    }
+
+    @Override
+    public void rollback() throws Exception {
+        System.out.println("MCmp rollback!");
+    }
+}
diff --git a/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/rollback/cmp/NCmp.java b/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/rollback/cmp/NCmp.java
new file mode 100644
index 0000000000000000000000000000000000000000..65d5099687c54dcef0b6b70e65dc8132f4f89137
--- /dev/null
+++ b/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/rollback/cmp/NCmp.java
@@ -0,0 +1,20 @@
+package com.yomahub.liteflow.test.rollback.cmp;
+
+import com.yomahub.liteflow.annotation.LiteflowRetry;
+import com.yomahub.liteflow.core.NodeComponent;
+import org.springframework.stereotype.Component;
+
+@Component("n")
+@LiteflowRetry(3)
+public class NCmp extends NodeComponent {
+    @Override
+    public void process() {
+        System.out.println("NCmp executed!");
+        throw new RuntimeException();
+    }
+
+    @Override
+    public void rollback() throws Exception {
+        System.out.println("NCmp rollback!");
+    }
+}
diff --git a/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/resources/rollback/flow.el.xml b/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/resources/rollback/flow.el.xml
index 2e46ba7aff8434371efd1e95947ce57ac2614269..8ab1a1403d28af0c11efee532dabc1887e0efee9 100644
--- a/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/resources/rollback/flow.el.xml
+++ b/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/resources/rollback/flow.el.xml
@@ -35,4 +35,8 @@
     <chain name="chain9">
         THEN(a.tag("1"), a.tag("2"), a.tag("3"), d);
     </chain>
+
+    <chain name="chain10">
+        THEN( m, n );
+    </chain>
 </flow>
\ No newline at end of file
diff --git a/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/java/com/yomahub/liteflow/test/rollback/RollbackSpringTest.java b/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/java/com/yomahub/liteflow/test/rollback/RollbackSpringTest.java
index e4b08ccc9d0a66e1628c9b49629f8eed3a400842..59a4e6160c94bedc66cd9a4b45c8be80eb631163 100644
--- a/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/java/com/yomahub/liteflow/test/rollback/RollbackSpringTest.java
+++ b/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/java/com/yomahub/liteflow/test/rollback/RollbackSpringTest.java
@@ -95,5 +95,13 @@ public class RollbackSpringTest extends BaseTest {
 		Assertions.assertEquals("321", context.getData("test"));
 	}
 
+	@Test
+	// 对重试的测试
+	public void testRetry() throws Exception {
+		LiteflowResponse response = flowExecutor.execute2Resp("chain10", "arg");
+		Assertions.assertFalse(response.isSuccess());
+		Assertions.assertEquals("n==>m", response.getRollbackStepStr());
+	}
+
 
 }
diff --git a/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/java/com/yomahub/liteflow/test/rollback/cmp/MCmp.java b/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/java/com/yomahub/liteflow/test/rollback/cmp/MCmp.java
new file mode 100644
index 0000000000000000000000000000000000000000..975de743ccdbcd60555a0ae6fb6d68a546d0d975
--- /dev/null
+++ b/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/java/com/yomahub/liteflow/test/rollback/cmp/MCmp.java
@@ -0,0 +1,25 @@
+package com.yomahub.liteflow.test.rollback.cmp;
+
+import com.yomahub.liteflow.annotation.LiteflowRetry;
+import com.yomahub.liteflow.core.NodeComponent;
+import org.springframework.stereotype.Component;
+
+@Component("m")
+@LiteflowRetry(5)
+public class MCmp extends NodeComponent {
+
+    private int flag = 0;
+    @Override
+    public void process() {
+        if(flag < 2) {
+            flag ++;
+            throw new RuntimeException();
+        }
+        System.out.println("MCmp executed!");
+    }
+
+    @Override
+    public void rollback() throws Exception {
+        System.out.println("MCmp rollback!");
+    }
+}
diff --git a/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/java/com/yomahub/liteflow/test/rollback/cmp/NCmp.java b/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/java/com/yomahub/liteflow/test/rollback/cmp/NCmp.java
new file mode 100644
index 0000000000000000000000000000000000000000..65d5099687c54dcef0b6b70e65dc8132f4f89137
--- /dev/null
+++ b/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/java/com/yomahub/liteflow/test/rollback/cmp/NCmp.java
@@ -0,0 +1,20 @@
+package com.yomahub.liteflow.test.rollback.cmp;
+
+import com.yomahub.liteflow.annotation.LiteflowRetry;
+import com.yomahub.liteflow.core.NodeComponent;
+import org.springframework.stereotype.Component;
+
+@Component("n")
+@LiteflowRetry(3)
+public class NCmp extends NodeComponent {
+    @Override
+    public void process() {
+        System.out.println("NCmp executed!");
+        throw new RuntimeException();
+    }
+
+    @Override
+    public void rollback() throws Exception {
+        System.out.println("NCmp rollback!");
+    }
+}
diff --git a/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/resources/rollback/flow.el.xml b/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/resources/rollback/flow.el.xml
index 2e46ba7aff8434371efd1e95947ce57ac2614269..8ab1a1403d28af0c11efee532dabc1887e0efee9 100644
--- a/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/resources/rollback/flow.el.xml
+++ b/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/resources/rollback/flow.el.xml
@@ -35,4 +35,8 @@
     <chain name="chain9">
         THEN(a.tag("1"), a.tag("2"), a.tag("3"), d);
     </chain>
+
+    <chain name="chain10">
+        THEN( m, n );
+    </chain>
 </flow>
\ No newline at end of file