支持AOP方式配置事务

Author: 1991wangliang@gmail.com

txlcn-common/src/main/java/com/codingapi/txlcn/common/util/Transactions.java

@@ -43,6 +43,17 @@ public class Transactions {
 
     public static final String TAG_TASK = "Transaction Task";
 
+
+    /**
+     * 分布式事务类型 Properties传递参数key
+     */
+    public static final String DTX_TYPE = "DTX_TYPE";
+
+    /**
+     * 分布式事务传播类型 Properties传递参数key
+     */
+    public static final String DTX_PROPAGATION = "DTX_PROPAGATION";
+
     /////////// 工具方法  ////////////////////////////////////////////
 
     /**

txlcn-tc/src/main/java/com/codingapi/txlcn/tc/annotation/DTXPropagation.java

@@ -30,5 +30,22 @@ public enum DTXPropagation {
     /**
      * 当前没有分布式事务，非分布式事务运行。当前有分布式事务，就加入
      */
-    SUPPORTS
+    SUPPORTS;
+
+
+
+    public static DTXPropagation parser(String code){
+        switch (code){
+            case "REQUIRED":{
+                return REQUIRED;
+            }
+            case "SUPPORTS":{
+                return SUPPORTS;
+            }
+            default:{
+                return REQUIRED;
+            }
+        }
+    }
+
 }

txlcn-tc/src/main/java/com/codingapi/txlcn/tc/aspect/interceptor/DTXInterceptor.java

@@ -19,6 +19,8 @@
 import org.aopalliance.intercept.MethodInvocation;
 import org.springframework.transaction.interceptor.TransactionInterceptor;
 
+import java.util.Properties;
+
 /**
  * Description:
  * Date: 1/12/19
@@ -30,13 +32,21 @@ public class DTXInterceptor extends TransactionInterceptor {
 
     private final DTXLogicWeaver dtxLogicWeaver;
 
+    private Properties transactionAttributes;
+
     public DTXInterceptor(DTXLogicWeaver dtxLogicWeaver) {
         this.dtxLogicWeaver = dtxLogicWeaver;
     }
 
+    @Override
+    public void setTransactionAttributes(Properties transactionAttributes) {
+        this.transactionAttributes = transactionAttributes;
+        super.setTransactionAttributes(transactionAttributes);
+    }
+
     @Override
     public Object invoke(MethodInvocation invocation) throws Throwable {
-        return dtxLogicWeaver.runTransaction(InterceptorInvocationUtils.load(invocation), () -> super.invoke(invocation));
+        return dtxLogicWeaver.runTransaction(InterceptorInvocationUtils.load(invocation,transactionAttributes), () -> super.invoke(invocation));
     }
 
 }

txlcn-tc/src/main/java/com/codingapi/txlcn/tc/aspect/interceptor/InterceptorInvocationUtils.java

@@ -21,6 +21,7 @@
 import org.aopalliance.intercept.MethodInvocation;
 
 import java.util.Objects;
+import java.util.Properties;
 
 /**
  * Description:
@@ -31,11 +32,17 @@
  */
 class InterceptorInvocationUtils {
 
-    static DTXInfo load(MethodInvocation invocation) {
-        TxTransaction txTransaction = invocation.getMethod().getAnnotation(TxTransaction.class);
+    static DTXInfo load(MethodInvocation invocation, Properties transactionAttributes) {
+        //默认值
         String transactionType = Transactions.LCN;
         DTXPropagation dtxPropagation = DTXPropagation.REQUIRED;
-
+        //优先获取配置的信息
+        if(transactionAttributes!=null){
+            transactionType = transactionAttributes.getProperty(Transactions.DTX_TYPE);
+            dtxPropagation =  DTXPropagation.parser(transactionAttributes.getProperty(Transactions.DTX_PROPAGATION));
+        }
+        //获取注解的信息
+        TxTransaction txTransaction = invocation.getMethod().getAnnotation(TxTransaction.class);
         if (Objects.nonNull(txTransaction)) {
             transactionType = txTransaction.type();
             dtxPropagation = txTransaction.propagation();

txlcn-tc/src/main/java/com/codingapi/txlcn/tc/aspect/interceptor/TxLcnInterceptor.java

@@ -19,6 +19,8 @@
 import org.aopalliance.intercept.MethodInterceptor;
 import org.aopalliance.intercept.MethodInvocation;
 
+import java.util.Properties;
+
 /**
  * Description:
  * Date: 1/12/19
@@ -29,12 +31,18 @@ public class TxLcnInterceptor implements MethodInterceptor {
 
     private final DTXLogicWeaver dtxLogicWeaver;
 
+    private Properties transactionAttributes;
+
     public TxLcnInterceptor(DTXLogicWeaver dtxLogicWeaver) {
         this.dtxLogicWeaver = dtxLogicWeaver;
     }
 
+    public void setTransactionAttributes(Properties transactionAttributes) {
+        this.transactionAttributes = transactionAttributes;
+    }
+
     @Override
     public Object invoke(MethodInvocation invocation) throws Throwable {
-        return dtxLogicWeaver.runTransaction(InterceptorInvocationUtils.load(invocation), invocation::proceed);
+        return dtxLogicWeaver.runTransaction(InterceptorInvocationUtils.load(invocation,transactionAttributes), invocation::proceed);
     }
 }