责任链（Chain of Resposibility） 模式
概念
责任链（chain of Resposibility） 模式：为了避免请求发送者与多个请求处理者耦合在一起，于是将所有请求的处理者 通过前一对象记住其下一个对象的引用而连成一条链；当有请求发生时，可将请求沿着这条链传递，直到有对象处理它位置。属于对象行为型模式。
-
抽象处理者（Handler）角色：定义一个处理请求的接口，包含抽象处理方法和一个后继连接。
-
具体处理者（Concrete Handler）角色：实现抽象处理者的处理方法，判断能否处理本次请求，如果可以处理请求则处理，否则将请求转给他的后继者。
-
客户类（Client）角色：创建处理链，并向链头的具体处理者对象提交请求，他不关心处理细节和请求的传递过程。
代码
需求1：a1 -> a2 -> a3
实现先a1处理完交给a2，a2处理完再交给a3的逻辑，即： a1 -> a2 -> a3
public class Teacher {private String name;public Teacher(String name) {this.name = name;}// 下一个处理的老师；1、链条的引用点private Teacher next;public Teacher getNext() {return next;}public void setNext(Teacher next) {this.next = next;}void handlerRequest() {System.out.println(this + "正在处理。。。。。。。。");// 2、下一个继续if (next != null) {next.handlerRequest();}}@Overridepublic String toString() {return "Teacher{" +"name='" + name + '\'' +'}';}
}public class MainTest {public static void main(String[] args) {Teacher a1 = new Teacher("a1");Teacher a2 = new Teacher("a2");Teacher a3 = new Teacher("a3");// 3、构造链条// a1->a2->a2a1.setNext(a2);a2.setNext(a3);a1.handlerRequest();}
}
测试结果：
Teacher{name='a1'}正在处理。。。。。。。。
Teacher{name='a2'}正在处理。。。。。。。。
Teacher{name='a3'}正在处理。。。。。。。。
需求2：1->2->3->本人->3->2->1
这个也就是我们学习过的Filter了
代码实现：
① Filter 接口
public interface Filter {void doFilter(Request request,Response response,FilterChain chain);
}
@Data
public class Request {// 请求内容String msg;public Request(String msg) {this.msg = msg;}
}@Data
public class Response {// 响应内容private String content;public Response(String content) {this.content = content;}
}② Filter 的三个实现类
public class HttpFilter implements Filter {@Overridepublic void doFilter(Request request, Response response, FilterChain chain) {// 第一个filter的功能request.msg += ">>>";System.out.println("HttpFilter ... doFilter之前");// 放行chain.doFilter(request, response, chain);System.out.println("HttpFilter ... doFilter之后");}
}
public class CharacterFilter implements Filter {@Overridepublic void doFilter(Request request, Response response, FilterChain chain) {// 功能request.msg += "====";System.out.println("CharacterFilter ... doFilter之前");// 放行chain.doFilter(request, response, chain);System.out.println("CharacterFilter ... doFilter之后");}
}
public class EncodingFilter implements Filter {@Overridepublic void doFilter(Request request, Response response, FilterChain chain) {// 功能request.msg += "oooo";System.out.println("EncodingFilter ... doFilter之前");// 放行chain.doFilter(request, response, chain);System.out.println("EncodingFilter ... doFilter之后");}
}
③ 我们的目标方法
public class My {void hello() {System.out.println("调用my.hello()方法");}
}```④ 维护链条```java
/*** 靠他维护链条* handlerExecutionChain** @author zhuicat* @since 2023/8/13 8:19*/
public class FilterChain implements Filter {// 游标：记录当前执行的步骤int cursor;// Filter 的链List<Filter> filterChain = new ArrayList<>();// 最终要执行的目标方法My target;// 添加 filter 方法void addFilter(Filter filter) {filterChain.add(filter);}@Overridepublic void doFilter(Request request, Response response, FilterChain chain) {// 执行第一个 filter ，一次往下// 游标小于总数量filter一直往下获取执行if (cursor < filterChain.size()) {Filter filter = filterChain.get(cursor);cursor++;// 执行 filterfilter.doFilter(request, response, chain);} else {// filter执行完了，需要执行目标方法了target.hello();}}public My getTarget() {return target;}public void setTarget(My target) {this.target = target;}
}⑤ 主方法
public class MainTest {public static void main(String[] args) {FilterChain chain = new FilterChain();// web.xmlHttpFilter httpFilter = new HttpFilter();CharacterFilter characterFilter = new CharacterFilter();EncodingFilter encodingFilter = new EncodingFilter();chain.addFilter(httpFilter);chain.addFilter(characterFilter);chain.addFilter(encodingFilter);chain.setTarget(new My());// filter 如何链式执行chain.doFilter(new Request("hello,world"), new Response("dddddddddddddddddd"), chain);}
}
⑥ 执行结果
HttpFilter ... doFilter之前
CharacterFilter ... doFilter之前
EncodingFilter ... doFilter之前
调用my.hello()方法
EncodingFilter ... doFilter之后
CharacterFilter ... doFilter之后
HttpFilter ... doFilter之后完成上述需求
