分布式事务demo：AT模式

beston123 · beston123 · commit 4806b675b251 · 2020-01-10T14:10:05.000+08:00
diff --git a/src/main/java/code/distribution/at/common/ArgContext.java b/src/main/java/code/distribution/at/common/ArgContext.java
@@ -1,4 +1,4 @@
-package code.distribution.transcation.common;
+package code.distribution.at.common;
 
 import lombok.Data;
 
diff --git a/src/main/java/code/distribution/at/common/BranchStatus.java b/src/main/java/code/distribution/at/common/BranchStatus.java
@@ -1,4 +1,4 @@
-package code.distribution.transcation.common;
+package code.distribution.at.common;
 
 /**
  * 〈一句话功能简述〉<p>
diff --git a/src/main/java/code/distribution/at/common/GlobalStatus.java b/src/main/java/code/distribution/at/common/GlobalStatus.java
@@ -1,4 +1,4 @@
-package code.distribution.transcation.common;
+package code.distribution.at.common;
 
 /**
  * 〈一句话功能简述〉<p>
diff --git a/src/main/java/code/distribution/at/common/LockKey.java b/src/main/java/code/distribution/at/common/LockKey.java
@@ -1,4 +1,4 @@
-package code.distribution.transcation.common;
+package code.distribution.at.common;
 
 import lombok.Data;
 
diff --git a/src/main/java/code/distribution/at/common/RoleType.java b/src/main/java/code/distribution/at/common/RoleType.java
@@ -1,4 +1,4 @@
-package code.distribution.transcation.common;
+package code.distribution.at.common;
 
 /**
  * 〈一句话功能简述〉<p>
diff --git a/src/main/java/code/distribution/at/common/SimpleSqlExecutor.java b/src/main/java/code/distribution/at/common/SimpleSqlExecutor.java
@@ -1,4 +1,4 @@
-package code.distribution.transcation.common;
+package code.distribution.at.common;
 
 /**
  * 〈一句话功能简述〉<p>
diff --git a/src/main/java/code/distribution/at/common/SqlExecutor.java b/src/main/java/code/distribution/at/common/SqlExecutor.java
@@ -1,4 +1,4 @@
-package code.distribution.transcation.common;
+package code.distribution.at.common;
 
 /**
  * 〈一句话功能简述〉<p>
diff --git a/src/main/java/code/distribution/at/common/UndoLog.java b/src/main/java/code/distribution/at/common/UndoLog.java
@@ -1,4 +1,4 @@
-package code.distribution.transcation.common;
+package code.distribution.at.common;
 
 import lombok.Data;
 
diff --git a/src/main/java/code/distribution/at/exception/TxLockException.java b/src/main/java/code/distribution/at/exception/TxLockException.java
@@ -1,4 +1,4 @@
-package code.distribution.transcation.exception;
+package code.distribution.at.exception;
 
 /**
  * 〈一句话功能简述〉<p>
diff --git a/src/main/java/code/distribution/at/exception/TxLockTimeoutException.java b/src/main/java/code/distribution/at/exception/TxLockTimeoutException.java
@@ -1,4 +1,4 @@
-package code.distribution.transcation.exception;
+package code.distribution.at.exception;
 
 import java.text.MessageFormat;
 
diff --git a/src/main/java/code/distribution/at/package-info.java b/src/main/java/code/distribution/at/package-info.java
@@ -0,0 +1,8 @@
+/**
+ * 〈AT模式的分布式事务〉<p>
+ * 〈功能详细描述〉
+ *
+ * @author zixiao
+ * @date 2020/1/7
+ */
+package code.distribution.at;
diff --git a/src/main/java/code/distribution/at/rm/ResourceManager.java b/src/main/java/code/distribution/at/rm/ResourceManager.java
@@ -1,7 +1,7 @@
-package code.distribution.transcation.rm;
+package code.distribution.at.rm;
 
 
-import code.distribution.transcation.common.ArgContext;
+import code.distribution.at.common.ArgContext;
 
 import java.util.concurrent.Callable;
 
diff --git a/src/main/java/code/distribution/at/rm/SimpleResourceManager.java b/src/main/java/code/distribution/at/rm/SimpleResourceManager.java
@@ -1,13 +1,13 @@
-package code.distribution.transcation.rm;
+package code.distribution.at.rm;
 
 
-import code.distribution.transcation.common.*;
-import code.distribution.transcation.exception.TxLockException;
-import code.distribution.transcation.exception.TxLockTimeoutException;
-import code.distribution.transcation.tc.DefaultTransactionCoordinator;
-import code.distribution.transcation.tc.TransactionCoordinator;
-import code.distribution.transcation.utils.Log;
-import code.distribution.transcation.utils.ResourceId;
+import code.distribution.at.common.*;
+import code.distribution.at.exception.TxLockException;
+import code.distribution.at.exception.TxLockTimeoutException;
+import code.distribution.at.tc.AtTransactionCoordinator;
+import code.distribution.at.tc.TransactionCoordinator;
+import code.distribution.at.utils.Log;
+import code.distribution.at.utils.ResourceId;
 
 import java.util.concurrent.Callable;
 
@@ -24,7 +24,7 @@ public class SimpleResourceManager implements ResourceManager {
 
     private long timeout = 10 * 1000;
 
-    private TransactionCoordinator tc = DefaultTransactionCoordinator.getInstance();
+    private TransactionCoordinator tc = AtTransactionCoordinator.getInstance();
 
     private SqlExecutor sqlExecutor;
 
diff --git a/src/main/java/code/distribution/at/tc/AtTransactionCoordinator.java b/src/main/java/code/distribution/at/tc/AtTransactionCoordinator.java
@@ -1,10 +1,11 @@
-package code.distribution.transcation.tc;
+package code.distribution.at.tc;
 
 
-import code.distribution.transcation.common.BranchStatus;
-import code.distribution.transcation.common.GlobalStatus;
-import code.distribution.transcation.common.LockKey;
-import code.distribution.transcation.rm.ResourceManager;
+import code.distribution.at.common.BranchStatus;
+import code.distribution.at.common.GlobalStatus;
+import code.distribution.at.common.LockKey;
+import code.distribution.at.rm.ResourceManager;
+import com.google.common.collect.Lists;
 
 import java.util.ArrayList;
 import java.util.Iterator;
@@ -18,9 +19,9 @@
  * @author zixiao
  * @date 2019/2/25
  */
-public class DefaultTransactionCoordinator implements TransactionCoordinator {
+public class AtTransactionCoordinator implements TransactionCoordinator {
 
-    private static TransactionCoordinator instance = new DefaultTransactionCoordinator();
+    private static TransactionCoordinator instance = new AtTransactionCoordinator();
 
     private static ConcurrentHashMap<String, GlobalSession> globalSessionMap = new ConcurrentHashMap<>();
 
@@ -131,8 +132,7 @@ public boolean registerBranch(String xid, String resourceId, LockKey lockKey, Re
 
         List<BranchSession> branchSessions = branchSessionMap.get(xid);
         if(branchSessions == null){
-            branchSessions = new ArrayList<>();
-            branchSessions.add(branchSession);
+            branchSessions = Lists.newArrayList(branchSession);
             branchSessionMap.put(xid, branchSessions);
         }else{
             for (BranchSession session : branchSessions) {
diff --git a/src/main/java/code/distribution/at/tc/BranchSession.java b/src/main/java/code/distribution/at/tc/BranchSession.java
@@ -1,8 +1,8 @@
-package code.distribution.transcation.tc;
+package code.distribution.at.tc;
 
-import code.distribution.transcation.common.BranchStatus;
-import code.distribution.transcation.common.LockKey;
-import code.distribution.transcation.rm.ResourceManager;
+import code.distribution.at.common.BranchStatus;
+import code.distribution.at.common.LockKey;
+import code.distribution.at.rm.ResourceManager;
 import lombok.Data;
 
 import java.util.Iterator;
diff --git a/src/main/java/code/distribution/at/tc/GlobalSession.java b/src/main/java/code/distribution/at/tc/GlobalSession.java
@@ -1,7 +1,7 @@
-package code.distribution.transcation.tc;
+package code.distribution.at.tc;
 
-import code.distribution.transcation.common.GlobalStatus;
-import code.distribution.transcation.utils.Xid;
+import code.distribution.at.common.GlobalStatus;
+import code.distribution.at.utils.Xid;
 
 /**
  * 〈一句话功能简述〉<p>
diff --git a/src/main/java/code/distribution/at/tc/LockManager.java b/src/main/java/code/distribution/at/tc/LockManager.java
@@ -1,8 +1,8 @@
-package code.distribution.transcation.tc;
+package code.distribution.at.tc;
 
-import code.distribution.transcation.common.LockKey;
-import code.distribution.transcation.common.RoleType;
-import code.distribution.transcation.utils.Log;
+import code.distribution.at.common.LockKey;
+import code.distribution.at.common.RoleType;
+import code.distribution.at.utils.Log;
 import io.netty.util.internal.ConcurrentSet;
 
 import java.util.HashMap;
diff --git a/src/main/java/code/distribution/at/tc/TransactionCoordinator.java b/src/main/java/code/distribution/at/tc/TransactionCoordinator.java
@@ -1,8 +1,8 @@
-package code.distribution.transcation.tc;
+package code.distribution.at.tc;
 
-import code.distribution.transcation.common.BranchStatus;
-import code.distribution.transcation.common.LockKey;
-import code.distribution.transcation.rm.ResourceManager;
+import code.distribution.at.common.BranchStatus;
+import code.distribution.at.common.LockKey;
+import code.distribution.at.rm.ResourceManager;
 
 /**
  * 〈TC〉<p>
diff --git a/src/main/java/code/distribution/at/test/BranchServiceA.java b/src/main/java/code/distribution/at/test/BranchServiceA.java
@@ -1,10 +1,10 @@
-package code.distribution.transcation.test;
+package code.distribution.at.test;
 
-import code.distribution.transcation.common.ArgContext;
-import code.distribution.transcation.common.RoleType;
-import code.distribution.transcation.rm.ResourceManager;
-import code.distribution.transcation.rm.SimpleResourceManager;
-import code.distribution.transcation.utils.Log;
+import code.distribution.at.common.ArgContext;
+import code.distribution.at.common.RoleType;
+import code.distribution.at.rm.ResourceManager;
+import code.distribution.at.rm.SimpleResourceManager;
+import code.distribution.at.utils.Log;
 
 import java.util.Random;
 import java.util.concurrent.Callable;
diff --git a/src/main/java/code/distribution/at/test/BranchServiceB.java b/src/main/java/code/distribution/at/test/BranchServiceB.java
@@ -1,10 +1,10 @@
-package code.distribution.transcation.test;
+package code.distribution.at.test;
 
-import code.distribution.transcation.common.ArgContext;
-import code.distribution.transcation.common.RoleType;
-import code.distribution.transcation.rm.ResourceManager;
-import code.distribution.transcation.rm.SimpleResourceManager;
-import code.distribution.transcation.utils.Log;
+import code.distribution.at.common.ArgContext;
+import code.distribution.at.common.RoleType;
+import code.distribution.at.rm.ResourceManager;
+import code.distribution.at.rm.SimpleResourceManager;
+import code.distribution.at.utils.Log;
 
 import java.util.Random;
 import java.util.concurrent.Callable;
diff --git a/src/main/java/code/distribution/at/test/GlobalService.java b/src/main/java/code/distribution/at/test/GlobalService.java
@@ -1,9 +1,10 @@
-package code.distribution.transcation.test;
+package code.distribution.at.test;
 
-import code.distribution.transcation.common.RoleType;
-import code.distribution.transcation.tm.DefaultTransactionManager;
-import code.distribution.transcation.tm.TransactionManager;
-import code.distribution.transcation.utils.Log;
+import code.distribution.at.common.RoleType;
+import code.distribution.at.tm.AtTransactionManager;
+import code.distribution.at.tm.TransactionManager;
+import code.distribution.at.utils.Log;
+import org.junit.Test;
 
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
@@ -15,16 +16,30 @@
  * @author zixiao
  * @date 2019/2/25
  */
-public class GlobalServiceTest {
+public class GlobalService {
 
-    private TransactionManager tm = DefaultTransactionManager.getInstance();
+    private TransactionManager tm = AtTransactionManager.getInstance();
 
     private BranchServiceA branchServiceA = new BranchServiceA();
 
     private BranchServiceB branchServiceB = new BranchServiceB();
 
     private Log log = Log.getLog(RoleType.TM);
 
+    @Test
+    public void singleThreadTest(){
+        doBiz();
+    }
+
+    @Test
+    public void concurrentTest(){
+        ExecutorService executorService = Executors.newFixedThreadPool(2);
+        for (int i = 0; i < 2; i++) {
+            executorService.execute(() -> doBiz());
+        }
+        executorService.shutdown();
+    }
+
     public void doBiz(){
         //1、开启事务
         String xid = tm.begin();
@@ -42,28 +57,5 @@ public void doBiz(){
         }
     }
 
-    public static void main(String[] args) {
-        //singleThreadTest();
-        concurrentTest();
-    }
-
-    public static void singleThreadTest(){
-        GlobalServiceTest serviceTest = new GlobalServiceTest();
-        serviceTest.doBiz();
-    }
-
-    public static void concurrentTest(){
-        GlobalServiceTest serviceTest = new GlobalServiceTest();
-        ExecutorService executorService = Executors.newFixedThreadPool(2);
-        for (int i = 0; i < 2; i++) {
-            executorService.execute(new Runnable() {
-                @Override
-                public void run() {
-                    serviceTest.doBiz();
-                }
-            });
-        }
-        executorService.shutdown();
-    }
 
 }
diff --git a/src/main/java/code/distribution/at/tm/AtTransactionManager.java b/src/main/java/code/distribution/at/tm/AtTransactionManager.java
@@ -1,9 +1,9 @@
-package code.distribution.transcation.tm;
+package code.distribution.at.tm;
 
-import code.distribution.transcation.common.RoleType;
-import code.distribution.transcation.tc.DefaultTransactionCoordinator;
-import code.distribution.transcation.tc.TransactionCoordinator;
-import code.distribution.transcation.utils.Log;
+import code.distribution.at.common.RoleType;
+import code.distribution.at.tc.AtTransactionCoordinator;
+import code.distribution.at.tc.TransactionCoordinator;
+import code.distribution.at.utils.Log;
 
 /**
  * 〈事务管理器〉<p>
@@ -12,15 +12,15 @@
  * @author zixiao
  * @date 2019/2/25
  */
-public class DefaultTransactionManager implements TransactionManager {
+public class AtTransactionManager implements TransactionManager {
 
     private static Log log = Log.getLog(RoleType.TM);
 
-    private static TransactionManager instance = new DefaultTransactionManager();
+    private static TransactionManager instance = new AtTransactionManager();
 
-    private TransactionCoordinator tc = DefaultTransactionCoordinator.getInstance();
+    private TransactionCoordinator tc = AtTransactionCoordinator.getInstance();
 
-    private DefaultTransactionManager(){}
+    private AtTransactionManager(){}
 
     public static TransactionManager getInstance() {
         return instance;
diff --git a/src/main/java/code/distribution/at/tm/TransactionManager.java b/src/main/java/code/distribution/at/tm/TransactionManager.java
@@ -1,4 +1,4 @@
-package code.distribution.transcation.tm;
+package code.distribution.at.tm;
 
 /**
  * 〈TM〉<p>
diff --git a/src/main/java/code/distribution/at/utils/Log.java b/src/main/java/code/distribution/at/utils/Log.java
@@ -1,6 +1,6 @@
-package code.distribution.transcation.utils;
+package code.distribution.at.utils;
 
-import code.distribution.transcation.common.RoleType;
+import code.distribution.at.common.RoleType;
 
 import java.text.MessageFormat;
 import java.text.SimpleDateFormat;
diff --git a/src/main/java/code/distribution/at/utils/ResourceId.java b/src/main/java/code/distribution/at/utils/ResourceId.java
@@ -1,4 +1,4 @@
-package code.distribution.transcation.utils;
+package code.distribution.at.utils;
 
 import java.util.HashMap;
 import java.util.Map;
diff --git a/src/main/java/code/distribution/at/utils/Xid.java b/src/main/java/code/distribution/at/utils/Xid.java
@@ -1,4 +1,4 @@
-package code.distribution.transcation.utils;
+package code.distribution.at.utils;
 
 import code.util.NetworkUtils;
 
@@ -16,7 +16,6 @@ public class Xid {
     private static String IP_PORT;
 
     static {
-        System.out.println("NetworkUtils.getLocalHostIp");
         String ip = NetworkUtils.getLocalHostIp();
         IP_PORT = ip + ":" + "1234";
     }

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-package code.distribution.transcation.common;`
	`1`	`+package code.distribution.at.common;`
`2`	`2`
`3`	`3`	`import lombok.Data;`
`4`	`4`
Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-package code.distribution.transcation.exception;`
	`1`	`+package code.distribution.at.exception;`
`2`	`2`
`3`	`3`	`/**`
`4`	`4`	`* 〈一句话功能简述〉<p>`