Compatible with Fory

Author: diguage

serializer/seata-serializer-fury/pom.xml

@@ -37,10 +37,17 @@
             <artifactId>seata-core</artifactId>
             <version>${project.version}</version>
         </dependency>
+        <dependency>
+            <groupId>${project.groupId}</groupId>
+            <artifactId>seata-serializer-fory</artifactId>
+            <version>${project.version}</version>
+            <scope>provided</scope>
+        </dependency>
 
         <dependency>
             <groupId>org.apache.fury</groupId>
             <artifactId>fury-core</artifactId>
+            <optional>true</optional>
         </dependency>
     </dependencies>
 </project>

serializer/seata-serializer-fury/src/main/java/org/apache/seata/serializer/fury/DynamicSerializerFactory.java

@@ -0,0 +1,59 @@
+/*
+ * 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.serializer.fury;
+
+import org.apache.seata.core.serializer.Serializer;
+
+public class DynamicSerializerFactory {
+    private static final DynamicSerializerFactory FACTORY = new DynamicSerializerFactory();
+
+    private final Serializer furyDelegate;
+
+    private DynamicSerializerFactory() {
+        this.furyDelegate = createFuryDelegate();
+    }
+
+    public static DynamicSerializerFactory getInstance() {
+        return FACTORY;
+    }
+
+    public Serializer get() {
+        return furyDelegate;
+    }
+
+    private Serializer createFuryDelegate() {
+        // First, try to load seata-serializer-fory.
+        try {
+            Class.forName("org.apache.seata.serializer.fory.ForySerializer");
+            return new ForySerializerDelegate();
+        } catch (ClassNotFoundException e) {
+        }
+        // Second, try to load Apache Fory.
+        try {
+            Class.forName("org.apache.fory.Fury");
+            return new ThreadSafeForyDelegate();
+        } catch (ClassNotFoundException e) {
+        }
+        // If Fory is unavailable, fallback to Fury.
+        try {
+            Class.forName("org.apache.fury.Fury");
+            return new ThreadSafeFuryDelegate();
+        } catch (ClassNotFoundException e) {
+            throw new IllegalStateException("Neither Apache Fory nor Apache Fury found in classpath", e);
+        }
+    }
+}

serializer/seata-serializer-fury/src/main/java/org/apache/seata/serializer/fury/ForySerializerDelegate.java

@@ -0,0 +1,36 @@
+/*
+ * 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.serializer.fury;
+
+import org.apache.seata.core.serializer.Serializer;
+import org.apache.seata.serializer.fory.ForySerializer;
+
+public class ForySerializerDelegate implements Serializer {
+
+    private static final ForySerializer SERIALIZER = new ForySerializer();
+
+    @Override
+    public byte[] serialize(Object obj) {
+        return SERIALIZER.serialize(obj);
+    }
+
+    @Override
+    public Object deserialize(byte[] bytes) {
+        return SERIALIZER.deserialize(bytes);
+    }
+
+}

serializer/seata-serializer-fury/src/main/java/org/apache/seata/serializer/fury/FurySerializer.java

@@ -16,7 +16,6 @@
  */
 package org.apache.seata.serializer.fury;
 
-import org.apache.fury.ThreadSafeFury;
 import org.apache.seata.common.loader.LoadLevel;
 import org.apache.seata.core.protocol.AbstractMessage;
 import org.apache.seata.core.serializer.Serializer;
@@ -28,16 +27,16 @@ public <T> byte[] serialize(T t) {
         if (!(t instanceof AbstractMessage)) {
             throw new IllegalArgumentException("AbstractMessage isn't available.");
         }
-        ThreadSafeFury threadSafeFury = FurySerializerFactory.getInstance().get();
-        return threadSafeFury.serialize(t);
+        Serializer serializer = DynamicSerializerFactory.getInstance().get();
+        return serializer.serialize(t);
     }
 
     @Override
     public <T> T deserialize(byte[] bytes) {
         if (bytes == null || bytes.length == 0) {
             throw new IllegalArgumentException("bytes is null");
         }
-        ThreadSafeFury threadSafeFury = FurySerializerFactory.getInstance().get();
-        return (T) threadSafeFury.deserialize(bytes);
+        Serializer serializer = DynamicSerializerFactory.getInstance().get();
+        return (T) serializer.deserialize(bytes);
     }
 }

serializer/seata-serializer-fury/src/main/java/org/apache/seata/serializer/fury/ThreadSafeForyDelegate.java

@@ -0,0 +1,60 @@
+/*
+ * 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.serializer.fury;
+
+import org.apache.fory.Fory;
+import org.apache.fory.ThreadLocalFory;
+import org.apache.fory.ThreadSafeFory;
+import org.apache.fory.config.CompatibleMode;
+import org.apache.fory.config.Language;
+import org.apache.seata.core.serializer.Serializer;
+import org.apache.seata.core.serializer.SerializerSecurityRegistry;
+
+public class ThreadSafeForyDelegate implements Serializer {
+
+    private static final ThreadSafeFory FORY = new ThreadLocalFory(classLoader -> {
+        Fory f = Fory.builder()
+                .withLanguage(Language.JAVA)
+                // In JAVA mode, classes cannot be registered by tag, and the different registration order between the
+                // server and the client will cause deserialization failure
+                // In XLANG cross-language mode has problems with Java class serialization, such as enum classes
+                // [https://github.com/apache/fory/issues/1644].
+                .requireClassRegistration(false)
+                // enable reference tracking for shared/circular reference.
+                .withRefTracking(true)
+                .withClassLoader(classLoader)
+                .withCompatibleMode(CompatibleMode.COMPATIBLE)
+                .build();
+
+        // register allow class
+        f.getClassResolver()
+                .setClassChecker((classResolver, className) ->
+                        SerializerSecurityRegistry.getAllowClassPattern().contains(className));
+        return f;
+    });
+
+    @Override
+    public byte[] serialize(Object obj) {
+        return FORY.serialize(obj);
+    }
+
+    @Override
+    public Object deserialize(byte[] bytes) {
+        return FORY.deserialize(bytes);
+    }
+
+}

serializer/seata-serializer-fury/src/main/java/org/apache/seata/serializer/fury/FurySerializerFactory.java renamed to serializer/seata-serializer-fury/src/main/java/org/apache/seata/serializer/fury/ThreadSafeFuryDelegate.java

@@ -22,10 +22,10 @@
 import org.apache.fury.config.CompatibleMode;
 import org.apache.fury.config.Language;
 import org.apache.fury.resolver.AllowListChecker;
+import org.apache.seata.core.serializer.Serializer;
 import org.apache.seata.core.serializer.SerializerSecurityRegistry;
 
-public class FurySerializerFactory {
-    private static final FurySerializerFactory FACTORY = new FurySerializerFactory();
+public class ThreadSafeFuryDelegate implements Serializer {
 
     private static final ThreadSafeFury FURY = new ThreadLocalFury(classLoader -> {
         Fury f = Fury.builder()
@@ -48,11 +48,13 @@ public class FurySerializerFactory {
         return f;
     });
 
-    public static FurySerializerFactory getInstance() {
-        return FACTORY;
+    @Override
+    public byte[] serialize(Object obj) {
+        return FURY.serialize(obj);
     }
 
-    public ThreadSafeFury get() {
-        return FURY;
+    @Override
+    public Object deserialize(byte[] bytes) {
+        return FURY.deserialize(bytes);
     }
 }