optimize: Modify workerid generation method

common/src/main/java/io/seata/common/util/IdWorker.java

@@ -14,8 +14,8 @@
  *  limitations under the License.
  */
 package io.seata.common.util;
-
-import java.util.concurrent.ThreadLocalRandom;
+import java.net.InetAddress;
+import java.net.UnknownHostException;
 
 /**
  * @author funkye
@@ -144,13 +144,24 @@ public static IdWorker getInstance() {
         if (idWorker == null) {
             synchronized (IdWorker.class) {
                 if (idWorker == null) {
-                    init(ThreadLocalRandom.current().nextLong(1024));
+                    init(initWorkerId());
                 }
             }
         }
         return idWorker;
     }
 
+    public static long initWorkerId() {
+        InetAddress address;
+        try {
+            address = InetAddress.getLocalHost();
+        } catch (final UnknownHostException e) {
+            throw new IllegalStateException("Cannot get LocalHost InetAddress, please check your network!");
+        }
+        byte[] ipAddressByteArray = address.getAddress();
+        return ((ipAddressByteArray[ipAddressByteArray.length - 2] & 0B11) << Byte.SIZE) + (ipAddressByteArray[ipAddressByteArray.length - 1] & 0xFF);
+    }
+
     public static void init(Long serverNodeId) {
         if (idWorker == null) {
             synchronized (IdWorker.class) {

common/src/main/java/io/seata/common/util/NumberUtils.java

@@ -53,4 +53,11 @@ public static Long toLong(String str, final Long defaultValue) {
             return defaultValue;
         }
     }
+
+    public static Long toLong(String str) {
+        if (StringUtils.isNotBlank(str)) {
+            return Long.valueOf(str);
+        }
+        return null;
+    }
 }

server/src/main/java/io/seata/server/ParameterParser.java

@@ -19,12 +19,12 @@
 import java.nio.file.Files;
 import java.nio.file.Path;
 import java.nio.file.Paths;
-import java.util.concurrent.ThreadLocalRandom;
 import java.util.stream.Stream;
 
 import com.beust.jcommander.JCommander;
 import com.beust.jcommander.Parameter;
 import com.beust.jcommander.ParameterException;
+import io.seata.common.util.IdWorker;
 import io.seata.common.util.NumberUtils;
 import io.seata.common.util.StringUtils;
 import io.seata.config.ConfigurationFactory;
@@ -49,7 +49,6 @@ public class ParameterParser {
 
     private static final int SERVER_DEFAULT_PORT = 8091;
     private static final String SERVER_DEFAULT_STORE_MODE = "file";
-    private static final Long SERVER_DEFAULT_NODE = ThreadLocalRandom.current().nextLong(1024);
 
     private static final String ENV_SYSTEM_KEY = "SEATA_ENV";
     private static final String ENV_SEATA_IP_KEY = "SEATA_IP";
@@ -68,8 +67,8 @@ public class ParameterParser {
     private int port = SERVER_DEFAULT_PORT;
     @Parameter(names = {"--storeMode", "-m"}, description = "log store mode : file, db", order = 3)
     private String storeMode;
-    @Parameter(names = {"--serverNode", "-n"}, description = "server node id, such as 1, 2, 3. default is 1", order = 4)
-    private Long serverNode = SERVER_DEFAULT_NODE;
+    @Parameter(names = {"--serverNode", "-n"}, description = "server node id, such as 1, 2, 3.it will be generated according to the snowflake by default", order = 4)
+    private Long serverNode;
     @Parameter(names = {"--seataEnv", "-e"}, description = "The name used for multi-configuration isolation.",
         order = 5)
     private String seataEnv;
@@ -93,7 +92,7 @@ private void init(String[] args) {
 
                 this.seataEnv = StringUtils.trimToNull(System.getenv(ENV_SYSTEM_KEY));
                 this.host = StringUtils.trimToNull(System.getenv(ENV_SEATA_IP_KEY));
-                this.serverNode = NumberUtils.toLong(System.getenv(ENV_SERVER_NODE_KEY), SERVER_DEFAULT_NODE);
+                this.serverNode = NumberUtils.toLong(System.getenv(ENV_SERVER_NODE_KEY));
                 this.port = NumberUtils.toInt(System.getenv(ENV_SEATA_PORT_KEY), SERVER_DEFAULT_PORT);
                 this.storeMode = StringUtils.trimToNull(System.getenv(ENV_STORE_MODE_KEY));
             } else {
@@ -105,6 +104,9 @@ private void init(String[] args) {
                     System.exit(0);
                 }
             }
+            if (this.serverNode == null) {
+                this.serverNode = IdWorker.initWorkerId();
+            }
             if (StringUtils.isNotBlank(seataEnv)) {
                 System.setProperty(ENV_PROPERTY_KEY, seataEnv);
             }
@@ -196,4 +198,4 @@ public String getSeataEnv() {
         return seataEnv;
     }
 
-}
+}