feature: saga-remove spring (apache#6370)

wangliang181230 · Feb 29, 2024 · 709bd30 · 709bd30
1 parent 1939a9f
commit 709bd30
Show file tree

Hide file tree

Showing 67 changed files with 669 additions and 451 deletions.
diff --git a/all/pom.xml b/all/pom.xml
@@ -316,19 +316,13 @@
         </dependency>
         <dependency>
             <groupId>org.apache.seata</groupId>
-            <artifactId>seata-saga-tm</artifactId>
+            <artifactId>seata-saga-engine-store</artifactId>
             <version>${project.version}</version>
         </dependency>
         <dependency>
             <groupId>org.apache.seata</groupId>
-            <artifactId>seata-saga-engine-store</artifactId>
+            <artifactId>seata-saga-spring</artifactId>
             <version>${project.version}</version>
-            <exclusions>
-                <exclusion>
-                    <groupId>${project.groupId}</groupId>
-                    <artifactId>seata-serializer-all</artifactId>
-                </exclusion>
-            </exclusions>
         </dependency>
 
         <!-- spring  -->

diff --git a/bom/pom.xml b/bom/pom.xml
@@ -333,11 +333,6 @@
                 <artifactId>seata-saga-rm</artifactId>
                 <version>${project.version}</version>
             </dependency>
-            <dependency>
-                <groupId>org.apache.seata</groupId>
-                <artifactId>seata-saga-tm</artifactId>
-                <version>${project.version}</version>
-            </dependency>
             <dependency>
                 <groupId>org.apache.seata</groupId>
                 <artifactId>seata-saga-engine-store</artifactId>

diff --git a/changes/en-us/2.x.md b/changes/en-us/2.x.md
@@ -3,6 +3,7 @@ Add changes here for all PR submitted to the 2.x branch.
 <!-- Please add the `changes` to the following location(feature/bugfix/optimize/test) based on the type of PR -->
 
 ### feature:
+- [[#6370](https://github.com/seata/seata/pull/6370)] seata saga decouple spring, optimize architecture.
 - [[#6205](https://github.com/apache/incubator-seata/pull/6205)] mock server
 - [[#6169](https://github.com/apache/incubator-seata/pull/6169)] full support for states in the refactored state machine designer
 

diff --git a/changes/zh-cn/2.x.md b/changes/zh-cn/2.x.md
@@ -3,6 +3,7 @@
 <!-- 请根据PR的类型添加 `变更记录` 到以下对应位置(feature/bugfix/optimize/test) 下 -->
 
 ### feature:
+- [[#6370](https://github.com/seata/seata/pull/6370)] seata saga spring接耦、架构优化。
 - [[#6205](https://github.com/apache/incubator-seata/pull/6205)] 提供mock server
 - [[#6169](https://github.com/apache/incubator-seata/pull/6169)] 支持新版本状态机设计器
 

diff --git a/common/src/main/java/org/apache/seata/common/util/StringUtils.java b/common/src/main/java/org/apache/seata/common/util/StringUtils.java
@@ -427,4 +427,23 @@ public static String join(Iterator iterator, String separator) {
         return builder.toString();
     }
 
+    public static boolean hasLength(CharSequence str) {
+        return str != null && str.length() > 0;
+    }
+
+
+    public static boolean hasText(CharSequence str) {
+        if (str == null || str.length() == 0) {
+            return false;
+        }
+
+        int strLen = str.length();
+        for (int i = 0; i < strLen; i++) {
+            if (!Character.isWhitespace(str.charAt(i))) {
+                return true;
+            }
+        }
+        return false;
+    }
+
 }
diff --git a/compatible/pom.xml b/compatible/pom.xml
@@ -34,12 +34,7 @@
     <dependencies>
         <dependency>
             <groupId>org.apache.seata</groupId>
-            <artifactId>seata-saga-engine</artifactId>
-            <version>${project.version}</version>
-        </dependency>
-        <dependency>
-            <groupId>org.apache.seata</groupId>
-            <artifactId>seata-saga-engine-store</artifactId>
+            <artifactId>seata-saga-spring</artifactId>
             <version>${project.version}</version>
         </dependency>
         <dependency>
@@ -82,11 +77,6 @@
             <artifactId>seata-rm-datasource</artifactId>
             <version>${project.version}</version>
         </dependency>
-        <dependency>
-            <groupId>org.apache.seata</groupId>
-            <artifactId>seata-integration-tx-api</artifactId>
-            <version>${project.version}</version>
-        </dependency>
         <dependency>
             <groupId>org.apache.httpcomponents</groupId>
             <artifactId>httpclient</artifactId>

diff --git a/compatible/src/main/java/io/seata/saga/engine/StateMachineConfig.java b/compatible/src/main/java/io/seata/saga/engine/StateMachineConfig.java
@@ -26,7 +26,6 @@
 import org.apache.seata.saga.engine.store.StateLogStore;
 import org.apache.seata.saga.engine.strategy.StatusDecisionStrategy;
 import org.apache.seata.saga.proctrl.eventing.impl.ProcessCtrlEventPublisher;
-import org.springframework.context.ApplicationContext;
 
 import javax.script.ScriptEngineManager;
 import java.util.concurrent.ThreadPoolExecutor;
@@ -121,13 +120,6 @@ public interface StateMachineConfig {
      */
     ProcessCtrlEventPublisher getAsyncProcessCtrlEventPublisher();
 
-    /**
-     * Gets get application context.
-     *
-     * @return the get application context
-     */
-    ApplicationContext getApplicationContext();
-
     /**
      * Gets get thread pool executor.
      *

diff --git a/compatible/src/main/java/io/seata/saga/engine/impl/DefaultStateMachineConfig.java b/compatible/src/main/java/io/seata/saga/engine/impl/DefaultStateMachineConfig.java
@@ -35,10 +35,10 @@
 import org.springframework.beans.factory.InitializingBean;
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.ApplicationContextAware;
-import org.springframework.core.io.Resource;
 
 import javax.script.ScriptEngineManager;
 import java.io.IOException;
+import java.io.InputStream;
 import java.util.List;
 import java.util.concurrent.ThreadPoolExecutor;
 import java.util.stream.Collectors;
@@ -146,8 +146,8 @@ public StateMachine registryStateMachine(StateMachine stateMachine) {
             }
 
             @Override
-            public void registryByResources(Resource[] resources, String tenantId) throws IOException {
-                repository.registryByResources(resources, tenantId);
+            public void registryByResources(InputStream[] resourceAsStreamArray, String tenantId) throws IOException{
+                repository.registryByResources(resourceAsStreamArray, tenantId);
             }
         };
     }
@@ -189,7 +189,6 @@ public void setAsyncProcessCtrlEventPublisher(ProcessCtrlEventPublisher asyncPro
         actual.setAsyncProcessCtrlEventPublisher(asyncProcessCtrlEventPublisher);
     }
 
-    @Override
     public ApplicationContext getApplicationContext() {
         return actual.getApplicationContext();
     }

diff --git a/.../src/main/java/org/apache/seata/integration/tx/api/interceptor/InvocationHandlerType.java b/.../src/main/java/org/apache/seata/integration/tx/api/interceptor/InvocationHandlerType.java
@@ -21,6 +21,14 @@
  */
 public enum InvocationHandlerType {
 
-    GlobalTransactional, TwoPhaseAnnotation
+    /**
+     * GlobalTransactional InvocationHandler
+     */
+    GlobalTransactional,
+
+    /**
+     * TwoPhase InvocationHandler
+     */
+    TwoPhaseAnnotation
 
 }
diff --git a/saga/pom.xml b/saga/pom.xml
@@ -36,8 +36,8 @@
         <module>seata-saga-statelang</module>
         <module>seata-saga-engine</module>
         <module>seata-saga-rm</module>
-        <module>seata-saga-tm</module>
         <module>seata-saga-engine-store</module>
+        <module>seata-saga-spring</module>
     </modules>
 
     <dependencies>

diff --git a/saga/seata-saga-engine-store/pom.xml b/saga/seata-saga-engine-store/pom.xml
@@ -33,22 +33,17 @@
     <dependencies>
         <dependency>
             <groupId>${project.groupId}</groupId>
-            <artifactId>seata-saga-engine</artifactId>
+            <artifactId>seata-saga-statelang</artifactId>
             <version>${project.version}</version>
         </dependency>
         <dependency>
             <groupId>${project.groupId}</groupId>
-            <artifactId>seata-saga-rm</artifactId>
+            <artifactId>seata-saga-processctrl</artifactId>
             <version>${project.version}</version>
         </dependency>
         <dependency>
             <groupId>${project.groupId}</groupId>
-            <artifactId>seata-saga-tm</artifactId>
-            <version>${project.version}</version>
-        </dependency>
-        <dependency>
-            <groupId>${project.groupId}</groupId>
-            <artifactId>seata-serializer-all</artifactId>
+            <artifactId>seata-common</artifactId>
             <version>${project.version}</version>
         </dependency>
     </dependencies>

diff --git a/...ata/saga/engine/store/StateLangStore.java → ...ata/saga/engine/store/StateLangStore.java b/...ata/saga/engine/store/StateLangStore.java → ...ata/saga/engine/store/StateLangStore.java
@@ -48,4 +48,4 @@ public interface StateLangStore {
      * @return whether the store state machine action is successful
      */
     boolean storeStateMachine(StateMachine stateMachine);
-}
+}
diff --git a/...eata/saga/engine/store/StateLogStore.java → ...eata/saga/engine/store/StateLogStore.java b/...eata/saga/engine/store/StateLogStore.java → ...eata/saga/engine/store/StateLogStore.java
@@ -114,4 +114,4 @@ public interface StateLogStore {
      * clear the LocalThread
      */
     void clearUp();
-}
+}
diff --git a/...in/resources/META-INF/services/org.apache.seata.saga.engine.pcext.StateHandlerInterceptor b/...in/resources/META-INF/services/org.apache.seata.saga.engine.pcext.StateHandlerInterceptor
diff --git a/saga/seata-saga-engine/pom.xml b/saga/seata-saga-engine/pom.xml
@@ -38,20 +38,18 @@
         </dependency>
         <dependency>
             <groupId>${project.groupId}</groupId>
-            <artifactId>seata-saga-processctrl</artifactId>
+            <artifactId>seata-saga-engine-store</artifactId>
             <version>${project.version}</version>
         </dependency>
         <dependency>
-            <groupId>org.springframework</groupId>
-            <artifactId>spring-context</artifactId>
-        </dependency>
-        <dependency>
-            <groupId>org.springframework</groupId>
-            <artifactId>spring-beans</artifactId>
+            <groupId>${project.groupId}</groupId>
+            <artifactId>seata-saga-processctrl</artifactId>
+            <version>${project.version}</version>
         </dependency>
         <dependency>
-            <groupId>org.springframework</groupId>
-            <artifactId>spring-expression</artifactId>
+            <groupId>${project.groupId}</groupId>
+            <artifactId>seata-tm</artifactId>
+            <version>${project.version}</version>
         </dependency>
     </dependencies>
 

diff --git a/saga/seata-saga-engine/src/main/java/org/apache/seata/saga/engine/StateMachineConfig.java b/saga/seata-saga-engine/src/main/java/org/apache/seata/saga/engine/StateMachineConfig.java
@@ -16,8 +16,6 @@
  */
 package org.apache.seata.saga.engine;
 
-import java.util.concurrent.ThreadPoolExecutor;
-
 import org.apache.seata.saga.engine.expression.ExpressionFactoryManager;
 import org.apache.seata.saga.engine.expression.ExpressionResolver;
 import org.apache.seata.saga.engine.invoker.ServiceInvokerManager;
@@ -28,9 +26,9 @@
 import org.apache.seata.saga.engine.store.StateLogStore;
 import org.apache.seata.saga.engine.strategy.StatusDecisionStrategy;
 import org.apache.seata.saga.proctrl.eventing.impl.ProcessCtrlEventPublisher;
-import org.springframework.context.ApplicationContext;
 
 import javax.script.ScriptEngineManager;
+import java.util.concurrent.ThreadPoolExecutor;
 
 /**
  * StateMachineConfig
@@ -122,13 +120,6 @@ public interface StateMachineConfig {
      */
     ProcessCtrlEventPublisher getAsyncProcessCtrlEventPublisher();
 
-    /**
-     * Gets get application context.
-     *
-     * @return the get application context
-     */
-    ApplicationContext getApplicationContext();
-
     /**
      * Gets get thread pool executor.
      *