设计模式--6观察者模式

1.观察者模式(Observer Pattern)
也叫发布订阅模式，定义对象间一种，一对多的依赖关系，使得当，一个对象状态改变时，所有依赖它的对象都能得到通知，并被自动更新

2.类图如图

（1）Subject 被观查者
定义被观察者必须实现的职责。它必须能够，管理观察者（动态添加或删除观察者），通知观察者。

（2）ConcreteSubject 具体的被观察者

（3）Observer 观察者
接收到消息后，进行update（消息处理）操作

（4）ConcreteObserver 具体观察者

3.关键，一个被观察者最好不要同时是观察者，否则这个关系很难维护
（1）优点：
观察者和被观察者之间是抽象耦合，方便扩展
建立一套触发机制，触发链

（2）观察者模式需要考虑一下开发效率和运行效率问题，一个被观察者，多个观察者，开发
和调试就会比较复杂，而且在Java中消息的通知默认是顺序执行，一个观察者卡壳，会影响
整体的执行效率。在这种情况下，一般考虑采用异步的方式。

被观察者发生动作了，观察者要做出回应，如果观察者比较多，而且处理时间比较长怎么办？那就用异步呗（具体怎么异步）

代码：

Observable

package com.design.观察者模式;

/**
 * 
 * @author yafei.lv
 * 被观察者，要作的通知
 */
public interface Observable {
    
    void addObserver(Observer observer); //添加观察者
    
    void deleteObserver(Observer observer); //减少观察者
    
    void notifyObservers(String context);
}

ObservableMotion

package com.design.观察者模式;

/**
 * 
 * @author yafei.lv
 * 被观察者，要做的动作
 */
public interface ObservableMotion {
    
    void haveBreakFast(); // 吃饭
    
    void haveFun(); // 娱乐
}

ObservableImpl

package com.design.观察者模式;

import java.util.ArrayList;
import java.util.List;

/**
 * 
 * @author yafei.lv
 * 被观察者实现
 */
public class ObservableImpl implements Observable,ObservableMotion {
    
    public List<Observer> observers = new ArrayList<Observer>(); // 观察者列表
    
    
    @Override
    public void haveBreakFast() {
        notifyObservers("开始吃饭....");
    }

    @Override
    public void haveFun() {
        notifyObservers("开始娱乐....");
    }

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

    @Override
    public void deleteObserver(Observer observer) {
        observers.remove(observer);
    }

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

}

Observer

package com.design.观察者模式;

/**
 * 
 * @author yafei.lv
 * 观察者
 */
public interface Observer {
    void update(String context);
}

ObserverLiSi

package com.design.观察者模式;

public class ObserverLiSi implements Observer{

    @Override
    public void update(String context) {
         System.out.println("观察者李斯，报告，被监控者有了活动：" + context);
    }

}

ObserverZhaogao

package com.design.观察者模式;

public class ObserverZhaogao implements Observer{

    @Override
    public void update(String context) {
         System.out.println("观察者赵高，报告，被监控者有了活动：" + context);
         System.out.println("所以我也开始吃饭，赵高");
    }

}

场景类：

package com.design.观察者模式;

/**
 * 
 * @author yafei.lv
 * 场景类
 */
public class Main {
    public static void main(String[] args) {
        Observer observerLisi = new ObserverLiSi();
        Observer observerZhaogao = new ObserverZhaogao();
        
        ObservableImpl observable = new ObservableImpl();
        observable.observers.add(observerZhaogao);
        observable.observers.add(observerLisi);
        
        observable.haveBreakFast();
        observable.haveFun();
    }
}