3
回答
rocketMq腾讯云服务器部署问题,无法消费消息
【寻找人气王】邀新用户免费体验华为云服务,百元话费等你拿!   

rocketMq本地测试都是好使的,但是部署到云服务就出先这个问题,可以发送,但是取不到消息。

2018-02-11 09:59:42 INFO main - createChannel: connect remote host[134.119.15.100:9876] success, DefaultChannelPromise@58ea606c(success)
2018-02-11 10:07:43 INFO NettyServerCodecThread_1 - NETTY SERVER PIPELINE: channelRegistered 106.120.100.166:21188
2018-02-11 10:07:43 INFO NettyServerCodecThread_1 - NETTY SERVER PIPELINE: channelActive, the channel[106.120.100.166:21188]
2018-02-11 10:08:20 INFO NettyServerCodecThread_2 - NETTY SERVER PIPELINE: channelRegistered 106.120.100.166:38790
2018-02-11 10:08:20 INFO NettyServerCodecThread_2 - NETTY SERVER PIPELINE: channelActive, the channel[106.120.100.166:38790]
2018-02-11 10:08:20 INFO NettyServerCodecThread_2 - NETTY SERVER PIPELINE: channelInactive, the channel[106.120.100.166:38790]
2018-02-11 10:08:20 INFO NettyServerCodecThread_2 - NETTY SERVER PIPELINE: channelUnregistered, the channel[106.120.100.166:38790]
2018-02-11 10:09:27 WARN NettyServerCodecThread_1 - NETTY SERVER PIPELINE: exceptionCaught 106.120.100.166:21188
2018-02-11 10:09:27 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_144]
	at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39) ~[na:1.8.0_144]
	at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223) ~[na:1.8.0_144]
	at sun.nio.ch.IOUtil.read(IOUtil.java:192) ~[na:1.8.0_144]
	at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380) ~[na:1.8.0_144]
	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_144]
2018-02-11 10:09:27 INFO NettyServerCodecThread_1 - NETTY SERVER PIPELINE: channelInactive, the channel[106.120.100.166:21188]
2018-02-11 10:09:27 INFO NettyServerCodecThread_1 - NETTY SERVER PIPELINE: channelUnregistered, the channel[106.120.100.166:21188]
2018-02-11 10:09:27 INFO NettyServerNIOSelector_3_1 - closeChannel: close the connection to remote address[106.120.100.166:21188] result: true

 

举报
猫啊
发帖于6个月前 3回/618阅
顶部