netty里面最重要的应该是ChannelHandler,这个里面也是用户编程直接打交道的接口,也是串行于ChannelPipeLine里面执行相应的业务逻辑。
从类结构来看,一个handler应该有一个ChannelHandlerContext,ChannelHandler是处在上层的一个标识接口,下面有两个接口分别来处理Upstream event和一个Downstream event。
ChannelHandler比较好理解,我们重点来看DefaultChannelHandlerContext的实现类。
volatile DefaultChannelHandlerContext next; volatile DefaultChannelHandlerContext prev; private final String name; private final ChannelHandler handler; private final boolean canHandleUpstream; private final boolean canHandleDownstream; private volatile Object attachment;
在这个里面,可以看到有个链表结构,next、prev分别有指向前一个和后一个的HandlerContext,一个是handlerContext的名称,一个是handler就是里面的handler对象,两个变量用来标识是否可以处理upstream和downstream事件的能力,最后一个是attachment,里面放的是handler里面可以传递的一些共享变量信息。
DefaultChannelHandlerContext( DefaultChannelHandlerContext prev, DefaultChannelHandlerContext next, String name, ChannelHandler handler) { if (name == null) { throw new NullPointerException("name"); } if (handler == null) { throw new NullPointerException("handler"); } canHandleUpstream = handler instanceof ChannelUpstreamHandler; canHandleDownstream = handler instanceof ChannelDownstreamHandler; if (!canHandleUpstream && !canHandleDownstream) { throw new IllegalArgumentException( "handler must be either " + ChannelUpstreamHandler.class.getName() + " or " + ChannelDownstreamHandler.class.getName() + '.'); } this.prev = prev; this.next = next; this.name = name; this.handler = handler; }
构造函数也很容易理解,在初始化的时候就将next和prev传递过来了,同时初始化了handler和name,以及根据handler的性质是否可以来处理相关的event。
我们来看sendDownstream和sendUpstream的实现吧。
public void sendDownstream(ChannelEvent e) { DefaultChannelHandlerContext prev = getActualDownstreamContext(this.prev); if (prev == null) { try { getSink().eventSunk(DefaultChannelPipeline.this, e); } catch (Throwable t) { notifyHandlerException(e, t); } } else { DefaultChannelPipeline.this.sendDownstream(prev, e); } }
从这个代码来看,通过getActualDownstreamContext顺着prev链条超前找,找到前一个可以处理downstream的handlerContext,然后开始执行,如果找不到就交给Sink来处理,从这里来看也能体会到一点handler和sink自己的一些关系,作者将这个抽象成两个组件来处理确实比较厉害。
同理我们也可以猜到upstream事件的处理逻辑,找到最后一个handler然后一点一点的处理。
public void sendUpstream(ChannelEvent e) { DefaultChannelHandlerContext next = getActualUpstreamContext(this.next); if (next != null) { DefaultChannelPipeline.this.sendUpstream(next, e); } }
相关推荐
一个netty的入门教程以及源码分析视频,适合刚学习的人
netty源码解析PDF,网络编程
美团基础架构部闪电侠老师的netty源码分析视频
共分两大章:第1 章:深入浅出Netty源码剖析,第2 章:NIO+Netty5各种RPC架构实战演练,以及课程资料,希望对象学习netty的童靴有用。
Netty源码分析总结.rar
netty源码
netty基本使用以及入门资料,具有netty的源码的分析以及服务器启动过程的介绍
netty源码和相关中文文档。帮助您快速上手netty开发。netty体验之旅祝您愉快
netty源码解析视频教程,深入浅出netty源码视频
Netty好资料,Buffer介绍
Netty源码剖析+视频
Netty5.0架构剖析和源码解读.pdf是一本比较全的讲解netty5的书籍,任何对java的nio技术感兴趣的人都值得一看。
【项目实战】Netty源码剖析&NIO;+Netty5各种RPC架构实战演练三部曲视频教程(未加密)
Netty权威指南源码
Netty源码解读之线程
netty-3.3.1.Final-sources.jar src源码
视频分两部分 第1 章 : 第一部分、深入浅出Netty源码剖析。。 第2 章 : 第二部分、NIO+Netty5各种RPC架构实战演练
netty源码包,可以本地搭建netty源码环境,学习nio模式
netty 源码
Netty源码依赖包,最新版源码依赖包,源码解读必备