暂无图片
暂无图片
暂无图片
暂无图片
暂无图片

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

贰级天災 2019-06-03
127

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

示例图


上图是官方提供的ChannelPipeline
的事例图。IO请求经由ChannelOutboundHandler
ChannelOutboundHandler
处理之后写出到服务端,服务接收到读入后,由ChannelInboundHandler
依次处理。
下面来看下DefaultChannelPipeline
的类图:

DefaultChannelPipeline
实现了ChannelPipeline
接口,而ChannelPipeline
又继承了ChannelInboundInvoker
ChannelOutboundInvoker
Iterable

ChannelInboundInvoker
:发起对ChannelPipeline
中下一个ChannelInboundHandler
的方法的调用。
ChannelOutboundInvoker
:发起对ChannelPipeline
中下一个ChannelOutboundHandler
的方法的调用。
Iterable
:可遍历ChannelPipeline
中的ChannelHandler

NioEventLoop
继承自SingleThreadEventLoop
,而SingleThreadEventLoop
又继承自SingleThreadEventExecutor

SingleThreadEventExecutor
内部持有一个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
添加成功后,再调用ChannelHandler
handlerAdded
方法。其它的添加方式和addFirst
类似。

事件触发

fireChannelActive
方法为例:

    public final ChannelPipeline fireChannelActive() {
        AbstractChannelHandlerContext.invokeChannelActive(head);
        return this;
    }

复制

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

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

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


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


文章转载自贰级天災,如果涉嫌侵权,请发送邮件至:contact@modb.pro进行举报,并提供相关证据,一经查实,墨天轮将立刻删除相关内容。

评论