pipeline.fireChannelActive()管道的遍历激活

原创

spbreak

发布于 2023-09-29 16:07:25

1810

发布于 2023-09-29 16:07:25

文章被收录于专栏：nettynetty

一. 管道的编历激活

pipeline管道是处理channel与socket之间数据传输的一系列加工流
添加到pipeline中的handler处理器, 代表一个数据加工处理的子步骤
每个handler处理器继承一个channelActive管道激活方法
pipeline.fireChannelActive() 管道的启动通道激活方法是遍历所有符合事件掩码的handler.channelActive()方法

二. 事件掩码

MASK事件掩码: 以二进制数值代表一个事件如: 二进制 1111, 代表4个事件
MASK_ONLY_INBOUND : 入站事件掩码集
MASK_ONLY_OUTBOUND : 出站事件掩码集

// 通过位运算的方法, 判断此处理器(Context)的事件掩码是否包含在符合的事件掩码集内
private static boolean skipContext(
    AbstractChannelHandlerContext ctx, EventExecutor currentExecutor, int mask, int onlyMask) {
// Ensure we correctly handle MASK_EXCEPTION_CAUGHT which is not included in the MASK_EXCEPTION_CAUGHT
return (ctx.executionMask & (onlyMask | mask)) == 0 ||
        // We can only skip if the EventExecutor is the same as otherwise we need to ensure we offload
        // everything to preserve ordering.
        //
        // See https://github.com/netty/netty/issues/10067
        (ctx.executor() == currentExecutor && (ctx.executionMask & mask) == 0);
}