netty学习--handler传递

在netty中的处理链pipeline中,事件是按顺序传递的,把自己拟人为netty程序,针对进来(inbound)的请求,会从head开始,依次往tail传递。

pipeline采用了链表结构,head中有next引用,指向下一个ChannelHandlerContext,直到传递到tail。

在io.netty.channel.DefaultChannelHandlerContext#fireChannelActive中,源码如下:

@Override
    public ChannelHandlerContext fireChannelActive() {
        DefaultChannelHandlerContext next = findContextInbound(MASK_CHANNEL_ACTIVE); //传递active掩码
        next.invoker.invokeChannelActive(next);
        return this;
    }

下面主要看看:

    private DefaultChannelHandlerContext findContextInbound(int mask) {
        DefaultChannelHandlerContext ctx = this;
        do {
            ctx = ctx.next; //针对inbound请求,在链表中的传递顺序为head到tail,所以这边取next
        } while ((ctx.skipFlags & mask) != 0);//可以看出,循环继续的条件为ctx.skipFlags & mask不为0,也就是该handler上下文的跳过标志中,如果包含了参数指定的掩码,就要跳过,不进行处理。
        return ctx;
    }

综上,遍历过程中,发现的第一个不跳过参数指定掩码的事件的处理器,就是要进行处理的下一个处理器。

原文地址:https://www.cnblogs.com/grey-wolf/p/7194936.html