Netty源码分析(七):初识ChannelPipeline

栏目: Java · 发布时间: 5年前

内容简介:的类图:与一个特定的线程进行了绑定,并且在其生命周期内,绑定的线程都不会再改变。

ChannelPipeline 单看名称就可以知道 Channel 的管道。本篇将结合它的默认实现类 DefaultChannelPipeline 来对它做一个简单的介绍。

示例图

Netty源码分析(七):初识ChannelPipeline
上图是官方提供的 ChannelPipeline 的事例图。IO请求经由 ChannelOutboundHandlerChannelOutboundHandler 处理之后写出到服务端,服务接收到读入后,由 ChannelInboundHandler 依次处理。 下面来看下 DefaultChannelPipeline

的类图:

Netty源码分析(七):初识ChannelPipeline
DefaultChannelPipeline 实现了 ChannelPipeline 接口,而 ChannelPipeline 又继承了 ChannelInboundInvokerChannelOutboundInvokerIterableChannelInboundInvoker :发起对 ChannelPipeline 中下一个 ChannelInboundHandler 的方法的调用。 ChannelOutboundInvoker :发起对 ChannelPipeline 中下一个 ChannelOutboundHandler 的方法的调用。 Iterable :可遍历 ChannelPipeline 中的 ChannelHandlerNioEventLoop 继承自 SingleThreadEventLoop ,而 SingleThreadEventLoop 又继承自 SingleThreadEventExecutorSingleThreadEventExecutor 内部持有一个Thread对象,是 Netty 多线程的基础。 可以认为, 一个 NioEventLoop

与一个特定的线程进行了绑定,并且在其生命周期内,绑定的线程都不会再改变。

DefaultChannelPipeline

DefaultChannelPipeline 的主要工作就是对 ChannelHandler 的管理,包括 ChannelHandler 的增减,事件的触发等。

ChannelHandler 的增减

addFirst 方法为例:

public final ChannelPipeline addFirst(EventExecutorGroup group, String name, ChannelHandler handler) {
        final AbstractChannelHandlerContext newCtx;
        synchronized (this) {
            // 检查handler是否可以共享
            checkMultiplicity(handler);
            // 给AbstractChannelHandlerContext起个独立的名字
            name = filterName(name, handler);
            // 创建DefaultChannelHandlerContext
            newCtx = newContext(group, name, handler);
            // 执行实际的添加操作
            addFirst0(newCtx);
            // channel尚未注册到eventloop
            if (!registered) {
                // 设置newCtx的状态为ADD_PENDING
                newCtx.setAddPending();
                // 设置过一会回调ChannelHandler的handlerAdded方法
                callHandlerCallbackLater(newCtx, true);
                return this;
            }
            EventExecutor executor = newCtx.executor();
            if (!executor.inEventLoop()) {
                newCtx.setAddPending();
                executor.execute(new Runnable() {
                    @Override
                    public void run() {
                        callHandlerAdded0(newCtx);
                    }
                });
                return this;
            }
        }
        callHandlerAdded0(newCtx);
        return this;
    }
复制代码

addFirst 方法先检查添加的 ChannelHandler 是否可以共享(判断共享的方法是对于每个channel当前ChannelHandler是否需要不同的状态),再创建 ChannelHandler 的上下文关系,使 ChannelHandler 以链表方式存在于 ChannelPipeline 中。当 ChannelHandler 添加成功后,再调用 ChannelHandlerhandlerAdded 方法。其它的添加方式和 addFirst 类似。

事件触发

fireChannelActive 方法为例:

public final ChannelPipeline fireChannelActive() {
        AbstractChannelHandlerContext.invokeChannelActive(head);
        return this;
    }
复制代码

HeadContext 的head开始,依次触发下一个 ChannelHandlerchannelActive 方法。

本篇简单介绍了 ChannelPipeline 的相关概念,当 ChannelHandler 介绍完后,再具体介绍 ChannelPipeline 中的 HeadContextTailContext

文中帖的代码注释全在: KAMIJYOUDOUMA , 有兴趣的童鞋可以关注一下。

本篇到此结束,如果读完觉得有收获的话,欢迎点赞、关注、加公众号【贰级天災】,查阅更多精彩历史!!!

Netty源码分析(七):初识ChannelPipeline

以上所述就是小编给大家介绍的《Netty源码分析(七):初识ChannelPipeline》,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持!

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

金融数量分析

金融数量分析

郑志勇 / 北京航空航天大学出版社 / 2014-7-1 / CNY 58.00

《金融数量分析——基于MATLAB编程(第3版)》一书中的案例均来源于作者的工作实际,并充分体现“案例的实用性、程序的可模仿性”,程序中附有详细的注释。例如,投资组合管理、KMV模型计算、期权定价模型与数值方法、风险价值VaR的计算等案例程序,读者可以直接使用或根据需要在源代码的基础上修改、完善。 本书共23章。前两章分别对金融市场的基本概况与MATLAB的基础知识进行概述;接下来为20个金......一起来看看 《金融数量分析》 这本书的介绍吧!

随机密码生成器
随机密码生成器

多种字符组合密码

XML、JSON 在线转换
XML、JSON 在线转换

在线XML、JSON转换工具

正则表达式在线测试
正则表达式在线测试

正则表达式在线测试