Java NIO框架Netty教程(七)-再谈收发信息次数问题
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了Java NIO框架Netty教程(七)-再谈收发信息次数问题，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1460字，纯文字阅读大概需要3分钟。
内容图文
在《Java NIO框架Netty教程（五）- 消息收发次数不匹配的问题》里我们试图分析一个消息收发次数不匹配的问题。当时笔者还是心存疑惑的。所以决定先学习一下Java NIO的Selector机制。
经过简单的了解，笔者大胆的猜测和“武断”一下该问题的原因。
首先，Selector机制让我们注册一个感兴趣的时间，然后只要有该时间发生，就会传递给接收端。我们写了三次，接收端一定会出发三次的。
然后，Netty实现机制里，有个Buffer缓冲池，把收到的信息都缓存在里面，通过一个线程统一处理。也就是我们看到的那个buffer的处理过程。
Netty的设置中，有一个一次性最多读取字节大小的设定。并且，事件的触发是在处理过缓冲池中的消息之后。我们再来回顾一下Netty中读取信息的那段代码：
01.
ByteBuffer bb = recvBufferPool.acquire(predictedRecvBufSize);
02.
try {
03.
while ((ret = ch.read(bb)) > 0) {
04.
readBytes += ret;
05.
if (!bb.hasRemaining()) {
06.
break
;
07.
}
08.
}
09.
failure =
false
;
10.
}
catch (ClosedChannelException e) {
11.
// Can happen, and does not need a user attention.
12.
}
catch (Throwable t) {
13.
fireExceptionCaught(channel, t);
14.
}
15.
16.
if (readBytes > 0) {
17.
bb.flip();
18.
19.
final ChannelBufferFactory bufferFactory =
20.
channel.getConfig().getBufferFactory();
21.
final ChannelBuffer buffer = bufferFactory.getBuffer(readBytes);
22.
buffer.setBytes(
0
, bb);
23.
buffer.writerIndex(readBytes);
24.
25.
recvBufferPool.release(bb);
26.
27.
// Update the predictor.
28.
predictor.previousReceiveBufferSize(readBytes);
29.
30.
// Fire the event.
31.
fireMessageReceived(channel, buffer);
32.
}
else {
33.
recvBufferPool.release(bb);
34.
}
可以看到，如果没有读取到字节是不会触发事件的，所以我们可能会收到2次或者3次信息。（如果发的快，解析的慢，后两次信息，一次性读取了，就2次，如果发送间隔长，分次解析，就收到3次。）原因应该就是如此。跟我们开始猜的差不多，只是不敢确认。
原文：http://www.cnblogs.com/hashcoder/p/7648416.html
内容总结
以上是互联网集市为您收集整理的Java NIO框架Netty教程(七)-再谈收发信息次数问题全部内容，希望文章能够帮你解决Java NIO框架Netty教程(七)-再谈收发信息次数问题所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。