设为首页 加入收藏

TOP

Netty的ChannelPipeline
2014-11-24 01:40:33 来源: 作者: 【 】 浏览:2
Tags:Netty ChannelPipeline

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的方向是从尾到头。


相关阅读:


】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
分享到: 
上一篇Netty的ChannelFuture 下一篇C++中的位运算符

评论

帐  号: 密码: (新用户注册)
验 证 码:
表  情:
内  容: