add dep fury

sofastack · Jan 11, 2024 · a54eea3 · a54eea3
1 parent a12fa20
commit a54eea3
Show file tree

Hide file tree

Showing 4 changed files with 15 additions and 12 deletions.
diff --git a/all/pom.xml b/all/pom.xml
@@ -73,6 +73,7 @@
         <grpc.version>1.53.0</grpc.version>
         <guava.version>32.0.0-jre</guava.version>
         <transmittable.version>2.12.1</transmittable.version>
+        <fury.version>0.4.1</fury.version>
     </properties>
 
     <dependencies>
@@ -434,6 +435,11 @@
             <artifactId>asm</artifactId>
             <version>${asm.version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.furyio</groupId>
+            <artifactId>fury-core</artifactId>
+            <version>${fury.version}</version>
+        </dependency>
 
     </dependencies>
 

diff --git a/codec/codec-sofa-fury/src/main/java/com/alipay/sofa/rpc/codec/fury/FurySerializer.java b/codec/codec-sofa-fury/src/main/java/com/alipay/sofa/rpc/codec/fury/FurySerializer.java
@@ -32,6 +32,7 @@
 import com.alipay.sofa.rpc.transport.ByteArrayWrapperByteBuf;
 import io.fury.Fury;
 import io.fury.ThreadLocalFury;
+import io.fury.ThreadSafeFury;
 import io.fury.config.Language;
 import io.fury.memory.MemoryBuffer;
 import io.fury.resolver.AllowListChecker;
@@ -47,9 +48,9 @@
 @Extension(value = "fury2", code = 22)
 public class FurySerializer extends AbstractSerializer {
 
-    private final ThreadLocalFury fury;
+    protected final ThreadSafeFury fury;
 
-    private final String          checkerMode = SofaConfigs.getOrDefault(RpcConfigKeys.SERIALIZE_CHECKER_MODE);
+    private final String           checkerMode = SofaConfigs.getOrDefault(RpcConfigKeys.SERIALIZE_CHECKER_MODE);
 
     public FurySerializer() {
         fury = new ThreadLocalFury(classLoader -> {
@@ -175,8 +176,4 @@ public void decode(final AbstractByteBuf data, final Object template, final Map<
         }
     }
 
-    public ThreadLocalFury getFury() {
-        return fury;
-    }
-
 }
diff --git a/...ury/src/main/java/com/alipay/sofa/rpc/codec/fury/serialize/SofaRequestFurySerializer.java b/...ury/src/main/java/com/alipay/sofa/rpc/codec/fury/serialize/SofaRequestFurySerializer.java
@@ -23,7 +23,7 @@
 import com.alipay.sofa.rpc.core.request.SofaRequest;
 import com.alipay.sofa.rpc.transport.AbstractByteBuf;
 import com.alipay.sofa.rpc.transport.ByteArrayWrapperByteBuf;
-import io.fury.ThreadLocalFury;
+import io.fury.ThreadSafeFury;
 import io.fury.memory.MemoryBuffer;
 
 import java.util.Map;
@@ -34,9 +34,9 @@
  */
 public class SofaRequestFurySerializer implements CustomSerializer<SofaRequest> {
 
-    private final ThreadLocalFury fury;
+    private final ThreadSafeFury fury;
 
-    public SofaRequestFurySerializer(ThreadLocalFury fury) {
+    public SofaRequestFurySerializer(ThreadSafeFury fury) {
         this.fury = fury;
     }
 

diff --git a/...ry/src/main/java/com/alipay/sofa/rpc/codec/fury/serialize/SofaResponseFurySerializer.java b/...ry/src/main/java/com/alipay/sofa/rpc/codec/fury/serialize/SofaResponseFurySerializer.java
@@ -22,7 +22,7 @@
 import com.alipay.sofa.rpc.core.response.SofaResponse;
 import com.alipay.sofa.rpc.transport.AbstractByteBuf;
 import com.alipay.sofa.rpc.transport.ByteArrayWrapperByteBuf;
-import io.fury.ThreadLocalFury;
+import io.fury.ThreadSafeFury;
 import io.fury.memory.MemoryBuffer;
 
 import java.util.Map;
@@ -33,9 +33,9 @@
  */
 public class SofaResponseFurySerializer implements CustomSerializer<SofaResponse> {
 
-    private final ThreadLocalFury fury;
+    private final ThreadSafeFury fury;
 
-    public SofaResponseFurySerializer(ThreadLocalFury fury) {
+    public SofaResponseFurySerializer(ThreadSafeFury fury) {
         this.fury = fury;
     }