一. 定义

观察者模式定义了对象之间的一对多依赖，这样依一来，当一个对象改变状态时，它的所有依赖者都会收到通知并自动更新。

二. 模式起源

三. 设计原则

3.1 原则1

为了交互对象之间的松耦合设计。

四. UML图

五.代码

package model.observer;

/**
 * 主题接口
 */
public interface Subject {

    /**
     * 订阅主题
     * @param observer
     */
    public abstract void registerObserver(Observer observer);

    /**
     * 取消订阅主题
     * @param observer
     */
    public abstract void removeObserver(Observer observer);

    /**
     * 通知所有的观察者
     */
    public abstract void notifyObservers();

}

5.2 观察者接口

package model.observer;

/**
 * 观察者接口
 */
public interface Observer {

    /**
     *  当主题发生改变的时候，该方法被调用，用来通知所有的观察者
     * @param num 传输数据
     */
    public abstract void update(int num);

}

5.3 展示接口(与设计模式无关,方便展示)

package model.observer;

/**
 * 展示接口  与设计模式无关的接口
 */
public interface Show {

    /**
     * 展示传输数据的接口
     */
    public abstract void show();

}

5.4 主题实现类A

package model.observer;

import java.util.ArrayList;

/**
 * A主题  实现了主题接口和展示接口
 */
public class ASubject implements Subject {

    /**
     * A主题内部维护了一批订阅了A主题的观察者集合
     */
    private ArrayList<Observer> observers;

    /**
     * 天气温度: A主题维护的提供给订阅者的数据
     */
    private Integer num;

    public ASubject() {
        this.observers = new ArrayList<>();
    }

    @Override
    public void registerObserver(Observer observer) {
        this.observers.add(observer);
    }

    @Override
    public void removeObserver(Observer observer) {
        int i = this.observers.indexOf(observer);
        if (i >= 0) {
            this.observers.remove(observer);
        }
    }

    @Override
    public void notifyObservers() {
        for (Observer observer : observers) {
            observer.update(num);
        }
    }

    /**
     * A主题用来更新传输数据的方法
     * @param num
     */
    public void updateNum(Integer num) {
        this.num = num;
        notifyObservers();
    }
}

5.5 观察者实现类A

package model.observer;

/**
 * A观察者
 */
public class AObserver implements Observer, Show {

    private Subject subject;

    /**
     * 观察者内部维护了传输的数据
     */
    private Integer num;

    /**
     * 观察者内部维护了一个主题,通过构造函数进行注册主题
     */
    public AObserver(Subject subject) {
        this.subject = subject;
        subject.registerObserver(this);
    }

    @Override
    public void update(int num) {
        this.num = num;
        show();
    }

    @Override 
    public void show() {
        System.out.println("hello observer A, today the temperature is " + num + "！ have a nice day。");
    }
}

5.6 观察者实现类B

package model.observer;

public class BObserver implements Observer, Show {

    private Subject subject;

    /**
     * 观察者内部维护了传输的数据
     */
    private Integer num;

    /**
     * 观察者内部维护了一个主题,通过构造函数进行注册主题
     */
    public BObserver(Subject subject) {
        this.subject = subject;
        subject.registerObserver(this);
    }

    @Override
    public void update(int num) {
        this.num = num;
        show();
    }

    @Override
    public void show() {
        System.out.println("hello observer B, today the temperature is " + num + "！ have a nice day。");
    }
}

5.7 测试类

package model.observer;

public class Main {

    public static void main(String[] args) {

        ASubject aSubject = new ASubject();

        AObserver aObserver = new AObserver(aSubject);
        BObserver bObserver = new BObserver(aSubject);

        aSubject.updateNum(30);
        aSubject.updateNum(25);

    }

}

5.8 结果

hello observer A, today the temperature is 30！ have a nice day。
hello observer B, today the temperature is 30！ have a nice day。
hello observer A, today the temperature is 25！ have a nice day。
hello observer B, today the temperature is 25！ have a nice day。