模式定义
责任链模式(Chain of Responsibility Pattern) 使多个对象都有机会处理请求,从而避免请求的发送者和接受者直接的耦合关系。将这些对象连成一条链,沿着这条链传递该请求,直到有一个对象处理它为止。
责任链模式强调的是每一个对象及其对下家的引用来组成一条链,利用这种方式将发送者和接收者解耦
模式结构
主要角色:
- 抽象处理者(Handler)角色 :定义一个请求的接口。如果需要可以定义个一个方法用来设定和返回下家对象的引用。
- 具体处理者(ConcreteHandler)角色 :如果可以处理就处理请求,如果不能处理,就把请求传给下家,让下家处理。也就是说它处理自己能处理的请求且可以访问它的下家。
示例
熟悉JavaWeb开发的同学,一定对Servlet规范 中的Filter 使用非常熟悉,其实它内部就是使用责任链模式(FilterChain)实现的,本文将揭晓Filter的实现原理。
Filter 接口定义如下:
public interface Filter {
void doFilter(ServletRequest request, ServletResponse response,
FilterChain chain) throws Exception;
}
DemoFilter 代码如下:
public class DemoFilter implements Filter {
@Override
public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws Exception {
System.out.println("filter execute...");
chain.doFilter(request, response);
}
}
当我们在Filter 的 doFilter方法处理完自己的业务逻辑后,老司机都会告诉你需要调用chain.doFilter(request, response);
将请求转到下一个Filter中,那FilterChain.doFilter(request, response)
到底是怎么实现的呢?
FilterChain
public interface FilterChain {
void doFilter(ServletRequest request, ServletResponse response) throws Exception;
}
FilterChain 接口定义很简单,接下来看看它的实现类FilterChainImpl ,代码如下:
import java.util.List;
/**
* ${DESCRIPTION}
*
* @author Ricky Fung
* @date 2017-02-18 14:02
*/
public class FilterChainImpl implements FilterChain {
private int pos; //当前位置
private List<Filter> filters;
private HttpHandler next;
public FilterChainImpl(List<Filter> filters, HttpHandler next) {
this.filters = filters;
this.next = next;
this.pos = 0;
}
@Override
public void doFilter(ServletRequest request, ServletResponse response) throws Exception {
if (pos >= filters.size()) {
this.next.handleRequest(request, response);
} else {
Filter filter = filters.get(pos++);
filter.doFilter(request, response, this);
}
}
}
最后,我们可以模拟一下Filter调用:
import java.util.ArrayList;
import java.util.List;
/**
* ${DESCRIPTION}
*
* @author Ricky Fung
* @date 2017-02-18 14:14
*/
public class FilterChainDemo {
public static void main(String[] args) {
List<Filter> filters = new ArrayList<>();
for(int i=1; i<=5;i++){
filters.add(new DemoFilter("Filter_"+i));
}
ServletRequest request = new ServletRequest();
ServletResponse response = new ServletResponse();
HttpHandler httpHandler = new HttpHandler(); //http请求处理器
FilterChain filterChain = new FilterChainImpl(filters, httpHandler);
try {
filterChain.doFilter(request, response);
} catch (Exception e) {
e.printStackTrace();
}
}
}