概述
Chanel的生命周期:
状态 | 描述 |
ChannelUnregistered | Channel已被创建,但未注册到EventLoop |
ChannelRegisterd | Channel注册到EventLoop |
ChannelActive | Channel处于活动状态 |
ChannelInactive | Channel没有连接到远程节点 |
Channel的状态发生改变是,会生成相应的事件,这些事件将会转发给ChannelPipline中的ChannelHandler.
ChannelHandler的生命周期:
在ChannelHandler被添加到ChannelPipline中或被从ChannelPipline中移除时回调用这些操作。
ChannelHandler中重要的子接口:
使用了适配器模式--对核心的ChannelHandler及其子类进行包装以向外提供接口。当你想在自己的ChannelHandler中使用这些适配器类,只需要简单的扩展它们,并且重写你想自定义的方法例如channelRead0();
- ChannelInBoundHandler---处理入站数据以及各种状态变化
- ChannelOutBoundHandler---处理出站数据并且允许拦截所有的操作
ChannelInBoundHandler接口:
我们常用的是SimpleChannelInboundHandler它继承自ChannelInboundHandlerAdapter, ChannelInboundHandlerAdapter的执行流程[我们在使用一个体系的时候,要参阅顶层,使用底层对象]:
如果在项目中直接使用ChannelInboundHandlerAdapter比较繁琐,需要自己来释放资源,而SimpleChannelInboundHandler会自动释放资源。
// 实现了上层的接口channelRead--所以不需要我们自己释放资源
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
boolean release = true;
try {
if (this.acceptInboundMessage(msg)) {
this.channelRead0(ctx, msg); // 调用我们自定义的方法
} else {
release = false;
ctx.fireChannelRead(msg);
}
} finally {
if (this.autoRelease && release) {
ReferenceCountUtil.release(msg); // 此处释放了资源
}
}
}
// 我们只需要继承SimpleChannelInboundHandler,然后实现channelRead0这个方法即可
protected abstract void channelRead0(ChannelHandlerContext var1, I var2) throws Exception;
调用的顺序:
ChannelInBoundHandler接口:
出站操作和数据将由ChannelOutboundHandler处理。它的方法将被Channel、ChannelPipLine以及ChannelHandlerContext调用。其强大功能就是可以按需推迟操作或者事件,使得可以通过复杂的方法处理请求。
ChannelOutboundHandler中的大部分方法都需要一个ChannelPromise参数以便在操作完成时得到通知。ChannelPromise是ChannelFuture的一个子类,定义了一些可写的方法,如setSuccess()和setFailure(),从而使ChannelFuture不可变。
最后
以上就是从容鸵鸟为你收集整理的Netty回调与Channel执行流程分析的全部内容,希望文章能够帮你解决Netty回调与Channel执行流程分析所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。
发表评论 取消回复