optimize: optimize the reflection operation in class SerializerServiceLoader

changes/en-us/2.x.md

@@ -64,6 +64,7 @@ Add changes here for all PR submitted to the 2.x branch.
 - [[#6761](https://github.com/apache/incubator-seata/pull/6761)] optimize the namingserver code to improve readability
 - [[#6768](https://github.com/apache/incubator-seata/pull/6768)] report the tcc fence transaction isolation level
 - [[#6770](https://github.com/apache/incubator-seata/pull/6770)] Automatic deletion of namingserver vgroup through Caffeine map
+- [[#6780](https://github.com/apache/incubator-seata/pull/6780)] optimize the reflection operation in class `SerializerServiceLoader`
 
 ### refactor:
 

changes/zh-cn/2.x.md

@@ -65,6 +65,7 @@
 - [[#6761](https://github.com/apache/incubator-seata/pull/6761)] 提升namingserver manager代码可读性
 - [[#6768](https://github.com/apache/incubator-seata/pull/6768)] 上报tcc fence事务隔离级别
 - [[#6770](https://github.com/apache/incubator-seata/pull/6770)] 通过caffeine map支持namingserver事务分组的过期删除
+- [[#6780](https://github.com/apache/incubator-seata/pull/6780)] 优化类 `SerializerServiceLoader` 中的反射操作
 
 
 ### refactor:

common/src/main/java/org/apache/seata/common/util/ReflectionUtil.java

@@ -89,6 +89,21 @@ public static Class<?> getClassByName(String className) throws ClassNotFoundExce
         return Class.forName(className, true, Thread.currentThread().getContextClassLoader());
     }
 
+    /**
+     * Is class present boolean.
+     *
+     * @param className the class name
+     * @return boolean true if the class is present
+     */
+    public static boolean isClassPresent(String className) {
+        try {
+            Class.forName(className, false, Thread.currentThread().getContextClassLoader());
+            return true;
+        } catch (ClassNotFoundException e) {
+            return false;
+        }
+    }
+
     /**
      * Get the wrapped class
      *

common/src/test/java/org/apache/seata/common/util/ReflectionUtilTest.java

@@ -45,6 +45,12 @@ public void testGetClassByName() throws ClassNotFoundException {
                 ReflectionUtil.getClassByName("java.lang.String"));
     }
 
+    @Test
+    public void testIsClassPresent() {
+        Assertions.assertTrue(ReflectionUtil.isClassPresent("java.lang.String"));
+        Assertions.assertFalse(ReflectionUtil.isClassPresent("java.lang.String2"));
+    }
+
     @Test
     public void testGetWrappedClass() {
         Assertions.assertEquals(Byte.class, ReflectionUtil.getWrappedClass(byte.class));

core/src/main/java/org/apache/seata/core/serializer/SerializerServiceLoader.java

@@ -56,6 +56,7 @@ private SerializerServiceLoader() {
     }
 
     private static final String PROTOBUF_SERIALIZER_CLASS_NAME = "org.apache.seata.serializer.protobuf.ProtobufSerializer";
+    private static final boolean CONTAINS_PROTOBUF_DEPENDENCY = ReflectionUtil.isClassPresent(PROTOBUF_SERIALIZER_CLASS_NAME);
 
     /**
      * Load the service of {@link Serializer}
@@ -65,15 +66,13 @@ private SerializerServiceLoader() {
      * @throws EnhancedServiceNotFoundException the enhanced service not found exception
      */
     public static Serializer load(SerializerType type, byte version) throws EnhancedServiceNotFoundException {
-        if (type == SerializerType.PROTOBUF) {
-            try {
-                ReflectionUtil.getClassByName(PROTOBUF_SERIALIZER_CLASS_NAME);
-            } catch (ClassNotFoundException e) {
-                throw new EnhancedServiceNotFoundException("'ProtobufSerializer' not found. " +
-                        "Please manually reference 'org.apache.seata:seata-serializer-protobuf' dependency ", e);
-            }
+        // The following code is only used to kindly prompt users to add missing dependencies.
+        if (type == SerializerType.PROTOBUF && !CONTAINS_PROTOBUF_DEPENDENCY) {
+            throw new EnhancedServiceNotFoundException("The class '" + PROTOBUF_SERIALIZER_CLASS_NAME + "' not found. " +
+                    "Please manually reference 'org.apache.seata:seata-serializer-protobuf' dependency.");
         }
 
+
         String key = serialzerKey(type, version);
         Serializer serializer = SERIALIZER_MAP.get(key);
         if (serializer == null) {