Java设计模式11：观察者模式

一、什么是观察者模式

在阎宏博士的《JAVA与模式》一书中开头是这样描述观察者（Observer）模式的：

　　观察者模式是对象的行为模式，又叫发布-订阅(Publish/Subscribe)模式、模型-视图(Model/View)模式、源-监听器(Source/Listener)模式或从属者(Dependents)模式。

　　观察者模式定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象。这个主题对象在状态上发生变化时，会通知所有观察者对象，使它们能够自动更新自己。

二、观察者模式所涉及的角色

抽象被观察者角色：也就是一个抽象主题，它把所有对观察者对象的引用保存在一个集合中，每个主题都可以有任意数量的观察者。抽象主题提供一个接口，可以增加和删除观察者角色。一般用一个抽象类和接口来实现。

抽象观察者角色：为所有的具体观察者定义一个接口，在得到主题通知时更新自己。

具体被观察者角色：也就是一个具体的主题，在集体主题的内部状态改变时，所有登记过的观察者发出通知。

具体观察者角色：实现抽象观察者角色所需要的更新接口，一边使本身的状态与制图的状态相协调。

三、代码示例：

在上代码之前，我们先假设下这样的使用场景：有一个通知服务（比如微信公众号），向用户推送消息，用户关注公众号就可以收到推送消息，取消关注就收不到推送消息。

先创建抽象观察者接口和抽象被观察者接口

/**
 * <pre>
 *    @author : orange
 *    @e-mail : [email protected]
 *    @time   : 2018/10/18 10:40
 *    @desc   : 抽象观察者接口
 *    @version: 1.0
 * </pre>
 */
public interface Observer {

    public void update(String message);

}

/**
 * <pre>
 *    @author : orange
 *    @e-mail : [email protected]
 *    @time   : 2018/10/18 10:39
 *    @desc   : 抽象被观察者接口
 *    @version: 1.0
 * </pre>
 */
public interface Observerable {

    public void addObserver(Observer observer);
    public void removeObserver(Observer observer);
    public void notifyObserver();
}

被观察者接口实现类：

/**
 * <pre>
 *    @author : orange
 *    @e-mail : [email protected]
 *    @time   : 2018/10/18 10:43
 *    @desc   : 具体的被观察者实现
 *    @version: 1.0
 * </pre>
 */
public class ObserverableImpl implements Observerable{

    private List<Observer> list = new ArrayList<>();

    private String message;


    @Override
    public void addObserver(Observer observer) {
        list.add(observer);
    }

    @Override
    public void removeObserver(Observer observer) {
        list.remove(observer);
    }

    @Override
    public void notifyObserver() {
        for (int i = 0; i < list.size(); i++) {
            Observer observer = list.get(i);
            observer.update(message);
        }

    }

    public void pushMessage(String message){
        this.message = message;

        //通知所有观察者，推送消息
        notifyObserver();

    }

}

具体的观察者：

/**
 * <pre>
 *    @author : orange
 *    @e-mail : [email protected]
 *    @time   : 2018/10/18 11:00
 *    @desc   :
 *    @version: 1.0
 * </pre>
 */
public class User implements Observer {

    private String mrssage;
    private String name;

    public User(String name) {
        this.name = name;
    }


    @Override
    public void update(String message) {
        this.mrssage = message;
        System.out.println(name + "收到推送消息：" + message);
    }
}

最后客户端测试：

/**
 * <pre>
 *    @author : orange
 *    @e-mail : [email protected]
 *    @time   : 2018/10/18 11:03
 *    @desc   : 客户端测试
 *    @version: 1.0
 * </pre>
 */
public class Client {
    public static void main(String[] args){

        ObserverableImpl observerable = new ObserverableImpl();
        Observer observer1 = new User("张飞");
        Observer observer2 = new User("关羽");
        Observer observer3 = new User("刘备");

        observerable.addObserver(observer1);
        observerable.addObserver(observer2);
        observerable.addObserver(observer3);

        observerable.pushMessage("通知来了");

    }
}

四、总结：

观察者模式的好处：

观察者模式提供了一种对象设计,让主题和观察者之间耦合度降得很低,为什么呢?关于观察者的一切,主题只知道观察者实现了Observer接口,并不需要观察者具体的类是谁,做了什么或者其他细节.

这样的话,由于松耦合,改变主题或者观察者其中一方,并不会影响另一方,只要他们之间的接口仍被遵守,就可以自由地改变它.

降低对象之间的耦合度,也是面设对象设计的一个很重要的原则.　　