You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by li...@apache.org on 2021/11/25 06:20:04 UTC
[dubbo] 18/45: revert hessian improve
This is an automated email from the ASF dual-hosted git repository.
liujun pushed a commit to branch release/3.0.14-rpccontext-bugfix
in repository https://gitbox.apache.org/repos/asf/dubbo.git
commit 35f2fdd9d417f4e3b666bdb3881f0dbe523da98d
Author: 未宇 <li...@alibaba-inc.com>
AuthorDate: Tue Nov 24 14:28:21 2020 +0800
revert hessian improve
---
.../dubbo/common/serialize/hessian2/Hessian2ObjectInput.java | 12 ++----------
.../common/serialize/hessian2/Hessian2ObjectOutput.java | 12 ++----------
2 files changed, 4 insertions(+), 20 deletions(-)
diff --git a/dubbo-serialization/dubbo-serialization-hessian2/src/main/java/org/apache/dubbo/common/serialize/hessian2/Hessian2ObjectInput.java b/dubbo-serialization/dubbo-serialization-hessian2/src/main/java/org/apache/dubbo/common/serialize/hessian2/Hessian2ObjectInput.java
index d38b5c0..08c758d 100644
--- a/dubbo-serialization/dubbo-serialization-hessian2/src/main/java/org/apache/dubbo/common/serialize/hessian2/Hessian2ObjectInput.java
+++ b/dubbo-serialization/dubbo-serialization-hessian2/src/main/java/org/apache/dubbo/common/serialize/hessian2/Hessian2ObjectInput.java
@@ -28,19 +28,11 @@ import java.lang.reflect.Type;
* Hessian2 object input implementation
*/
public class Hessian2ObjectInput implements ObjectInput {
-
- private static ThreadLocal<Hessian2Input> INPUT_TL = ThreadLocal.withInitial(() -> {
- Hessian2Input h2i = new Hessian2Input(null);
- h2i.setSerializerFactory(Hessian2SerializerFactory.SERIALIZER_FACTORY);
- h2i.setCloseStreamOnClose(true);
- return h2i;
- });
-
private final Hessian2Input mH2i;
public Hessian2ObjectInput(InputStream is) {
- mH2i = INPUT_TL.get();
- mH2i.init(is);
+ mH2i = new Hessian2Input(is);
+ mH2i.setSerializerFactory(Hessian2SerializerFactory.SERIALIZER_FACTORY);
}
@Override
diff --git a/dubbo-serialization/dubbo-serialization-hessian2/src/main/java/org/apache/dubbo/common/serialize/hessian2/Hessian2ObjectOutput.java b/dubbo-serialization/dubbo-serialization-hessian2/src/main/java/org/apache/dubbo/common/serialize/hessian2/Hessian2ObjectOutput.java
index a878593..61e38c0 100644
--- a/dubbo-serialization/dubbo-serialization-hessian2/src/main/java/org/apache/dubbo/common/serialize/hessian2/Hessian2ObjectOutput.java
+++ b/dubbo-serialization/dubbo-serialization-hessian2/src/main/java/org/apache/dubbo/common/serialize/hessian2/Hessian2ObjectOutput.java
@@ -27,19 +27,11 @@ import java.io.OutputStream;
* Hessian2 object output implementation
*/
public class Hessian2ObjectOutput implements ObjectOutput {
-
- private static ThreadLocal<Hessian2Output> OUTPUT_TL = ThreadLocal.withInitial(() -> {
- Hessian2Output h2o = new Hessian2Output(null);
- h2o.setSerializerFactory(Hessian2SerializerFactory.SERIALIZER_FACTORY);
- h2o.setCloseStreamOnClose(true);
- return h2o;
- });
-
private final Hessian2Output mH2o;
public Hessian2ObjectOutput(OutputStream os) {
- mH2o = OUTPUT_TL.get();
- mH2o.init(os);
+ mH2o = new Hessian2Output(os);
+ mH2o.setSerializerFactory(Hessian2SerializerFactory.SERIALIZER_FACTORY);
}
@Override