feature: support fory serializer and fory undolog parser

Author: diguage

all/pom.xml

@@ -267,6 +267,11 @@
             <artifactId>seata-serializer-fury</artifactId>
             <version>${project.version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.apache.seata</groupId>
+            <artifactId>seata-serializer-fory</artifactId>
+            <version>${project.version}</version>
+        </dependency>
         <dependency>
             <groupId>org.apache.seata</groupId>
             <artifactId>seata-serializer-kryo</artifactId>

changes/en-us/2.x.md

@@ -67,6 +67,7 @@ Add changes here for all PR submitted to the 2.x branch.
 - [[#7478](https://github.com/apache/incubator-seata/pull/7478)] metrics add retry status
 - [[#7483](https://github.com/apache/incubator-seata/pull/7483)] change the value of retryDeadThreshold to 70 seconds
 - [[#7488](https://github.com/apache/incubator-seata/pull/7488)] upgrade tomcat to 9.0.106
+- [[#7503](https://github.com/apache/incubator-seata/pull/7503)] support fory serializer and fory undolog parser
 
 ### security:
 
@@ -138,6 +139,7 @@ Thanks to these contributors for their code commits. Please report an unintended
 - [jsbxyyx](https://github.com/jsbxyyx)
 - [simzyoo](https://github.com/simzyoo)
 - [Dltmd202](https://github.com/Dltmd202)
+- [diguage](https://github.com/diguage)
 
 
 

changes/zh-cn/2.x.md

@@ -64,6 +64,7 @@
 - [[#7466](https://github.com/apache/incubator-seata/pull/7466)] 在 issue 模板中添加贡献意向勾选框
 - [[#7478](https://github.com/apache/incubator-seata/pull/7478)] 增加处于重试状态的数据采集
 - [[#7483](https://github.com/apache/incubator-seata/pull/7483)] 将retryDeadThreshold改为70秒
+- [[#7503](https://github.com/apache/incubator-seata/pull/7503)] 支持 Fory 序列化器 和 UndoLog的 Fory 序列化方式
 
 
 ### security:
@@ -138,6 +139,7 @@
 - [YvCeung](https://github.com/YvCeung)
 - [jsbxyyx](https://github.com/jsbxyyx)
 - [simzyoo](https://github.com/simzyoo)
+- [diguage](https://github.com/diguage)
 
 
 同时，我们收到了社区反馈的很多有价值的issue和建议，非常感谢大家。

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

@@ -33,6 +33,7 @@
 import java.util.stream.Collectors;
 
 import static org.apache.seata.core.serializer.SerializerType.FASTJSON2;
+import static org.apache.seata.core.serializer.SerializerType.FORY;
 import static org.apache.seata.core.serializer.SerializerType.FURY;
 import static org.apache.seata.core.serializer.SerializerType.HESSIAN;
 import static org.apache.seata.core.serializer.SerializerType.KRYO;
@@ -48,7 +49,7 @@ public final class SerializerServiceLoader {
     private static final Configuration CONFIG = ConfigurationFactory.getInstance();
 
     private static final SerializerType[] DEFAULT_SERIALIZER_TYPE =
-            new SerializerType[] {SEATA, PROTOBUF, KRYO, HESSIAN, FASTJSON2, FURY};
+            new SerializerType[] {SEATA, PROTOBUF, KRYO, HESSIAN, FASTJSON2, FURY, FORY};
 
     private static final Map<String, Serializer> SERIALIZER_MAP = new HashMap<>();
 

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

@@ -83,7 +83,15 @@ public enum SerializerType {
      * <p>
      * Math.pow(2, 8)
      */
-    FURY((byte) 0x256);
+    FURY((byte) 0x256),
+
+    /**
+     * The fory.
+     * <p>
+     * Math.pow(2, 9)
+     */
+    FORY((byte) 0x512);
+
 
     private final byte code;
 

dependencies/pom.xml

@@ -144,6 +144,7 @@
 
         <!--  for fury  -->
         <fury.version>0.8.0</fury.version>
+        <fory.version>0.11.1</fory.version>
     </properties>
 
     <dependencyManagement>
@@ -899,6 +900,11 @@
                 <artifactId>fury-core</artifactId>
                 <version>${fury.version}</version>
             </dependency>
+            <dependency>
+                <groupId>org.apache.fory</groupId>
+                <artifactId>fory-core</artifactId>
+                <version>${fory.version}</version>
+            </dependency>
             <dependency>
                 <groupId>commons-io</groupId>
                 <artifactId>commons-io</artifactId>

rm-datasource/pom.xml

@@ -149,6 +149,12 @@
             <scope>provided</scope>
             <optional>true</optional>
         </dependency>
+        <dependency>
+            <groupId>org.apache.fory</groupId>
+            <artifactId>fory-core</artifactId>
+            <scope>provided</scope>
+            <optional>true</optional>
+        </dependency>
         <dependency>
             <groupId>cn.com.kingbase</groupId>
             <artifactId>kingbase8</artifactId>

rm-datasource/src/main/java/org/apache/seata/rm/datasource/undo/parser/ForyUndoLogParser.java

@@ -0,0 +1,68 @@
+/*
+ * 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.rm.datasource.undo.parser;
+
+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.common.executor.Initialize;
+import org.apache.seata.common.loader.LoadLevel;
+import org.apache.seata.rm.datasource.undo.BranchUndoLog;
+import org.apache.seata.rm.datasource.undo.UndoLogParser;
+
+@LoadLevel(name = ForyUndoLogParser.NAME)
+public class ForyUndoLogParser implements UndoLogParser, Initialize {
+    public static final String NAME = "fory";
+
+    private static final ThreadSafeFory FORY = new ThreadLocalFory(classLoader -> 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());
+
+    @Override
+    public void init() {}
+
+    @Override
+    public String getName() {
+        return NAME;
+    }
+
+    @Override
+    public byte[] getDefaultContent() {
+        return encode(new BranchUndoLog());
+    }
+
+    @Override
+    public byte[] encode(BranchUndoLog branchUndoLog) {
+        return FORY.serializeJavaObject(branchUndoLog);
+    }
+
+    @Override
+    public BranchUndoLog decode(byte[] bytes) {
+        return FORY.deserializeJavaObject(bytes, BranchUndoLog.class);
+    }
+}

rm-datasource/src/main/resources/META-INF/services/org.apache.seata.rm.datasource.undo.UndoLogParser

@@ -19,4 +19,5 @@ org.apache.seata.rm.datasource.undo.parser.JacksonUndoLogParser
 org.apache.seata.rm.datasource.undo.parser.ProtostuffUndoLogParser
 org.apache.seata.rm.datasource.undo.parser.KryoUndoLogParser
 org.apache.seata.rm.datasource.undo.parser.Fastjson2UndoLogParser
-org.apache.seata.rm.datasource.undo.parser.FuryUndoLogParser
+org.apache.seata.rm.datasource.undo.parser.FuryUndoLogParser
+org.apache.seata.rm.datasource.undo.parser.ForyUndoLogParser

rm-datasource/src/test/java/org/apache/seata/rm/datasource/undo/parser/ForyUndoLogParserTest.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.rm.datasource.undo.parser;
+
+import org.apache.seata.common.loader.EnhancedServiceLoader;
+import org.apache.seata.rm.datasource.undo.BaseUndoLogParserTest;
+import org.apache.seata.rm.datasource.undo.UndoLogParser;
+
+public class ForyUndoLogParserTest extends BaseUndoLogParserTest {
+
+    ForyUndoLogParser parser =
+            (ForyUndoLogParser) EnhancedServiceLoader.load(UndoLogParser.class, ForyUndoLogParser.NAME);
+
+    @Override
+    public UndoLogParser getParser() {
+        return parser;
+    }
+
+    @Override
+    public void testTimestampEncodeAndDecode() {
+    }
+}