Netty中的channelRead和messageReceived的区别
2个回答
展开全部
需要编解码的才会去用messageReceived,一般都是使用ChannelRead来读取的。
SimpleChannelInboundHandler的源代码你就知道了,泛型不匹配,不会调用messageReceived的。
另:如果你特别特别想用SimpleChannelInboundHandler,你可以这样搞:public classYouTCPServerHandler extends SimpleChannelInboundHandler<ByteBuf>{...}
因为你没有做过任何的编码解码,所以你的泛型是ByteBuf,这样你肯定可以使用messageReceived来接收到消息了。如果还不明白,建议你去看一下netty自带的sample,里面有个求阶乘的例子,server和client传递的BigInteger对象,所以就用的是
SimpleChannelInboundHandler<BigInteger>。没有经过任何编码解码的那就肯定是ByteBuf对象。
SimpleChannelInboundHandler的源代码你就知道了,泛型不匹配,不会调用messageReceived的。
另:如果你特别特别想用SimpleChannelInboundHandler,你可以这样搞:public classYouTCPServerHandler extends SimpleChannelInboundHandler<ByteBuf>{...}
因为你没有做过任何的编码解码,所以你的泛型是ByteBuf,这样你肯定可以使用messageReceived来接收到消息了。如果还不明白,建议你去看一下netty自带的sample,里面有个求阶乘的例子,server和client传递的BigInteger对象,所以就用的是
SimpleChannelInboundHandler<BigInteger>。没有经过任何编码解码的那就肯定是ByteBuf对象。
展开全部
我看了SimpleChannelInboundHandler类里面 messageReceived是一个抽象方法 最终还是靠channelRead调用
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
boolean release = true;
try {
if (acceptInboundMessage(msg)) {
@SuppressWarnings("unchecked")
I imsg = (I) msg;
messageReceived(ctx, imsg);
} else {
release = false;
ctx.fireChannelRead(msg);
}
} finally {
if (autoRelease && release) {
ReferenceCountUtil.release(msg);
}
}
}
PS: 我用最原始的TCP—客户端连netty, 在messageReceived方法中是收不到消息的,而在channelRead方法中可以通过ByteBuf读出来的
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
boolean release = true;
try {
if (acceptInboundMessage(msg)) {
@SuppressWarnings("unchecked")
I imsg = (I) msg;
messageReceived(ctx, imsg);
} else {
release = false;
ctx.fireChannelRead(msg);
}
} finally {
if (autoRelease && release) {
ReferenceCountUtil.release(msg);
}
}
}
PS: 我用最原始的TCP—客户端连netty, 在messageReceived方法中是收不到消息的,而在channelRead方法中可以通过ByteBuf读出来的
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
推荐律师服务:
若未解决您的问题,请您详细描述您的问题,通过百度律临进行免费专业咨询