本文主要是介绍Netty源码分析(四):关于ChannelPipeline和addLast,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
ChannelPipeline
1.架构设计:
Channel都有且仅有一个ChannelPipeline与之对应,Channel包含了ChannelPipeline,ChannelPipeline内部包含了N个handler,每一个handler都是由一个线程去执行;
ChannelPipeline内部维护了一个由ChannelHandlerContext组成的双向链表,头为HeadContext,尾为TailHandler(双向链表为自己写的,而不是使用JDK的链表,为了轻量级),并且每个ChannelHandlerContext中又关联着一个ChannelHandler:
2.ChannelInboundHandler和ChannelOutboundHandler
设计技巧:tail是Inbound为true,head是outbound为true,可以理解为尾进头出,就是由inbound和outbound变量来控制的,这也是使用者要添加handler则使用addLast方法的原因;不过注意这里不能理解成队列,因为是有顺序的
inbound设计
in和out是相对channel、即程序来说的;out即往外面发送东西,in即接收东西。
两者都是异步发生、在线程中响应的,通过线程去执行。
out为请求型的动作,由业务程序来触发;in为响应型的动作,由Netty来触发,业务程序被动接收。
什么时候使用inbound呢?
实现了接口后,可以看到需要实现channelRead0方法,这个方法使用者无须调用,因为是由netty调用的,此接口的其他方法也是如此,因此做业务过程中,最多的就是用inbound,而outbound需要手动去调用
connect方法中,层层调用,到达AbstractChannel.AbstractUnsafe#register0方法
//AbstractChannel.AbstractUnsafe#register0
private void register0(ChannelPromise promise) {doRegister();//将SocketChannel注册到selector中,之前已经分析过pipeline.fireChannelRegistered();//重点分析
}
//DefaultChannelPipeline#fireChannelRegistered
public final ChannelPipeline fireChannelRegistered() {AbstractChannelHandlerContext.invokeChannelRegistered(head);//传入headreturn this;<
这篇关于Netty源码分析(四):关于ChannelPipeline和addLast的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!