tx:clean

Author: ujued

example/spring-demo-client/src/main/java/com/codingapi/example/client/TransactionConfiguration.java

@@ -1,6 +1,6 @@
 package com.codingapi.example.client;
 
-import com.codingapi.tx.client.aspect.DTXInterceptor;
+import com.codingapi.tx.client.aspect.interceptor.DTXInterceptor;
 import com.codingapi.tx.client.aspect.weave.DTXLogicWeaver;
 import org.springframework.aop.framework.autoproxy.BeanNameAutoProxyCreator;
 import org.springframework.boot.autoconfigure.transaction.TransactionProperties;

tx-client/src/main/java/com/codingapi/tx/client/support/separate/CustomizableTransactionSeparator.java

@@ -27,7 +27,7 @@ public TXLCNTransactionState loadTransactionState(TxTransactionInfo txTransactio
         if (txTransactionInfo.isTransactionStart()) {
             // 发起方时，对于只加入DTX的事务单元走默认处理
             if (txTransactionInfo.getPropagation().equals(DTXPropagation.SUPPORTS)) {
-                return TXLCNTransactionState.DEFAULT;
+                return TXLCNTransactionState.NON;
             }
             return TXLCNTransactionState.STARTING;
         }

tx-client/src/main/java/com/codingapi/tx/client/support/separate/NoTransactionControl.java

@@ -0,0 +1,11 @@
+package com.codingapi.tx.client.support.separate;
+
+/**
+ * Description:
+ * Date: 19-1-13 下午5:19
+ *
+ * @author ujued
+ */
+
+public class NoTransactionControl implements TXLCNTransactionControl {
+}

tx-client/src/main/java/com/codingapi/tx/client/support/separate/TXLCNTransactionServiceExecutor.java

@@ -47,6 +47,10 @@ public Object transactionRunning(TxTransactionInfo info) throws Throwable {
 
         // 3. 获取事务状态
         TXLCNTransactionState lcnTransactionState = lcnTransactionSeparator.loadTransactionState(info);
+        // 3.1 如果不参与分布式事务立即终止
+        if (lcnTransactionState.equals(TXLCNTransactionState.NON)) {
+            return info.getBusinessCallback().call();
+        }
 
         // 4. 获取bean
         TXLCNTransactionControl lcnTransactionControl =
@@ -70,8 +74,8 @@ public Object transactionRunning(TxTransactionInfo info) throws Throwable {
             txLogger.trace(info.getGroupId(), info.getUnitId(), "transaction", "business code success");
             lcnTransactionControl.onBusinessCodeSuccess(info, result);
             return result;
-        }catch (BeforeBusinessException e){
-            log.error("business",e);
+        } catch (BeforeBusinessException e) {
+            log.error("business", e);
             throw e;
         } catch (Throwable e) {
             // 5.5 业务执行失败

tx-client/src/main/java/com/codingapi/tx/client/support/separate/TXLCNTransactionState.java

@@ -17,10 +17,15 @@ public enum TXLCNTransactionState {
      */
     RUNNING("running"),
 
+    /**
+     * 默认事务
+     */
+    DEFAULT("default"),
+
     /**
      * 不参与分布式事务
      */
-    DEFAULT("default");
+    NON("non");
 
 
     private String code;