fix bug.

Author: ujued

txlcn-common/src/main/java/com/codingapi/txlcn/common/util/id/DefaultIdGen.java

@@ -12,6 +12,8 @@
 public abstract class IdGenInit {
 
     public static void applySnowFlakeIdGen(int machineLen, int machineId) {
-        RandomUtils.init(new DefaultIdGen(machineLen, 12, machineId));
+        SnowFlakeGenerator.Factory factory = new SnowFlakeGenerator.Factory(machineLen, 0);
+        SnowFlakeGenerator snowFlakeGenerator = factory.create(0, machineId);
+        RandomUtils.init(snowFlakeGenerator::nextId);
     }
 }

txlcn-common/src/main/java/com/codingapi/txlcn/common/util/id/IdGenInit.java

@@ -17,8 +17,6 @@
 
 import java.util.Objects;
 import java.util.UUID;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
 
 /**
  * @author lorne 2018/12/2
@@ -45,22 +43,4 @@ public static String randomKey() {
     public static String simpleKey() {
         return String.valueOf(System.nanoTime());
     }
-
-    static volatile String last = "";
-
-    public static void main(String[] args) {
-        IdGenInit.applySnowFlakeIdGen(10, 1);
-        System.out.println(randomKey());
-
-        ExecutorService executorService = Executors.newFixedThreadPool(20);
-        for (int i = 0; i < 100; i++) {
-            executorService.submit(() -> {
-                String now = randomKey();
-                if (now.equals(last)) {
-                    System.out.println("error");
-                }
-                last = now;
-            });
-        }
-    }
 }

txlcn-common/src/main/java/com/codingapi/txlcn/common/util/id/RandomUtils.java

@@ -93,7 +93,7 @@ public TxManagerConfig(ServerProperties serverProperties) {
     /**
      * 机器ID长度
      */
-    private int machineIdLen = 20;
+    private int machineIdLen = 10;
 
     public long getDtxLockTime() {
         return dtxLockTime == -1 ? dtxTime : dtxLockTime;