【设计模式】责任链模式的介绍及其应用

责任链的介绍

责任链模式是一种对象的行为模式。在责任链模式里，很多对象由每一个对象对其下家的引用而连接起来形成一条链。请求在这个链上传递，直到链上的某一个对象决定处理此请求。发出这个请求的客户端并不知道链上的哪一个对象最终处理这个请求，这使得系统可以在不影响客户端的情况下动态地重新组织和分配责任。

在责任链模式当中，客户端只用执行一次流程开始的请求便不再需要参与到流程执行当中，责任链上的流程便能够自己一直往下执行，客户端同样也并不关心执行流程细节，从而实现与流程之间的解耦。

责任链的结构

责任链模式需要有以下几个角色：

抽象处理器（Handler）：处理器抽象接口，定义了处理请求的方法和执行下一步处理的处理器
具体处理器（ConcreteHandler）：执行请求的具体实现，先根据请求执行处理逻辑，完成之后将请求交给下一个处理器执行
调用者：调用者通过创建处理器并将请求交给处理器进行处理

Java实现

Context是全部参数，用于在各个处理器中流转。

@Data
@Builder
public class Context {

    private String name;

    private String type;
}

Handler抽象的处理器，定义了执行和判断是否需要执行的接口。

public interface Handler {

    void execute(Context context, HandlerChain chain);

    default boolean skip(Context context) {
        return false;
    }
}

NameHandler用来处理参数中的name属性

@AutoService(Handler.class)
public class NameHandler implements Handler {
    @Override
    public void execute(Context context, HandlerChain chain) {
        System.out.println("name: " + context.getName());
        chain.execute(context);
    }

    @Override
    public boolean skip(Context context) {
        if ("name1".equals(context.getName())) {
            return true;
        }
        return false;
    }
}

TypeHandler用来处理参数中的type属性

@AutoService(Handler.class)
public class TypeHandler implements Handler {
    @Override
    public void execute(Context context, HandlerChain chain) {
        System.out.println("type: " + context.getType());
        chain.execute(context);
    }
}

HandlerChain用于封装处理器链条，提供执行入口。

public class HandlerChain {

    private int index;

    private final List<Handler> handlers;

    HandlerChain(List<Handler> handlers) {
        this.handlers = handlers;
    }

    public void execute(Context context) {
        if (this.index < handlers.size()) {
            Handler handler = handlers.get(this.index++);
            boolean skip = handler.skip(context);
            if (skip) {
                this.execute(context);
            }else {
                handler.execute(context, this);
            }

        }
    }

}

测试效果

public class ChainTest {

    public static void main(String[] args) {
        ServiceLoader<Handler> serviceLoader = ServiceLoader.load(Handler.class);
        List<Handler> handlers = StreamSupport
                .stream(serviceLoader.spliterator(), false)
                .collect(Collectors.toList());
        HandlerChain handlerChain = new HandlerChain(handlers);
        Context context = Context.builder().name("name").type("type").build();
        handlerChain.execute(context);

        HandlerChain handlerChain1 = new HandlerChain(handlers);
        Context context1 = Context.builder().name("name1").type("type1").build();
        handlerChain1.execute(context1);

    }
}