JavaEE互联网轻量级框架整合开发（书籍）阅读笔记（5）：责任链模式、观察者模式

一、责任链模式、观察者模式

　　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("德芙·巧克力");        
    }
}

 测试结果： 

产品列表新增了产品：德芙·巧克力
发送新产品【德芙·巧克力】同步到淘宝商城
发送新产品【德芙·巧克力】同步到京东商城