动手写技术文章的时间越来越少,为了能让自己保持该习惯,逼迫自己写点东西。主要目的还是以学习和总结为主,并尽量提供示例源码
首先接触该概念最多的应该是Servlet的Filter,还有在Dubbo中也有Filter的使用
1.Filter和Invoker(容器)
我们通过代码来看一下Filter的构建和使用
代码示例1
public class Filter1 implements Filter{
public int invoke(Invoker invoker) {
System.out.println("Filter1");
invoker.invoke();
return 0;
}
}
public class Filter2 implements Filter{
public int invoke(Invoker invoker) {
System.out.println("Filter2");
invoker.invoke();
return 0;
}
}
public static void main(String[] args) {
List<Filter> filters = Arrays.asList(new Filter1(),new Filter2());
Invoker last = new Invoker() {
public int invoke() {
System.out.println("invoker");
return 0;
}
};
for(int i = filters.size() - 1; i >= 0; i--) {
// 获取filter
final Filter filter = filters.get(i);
final Invoker next = last;
// 更新last
last = new Invoker() {
public int invoke() {
return filter.invoke(next);
}
};
}
last.invoke();
}
我们通过图示来看一下上面的执行流程
1.首先Invoker实例last是真正想要执行的动作
2.Filter想要在last执行之前做一些预处理
3.由于参数是Invoker,Filter无法单独构成链,想要构建一个链的话,这个链必然是Invoker,Invoker承担了容器的作用
这里提出一个问题
为什么要构建Invoker链呢?不构建可以吗?
个人理解是为了构建类型一致的链,且Filter对使用者而言是无感知的,所以强制将Filter转成了Invoker
2.链的构建
如果自上而下构建,将永远在寻找下一个链的对象,行不通.
由于最后一跳是Last Invoker已经确认,所以构建的时候可以选择自底向上来构建.
3.其他模式的替代
3.1
如果Filter只是做预处理的作用的话,可以以其他的模式的来替代,不需要来构建链
代码示例2
public interface Invoker {
int invoke(List<Filter> list);
}
public class Filter1 implements Filter {
public int invoke(Invoker invoker) {
System.out.println("Filter1");
return 0;
}
}
public class FilterInvoker implements Invoker {
public int invoke(List<Filter> filters) {
for(int i = 0; i <filters.size(); i++) {
// 获取filter
final Filter filter = filters.get(i);
filter.invoke(this);
}
System.out.println("invoker");
return 0;
}
}
public static void main(String[] args) {
final List<Filter> filters = Arrays.asList(new Filter1(),new Filter2());
FilterInvoker last = new FilterInvoker();
last.invoke(filters);
}
改造了Invoker接口和Filter的实际方法,并不再链式执行.
区别在于需要传递filter列表入参,比如麻烦,破坏了封装.
解决方案:可以将filter列表作为成员变量使用,将会解决该问题
代码示例3
public class FilterInvoker implements Invoker {
private List<Filter> filters;
public List<Filter> getFilters() {
return filters;
}
public void setFilters(List<Filter> filters) {
this.filters = filters;
}
public int invoke() {
for(int i = 0; i <filters.size(); i++) {
// 获取filter
final Filter filter = filters.get(i);
filter.invoke(this);
}
System.out.println("invoker");
return 0;
}
}
3.2
由于web请求每次都是一个线程,如果该对象是单例的话,又会出现问题,如果每次创建都是新实例的话,是可以解决该问题的,但会损耗性能.实际上该问题了为了解决上下文参数传递的问题,同时又想简化参数的传递,这时候可以采用ThreadLocal来封装上下文
代理实例4
public class InvokerContext {
private static final ThreadLocal<InvokerContext> LOCAL = new ThreadLocal<InvokerContext>() {
@Override
protected InvokerContext initialValue() {
return new InvokerContext();
}
};
public static InvokerContext getContext() {
return LOCAL.get();
}
private List<Filter> filters;
public List<Filter> getFilters() {
return filters;
}
public void setFilters(List<Filter> filters) {
this.filters = filters;
}
}
public class FilterInvoker implements Invoker {
public int invoke() {
List<Filter> filters=InvokerContext.getContext().getFilters();
for(int i = 0; i <filters.size(); i++) {
// 获取filter
final Filter filter = filters.get(i);
filter.invoke(this);
}
System.out.println("invoker");
return 0;
}
}
public class Test {
public static void main(String[] args) {
List<Filter> filters = Arrays.asList(new Filter1(),new Filter2());
InvokerContext.getContext().setFilters(filters);
FilterInvoker last = new FilterInvoker();
last.invoke();
}
}
以上均为代码设计相关,供比较和参考,因为感觉有些地方其实无需使用责任链,所以拿处理比较一下。
示例源码:
https://github.com/sevenXin/javaDemo/tree/master/demo-base/src/main/java/demo/design
参考文章: