1、如何理解Netty的ChannelPipeline
在Netty中,每个Channel被创建的时候都需要被关联一个对应的pipeline(通道),这种关联关系是永久的(整个程序运行的生命周期中)。ChannelPipeline可以理解成一个消息( 或消息事件,ChanelEvent)流转的通道,在这个通道中可以被附上许多用来处理消息的handler,当消息在这个通道中流转的时候,如果有与这个消息类型相对应的handler,就会触发这个handler去执行相应的动作。它实现了Intercepting Filter模式(个人理解与Filter Chain模式类似)。
可以通过下面这句话来理解一些相关的概念:ChannelEvents are processed by ChannelHandlers in a ChannelPipeline
2、ChannelPipeline的创建方式
Netty的作者建议采用辅助类org.jboss.netty.channel.Channels的静态无参函数pipeline来创建一个ChannelPipeline对象,从源代码上看其实就是调用了DefaultChannelPipeline的无参构造函数,返回new出来的对象而已。
3、消息的流转
Netty中消息的流转有两个方向:上行、下行
因此,处理消息事件(ChannelEvent)的处理器(ChannelHandler)大致可以分为两个方向:ChannelUpstreamHandler、ChannelDownstreamHandler
* I/O Request
以upstream为例,从socket读出来的数据,逐渐往上进行传递,即原始数据依次往上被进行解析,可能因为所需要的业务数据外面包裹着许多其它附加的数据。如加密、验证、签名等。
downstream与此相反,即把业务数据进行一层层地加密、签名等处理后,写到socket中发出去。这个模型其实可以参考(TCP的七层模型)
4 、pipeline中的handlers顺序如何理解
在添加handler的时候,如果理解顺序。可以把pipeline理解成一个队列,addLast是添加到队列的尾部,addFirst是添加到队列的头部。
upstream的方向是从头到尾,downstream的方向是从尾到头。
相关阅读: