Netty基本概念

原文请参考微信公众账号（包含图文）：https://mp.weixin.qq.com/s/8zyoj-FGyepXb5UkA1CqYw 

Netty基本概念

原创： 千本樱 后端技术笔记 9月28日

ByteBuf

ByteBuf：设计ByteBuf是为了在Netty的pipeline中传输数据，是数据传输数据的容器，功能类似于JDK中的ByteBuffer；

使用引用计数器来处理池化的ByteBuf，当ByteBuf处理完后，需确保引用计数器被调整，使用 ReferenceCountUtil.release() 来释放资源

ByteBuf作用：（1）可以自定义缓冲类型（2）通过一个内置的复合缓冲类型实现零拷贝 （3）扩展性好 （4）不需要调用 flip() 来切换读/写模式 （5）读取和写入索引分开 （6）方法链 （7）引用计数 （8）pooling资源池

ByteBuf中有2个索引:读索引和写索引；写入数据到ByteBuf后，writeIndex增加写入的字节，从ByteBuf读取字节后，readIndex增加读取的字节数，当writeIndex和readIndex处于相同位置时，数据读取完成，否则将抛出越界异常IndexOutOfBoundsException；ByteBuf初始化时readerIndex和writerIndex都处于0位置

ByteBuf中以read、write开头的方法都将增加相应的索引；可以为ByteBuf设置最大容量值，默认容量值为Integer.MAX_VALUE；

ByteBuf 类似于一个字节数组，最大的区别是读和写的索引可以用来控制对缓冲区数据的访问

ByteBuf容量：0 <= readerIndex <= writerIndex <= capacity。

ByteBuf中已读取过的字节，调用discardReadBytes()方法来回收空间，增加ByteBuf中可用的空间，readableBytes()返回可读字节数（this.writerIndex - this.readerIndex），writableBytes()返回可写字节容量（this.capacity - this.writerIndex）

标记或重设读/写索引位置：markReaderIndex(), markWriterIndex(), resetReaderIndex() 和 resetWriterIndex()

clear() 可以同时设置 readerIndex 和 writerIndex 为 0，但不会清除内容中的内容

Channel生命周期

channelUnregistered：channel已创建但未注册到一个 EventLoop. channelRegistered：channel 注册到一个 EventLoop. channelActive：channel 变为活跃状态(连接到了远程主机)，可以接收和发送数据了 channelInactive：channel 处于非活跃状态，没有连接到远程主机

ChannelHandler

当 ChannelHandler 添加到 ChannelPipeline，或者从 ChannelPipeline 移除后，handlerAdded、handlerRemoved、exceptionCaught将会被调用；

handlerAdded：当 ChannelHandler 添加到 ChannelPipeline 调用 handlerRemoved：当 ChannelHandler 从 ChannelPipeline 移除时调用 exceptionCaught：当 ChannelPipeline 执行抛出异常时调用

ChannelHandler扩展

ChannelInboundHandler：处理进站数据和所有状态更改事件 ChannelOutboundHandler：处理出站数据，提供了出站操作时调用的方法，这些方法会被 Channel, ChannelPipeline, 和 ChannelHandlerContext 调用； ChannelPromise：是特殊的ChannelFuture，一个新的 ChannelPromise将会创建并且通过 ChannelPipeline传递

ChannelPipeline中一系列的ChannelHandler入站和出站操作：

ChannelPipeline

ChannelPipeline：是一系列的ChannelHandler实例，ChannelHandler流经一个 Channel 的入站和出站事件可以被ChannelPipeline 拦截，ChannelPipeline能够让用户自定义入站/出站事件的处理逻辑，以及pipeline里的各个Handler之间的交互；每当一个新的Channel被创建，都会建立并绑定一个channelPipeline；ChannelPipeline 有着丰富的API调用动作来回应入站和出站事件

可以动态添加和删除 ChannelHandler来修改ChannelPipeline

ChannelHandlerContext

在ChannelHandler 添加到 ChannelPipeline 时会创建一个ChannelHandlerContext实例，代表了 ChannelHandler 和ChannelPipeline 之间的关联

ChannelPipeline, Channel, ChannelHandler 和 ChannelHandlerContext 的关系：

（1）Channel绑定到ChannelPipeline （2）ChannelPipeline 绑定到 包含 ChannelHandler 的 Channel上 （3）当添加 ChannelHandler 到 ChannelPipeline 时，ChannelHandlerContext 被创建 

从一个handler转到下一个handler要通过调用ChannelHandlerContext中write相关的方法来实现

 

 

 

 

 

微信扫一扫
关注该公众号