optimize: RM TM startup connect server fail fast

changes/en-us/2.0.0.md

@@ -148,6 +148,7 @@ The version is updated as follows:
 - [[#5938](https://github.com/seata/seata/pull/5938)] support jmx port in seata
 - [[#5951](https://github.com/seata/seata/pull/5951)] remove un support config in jdk17
 - [[#5959](https://github.com/seata/seata/pull/5959)] modify code style and remove unused import
+- [[#6004](https://github.com/seata/seata/pull/6004)] optimize RM TM startup connect server fail fast
 
 ### security:
 - [[#5642](https://github.com/seata/seata/pull/5642)] add Hessian Serializer WhiteDenyList

changes/zh-cn/2.0.0.md

@@ -148,6 +148,7 @@ Seata 是一款开源的分布式事务解决方案，提供高性能和简单
 - [[#5938](https://github.com/seata/seata/pull/5938)] 支持 jmx 监控配置
 - [[#5951](https://github.com/seata/seata/pull/5951)] 删除在 jdk17 中不支持的配置项
 - [[#5959](https://github.com/seata/seata/pull/5959)] 修正代码风格问题及去除无用的类引用
+- [[#6004](https://github.com/seata/seata/pull/6004)] 优化RM,TM连接server快速失败
 
 
 ### security:

common/src/main/java/io/seata/common/ConfigurationKeys.java

@@ -638,6 +638,11 @@ public interface ConfigurationKeys {
      */
     String ENABLE_TM_CLIENT_BATCH_SEND_REQUEST = TRANSPORT_PREFIX + "enableTmClientBatchSendRequest";
 
+    /**
+     * The constant ENABLE_CLIENT_CHANNEL_CHECK_FAIL_FAST
+     */
+    String ENABLE_CLIENT_CHANNEL_CHECK_FAIL_FAST = TRANSPORT_PREFIX + "enableClientChannelCheckFailFast";
+
     /**
      * The constant ENABLE_RM_CLIENT_BATCH_SEND_REQUEST
      */

common/src/main/java/io/seata/common/DefaultValues.java

@@ -60,6 +60,8 @@ public interface DefaultValues {
     boolean DEFAULT_ENABLE_RM_CLIENT_BATCH_SEND_REQUEST = true;
     boolean DEFAULT_ENABLE_TC_SERVER_BATCH_SEND_RESPONSE = false;
 
+    boolean DEFAULT_CLIENT_CHANNEL_CHECK_FAIL_FAST = false;
+
     String DEFAULT_BOSS_THREAD_PREFIX = "NettyBoss";
     String DEFAULT_NIO_WORKER_THREAD_PREFIX = "NettyServerNIOWorker";
     String DEFAULT_EXECUTOR_THREAD_PREFIX = "NettyServerBizHandler";

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

@@ -23,6 +23,7 @@
 import java.text.SimpleDateFormat;
 import java.util.Collection;
 import java.util.Date;
+import java.util.Iterator;
 import java.util.Map;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
@@ -373,4 +374,31 @@ public static boolean hasUpperCase(String str) {
         return false;
     }
 
+    public static String join(Iterator iterator, String separator) {
+        if (iterator == null) {
+            return null;
+        }
+        if (!iterator.hasNext()) {
+            return EMPTY;
+        }
+        Object first = iterator.next();
+        if (!iterator.hasNext()) {
+            return first == null ? "" : first.toString();
+        }
+        StringBuilder builder = new StringBuilder(256);
+        if (first != null) {
+            builder.append(first);
+        }
+        while (iterator.hasNext()) {
+            if (separator != null) {
+                builder.append(separator);
+            }
+            Object obj = iterator.next();
+            if (obj != null) {
+                builder.append(obj);
+            }
+        }
+        return builder.toString();
+    }
+
 }

core/src/main/java/io/seata/core/rpc/netty/AbstractNettyRemotingClient.java

@@ -106,7 +106,13 @@ public abstract class AbstractNettyRemotingClient extends AbstractNettyRemoting
 
     @Override
     public void init() {
-        timerExecutor.scheduleAtFixedRate(() -> clientChannelManager.reconnect(getTransactionServiceGroup()), SCHEDULE_DELAY_MILLS, SCHEDULE_INTERVAL_MILLS, TimeUnit.MILLISECONDS);
+        timerExecutor.scheduleAtFixedRate(() -> {
+            try {
+                clientChannelManager.reconnect(getTransactionServiceGroup());
+            } catch (Exception ex) {
+                LOGGER.warn("reconnect TC error. reason: {}", ex.getMessage());
+            }
+        }, SCHEDULE_DELAY_MILLS, SCHEDULE_INTERVAL_MILLS, TimeUnit.MILLISECONDS);
         if (this.isEnableClientBatchSendRequest()) {
             mergeSendExecutorService = new ThreadPoolExecutor(MAX_MERGE_SEND_THREAD,
                 MAX_MERGE_SEND_THREAD,

core/src/main/java/io/seata/core/rpc/netty/NettyClientChannelManager.java

@@ -181,12 +181,21 @@ void reconnect(List<String> availList, String transactionServiceGroup) {
             }
             if (failedMap.size() > 0) {
                 if (LOGGER.isInfoEnabled()) {
-                    LOGGER.error("{} can not connect to {} cause:{}", FrameworkErrorCode.NetConnect.getErrCode(), failedMap.keySet(), failedMap.values().stream().map(Throwable::getMessage).collect(Collectors.toSet()));
+                    LOGGER.error("{} can not connect to {} cause:{}", FrameworkErrorCode.NetConnect.getErrCode(),
+                            failedMap.keySet(),
+                            failedMap.values().stream().map(Throwable::getMessage).collect(Collectors.toSet()));
                 } else if (LOGGER.isDebugEnabled()) {
                     failedMap.forEach((key, value) -> {
-                        LOGGER.error("{} can not connect to {} cause:{} trace information:{}", FrameworkErrorCode.NetConnect.getErrCode(), key, value.getMessage(), value);
+                        LOGGER.error("{} can not connect to {} cause:{} trace information:{}",
+                                FrameworkErrorCode.NetConnect.getErrCode(), key, value.getMessage(), value);
                     });
                 }
+                boolean failFast = NettyClientConfig.isEnableClientChannelCheckFailFast();
+                boolean main = Thread.currentThread().getId() == 1L;
+                if (failFast && main) {
+                    String invalidAddress = StringUtils.join(failedMap.keySet().iterator(), ", ");
+                    throw new FrameworkException("can not connect to [" + invalidAddress + "]");
+                }
             }
         } finally {
             if (CollectionUtils.isNotEmpty(channelAddress)) {

core/src/main/java/io/seata/core/rpc/netty/NettyClientConfig.java

@@ -19,6 +19,7 @@
 import io.seata.core.constants.ConfigurationKeys;
 import io.seata.core.rpc.TransportServerType;
 
+import static io.seata.common.DefaultValues.DEFAULT_CLIENT_CHANNEL_CHECK_FAIL_FAST;
 import static io.seata.common.DefaultValues.DEFAULT_ENABLE_CLIENT_BATCH_SEND_REQUEST;
 import static io.seata.common.DefaultValues.DEFAULT_RPC_RM_REQUEST_TIMEOUT;
 import static io.seata.common.DefaultValues.DEFAULT_RPC_TM_REQUEST_TIMEOUT;
@@ -59,6 +60,7 @@ public class NettyClientConfig extends NettyBaseConfig {
     private static final boolean DEFAULT_POOL_TEST_RETURN = true;
     private static final boolean DEFAULT_POOL_LIFO = true;
     private static final boolean ENABLE_CLIENT_BATCH_SEND_REQUEST = CONFIG.getBoolean(ConfigurationKeys.ENABLE_CLIENT_BATCH_SEND_REQUEST, DEFAULT_ENABLE_CLIENT_BATCH_SEND_REQUEST);
+    private static final boolean ENABLE_CLIENT_CHANNEL_CHECK_FAIL_FAST = CONFIG.getBoolean(io.seata.common.ConfigurationKeys.ENABLE_CLIENT_CHANNEL_CHECK_FAIL_FAST, DEFAULT_CLIENT_CHANNEL_CHECK_FAIL_FAST);
 
     /**
      * Gets connect timeout millis.
@@ -455,4 +457,8 @@ public String getRmDispatchThreadPrefix() {
     public static boolean isEnableClientBatchSendRequest() {
         return ENABLE_CLIENT_BATCH_SEND_REQUEST;
     }
+
+    public static boolean isEnableClientChannelCheckFailFast() {
+        return ENABLE_CLIENT_CHANNEL_CHECK_FAIL_FAST;
+    }
 }