观察者模式 : 一支穿云箭，千军万马来相见

小时候一块钱就可以在录像厅看一天电影，印象里最喜欢星爷的电影，特别搞笑。

后来渐渐长大，接触了一些人和事，略微懂了他的那些苦笑、狂笑和欲哭无泪。

我喜欢的演员很多，唯独星爷，能让我看到他的照片，有种想哭的感觉。

星爷，may the god bless you.

最近又看了遍《功夫》，其中有一幕：

阿星装比失败，不曾想引来了斧头帮，斧头帮老大一支穿云箭，真的是千军万马来相见，帅呆了！

骨子里也是个古惑仔的我好崇拜这种场景！太帅了！那，这是怎么做到的呢？

首先我得加入斧头帮，成为斧头帮一份子
然后去登记，有啥事方便通知
等老大一发穿云箭
我跟其他小弟就赶紧出现

用代码实现一下：

1.首先定义斧头帮老大 AxeGangBoss:

代码语言：javascript复制

/**
 * description: 斧头帮老大，消息发布者，继承 Observable
 * <br/>
 * author: shixinzhang
 * <br/>
 * data: 9/20/2016
 */
public class AxeGangBoss extends Observable {
    private String mName;

    public AxeGangBoss(String name) {
        mName = name;
    }

    /**
     * 在需要通知小弟的时候调用 setChanged()方法，表明有更新
     * 然后提醒所有小弟
     * @param msg
     */
    public void sendMsg(String msg) {
        //表示有更新
        setChanged();
        notifyObservers(msg);
    }

    public String getName() {
        return mName;
    }

    public void setName(String name) {
        mName = name;
    }
}

斧头帮老大是消息发布者，当有情况时就调用 sendMsg(…) 方法给小弟发消息。他继承自 Java 源代码提供的 Observable ：

代码语言：javascript复制

public class Observable {

    List<Observer> observers = new ArrayList<Observer>();

    boolean changed = false;

    public Observable() {
    }

    public void addObserver(Observer observer) {
        if (observer == null) {
            throw new NullPointerException("observer == null");
        }
        synchronized (this) {
            if (!observers.contains(observer))
                observers.add(observer);
        }
    }

    protected void clearChanged() {
        changed = false;
    }

    public int countObservers() {
        return observers.size();
    }

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

    public synchronized void deleteObservers() {
        observers.clear();
    }

    public boolean hasChanged() {
        return changed;
    }

    public void notifyObservers() {
        notifyObservers(null);
    }

    @SuppressWarnings("unchecked")
    public void notifyObservers(Object data) {
        int size = 0;
        Observer[] arrays = null;
        synchronized (this) {
            if (hasChanged()) {
                clearChanged();
                size = observers.size();
                arrays = new Observer[size];
                observers.toArray(arrays);
            }
        }
        if (arrays != null) {
            for (Observer observer : arrays) {
                observer.update(this, data);
            }
        }
    }

    protected void setChanged() {
        changed = true;
    }
}

Observable 里保存着一个 Observer 的集合，然后提供了添加、删除、提醒等方法。其中重要的是 notifyObservers(…) 方法，当确定出事了（changed 为 true）时，挨个通知小弟。 Observer 是一个接口，规定了小弟收到消息的方法 update(…)：

代码语言：javascript复制

public interface Observer {
    void update(Observable observable, Object data);
}

2.定义斧头帮小弟 AxeGangPeople，小弟需要按规矩来，实现 Observer 接口:

代码语言：javascript复制

/**
 * description: 斧头帮小弟，订阅者，实现 Observer 接口
 * <br/>
 * author: shixinzhang
 * <br/>
 * data: 9/20/2016
 */
public class AxeGangPeople implements Observer {
    String mName;

    public AxeGangPeople(String name){
        mName = name;
    }

    /**
     * 必须实现的方法，当消息发布者发出通知后，会调用这个方法
     * @param observable
     * @param data
     */
    @Override
    public void update(Observable observable, Object data) {
        AxeGangBoss writer;
        if (observable instanceof AxeGangBoss) {
            writer = (AxeGangBoss) observable;
            System.out.println(getName()   " 收到来自 "   writer.getName()   " 的消息: "   data.toString());
        }
    }

    public String getName() {
        return mName;
    }

    public void setName(String name) {
        mName = name;
    }
}

3.然后小弟去老大那登记，老大有消息了就射穿云箭：

代码语言：javascript复制

    @Test
    public void testSendMsg() throws Exception {
        //创建一个斧头帮老大
        AxeGangBoss shixinzhang = new AxeGangBoss("张拭心");
        //创建两个小弟
        AxeGangPeople niefeng = new AxeGangPeople("聂风");
        AxeGangPeople bujingyun = new AxeGangPeople("步惊云");
        //老大觉得可以，收入麾下
        shixinzhang.addObserver(niefeng);
        shixinzhang.addObserver(bujingyun);
        //老大出事了，赶紧射箭！
        shixinzhang.sendMsg("我有难了，快来救我！");
    }

4.运行结果：

这种一对多的通知场景就是传说中的观察者模式。