mxsm commented on issue #3271: URL: https://github.com/apache/incubator-eventmesh/issues/3271#issuecomment-1445843832
@jonyangx started in IDEA, master and the latest code:  test code :  then run test code, runtime server exception: ``` 2023-02-27 15:36:32,016 DEBUG [eventMesh-http-worker-2] AbstractHTTPServer(AbstractHTTPServer.java:438) - httpCommand={REQ,POST/HTTP,requestCode=104,opaque=3,header=sendMessageRequestHeader={code=104,language=JAVA,version=V1,env=DEV,idc=idc,sys=1234,pid=21436,ip=172.19.63.136:57237,username=eventmesh,passwd=password},body=sendMessageRequestBody={topic=null,bizSeqNo=null,uniqueId=null,content={"specversion":"1.0","id":"a1e291f2-8efa-4a40-9566-0fbcd0715a44","source":"/","type":"cloudevents","datacontenttype":"application/cloudevents+json","subject":"eventmesh-async-topic","protocolversion":"1.0","ip":"172.19.63.136","idc":"idc","protocoldesc":"V1","bizseqno":"750847729482426165841644938330","pid":"21436","language":"JAVA","env":"DEV","sys":"1234","ttl":"4000","uniqueid":"283198725850969120046106290900","data_base64":"eyJjb250ZW50IjoidGVzdEFzeW5jTWVzc2FnZSJ9"},ttl=null,tag=,producerGroup=TEST_PRODUCER_GROUP,extFields=null}} 2023-02-27 15:36:32,017 ERROR [eventMesh-http-worker-2] AbstractHTTPServer(AbstractHTTPServer.java:595) - io.netty.util.IllegalReferenceCountException: refCnt: 0, decrement: 1 at io.netty.util.internal.ReferenceCountUpdater.toLiveRealRefCnt(ReferenceCountUpdater.java:83) ~[netty-common-4.1.79.Final.jar:4.1.79.Final] at io.netty.util.internal.ReferenceCountUpdater.release(ReferenceCountUpdater.java:147) ~[netty-common-4.1.79.Final.jar:4.1.79.Final] at io.netty.buffer.AbstractReferenceCountedByteBuf.release(AbstractReferenceCountedByteBuf.java:101) ~[netty-buffer-4.1.79.Final.jar:4.1.79.Final] at io.netty.handler.codec.http.HttpObjectAggregator$AggregatedFullHttpMessage.release(HttpObjectAggregator.java:378) ~[netty-codec-http-4.1.79.Final.jar:4.1.79.Final] at io.netty.util.ReferenceCountUtil.release(ReferenceCountUtil.java:90) ~[netty-common-4.1.79.Final.jar:4.1.79.Final] at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:106) ~[netty-transport-4.1.79.Final.jar:4.1.79.Final] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) [netty-transport-4.1.79.Final.jar:4.1.79.Final] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) [netty-transport-4.1.79.Final.jar:4.1.79.Final] at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) [netty-transport-4.1.79.Final.jar:4.1.79.Final] at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103) [netty-codec-4.1.79.Final.jar:4.1.79.Final] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) [netty-transport-4.1.79.Final.jar:4.1.79.Final] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) [netty-transport-4.1.79.Final.jar:4.1.79.Final] at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) [netty-transport-4.1.79.Final.jar:4.1.79.Final] at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:327) [netty-codec-4.1.79.Final.jar:4.1.79.Final] at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:299) [netty-codec-4.1.79.Final.jar:4.1.79.Final] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) [netty-transport-4.1.79.Final.jar:4.1.79.Final] at io.netty.channel.AbstractChannelHandlerContext.access$600(AbstractChannelHandlerContext.java:61) [netty-transport-4.1.79.Final.jar:4.1.79.Final] at io.netty.channel.AbstractChannelHandlerContext$7.run(AbstractChannelHandlerContext.java:370) [netty-transport-4.1.79.Final.jar:4.1.79.Final] at io.netty.util.concurrent.AbstractEventExecutor.runTask$$$capture(AbstractEventExecutor.java:174) [netty-common-4.1.79.Final.jar:4.1.79.Final] at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java) [netty-common-4.1.79.Final.jar:4.1.79.Final] at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:167) [netty-common-4.1.79.Final.jar:4.1.79.Final] at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java) [netty-common-4.1.79.Final.jar:4.1.79.Final] at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470) [netty-common-4.1.79.Final.jar:4.1.79.Final] at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:503) [netty-transport-4.1.79.Final.jar:4.1.79.Final] at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) [netty-common-4.1.79.Final.jar:4.1.79.Final] at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) [netty-common-4.1.79.Final.jar:4.1.79.Final] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_202] 2023-02-27 15:36:32,373 INFO [eventMesh-sendMsg-2] cmd(SendAsyncMessageProcessor.java:89) - cmd=MSG_SEND_ASYNC|http|client2eventMesh|from=172.19.63.136:57237|to=172.19.63.136 2023-02-27 15:36:32,374 DEBUG [eventMesh-sendMsg-2] message(SendAsyncMessageProcessor.java:262) - msg2MQMsg suc, bizSeqNo=750847729482426165841644938330, topic=eventmesh-async-topic 2023-02-27 15:36:32,374 INFO [eventMesh-sendMsg-2] message(SendAsyncMessageProcessor.java:319) - message|eventMesh2mq|REQ|ASYNC|send2MQCost=0ms|topic=eventmesh-async-topic|bizSeqNo=750847729482426165841644938330|uniqueId=283198725850969120046106290900 2023-02-27 15:36:32,374 DEBUG [eventMesh-sendMsg-2] TraceUtils(TraceUtils.java:86) - finishSpan with event:CloudEvent{id='a1e291f2-8efa-4a40-9566-0fbcd0715a44', source=/, type='cloudevents', datacontenttype='application/cloudevents+json', subject='eventmesh-async-topic', data=BytesCloudEventData{value=[123, 34, 99, 111, 110, 116, 101, 110, 116, 34, 58, 34, 116, 101, 115, 116, 65, 115, 121, 110, 99, 77, 101, 115, 115, 97, 103, 101, 34, 125]}, extensions={protocolversion=1.0, reqeventmesh2mqtimestamp=1677483392374, code=104, reqsendeventmeship=172.19.63.136, ip=172.19.63.136:57237, idc=idc, protocoldesc=http, pid=21436, language=JAVA, env=DEV, sys=1234, ttl=4000, version=1.0, producergroup=TEST_PRODUCER_GROUP, passwd=password, bizseqno=750847729482426165841644938330, protocoltype=cloudevents, msgtype=persistent, uniqueid=283198725850969120046106290900, username=eventmesh, reqc2eventmeshtimestamp=1677483392015}} 2023-02-27 15:36:32,374 DEBUG [eventMesh-sendMsg-2] TraceUtils(TraceUtils.java:86) - finishSpan with event:CloudEvent{id='a1e291f2-8efa-4a40-9566-0fbcd0715a44', source=/, type='cloudevents', datacontenttype='application/cloudevents+json', subject='eventmesh-async-topic', data=BytesCloudEventData{value=[123, 34, 99, 111, 110, 116, 101, 110, 116, 34, 58, 34, 116, 101, 115, 116, 65, 115, 121, 110, 99, 77, 101, 115, 115, 97, 103, 101, 34, 125]}, extensions={protocolversion=1.0, reqeventmesh2mqtimestamp=1677483392374, code=104, reqsendeventmeship=172.19.63.136, ip=172.19.63.136:57237, idc=idc, protocoldesc=http, pid=21436, language=JAVA, env=DEV, sys=1234, ttl=4000, version=1.0, producergroup=TEST_PRODUCER_GROUP, passwd=password, bizseqno=750847729482426165841644938330, protocoltype=cloudevents, msgtype=persistent, uniqueid=283198725850969120046106290900, username=eventmesh, reqc2eventmeshtimestamp=1677483392015}} 2023-02-27 15:36:32,374 DEBUG [eventMesh-sendMsg-2] AbstractHTTPServer(AbstractHTTPServer.java:555) - httpCommand={RES,POST/HTTP,requestCode=104,opaque=3,cost=359,header=sendMessageResponseHeader={code=104,eventMeshEnv=PRD,eventMeshIdc=DEFAULT,eventMeshCluster=COMMON,eventMeshIp=172.19.63.136},body=sendMessageResponseBody={retCode=0,retMsg=successSendResult[topic=eventmesh-async-topic, messageId=1],resTime=2023-02-27 15:36:32.374}} 2023-02-27 15:36:32,374 DEBUG [EventMesh-http-asyncContext-2] http(SendAsyncMessageProcessor.java:288) - httpCommand={RES,POST/HTTP,requestCode=104,opaque=3,cost=359,header=sendMessageResponseHeader={code=104,eventMeshEnv=PRD,eventMeshIdc=DEFAULT,eventMeshCluster=COMMON,eventMeshIp=172.19.63.136},body=sendMessageResponseBody={retCode=0,retMsg=successSendResult[topic=eventmesh-async-topic, messageId=1],resTime=2023-02-27 15:36:32.374}} 2023-02-27 15:36:32,376 WARN [eventMesh-http-worker-2] AbstractHTTPServer(AbstractHTTPServer.java:194) - send response to [172.19.63.136:57237] fail, will close this channel 2023-02-27 15:36:32,376 WARN [eventMesh-http-worker-2] AbstractHTTPServer(AbstractHTTPServer.java:194) - send response to [172.19.63.136:57237] fail, will close this channel ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
