-
Channel
的生命周期- ChannelUnregistered:Channel 已经被创建,但还未注册到 EventLoop
- ChannelRegistered:Channel 已经被注册到了 EventLoop
- ChannelActive:Channel 处于活动状态(已经连接到它的远程节点)。现在可以接收和发送数据了
-
ChannelInactive:Channel 没有连接到远程节点
-
ChannelHandler
的生命周期- handlerAdded:当把 ChannelHandler 添加到 ChannelPipeline 中时被调用
- handlerRemoved:当从 ChannelPipeline 中移除 ChannelHandler 时被调用
- exceptionCaught:当处理过程中在 ChannelPipeline 中有错误产生时被调用
-
ChannelHandler
定义了两个重要子接口-
ChannInboundHandler
处理入站数据以及各种状态变化 -
ChannelOutboundHandler
处理出站数据并且允许拦截所有的操作
-
-
ChannelInboundHandler
的生命周期方法- channelRegistered:当 Channel 已经注册到它的 EventLoop 并且能够处理IO时被调用
- channelUnregistered:当 Channel 从它的 EventLoop 注销并且无法处理任何IO时被调用
- channelActive:当 Channel 处于活动状态时被调用;Channel已经连接、绑定并且已经就绪
- channelInactive:当 Channel 离开活动状态并且不再连接它的远程节点时被调用
- channelReadComplete:当 Channel 上的一个读操作完成时被调用
- channelRead:当从 Channel 读取数据时被调用
- channelWritabilityChanged:当 Channel 的可写状态发生改变时被调用。用户可以确保写操作不会完成得太快或者可以在 Channel 变为再次可写时恢复写入。可以通过调用 Channel 的 isWritable 方法来检测 Channel 的可写性。与可写性相关的阈值可以通过 Channel.config().setWriteHighWaterMark 和 Channel.config().setWriteLowWaterMark 方法来设置
- userEventTriggered:当
ChannelInboundHandler.fireUserEventTriggered
方法被调用时调用,因为一个POJO 被传经了 ChannelPipeline
当
ChannelInboundHandler
的实现重写channelRead
方法时,将显式地释放与池化的 ByteBuf 实例相关的内存。可调用ReferenceCountUtil.release(msg)
来丢弃已经接收的消息。通过继承SimpleChannelInboundHandler
,重写的channelRead0方法会自动释放资源无需显式指定-
ChannelOutboundHandler
接口方法,这些方法中大都需要一个ChannelPromise
参数,以便在操作完成时得到通知,ChannelPromise
是ChannelFuture
的一个子类,其定义了一些可写的方法,如setSuccess,setFailure
- bind:当请求将 Channel 绑定到本地地址时被调用
- connect:当请求将 Channel 连接到远程节点时被调用
- disconnect:当请求将 Channel 从远程节点断开时被调用
- close:当请求关闭 Channel 时被调用
- deregister:当请求将 Channel 从它的 EventLoop 注销时被调用
- read:当请求从 Channel 读取更多的数据时被调用
- flush:当请求通过 Channel 将入队数据冲刷到远程节点时被调用
- write:当请求通过 Channel 将数据写到远程节点时被调用
-
ChannelHandlerAdapter
抽象类实现了ChannelHander
接口中ChannelInboundHandler
和ChannelOutboundHandler
的共同方法,ChannelInboundHandlerAdapter
和ChannelOutboundHandlerAdapter
中提供的方法体调用了相关联的ChannelHandlerContext
上的等效方法,从而将事件转发到ChannelPipeline中的下一个ChannelHandler中
-
ResourceLeakDetector
可以对应用程序的缓冲区分配做大约1%的采样来检测内存泄漏,Netty定义的泄漏检测级别java -Dio.netty.leakDetectionLevel=ADVANCED
- DISABLED,禁用泄漏检测
- SIMPLE,使用1%的默认采样率检测并报告任何发现的泄漏(默认)
- ADVANCED,使用默认采样率,报告所发现的任何的泄漏以及对应的消息被访问的位置
- PARANOID,类似于ADVANCED,但是其将会对每次对消息的访问都进行采样,这对性能将会有很大的影响,应该只在调试阶段使用
ChannelOutboundHandler
的write方法,中释放资源后,还需要promise.setSuccess
通知数据已经被处理了
ChannelPipeline
传播事件时,会测试下一个ChannelHandler
的类型是否和事件的运用方向相匹配(出入站类型),如果不匹配,ChannelPipeline
将跳过该ChannelHandler
并前进到下一个,知道和该事件所期 望的方向相匹配为止ChannelPipeline
可通过添加、删除或者替换其他ChannelHandler
来实时的修改ChannelPipeline
的布局,get
可以通过类型或者名称返回ChannelHandler
,context
返回和ChannelHandler
绑定的ChannelHandlerContext
,names
返回ChannelPipeline
中所有ChannelHandler
的名称ChannelPipeline
的fireXXX
方法会调用下一个ChannelHandler
的相关方法来进行触发事件-
ChannelHandlerContext
具有丰富的事件处理API,使得ChannelHandler
能够和它的ChannelPipeline
以及其他的ChannelHandler
交互,他们的关系如下
通过ctx.pipeline
得到ChannelPipeline
或者ctx.channel
得到Channel
后,在ChannelPipeline
和Channel
上执行的事件触发将通过整个ChannelPipeline
,而ctx
执行的事件触发将从下一个ChannelHandler
开始(减少开销,避免传入不必要的处理) 可以在
ChannelHandler
中缓存ctx
的引用便于之后调用,时刻需要注意是否是线程安全的@Sharable
-
入站异常将从它在
ChannelInboundHandler
里被触发的那一点开始流经ChannelPipeline
,可以重写exceptionCaught
来进行处理-
hannelHandler.exceptionCaught
的默认实现是简单地将当前异常转发给ChannelPipeline
中的下一个ChannelHandler
- 如果异常到达了
ChannelPipeline
的尾端,它将会被记录为未被处理 - 要想定义自定义的处理逻辑,你需要重写
exceptionCaught
方法。然后你需要决定是否需要将该异常传播出去
-
-
出站异常的处理都基于通知机制。在返回的
ChannelFuture
实例上执行addListener
方法(如write
方法返回的ChannelFuture
)或者在ChannelHandler
的方法中的ChannelPromise
对象- 每个出站操作都将返回一个
ChannelFuture
,注册到ChannelFuture
的ChannelFutureListener
将在操作完成时被通知该操作是成功了还是出错了 - 几乎所有
ChannelOutboundHandler
上的方法都会传入一个ChannelPromise
实例,作为ChannelFuture
的子类,ChannelPromise
也可以被分配用于异步通知的监听器,同时也提供了立即通知的可写方法(setSuccess,setFailure
)
- 每个出站操作都将返回一个
第 6 章 ChannelHandler 和 ChannelPipeline
最后编辑于 :
©著作权归作者所有,转载或内容合作请联系作者
- 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
- 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
- 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
推荐阅读更多精彩内容
- 本文是Netty文集中“Netty in action”系列的文章。主要是对Norman Maurer and M...
- 1. ByteBuf API的优点 可以被扩展 通过内置的复合缓冲区类型实现了透明的零拷贝 容量可以按需增长 读写...
- 本文是Netty文集中“Netty 源码解析”系列的文章。主要对Netty的重要流程以及类进行源码解析,以使得我们...