test: fix the exception caused by the disorder of test case execution order (#7580)

Author: funky-eyes

changes/en-us/2.x.md

@@ -50,6 +50,7 @@ Add changes here for all PR submitted to the 2.x branch.
 
 - [[#7541](https://github.com/seata/seata/pull/7541)] fix jakarta UT failed in jdk17+
 - [[#7540](https://github.com/seata/seata/pull/7540)] fix port of mock server
+- [[#7580](https://github.com/seata/seata/pull/7580)]  fix the exception caused by the disorder of test case execution order
 
 
 ### refactor:

changes/zh-cn/2.x.md

@@ -49,7 +49,7 @@
 - [[#7541](https://github.com/seata/seata/pull/7541)] 修复 jakarta 依赖在 jdk17+ 单测失败问题
 - [[#7540](https://github.com/seata/seata/pull/7540)] 修复mock server端口冲突问题
 - [[#7578](https://github.com/seata/seata/pull/7578)]  zstd解压由jni改为ZstdInputStream
-
+- [[#7580](https://github.com/seata/seata/pull/7580)]  修复测试用例顺序错乱导致的异常
 
 ### refactor:
 

core/src/main/java/org/apache/seata/core/rpc/netty/RmNettyRemotingClient.java

@@ -320,6 +320,7 @@ public void destroy() {
         super.destroy();
         initialized.getAndSet(false);
         instance = null;
+        transactionServiceGroup = null;
     }
 
     @Override

mock-server/src/main/java/org/apache/seata/mockserver/MockServer.java

@@ -23,6 +23,8 @@
 import org.apache.seata.common.util.NetUtil;
 import org.apache.seata.common.util.NumberUtils;
 import org.apache.seata.common.util.UUIDGenerator;
+import org.apache.seata.config.ConfigurationCache;
+import org.apache.seata.core.constants.ConfigurationKeys;
 import org.apache.seata.core.rpc.netty.NettyServerConfig;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -74,6 +76,10 @@ public static void start(int port) {
         if (!inited) {
             synchronized (MockServer.class) {
                 if (!inited) {
+                    ConfigurationCache.clear();
+                    // Clear the property for any of the supported events
+                    System.clearProperty(ConfigurationKeys.SERVER_SERVICE_PORT_CAMEL);
+                    System.clearProperty("server.port");
                     inited = true;
                     workingThreads = new ThreadPoolExecutor(
                             50,

server/src/main/java/org/apache/seata/server/ServerRunner.java

@@ -82,14 +82,14 @@ public void destroy() throws Exception {
         if (LOGGER.isDebugEnabled()) {
             LOGGER.debug("destoryAll starting");
         }
-
         for (Disposable disposable : DISPOSABLE_LIST) {
             disposable.destroy();
         }
 
         if (LOGGER.isDebugEnabled()) {
             LOGGER.debug("destoryAll finish");
         }
+        DISPOSABLE_LIST.clear();
     }
 
     @Override

server/src/main/java/org/apache/seata/server/session/SessionHolder.java

@@ -48,7 +48,6 @@
 import java.util.concurrent.CompletableFuture;
 
 import static java.io.File.separator;
-import static org.apache.seata.common.ConfigurationKeys.SERVER_SERVICE_PORT_CAMEL;
 import static org.apache.seata.common.DefaultValues.DEFAULT_DISTRIBUTED_LOCK_EXPIRE_TIME;
 import static org.apache.seata.common.DefaultValues.DEFAULT_SEATA_GROUP;
 import static org.apache.seata.common.DefaultValues.DEFAULT_SESSION_STORE_FILE_DIR;
@@ -125,11 +124,11 @@ public static void init(SessionMode sessionMode) {
                 String vGroupMappingStorePath =
                         CONFIG.getConfig(ConfigurationKeys.STORE_FILE_DIR, DEFAULT_VGROUP_MAPPING_STORE_FILE_DIR)
                                 + separator
-                                + System.getProperty(SERVER_SERVICE_PORT_CAMEL);
+                                + XID.getPort();
                 String sessionStorePath =
                         CONFIG.getConfig(ConfigurationKeys.STORE_FILE_DIR, DEFAULT_SESSION_STORE_FILE_DIR)
                                 + separator
-                                + System.getProperty(SERVER_SERVICE_PORT_CAMEL);
+                                + XID.getPort();
                 if (StringUtils.isBlank(sessionStorePath) || StringUtils.isBlank(vGroupMappingStorePath)) {
                     throw new StoreException("the {store.file.dir} is empty.");
                 }

server/src/main/java/org/apache/seata/server/spring/listener/ServerApplicationListener.java

@@ -114,6 +114,7 @@ private void setTargetPort(ConfigurableEnvironment environment, String port, boo
             // add property source to the first position
             Properties pro = new Properties();
             pro.setProperty(SERVER_SERVICE_PORT_CONFIG, port);
+            pro.setProperty(SERVER_SERVICE_PORT_CAMEL, port);
             environment.getPropertySources().addFirst(new PropertiesPropertySource("serverProperties", pro));
         }
     }

server/src/test/java/org/apache/seata/server/BaseSpringBootTest.java

@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.seata.server;
+
+import org.apache.seata.config.ConfigurationCache;
+import org.apache.seata.config.ConfigurationFactory;
+import org.apache.seata.core.constants.ConfigurationKeys;
+import org.junit.jupiter.api.AfterAll;
+import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.BeforeAll;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.annotation.DirtiesContext;
+import org.springframework.test.context.TestPropertySource;
+
+@TestPropertySource(properties = {"server.port=${random.int[10000,60000]}"})
+@SpringBootTest
+@DirtiesContext(classMode = DirtiesContext.ClassMode.BEFORE_CLASS)
+public abstract class BaseSpringBootTest {
+
+    @BeforeAll
+    public static void beforeAll() {
+        System.setProperty(ConfigurationKeys.SHUTDOWN_WAIT, "1");
+        ConfigurationCache.clear();
+        System.clearProperty(ConfigurationKeys.SERVER_SERVICE_PORT_CAMEL);
+    }
+
+    @AfterAll
+    public static void afterAll() {
+        ConfigurationCache.clear();
+        System.clearProperty(ConfigurationKeys.SERVER_SERVICE_PORT_CAMEL);
+    }
+
+    @AfterEach
+    public void AfterEach() {
+        ConfigurationFactory.reload();
+        System.clearProperty(ConfigurationKeys.SERVER_SERVICE_PORT_CAMEL);
+    }
+}

server/src/test/java/org/apache/seata/server/DynamicPortTestConfig.java

@@ -19,17 +19,13 @@
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.Test;
-import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.context.ApplicationContext;
-import org.springframework.context.annotation.Import;
 import org.springframework.core.env.Environment;
 
 /**
  *
  */
-@SpringBootTest
-@Import(DynamicPortTestConfig.class)
-public class LoaderConfTest {
+public class LoaderConfTest extends BaseSpringBootTest {
 
     static Environment environment;