ChannelHandlerContext 相关源码分析（二十四）

水深无声 2022-10-29 14:20 116阅读 0赞

今天我们对ChannelHandlerContext 相关源码分析

**一、ChannelHandlerContext **

ChannelHandlerContext 代表了一个 ChannelHandler 和 ChannelPipeline 之间的关系，Netty会把 ChannelHandler 包装进 ChannelHandlerContext 的实例 DefaultChannelHandlerContext，然后把 ChannelHandlerContext 作为元素来组成链表。所以 ChannelHandlerContext 中一定有获得ChannelHandler 和 ChannelPipeline 相关的方法。ChannelHandlerContext 主要功能是管理在统一 ChannelPipeline 中各个 ChannelHandler的交互，所以同时 ChannelHandlerContext 也有很多触发事件传播相关的方法。ChannelHandlerContext 主要实现就三个

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70][]

都继承自 AbstractChannelHandlerContext。

**1、AbstractChannelHandlerContext**

这里面几乎所有与网络通信相关的方法，套路都一样，比如  fireChannelRead  方法，这是个 inbound  类型的方法，当调用  ctx.fireChannelRead  方法时，首先找到链表中下一个 inbound 类型的  handler ，然后进行线程本地性判断，是则直接执行，不是则投入线程的队列异步执行。

**2、HeadContext**  **和**  **TailContext  ** 通过 DefaultChannelPipeline  的构造方法，我们可以看到

protected DefaultChannelPipeline(Channel channel) {
        this.channel = ObjectUtil.checkNotNull(channel, "channel");
        succeededFuture = new SucceededChannelFuture(channel, null);
        voidPromise =  new VoidChannelPromise(channel, true);
    
        tail = new TailContext(this);
        head = new HeadContext(this);
    
        head.next = tail;
        tail.prev = head;
    }

HeadContext 和 TailContext 是 DefaultChannelPipeline 是在创建的时候被加入 DefaultChannelPipeline 管理的链表中，而且是居于头尾的两个，也就是说，加入我们的业务 handle 后，handle 链表其实是： HeadContext->业务 handler->TailContext->我们的业务代码

***3、HeadContext***

final class HeadContext extends AbstractChannelHandlerContext
            implements ChannelOutboundHandler, ChannelInboundHandler {

可以看见，HeadContext 既是 ChannelHandlerContext，又是 ChannelHandler，而且是同时处理 inbound 类型和 outbound 类型的 ChannelHandler。 在具体的方法上，outbound 类型事件的方法都是直接调用 unsafe 中的相关方法，而inbound 类型事件的方法则会触发事件在 ChannelPipeline 中的传播。

***4、TailContext***

final class TailContext extends AbstractChannelHandlerContext implements ChannelInboundHandler {

可以看见，TailContext  既是  ChannelHandlerContext ，又是  ChannelHandler ，而且是处理inbound 类型  ChannelHandler 。

在具体的方法上， TailContext  里的方法基本上都是空实现，有确实代码实现的是：

final class TailContext extends AbstractChannelHandlerContext implements ChannelInboundHandler {
    
        TailContext(DefaultChannelPipeline pipeline) {
            super(pipeline, null, TAIL_NAME, true, false);
            setAddComplete();
        }
    
        @Override
        public ChannelHandler handler() {
            return this;
        }
    
        @Override
        public void channelRegistered(ChannelHandlerContext ctx) throws Exception { }
    
        @Override
        public void channelUnregistered(ChannelHandlerContext ctx) throws Exception { }
    
        @Override
        public void channelActive(ChannelHandlerContext ctx) throws Exception {
            onUnhandledInboundChannelActive();
        }
    
        @Override
        public void channelInactive(ChannelHandlerContext ctx) throws Exception {
            onUnhandledInboundChannelInactive();
        }
    
        @Override
        public void channelWritabilityChanged(ChannelHandlerContext ctx) throws Exception {
            onUnhandledChannelWritabilityChanged();
        }
    
        @Override
        public void handlerAdded(ChannelHandlerContext ctx) throws Exception { }
    
        @Override
        public void handlerRemoved(ChannelHandlerContext ctx) throws Exception { }
    
        @Override
        public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
            onUnhandledInboundUserEventTriggered(evt);
        }
    
        @Override
        public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
            onUnhandledInboundException(cause);
        }
    
        @Override
        public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
            onUnhandledInboundMessage(msg);
        }
    
        @Override
        public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
            onUnhandledInboundChannelReadComplete();
        }
    }

点击：onUnhandledInboundUserEventTriggered(evt);

protected void onUnhandledInboundUserEventTriggered(Object evt) {
        // This may not be a configuration error and so don't log anything.
        // The event may be superfluous for the current pipeline configuration.
        ReferenceCountUtil.release(evt);
    }

点击”：onUnhandledInboundException(cause);

protected void onUnhandledInboundException(Throwable cause) {
        try {
            logger.warn(
                    "An exceptionCaught() event was fired, and it reached at the tail of the pipeline. " +
                            "It usually means the last handler in the pipeline did not handle the exception.",
                    cause);
        } finally {
            ReferenceCountUtil.release(cause);
        }
    }

点击：onUnhandledInboundMessage(msg);

protected void onUnhandledInboundMessage(Object msg) {
        try {
            logger.debug(
                    "Discarded inbound message {} that reached at the tail of the pipeline. " +
                            "Please check your pipeline configuration.", msg);
        } finally {
            ReferenceCountUtil.release(msg);
        }
    }

这三个方法无一例外都是进行了相关资源的释放工作。

**5、DefaultChannelHandlerContext**

DefaultChannelHandlerContext  这个里面的代码就非常简单了，大家自行查阅。

ChannelHandlerContext 相关源码分析到此结束，下篇分析ChannelHandler 源码，敬请期待！

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70]: /images/20221024/3efa09159e63427e99b6c55326b51caf.png