netty设计模式-责任链模式

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

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

1、责任处理器接口

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

3、上下文

4、责任链终止机制。

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

 

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

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

 

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

里面有各种add和remove的方法

 

3、然后是上下文ChannelHandlerContext：

1. public interface ChannelHandlerContext extends AttributeMap, ChannelInboundInvoker, ChannelOutboundInvoker {

2.  

3. /**

4. * Return the {@link Channel} which is bound to the {@link ChannelHandlerContext}.

5. */

6. Channel channel();

7.  

8. /**

9. * Returns the {@link EventExecutor} which is used to execute an arbitrary task.

10. */

11. EventExecutor executor();

12.  

13. ...

14. }

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

 

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

现在我们自定义一个InBoundHandlerC

1. public class InBoundHandlerC extends ChannelInboundHandlerAdapter {

2. @Override

3. public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {

4. System.out.println("InBoundHandlerC: " + msg);

5. ctx.fireChannelRead(msg);

6. }

7. }

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

1. @Override

2. public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {

3. ctx.fireChannelRead(msg);

4. }

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

 

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

1. @Override

2. public ChannelHandlerContext fireChannelRead(final Object msg) {

3. invokeChannelRead(findContextInbound(), msg);

4. return this;

5. }

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

1. private AbstractChannelHandlerContext findContextInbound() {

2. AbstractChannelHandlerContext ctx = this;

3. do {

4. ctx = ctx.next;

5. } while (!ctx.inbound);

6. return ctx;

7. }

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