netty设计模式-责任链模式

灰太狼 2022-05-18 11:08 128阅读 0赞

责任链模式的定义：使多个对象都有机会处理请求，从而避免请求的发送者和接受者之间的耦合关系， 将这个对象连成一条链，并沿着这条链传递该请求，直到有一个对象处理他为止。

首先来看看责任链模式的四个要素：

1、责任处理器接口

2、创建链，添加删除责任处理器接口

3、上下文

4、责任链终止机制。

在netty里面，很明显channelHandler和Pipeline构成了责任链模式。让我们通过上面的要素，一个一个分析

1、首先是责任处理器接口：

ChannelHandler就是责任处理器接口，ChannelInboundHandler、ChannelOuntboundHandler是它的两个增强。

2、找到创建链，添加删除责任处理器接口ChannelPipeline：

![70][]

里面有各种add和remove的方法

3、然后是上下文ChannelHandlerContext：

public interface ChannelHandlerContext extends AttributeMap, ChannelInboundInvoker, ChannelOutboundInvoker {
    
        /**
         * Return the {@link Channel} which is bound to the {@link ChannelHandlerContext}.
         */
        Channel channel();
    
        /**
         * Returns the {@link EventExecutor} which is used to execute an arbitrary task.
         */
        EventExecutor executor();
    
        ...
    }

里面有两个最重要的方法，一个返回绑定的channel，一个返回executor来执行任务。

4、最后我们看责任链终止机制

现在我们自定义一个InBoundHandlerC

public class InBoundHandlerC extends ChannelInboundHandlerAdapter {
        @Override
        public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
            System.out.println("InBoundHandlerC: " + msg);
            ctx.fireChannelRead(msg);
        }
    }

ctx.fiteChannelRead方法就是为了把责任传递下去。如果注释掉了，消息就不会传递。另外如果不重写channelRead方法，默认会传递，让我们查看ChannelInboundHandlerAdapter的channelRead方法：

@Override
        public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
            ctx.fireChannelRead(msg);
        }

默认会传递。这里另外提一句，java里面的很多filter，是否继续向下传递，都是return true还是return 方法来实现的。

最后，消息是如何一步步向下传递的呢，让我们看AbstractChannelHandlerContext的fireChannelRead方法：

@Override
        public ChannelHandlerContext fireChannelRead(final Object msg) {
            invokeChannelRead(findContextInbound(), msg);
            return this;
        }

继续点击findContextInbound(),可以看到：

private AbstractChannelHandlerContext findContextInbound() {
            AbstractChannelHandlerContext ctx = this;
            do {
                ctx = ctx.next;
            } while (!ctx.inbound);
            return ctx;
        }

也就是，这里是不停地指向下一个对象实现的。

[70]: /images/20220518/b1bd2501e22e4a93bd2a8e0491316a1b.png