自适应数据大小的分配器。
- 小了不够
- 大了浪费
所以根据自己实际装预估下次情况,从而决定下次带多大桶。
AdaptiveRecvByteBufAllocator对bytebuf的猜测
- 果断地放大
- 谨慎地缩小( 需连续2次的判断)
连续读。 排队打水时,假设当前桶装满了,这时你会觉得可能还要打点水才够用,所以直接拿个新桶等装,而非回家,直到后面出现
- 有桶没有装满
- 装了很多桶了,需要给别人留个机会
等原因才停止,回家。
如下都是worker线程的事。
多路复用器( Selector )接收到OP_READ事件 处理OP_READ事件:NioSocketChannel.NioSocketChannelUnsafe.read()
- 分配一个初始1024字节的byte buffer来接受数据
- 从Channel接受数据到byte buffer
- 记录实际接受数据大小,调整下次分配byte buffer大小
- 触发 pipeline.fireChannelRead(byteBuf)把读取到的数据传播出去
- 判断接受byte buffer是否满载而归:是,尝试继续读取直到没有数据或满16次;否,结束本轮读取,等待下次OP_READ事件
和连接事件类似,我们肯定还是主要在 NioEventLoop
- NioSocketChannel#read 读数据
- NioServerSocketChannel#read 创建连接
- pipeline.fireChannelReadComplete() 一次读事件处理完成
- pipeline fireChannelRead(byteBuf)
一次读数据完成, 一次读事件处理可能会包含多次读数据操作
给别人留机会。





