3、设计模式之观察者模式

1、背景:在现实生活或者应用程序中，对象（人）与对象（人）之间的合作是根据对方的状态来进行的，或者说自己的状态发生变化之后，通知对方也发生相应的改变。比如场景:“儿子”睡醒后，爸爸要给“儿子”喂奶吃。在程序中是如何实现这样的场景的呢？相信很多人思路大概是这样：启动一个“爸爸”线程，不断询问（监听）“儿子”的状态是不是醒了，如果是，则进行喂奶的操作。这样的方法虽然能实现了上述的场景，但是显然这样做并不高效，因为“爸爸”在这个过程中什么也做不了，只能不断看着“儿子”醒了没有，在计算机世界中就是白白浪费了CPU和资源，而且如果“爷爷”也想在“孙子”睡醒后，打开电视给他看，程序实现的复杂度又加了一倍，扩展性不好，维护起来很困难。
    那么有没有另外一种好的设计思路，将“儿子”和“爸爸”松耦降低，“儿子”睡自己觉，“爸爸”干自己的事，如上网，看世界杯，听到“儿子”哭醒后，才去喂奶。这样子，但被监听的对象的状态发送变化后，可以通知其他(多个)对象，而不需要知道被监听对象的细节。

2、例子
    2.1 事件委派模型，在awt编程，可以为一个按钮，注册多个监听事件。

    2.2 关注某个主题消息，但消息更新时，发送给多个关注者。

3、观察者模式
    3.1 观察者模式又叫做发布-订阅(Publish-Subscribe)模式
观察者模式定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象，当主题对象的状态发生变化时，会通知所有观察者对象，让它们同时更新自己的状态。
    3.2 观察者的UML图如下

Subject：主题抽象类，定义发布通知，添加，删除监听者接口。
ConcreteSubject：具体主题实现类。
Observer：订阅者接口
ConcreteObserver：订阅者具体实现类，拥有一个主题对象。
    3.3 优缺点
         优点：
· Subject和Observer是松耦合，自己可以独立发生改变。
· Subject可以广播给多个订阅者，符合高内聚，低耦合。
         缺点：
· 大量订阅主题，遍历订阅者广播时，效率会下降。
4、源代码实现参考

//主题抽象类
public abstract class Subject {
    private List<Observer> observers = new ArrayList<Observer>();//观察者列表

    public void attach(Observer observer){//订阅
        observers.add(observer);
    }

    public void dettach(Observer observer){//取消
        observers.remove(observer);
    }

    public void notifyObservers(){//通知所有订阅者
        for(Observer o:observers){
            o.update();
        }
    }
}

//主题具体实现类
public class ConcreteSubject extends Subject {
    private String state;

    public String getState() {
        return state;
    }

    public void setState(String state) {
        this.state = state;
    }
}

//观察者接口
public interface Observer {
    public void update();//更新自己的状态
}

//具体观察者
public class ConcreteObserver implements Observer {

    @Override
    public void update() {
           System.out.println("观察者ConcreteObserverA监听到状态:"+subject.getState());
    }

    private String name;//名称
    private ConcreteSubject subject;//订阅主题
    public ConcreteObserver(String name, ConcreteSubject subject) {
        this.name = name;
        this.subject = subject;
    }

}

//测试类
public class Client {
    public static void main(String[] args) {
        ConcreteSubject subject = new ConcreteSubject();
        subject.attach(new ConcreteObserver("小纯洁", subject));//添加观察者
        subject.attach(new ConcreteObserver("钢铁侠", subject));

        subject.setState("go go");//改变状态
        subject.notifyObservers();//通知所有观察者
    }
}