Spring中使用到的设计模式(十一)----观察者模式

1. 观察者模式简介

1.1 简介

当对象间存在一对多关系时，则使用观察者模式（Observer Pattern）。比如，当一个对象被修改时，则会自动通知它的依赖对象。观察者模式属于行为型模式。

其实就是发布订阅模式，发布者发布信息，订阅者获取信息，订阅了就能收到信息，没订阅就收不到信息。

1.2 意图

定义对象间的一种一对多的依赖关系，当一个对象的状态发生改变时，所有依赖于它的对象都得到通知并被自动更新。

1.3 UML图解

观察者模式使用三个类 Subject、Observer 和 Client。Subject 对象带有绑定观察者到 Client 对象和从 Client 对象解绑观察者的方法。我们创建 Subject 类、Observer 抽象类和扩展了抽象类 Observer 的实体类。

ObserverPatternDemo，我们的演示类使用 Subject 和实体类对象来演示观察者模式。

1.4 优缺点

优点：

         1、观察者和被观察者是抽象耦合的;

         2、建立一套触发机制。

缺点：

1、如果一个被观察者对象有很多的直接和间接的观察者的话，将所有的观察者都通知到会花费很多时间;

2、如果在观察者和观察目标之间有循环依赖的话，观察目标会触发它们之间进行循环调用，可能导致系统崩溃;

3、观察者模式没有相应的机制让观察者知道所观察的目标对象是怎么发生变化的，而仅仅只是知道观察目标发生了变化。

1.5 应用实例

1、拍卖的时候，拍卖师观察最高标价，然后通知给其他竞价者竞价。

2、西游记里面悟空请求菩萨降服红孩儿，菩萨洒了一地水招来一个老乌龟，这个乌龟就是观察者，他观察菩萨洒水这个动作。

1.6 主要解决的问题

一个对象状态改变给其他对象通知的问题，而且要考虑到易用和低耦合，保证高度的协作。

1.7 应用场景

• A对象的行为将影响B对象，B对象的行为将影响C对象……，可以使用观察者模式创建一种链式触发机制

1.8 注意事项

1、JAVA 中已经有了对观察者模式的支持类；

2、避免循环引用；

3、如果顺序执行，某一观察者错误会导致系统卡壳，一般采用异步方式。

2. 观察者模式的实现

/***

 * 抽象被观察者接口

 * 声明了添加、删除、通知观察者方法

 */

public interface Observerable {

    public void registerObserver(Observer o);

    public void removeObserver(Observer o);

    public void notifyObserver();

}

/**

 * 被观察者实现

 */

public class WechatServer implements Observerable {

    //注意到这个List集合的泛型参数为Observer接口，设计原则：面向接口编程而不是面向实现编程

    private List<Observer> list;

    private String message;

    

    public WechatServer() {

        list = new ArrayList<Observer>();

    }

    @Override

    public void registerObserver(Observer o) {

        list.add(o);

    }

    @Override

    public void removeObserver(Observer o) {

        if(!list.isEmpty())

            list.remove(o);

    }

    //遍历

    @Override

    public void notifyObserver() {

        for(int i = 0; i < list.size(); i++) {

            Observer oserver = list.get(i);

            oserver.update(message);

        }

    }

    public void setInfomation(String s) {

        this.message = s;

        System.out.println("微信服务更新消息： " + s);

        //消息更新，通知所有观察者

        notifyObserver();

    }

}

/***

 * 抽象观察者

 * 定义了一个update()方法，当被观察者调用notifyObservers()方法时，观察者的update()方法会被回调。

 *

 */

public interface Observer {

    public void update(String message);

}

/**

 * 观察者

 * 实现了update方法

 */

public class User implements Observer {

    private String name;

    private String message;

    public User(String name) {

        this.name = name;

    }

    @Override

    public void update(String message) {

        this.message = message;

        read();

    }

    public void read() {

        System.out.println(name + " 收到推送消息： " + message);

    }

}

/**

 * 测试主类

 */

public class MainTest {

public static void main(String[] args) {

        WechatServer server = new WechatServer();

        

        Observer userZhang = new User("ZhangSan");

        Observer userLi = new User("LiSi");

        Observer userWang = new User("WangWu");

        

        server.registerObserver(userZhang);

        server.registerObserver(userLi);

        server.registerObserver(userWang);

        server.setInfomation("PHP是世界上最好用的语言！");

        

        System.out.println("----------------------------------------------");

        server.removeObserver(userZhang);

        server.setInfomation("JAVA是世界上最好用的语言！");

    }

}