[ISSUE #3271]Fix handle http message throw IllegalReferenceCountException

mxsm · mxsm · commit 3a362753c43e · 2023-02-26T10:22:25.000+08:00
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractHTTPServer.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractHTTPServer.java
@@ -95,7 +95,6 @@
 import io.netty.handler.ssl.SslHandler;
 import io.netty.handler.timeout.IdleState;
 import io.netty.handler.timeout.IdleStateEvent;
-import io.netty.util.ReferenceCountUtil;
 import io.opentelemetry.api.trace.Span;
 import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
 
@@ -444,9 +443,7 @@ protected void channelRead0(ChannelHandlerContext ctx, HttpRequest httpRequest)
                 }
 
             } catch (Exception ex) {
-                log.error("AbrstractHTTPServer.HTTPHandler.channelRead error", ex);
-            } finally {
-                ReferenceCountUtil.release(httpRequest);
+                log.error("execute AbstractHTTPServer.HTTPHandler.channelRead0 error", ex);
             }
         }
 

Original file line number	Diff line number	Diff line change
`@@ -95,7 +95,6 @@`
`95`	`95`	`import io.netty.handler.ssl.SslHandler;`
`96`	`96`	`import io.netty.handler.timeout.IdleState;`
`97`	`97`	`import io.netty.handler.timeout.IdleStateEvent;`
`98`		`-import io.netty.util.ReferenceCountUtil;`
`99`	`98`	`import io.opentelemetry.api.trace.Span;`
`100`	`99`	`import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;`
`101`	`100`
`@@ -444,9 +443,7 @@ protected void channelRead0(ChannelHandlerContext ctx, HttpRequest httpRequest)`
`444`	`443`	`}`
`445`	`444`
`446`	`445`	`} catch (Exception ex) {`
`447`		`- log.error("AbrstractHTTPServer.HTTPHandler.channelRead error", ex);`
`448`		`- } finally {`
`449`		`- ReferenceCountUtil.release(httpRequest);`
	`446`	`+ log.error("execute AbstractHTTPServer.HTTPHandler.channelRead0 error", ex);`
`450`	`447`	`}`
`451`	`448`	`}`
`452`	`449`