[ISSUE #4236] TCP reconnection failed

yiqf · yiqf · commit 1ba925bdd48a · 2023-07-20T10:31:23.000+08:00
diff --git a/eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/cloudevent/CloudEventTCPPubClient.java b/eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/cloudevent/CloudEventTCPPubClient.java
@@ -37,6 +37,7 @@
 import io.cloudevents.core.format.EventFormat;
 import io.cloudevents.core.provider.EventFormatProvider;
 import io.cloudevents.jackson.JsonFormat;
+import io.netty.channel.ChannelHandler.Sharable;
 import io.netty.channel.ChannelHandlerContext;
 
 import com.google.common.base.Preconditions;
@@ -138,6 +139,7 @@ public void close() {
         }
     }
 
+    @Sharable
     private class CloudEventTCPPubHandler extends AbstractEventMeshTCPPubHandler<CloudEvent> {
 
         public CloudEventTCPPubHandler(ConcurrentHashMap<Object, RequestContext> contexts) {
diff --git a/eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/cloudevent/CloudEventTCPSubClient.java b/eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/cloudevent/CloudEventTCPSubClient.java
@@ -44,6 +44,7 @@
 import io.cloudevents.core.format.EventFormat;
 import io.cloudevents.core.provider.EventFormatProvider;
 import io.cloudevents.jackson.JsonFormat;
+import io.netty.channel.ChannelHandler.Sharable;
 import io.netty.channel.ChannelHandlerContext;
 
 import com.google.common.base.Preconditions;
@@ -141,6 +142,7 @@ public void close() {
         }
     }
 
+    @Sharable
     private class CloudEventTCPSubHandler extends AbstractEventMeshTCPSubHandler<CloudEvent> {
 
         public CloudEventTCPSubHandler(

Original file line number	Diff line number	Diff line change
`@@ -37,6 +37,7 @@`
`37`	`37`	`import io.cloudevents.core.format.EventFormat;`
`38`	`38`	`import io.cloudevents.core.provider.EventFormatProvider;`
`39`	`39`	`import io.cloudevents.jackson.JsonFormat;`
	`40`	`+import io.netty.channel.ChannelHandler.Sharable;`
`40`	`41`	`import io.netty.channel.ChannelHandlerContext;`
`41`	`42`
`42`	`43`	`import com.google.common.base.Preconditions;`
`@@ -138,6 +139,7 @@ public void close() {`
`138`	`139`	`}`
`139`	`140`	`}`
`140`	`141`
	`142`	`+ @Sharable`
`141`	`143`	`private class CloudEventTCPPubHandler extends AbstractEventMeshTCPPubHandler<CloudEvent> {`
`142`	`144`
`143`	`145`	`public CloudEventTCPPubHandler(ConcurrentHashMap<Object, RequestContext> contexts) {`
Original file line number	Diff line number	Diff line change
`@@ -44,6 +44,7 @@`
`44`	`44`	`import io.cloudevents.core.format.EventFormat;`
`45`	`45`	`import io.cloudevents.core.provider.EventFormatProvider;`
`46`	`46`	`import io.cloudevents.jackson.JsonFormat;`
	`47`	`+import io.netty.channel.ChannelHandler.Sharable;`
`47`	`48`	`import io.netty.channel.ChannelHandlerContext;`
`48`	`49`
`49`	`50`	`import com.google.common.base.Preconditions;`
`@@ -141,6 +142,7 @@ public void close() {`
`141`	`142`	`}`
`142`	`143`	`}`
`143`	`144`
	`145`	`+ @Sharable`
`144`	`146`	`private class CloudEventTCPSubHandler extends AbstractEventMeshTCPSubHandler<CloudEvent> {`
`145`	`147`
`146`	`148`	`public CloudEventTCPSubHandler(`