一、责任链模式、观察者模式
1、责任链模式：当一个对象在一条链上被多个拦截器处理（烂机器也可以选择不拦截处理它）时，我们把这样的设计模式称为责任链模式，它用于一个对象在多个角色中传递的场景。
2、观察者模式：观察者模式又称为发布电话与模式，是对象的行为模式。观察者模式定义了一种一对多的依赖关系，让多个观察者对象同时监视着被观察者的状态，当被观察者的状态变化时，会通知观察者，并让其自动更新自己。
二、责任链模式（例子）
创建测试接口：HelloWorld.java
package com.xfwl.proxy.jdk;
public interface HelloWorld {
public void sayHelloWorld();
}
创建测试接口的实现子类：HelloWorldImpl.java
package com.xfwl.proxy.jdk;
public class HelloWorldImpl implements HelloWorld {
public void sayHelloWorld() {
System.out.println("Hello World!");
}
}
创建代理类：JdkProxyExample.java
package com.xfwl.proxy.jdk; import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
/**
* JDK的动态代理
* @function 两个步骤：（1）建立代理对象和真实服务对象的关系。（2）实现代理逻辑。
* @author 小风微凉
* @time 2018-7-9 上午10:45:53
*/
public class JdkProxyExample implements InvocationHandler {
//真实对象
private Object target=null;
/**
* 建立代理对象和真实对象之间的代理关系，并返回代理对象
* @param target 真实对象
* @return 代理对象
*/
public Object bind(Object target){
this.target=target;
return Proxy.newProxyInstance(
target.getClass().getClassLoader(), //类加载器
target.getClass().getInterfaces(), //动态代理所挂的接口
this //实现方法逻辑的代理类，必须实现InvocationHandler接口的invoke方法
);
}
/**
* 代理方法逻辑
* @param proxy 代理对象
* @param method 当前调度方法
* @param args 当前方法参数
* @return 代理结果返回
* @throws Throwable 异常
*/
public Object invoke(Object proxy, Method method, Object[] args)throws Throwable {
System.out.println("进入代理方法");
System.out.println("在调度真实方法之前的服务");
Object obj=method.invoke(this.target, args);//相当于调用sayHelloWorld方法
System.out.println("在调度真实方法之后的服务");
return obj;
}
}
创建责任链拦截器-1
package com.xfwl.designmodels.responseChain; import java.lang.reflect.Method; import com.xfwl.interceptor.Interceptor;
/**
* 拦截逻辑1
* @function
* @author 小风微凉
* @time 2018-7-9 下午4:03:37
*/
public class Interceptor1 implements Interceptor { @Override
public boolean before(Object proxy, Object target, Method method,
Object[] args) {
System.out.println("【拦截器1】的before方法");
return true;
} @Override
public void around(Object proxy, Object target, Method method, Object[] args) {
// TODO Auto-generated method stub } @Override
public void after(Object proxy, Object target, Method method, Object[] args) {
System.out.println("【拦截器1】的after方法");
}
}
创建责任链拦截器-2
package com.xfwl.designmodels.responseChain; import java.lang.reflect.Method; import com.xfwl.interceptor.Interceptor;
/**
* 拦截逻辑2
* @function
* @author 小风微凉
* @time 2018-7-9 下午4:03:37
*/
public class Interceptor2 implements Interceptor { @Override
public boolean before(Object proxy, Object target, Method method,
Object[] args) {
System.out.println("【拦截器2】的before方法");
return true;
} @Override
public void around(Object proxy, Object target, Method method, Object[] args) {
// TODO Auto-generated method stub } @Override
public void after(Object proxy, Object target, Method method, Object[] args) {
System.out.println("【拦截器2】的after方法");
}
}
创建责任链拦截器-3
package com.xfwl.designmodels.responseChain; import java.lang.reflect.Method; import com.xfwl.interceptor.Interceptor;
/**
* 拦截逻辑3
* @function
* @author 小风微凉
* @time 2018-7-9 下午4:03:37
*/
public class Interceptor3 implements Interceptor { @Override
public boolean before(Object proxy, Object target, Method method,
Object[] args) {
System.out.println("【拦截器3】的before方法");
return true;
} @Override
public void around(Object proxy, Object target, Method method, Object[] args) {
// TODO Auto-generated method stub } @Override
public void after(Object proxy, Object target, Method method, Object[] args) {
System.out.println("【拦截器3】的after方法");
}
}
创建测试类：TestChain.java
package com.xfwl.designmodels.responseChain; import com.xfwl.interceptor.InterceptorJdkProxy;
import com.xfwl.proxy.jdk.HelloWorld;
import com.xfwl.proxy.jdk.HelloWorldImpl; /**
* 测试责任链模式
* @function
* @author 小风微凉
* @time 2018-7-9 下午4:05:43
*/
public class TestChain {
/**
* @param args
*/
public static void main(String[] args) { //拿到代理对象1，并绑定真实对象
HelloWorld proxy1=(HelloWorld) new InterceptorJdkProxy().bind(
new HelloWorldImpl(),
"com.xfwl.designmodels.responseChain.Interceptor1"
);
//拿到代理对象2，并绑定真实对象
HelloWorld proxy2=(HelloWorld) new InterceptorJdkProxy().bind(
proxy1,
"com.xfwl.designmodels.responseChain.Interceptor2"
);
//拿到代理对象3，并绑定真实对象
HelloWorld proxy3=(HelloWorld) new InterceptorJdkProxy().bind(
proxy2,
"com.xfwl.designmodels.responseChain.Interceptor3"
);
//执行代理逻辑
proxy3.sayHelloWorld(); } }
运行结果：
【拦截器3】的before方法
【拦截器2】的before方法
【拦截器1】的before方法
Hello World!
【拦截器1】的after方法
【拦截器2】的after方法
【拦截器3】的after方法
三、观察者模式（例子）
创建一个产品列表类：ProductionList.java
package com.xfwl.designmodels.observer;
import java.util.ArrayList;
import java.util.List;
import java.util.Observable;
import java.util.Observer;
/**
* 创建一个产品列表
* @function
* @author 小风微凉
* @time 2018-7-9 下午4:18:36
*/
public class ProductionList extends Observable {
//产品容器
private List<String> productionList=null;
//单例模式:懒汉式
private static ProductionList instance;
private ProductionList(){}
/**
* 取得唯一实例
* @return 产品列表唯一实例
*/
public static ProductionList getInstance(){
if(instance==null){
instance=new ProductionList();
instance.productionList=new ArrayList<String>();
}
return instance;
}
/**
* 增加观察则（电商接口）
* @param observer 观察者
*/
public void addProductionListObserver(Observer observer){
this.addObserver(observer);
}
/**
* 新增产品
* @param newProudct 新产品
*/
public void addProudct(String newProudct){
this.productionList.add(newProudct);
System.out.println("产品列表新增了产品："+newProudct);
//告诉观察者，当前被观察者发生了变化
this.setChanged();
//通知观察者，开始相关操作
this.notifyObservers(newProudct);
}
}
创建一个京东电商推送接口类:JingDongObserver.java
package com.xfwl.designmodels.observer; import java.util.Observable;
import java.util.Observer;
/**
* 京东电商接口
* @function
* @author 小风微凉
* @time 2018-7-9 下午4:29:03
*/
public class JingDongObserver implements Observer { @Override
public void update(Observable o, Object product) {
String newProudct=(String)product;
System.out.println("发送新产品【"+newProudct+"】同步到京东商城");
}
}
创建一个淘宝电商推送接口类：TaoBaoObserver.java
package com.xfwl.designmodels.observer; import java.util.Observable;
import java.util.Observer;
/**
* 淘宝电商接口
* @function
* @author 小风微凉
* @time 2018-7-9 下午4:29:03
*/
public class TaoBaoObserver implements Observer { @Override
public void update(Observable o, Object product) {
String newProudct=(String)product;
System.out.println("发送新产品【"+newProudct+"】同步到淘宝商城");
}
}
创建一个测试类：TestObserver.java
package com.xfwl.designmodels.observer;
/**
* 观察者模式测试
* @function
* @author 小风微凉
* @time 2018-7-9 下午4:32:12
*/
public class TestObserver {
/**
* @param args
*/
public static void main(String[] args) {
ProductionList observable=ProductionList.getInstance();
TaoBaoObserver taobao=new TaoBaoObserver();
JingDongObserver jingdong=new JingDongObserver();
observable.addObserver(jingdong);
observable.addObserver(taobao);
observable.addProudct("德芙·巧克力");
}
}
测试结果：
产品列表新增了产品：德芙·巧克力
发送新产品【德芙·巧克力】同步到淘宝商城
发送新产品【德芙·巧克力】同步到京东商城