clean txlcn project.

Author: ujued

txlcn-common/src/main/java/com/codingapi/txlcn/common/exception/BeforeBusinessException.java

@@ -21,7 +21,7 @@
  *
  * @author ujued
  */
-public class TransactionStateException extends Exception {
+public class TransactionStateException extends TransactionException {
     public static final int NON_MOD = 10;
     public static final int NON_ASPECT = 11;
     public static final int RPC_ERR = 12;

txlcn-common/src/main/java/com/codingapi/txlcn/common/exception/JoinGroupException.java

@@ -59,16 +59,22 @@ public Object runTransaction(DTXInfo dtxInfo, BusinessCallback business) throws
         log.debug("TX-unit start---->");
         DTXLocalContext dtxLocalContext = DTXLocalContext.getOrNew();
         TxContext txContext;
-        if (Objects.isNull(dtxLocalContext.getGroupId()) && !globalContext.hasTxContext()) {
-            // 非子Unit开启本地事务上下文
-            log.debug("Unit start TxContext.");
-            txContext = globalContext.startTx();
-        } else {
+        if (globalContext.hasTxContext()) {
             // 子Unit获取父上下文
             log.debug("Unit[{}] in unit: {}, use parent's TxContext.", dtxInfo.getUnitId(), dtxLocalContext.getUnitId());
             txContext = globalContext.txContext();
+            dtxLocalContext.setInGroup(true);
+        } else {
+            // 非子Unit开启本地事务上下文
+            log.debug("Unit start TxContext.");
+            txContext = globalContext.startTx();
+        }
+
+        // 本地事务调用
+        if (Objects.nonNull(dtxLocalContext.getGroupId())) {
             dtxLocalContext.setInUnit(true);
         }
+
         dtxLocalContext.setUnitId(dtxInfo.getUnitId());
         dtxLocalContext.setGroupId(txContext.getGroupId());
         dtxLocalContext.setTransactionType(dtxInfo.getTransactionType());

txlcn-common/src/main/java/com/codingapi/txlcn/common/exception/TransactionStateException.java

@@ -16,8 +16,8 @@
 package com.codingapi.txlcn.tc.aspect.weave;
 
 import com.codingapi.txlcn.tc.core.DTXLocalContext;
-import com.codingapi.txlcn.tc.support.TXLCNTransactionBeanHelper;
-import com.codingapi.txlcn.tc.support.resouce.TransactionResourceExecutor;
+import com.codingapi.txlcn.tc.support.TxLcnBeanHelper;
+import com.codingapi.txlcn.tc.support.resouce.TransactionResourceProxy;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 
@@ -35,19 +35,18 @@
 @Slf4j
 public class DTXResourceWeaver {
 
-    private final TXLCNTransactionBeanHelper transactionBeanHelper;
+    private final TxLcnBeanHelper txLcnBeanHelper;
 
-    public DTXResourceWeaver(TXLCNTransactionBeanHelper transactionBeanHelper) {
-        this.transactionBeanHelper = transactionBeanHelper;
+    public DTXResourceWeaver(TxLcnBeanHelper txLcnBeanHelper) {
+        this.txLcnBeanHelper = txLcnBeanHelper;
     }
 
     public Object getConnection(ConnectionCallback connectionCallback) throws Throwable {
         DTXLocalContext dtxLocalContext = DTXLocalContext.cur();
         if (Objects.nonNull(dtxLocalContext) && dtxLocalContext.isProxy()) {
             String transactionType = dtxLocalContext.getTransactionType();
-            TransactionResourceExecutor transactionResourceExecutor =
-                    transactionBeanHelper.loadTransactionResourceExecuter(transactionType);
-            Connection connection = transactionResourceExecutor.proxyConnection(connectionCallback);
+            TransactionResourceProxy resourceProxy = txLcnBeanHelper.loadTransactionResourceProxy(transactionType);
+            Connection connection = resourceProxy.proxyConnection(connectionCallback);
             log.debug("proxy a sql connection: {}.", connection);
             return connection;
         }

txlcn-tc/src/main/java/com/codingapi/txlcn/tc/aspect/weave/DTXLogicWeaver.java

@@ -60,6 +60,11 @@ public class DTXLocalContext {
      */
     private boolean inUnit;
 
+    /**
+     * 同事务组标识
+     */
+    private boolean inGroup;
+
     /**
      * 额外的附加值
      */

txlcn-tc/src/main/java/com/codingapi/txlcn/tc/aspect/weave/DTXResourceWeaver.java

@@ -15,8 +15,7 @@
  */
 package com.codingapi.txlcn.tc.core;
 
-import com.codingapi.txlcn.common.exception.BeforeBusinessException;
-import com.codingapi.txlcn.common.exception.TxClientException;
+import com.codingapi.txlcn.common.exception.TransactionException;
 
 /**
  *  LCN分布式事务控制
@@ -28,9 +27,9 @@ public interface DTXLocalControl {
      * 业务代码执行前
      *
      * @param info info
-     * @throws  BeforeBusinessException BeforeBusinessException
+     * @throws  TransactionException TransactionException
      */
-    default void preBusinessCode(TxTransactionInfo info) throws BeforeBusinessException {
+    default void preBusinessCode(TxTransactionInfo info) throws TransactionException {
 
     }
 
@@ -52,7 +51,7 @@ default Object doBusinessCode(TxTransactionInfo info) throws Throwable {
      * @param info info
      * @param throwable throwable
      */
-    default void onBusinessCodeError(TxTransactionInfo info, Throwable throwable) {
+    default void onBusinessCodeError(TxTransactionInfo info, Throwable throwable) throws TransactionException {
 
     }
 
@@ -61,9 +60,9 @@ default void onBusinessCodeError(TxTransactionInfo info, Throwable throwable) {
      *
      * @param info info
      * @param result result
-     * @throws TxClientException TxClientException
+     * @throws TransactionException TransactionException
      */
-    default void onBusinessCodeSuccess(TxTransactionInfo info, Object result) throws TxClientException {
+    default void onBusinessCodeSuccess(TxTransactionInfo info, Object result) throws TransactionException {
 
     }
 

txlcn-tc/src/main/java/com/codingapi/txlcn/tc/core/DTXLocalContext.java

@@ -18,38 +18,42 @@
 /**
  * @author lorne
  */
-public enum DTXLogicState {
+public enum DTXPropagationState {
 
     /**
-     * 发起事务状态
+     * 创建DTX
      */
-    STARTING("starting"),
+    CREATE("starting"),
 
     /**
-     * 参与中事务状态
+     * 加入DTX
      */
-    RUNNING("running"),
+    JOIN("running"),
 
     /**
-     * 默认事务
+     * 静默加入DTX
      */
-    DEFAULT("default"),
+    SILENT_JOIN("default"),
 
     /**
-     * 不参与分布式事务
+     * 不参与DTX
      */
     NON("non");
 
 
     private String code;
 
 
-    DTXLogicState(String code) {
+    DTXPropagationState(String code) {
         this.code = code;
     }
 
 
     public String getCode() {
         return code;
     }
+
+    public boolean isIgnored() {
+        return this.equals(NON);
+    }
 }

txlcn-tc/src/main/java/com/codingapi/txlcn/tc/core/DTXLocalControl.java

@@ -16,11 +16,11 @@
 package com.codingapi.txlcn.tc.core;
 
 
-import com.codingapi.txlcn.common.exception.BeforeBusinessException;
+import com.codingapi.txlcn.common.exception.TransactionException;
 import com.codingapi.txlcn.common.util.Transactions;
 import com.codingapi.txlcn.logger.TxLogger;
-import com.codingapi.txlcn.tc.core.propagation.TxLcnTransactionPropagationResolver;
-import com.codingapi.txlcn.tc.support.TXLCNTransactionBeanHelper;
+import com.codingapi.txlcn.tc.core.propagation.DTXPropagationResolver;
+import com.codingapi.txlcn.tc.support.TxLcnBeanHelper;
 import com.codingapi.txlcn.tc.core.context.TCGlobalContext;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -40,15 +40,15 @@ public class DTXServiceExecutor {
 
     private final TxLogger txLogger;
 
-    private final TXLCNTransactionBeanHelper txlcnTransactionBeanHelper;
+    private final TxLcnBeanHelper txLcnBeanHelper;
 
-    private final TxLcnTransactionPropagationResolver propagationResolver;
+    private final DTXPropagationResolver propagationResolver;
 
     @Autowired
-    public DTXServiceExecutor(TxLogger txLogger, TXLCNTransactionBeanHelper txlcnTransactionBeanHelper,
-                              TCGlobalContext globalContext, TxLcnTransactionPropagationResolver propagationResolver) {
+    public DTXServiceExecutor(TxLogger txLogger, TxLcnBeanHelper txLcnBeanHelper,
+                              TCGlobalContext globalContext, DTXPropagationResolver propagationResolver) {
         this.txLogger = txLogger;
-        this.txlcnTransactionBeanHelper = txlcnTransactionBeanHelper;
+        this.txLcnBeanHelper = txLcnBeanHelper;
         this.globalContext = globalContext;
         this.propagationResolver = propagationResolver;
     }
@@ -65,53 +65,48 @@ public Object transactionRunning(TxTransactionInfo info) throws Throwable {
         // 1. 获取事务类型
         String transactionType = info.getTransactionType();
 
-        // 2. 获取事务状态
-        DTXLogicState lcnTransactionState = propagationResolver.loadTransactionState(info);
+        // 2. 获取事务传播状态
+        DTXPropagationState propagationState = propagationResolver.resolvePropagationState(info);
 
         // 2.1 如果不参与分布式事务立即终止
-        if (lcnTransactionState.equals(DTXLogicState.NON)) {
+        if (propagationState.isIgnored()) {
             return info.getBusinessCallback().call();
         }
 
-        // 3. 获取bean
-        DTXLocalControl lcnTransactionControl =
-                txlcnTransactionBeanHelper.loadLCNTransactionControl(transactionType, lcnTransactionState);
+        // 3. 获取本地分布式事务控制器
+        DTXLocalControl dtxLocalControl = txLcnBeanHelper.loadDTXLocalControl(transactionType, propagationState);
 
         // 4. 织入事务操作
         try {
             // 4.1 记录事务类型到事务上下文
             Set<String> transactionTypeSet = globalContext.txContext(info.getGroupId()).getTransactionTypes();
             transactionTypeSet.add(transactionType);
 
+            dtxLocalControl.preBusinessCode(info);
+
             // 4.2 业务执行前
-            txLogger.info(info.getGroupId(), info.getUnitId(), Transactions.TAG_TRANSACTION,
-                    "pre service business code, add transaction type: %s, types: %s",
-                    transactionType, transactionTypeSet);
-            lcnTransactionControl.preBusinessCode(info);
+            txLogger.transactionInfo(
+                    info.getGroupId(), info.getUnitId(), "pre business code, unit type: %s", transactionType);
 
             // 4.3 执行业务
-            txLogger.info(info.getGroupId(), info.getUnitId(), Transactions.TAG_TRANSACTION,
-                    "do service business code");
-            Object result = lcnTransactionControl.doBusinessCode(info);
+            Object result = dtxLocalControl.doBusinessCode(info);
 
             // 4.4 业务执行成功
-            txLogger.info(info.getGroupId(), info.getUnitId(), Transactions.TAG_TRANSACTION,
-                    "service business success");
-            lcnTransactionControl.onBusinessCodeSuccess(info, result);
+            txLogger.transactionInfo(info.getGroupId(), info.getUnitId(), "business success");
+            dtxLocalControl.onBusinessCodeSuccess(info, result);
             return result;
-        } catch (BeforeBusinessException e) {
-            txLogger.error(info.getGroupId(), info.getUnitId(), Transactions.TAG_TRANSACTION,
-                    "before business code error");
+        } catch (TransactionException e) {
+            txLogger.error(info.getGroupId(), info.getUnitId(), "before business code error");
             throw e;
         } catch (Throwable e) {
             // 4.5 业务执行失败
             txLogger.error(info.getGroupId(), info.getUnitId(), Transactions.TAG_TRANSACTION,
                     "business code error");
-            lcnTransactionControl.onBusinessCodeError(info, e);
+            dtxLocalControl.onBusinessCodeError(info, e);
             throw e;
         } finally {
             // 4.6 业务执行完毕
-            lcnTransactionControl.postBusinessCode(info);
+            dtxLocalControl.postBusinessCode(info);
         }
     }