关于观察者模式的一些小的Demo

以前总是用，都是从晚上进行copy。今天自己写了一个。
分别定义两个接口。一个是观察者，一个是被观察者。

观察者

/**
 * 观察者
 */
public interface ObserverDemo1 {
    // 进行更新
    void update();
}

进行观察被观察者，当被观察者有变化的时候，进行调用更新的方法。

被观察者

/**
 * 被观察者
 */
public interface SubjectDemo1 {

    /**
     * 注册 observer
     */
    void registerObserver(ObserverDemo1 observerDemo1);

    /**
     * 移除 observer
     */
    void removeObserver(ObserverDemo1 observerDemo1);

    /**
     * 进行通知 所有的观察者
     */
    void notifyObservers();

}

里面定义了三个方法

• 对观察者进行注册
• 对观察者进行移除
• 对注册过的观察者们进行注册

被观察者的实现类

实现被观察者中定义的方法。

public class SubjectDemoImpl implements SubjectDemo1 {

    private List<ObserverDemo1> observers;

    public SubjectDemoImpl() {
        observers=new ArrayList<>();
    }

    @Override
    public void registerObserver(ObserverDemo1 observerDemo1) {
        observers.add(observerDemo1);
    }

    @Override
    public void removeObserver(ObserverDemo1 observerDemo1) {
        observers.remove(observerDemo1);
    }

    @Override
    public void notifyObservers() {
        for (ObserverDemo1 observerDemo1 : observers) {
            observerDemo1.update();
        }
    }
}

次方法定义一个，要求所有的观察者都要来引用次方法的实例。在此方法中创建了一个所有观察者的集合类。观察者注册了都要添加到集合中去。

观察者的实现类（可以有很多个，因为观察者很多）

public class ObserverDemo1Impl implements ObserverDemo1 {
    private SubjectDemoImpl subjectDemoImpl; 

    public ObserverDemo1Impl(SubjectDemoImpl subjectDemoImpl) {
        this.subjectDemoImpl=subjectDemoImpl;
        subjectDemoImpl.registerObserver(this);
    }

    @Override
    public void update() {
        System.out.println("开始响应------ObserverDemo1Impl");
    }
}

构造方法中一定要引用同一个被观察者。

最后是测试方法

    public static void main(String[] args) {
        SubjectDemoImpl subjectDemoImpl = new SubjectDemoImpl();
        ObserverDemo1Impl observerDemo1Impl = new ObserverDemo1Impl(subjectDemoImpl);
        ObserverDemo2Impl observerDemo2Impl = new ObserverDemo2Impl(subjectDemoImpl);

        subjectDemoImpl.notifyObservers();

    }