Netty框架之ChannelPipeline

本文主要记录下本人看Netty源码中关于ChannelPipeline的细节问题,为原创内容,如有文中有书写或其他问题,请留言指导修正,互相交流,共同进步,本人QQ:417213902。

认识ChannelPipeline

image.png

ChannelPipeline内部是实现类似责任链的调用,每一个handler记录下一个handler,感觉有点像servlet中的Filter链。

源码解读

image.png

首先,看下ChannelPipeline接口主要继承ChannelInboundInvoker 和ChannelOutboundInvoker这两个接口

  • ChannelInboundInvoker :AbstractChannelHandlerContext中实现了该接口,并调用ChannelInboundHandler的接口,从而实现真正的调用
  • ChannelOutboundInvoker :AbstractChannelHandlerContext中实现了该接口,并调用ChannelOutboundHandler的接口,从而实现真正的调用
  • ChannelInboundHandler:对从客户端发往服务端的报文进行处理,一般用来执行解码、读取客户端数据、进行业务处理等,按照注册的先后顺序执行,若要自行实现ChannelInboundHandler接口,直接继承ChannelInboundHandlerAdapter,因为此类已经有默认接口实现。
  • ChannelOutboundHandler:对从服务端发往客户端的报文进行处理,一般用来进行编码、发送报文到客户端,按照注册的先后顺序逆序执行 ,同上。

其次,来讲下ChannelPipeline的初始化,以下代码是Netty-4.1官方提供的Example 中服务端代码(io.netty.example.echo.EchoServer),这里做了不少的事情,这里除了ChannelPipeline初始化,其他内容会在其他的文章中做阐述,这里我们主要看 .channel(NioServerSocketChannel.class)

EventLoopGroup bossGroup = new NioEventLoopGroup(1);
EventLoopGroup workerGroup = new NioEventLoopGroup();
 try {
             ServerBootstrap b = new ServerBootstrap();
             b.group(bossGroup, workerGroup)
             .channel(NioServerSocketChannel.class)
             .option(ChannelOption.SO_BACKLOG, 100)
             .handler(new LoggingHandler(LogLevel.INFO))
             .childHandler(new ChannelInitializer<SocketChannel>() {
                 @Override
                 public void initChannel(SocketChannel ch) throws Exception {
                     ChannelPipeline p = ch.pipeline();
                     if (sslCtx != null) {
                         p.addLast(sslCtx.newHandler(ch.alloc()));
                     }
                     //p.addLast(new LoggingHandler(LogLevel.INFO));
                      p.addLast(new EchoServerHandler());
                 }
             });
            ChannelFuture f = b.bind(PORT).sync();
            f.channel().closeFuture().sync();
        } finally {        
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
image.png

这是NioServerSocketChannel的类结构层次图,这里我们主要看AbstractChannel这个抽象类,查看其构造方法,这里同时也实例化了一个DefaultChannelPipeline。


image.png

它其实是Netty中ChannelPipeline接口的具体实现类,是ChannelPipeline的核心类,责任链的一系列实现基本都是通过这个类来操作。

image.png

我们再来看下DefaultChannelPipeline的构造方法中实例化了两个类,分别是TailContext和HeadContext,都继承或实现了这两个接口ChannelHandlerContext 和 ChannelHandler ,它们互相指向, 构成一个类似于双向链表的容器

  • TailContext :我的理解是它是整个链的最后,虽然它实现了ChannelInboundHandler,但是实现的方法都是空实现,我认为它针对Inbound没有实际上的作用(有点怪异),查资料网上有说法,因为在最后,没有具体实现,说明是一种优雅的退出。


    image.png
  • HeadContext :我的理解是它是整个链的第一个,它对ChannelInboundHandler和ChannelOutboundHandler所有方法都有了实现


    image.png
  • ChannelHandlerContext :是ChannelPipeline 链中每一个handler 的上下文信息,负责调用对应的ChannelHandler,并指定下一个ChannelHandlerContext(我的理解)

  • ChannelHandler : 负责执行对应的handler,并回调context进行下一次调用

image.png

最后ChannelPipeline真正在哪加载的?
我们会看到上面摘取的部分Example源码中,有初始化ChannelPipeline,本以为此处就是加载处,但是后面看到ServerBootstrap.bind方法后,发现里面有个init方法,这里又再次重新加载了,我猜想是因为刚开始的Channel通道没有被绑定或注册到真正的Channel上,还需要进一步探讨。


image.png

2017-12-17 01:24

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 218,204评论 6 506
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 93,091评论 3 395
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 164,548评论 0 354
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,657评论 1 293
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,689评论 6 392
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,554评论 1 305
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,302评论 3 418
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 39,216评论 0 276
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,661评论 1 314
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,851评论 3 336
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,977评论 1 348
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,697评论 5 347
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,306评论 3 330
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,898评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 33,019评论 1 270
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 48,138评论 3 370
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,927评论 2 355

推荐阅读更多精彩内容

  • “我的天啊,乔治”金发男孩哭丧着脸,一边揉着肩膀,一边跟旁边做着推举的同伴抱怨道,“我们有半年没见了吧?好不容...
    winng伍寅阅读 348评论 0 0
  • 睡眠日夜颠倒已有一段时间,尝试了不少方法来改变,依旧如常。 每到假期,心中的恶魔仿佛释放了一般,肆意的放纵自己,抱...
    鲜活了颜色阅读 308评论 4 3
  • 1.重要的三部分 a.情绪. c.情绪的分类. c.情操. 2.原因. a.知道了负面情绪,原来也不是像我们认识的...
    初见_86a6阅读 146评论 0 0
  • chenyaoyao123阅读 99评论 0 0
  • 《秋》:致好友 秋 似酒 味醇厚 岁月悠悠 转身又回首 再抚喜乐哀愁 往事如烟花依旧 唯友谊绵长如水流 只缘一路有...
    本颗奋斗心阅读 711评论 0 1