BootsShu commented on issue #2470: URL: https://github.com/apache/rocketmq/issues/2470#issuecomment-738495202
> @BootsShu 仅仅偶尔是 Connection reset by peer 是正常的，上面的那个报错请问是哪里的？具体的要看下客户端的日志，在～/logs/rocketmq_client.log 里面，欢迎在[邮件列表](https://rocketmq.apache.org/about/contact/)里面讨论，这样可以沉淀下来：） 目前使用RocketMQ，频繁出现“集群所有地址连接失败”，排查RocketMQ日志，有很多频繁出现的ErrorMsg: broker.log 几分钟出现一次，头疼： 2020-12-03 03:36:40 ERROR NettyServerNIOSelector_3_1 - processRequestWrapper response to /120.76.102.210:54412 failed java.nio.channels.ClosedChannelException: null at io.netty.channel.AbstractChannel$AbstractUnsafe.write(...)(Unknown Source) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] 2020-12-03 03:36:40 ERROR NettyServerNIOSelector_3_1 - RemotingCommand [code=11, language=CPP, version=275, opaque=4255146, flag(B)=0, remark=PULL_MESSAGE, extFields={queueId=5, maxMsgNums=32, suspendTimeoutMillis=15000, sysFlag=6, commitOffset=95, topic=GlobalPurchase_Common_Log_Service_Topic, queueOffset=95, subscription=*, subVersion=1606773467287, consumerGroup=GlobalPurchase_Common_Log_Service_Group}, serializeTypeCurrentRPC=JSON] 2020-12-03 03:36:40 ERROR NettyServerNIOSelector_3_1 - RemotingCommand [code=19, language=JAVA, version=317, opaque=4255146, flag(B)=1, remark=OFFSET_OVERFLOW_ONE, extFields=null, serializeTypeCurrentRPC=JSON] 2020-12-03 03:36:40 ERROR NettyServerNIOSelector_3_1 - processRequestWrapper response to /120.76.102.210:54412 failed java.nio.channels.ClosedChannelException: null at io.netty.channel.AbstractChannel$AbstractUnsafe.write(...)(Unknown Source) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] 2020-12-03 03:36:40 ERROR NettyServerNIOSelector_3_1 - RemotingCommand [code=11, language=CPP, version=275, opaque=4255144, flag(B)=0, remark=PULL_MESSAGE, extFields={queueId=6, maxMsgNums=32, suspendTimeoutMillis=15000, sysFlag=6, commitOffset=91, topic=GlobalPurchase_Common_Log_Service_Topic, queueOffset=91, subscription=*, subVersion=1606773467287, consumerGroup=GlobalPurchase_Common_Log_Service_Group}, serializeTypeCurrentRPC=JSON] 2020-12-03 03:36:40 ERROR NettyServerNIOSelector_3_1 - RemotingCommand [code=19, language=JAVA, version=317, opaque=4255144, flag(B)=1, remark=OFFSET_OVERFLOW_ONE, extFields=null, serializeTypeCurrentRPC=JSON] 2020-12-03 03:36:40 ERROR NettyServerNIOSelector_3_1 - processRequestWrapper response to /120.76.102.210:54412 failed java.nio.channels.ClosedChannelException: null at io.netty.channel.AbstractChannel$AbstractUnsafe.write(...)(Unknown Source) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] 2020-12-03 03:36:40 ERROR NettyServerNIOSelector_3_1 - RemotingCommand [code=11, language=CPP, version=275, opaque=4255145, flag(B)=0, remark=PULL_MESSAGE, extFields={queueId=7, maxMsgNums=32, suspendTimeoutMillis=15000, sysFlag=6, commitOffset=91, topic=GlobalPurchase_Common_Log_Service_Topic, queueOffset=91, subscription=*, subVersion=1606773467287, consumerGroup=GlobalPurchase_Common_Log_Service_Group}, serializeTypeCurrentRPC=JSON] 2020-12-03 03:36:40 ERROR NettyServerNIOSelector_3_1 - RemotingCommand [code=19, language=JAVA, version=317, opaque=4255145, flag(B)=1, remark=OFFSET_OVERFLOW_ONE, extFields=null, serializeTypeCurrentRPC=JSON] namesrv.log 几分钟出现一次，头疼： 2020-11-30 23:11:18 WARN NettyServerCodecThread_8 - NETTY SERVER PIPELINE: exceptionCaught exception. java.io.IOException: Connection reset by peer at sun.nio.ch.FileDispatcherImpl.read0(Native Method) ~[na:1.8.0_222] at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39) ~[na:1.8.0_222] at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223) ~[na:1.8.0_222] at sun.nio.ch.IOUtil.read(IOUtil.java:192) ~[na:1.8.0_222] at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380) ~[na:1.8.0_222] at io.netty.buffer.PooledUnsafeDirectByteBuf.setBytes(PooledUnsafeDirectByteBuf.java:221) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] at io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:899) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] at io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:275) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:119) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:652) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:575) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:489) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:451) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:140) [netty-all-4.0.42.Final.jar:4.0.42.Final] at java.lang.Thread.run(Thread.java:748) [na:1.8.0_222] 2020-11-30 23:11:18 INFO NettyServerCodecThread_8 - NETTY SERVER PIPELINE: channelInactive, the channel[180.102.120.14:31539] 2020-11-30 23:11:18 INFO NettyServerCodecThread_8 - NETTY SERVER PIPELINE: channelUnregistered, the channel[180.102.120.14:31539] 2020-11-30 23:11:18 INFO NettyServerNIOSelector_3_1 - closeChannel: close the connection to remote address[180.102.120.14:31539] result: true 2020-11-30 23:11:18 WARN NettyServerCodecThread_7 - NETTY SERVER PIPELINE: exceptionCaught 180.102.120.14:31538 2020-11-30 23:11:18 WARN NettyServerCodecThread_7 - NETTY SERVER PIPELINE: exceptionCaught exception. java.io.IOException: Connection reset by peer at sun.nio.ch.FileDispatcherImpl.read0(Native Method) ~[na:1.8.0_222] at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39) ~[na:1.8.0_222] at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223) ~[na:1.8.0_222] at sun.nio.ch.IOUtil.read(IOUtil.java:192) ~[na:1.8.0_222] at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380) ~[na:1.8.0_222] at io.netty.buffer.PooledUnsafeDirectByteBuf.setBytes(PooledUnsafeDirectByteBuf.java:221) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] at io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:899) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] at io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:275) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:119) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:652) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:575) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:489) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:451) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:140) [netty-all-4.0.42.Final.jar:4.0.42.Final] at java.lang.Thread.run(Thread.java:748) [na:1.8.0_222] 2020-11-30 23:11:18 INFO NettyServerCodecThread_7 - NETTY SERVER PIPELINE: channelInactive, the channel[180.102.120.14:31538] 2020-11-30 23:11:18 INFO NettyServerCodecThread_7 - NETTY SERVER PIPELINE: channelUnregistered, the channel[180.102.120.14:31538] 2020-11-30 23:11:18 INFO NettyServerNIOSelector_3_3 - closeChannel: close the connection to remote address[180.102.120.14:31538] result: true 2020-11-30 23:11:18 WARN NettyServerCodecThread_1 - NETTY SERVER PIPELINE: exceptionCaught 180.102.120.14:31541 2020-11-30 23:11:18 WARN NettyServerCodecThread_1 - NETTY SERVER PIPELINE: exceptionCaught exception. java.io.IOException: Connection reset by peer at sun.nio.ch.FileDispatcherImpl.read0(Native Method) ~[na:1.8.0_222] at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39) ~[na:1.8.0_222] at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223) ~[na:1.8.0_222] at sun.nio.ch.IOUtil.read(IOUtil.java:192) ~[na:1.8.0_222] at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380) ~[na:1.8.0_222] at io.netty.buffer.PooledUnsafeDirectByteBuf.setBytes(PooledUnsafeDirectByteBuf.java:221) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] at io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:899) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] at io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:275) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:119) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:652) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:575) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:489) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:451) ~[netty-all-4.0.42.Final.jar:4.0.42.Final] at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:140) [netty-all-4.0.42.Final.jar:4.0.42.Final] at java.lang.Thread.run(Thread.java:748) [na:1.8.0_222] 请问该类RocketMQ问题应该如何解决呢？ ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
