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

2016年9月27日 254次阅读来源: 算法小白

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

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

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

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

星爷，may the god bless you.

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

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

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

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

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

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

用代码实现一下：

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

/**
 * description: 斧头帮老大，消息发布者，继承 Observable
 * 

 * author: shixinzhang
 * 

 * 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 ：

public class Observable {

    List
    
      observers = new ArrayList
     
      (); 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(…)：

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

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

/**
 * description: 斧头帮小弟，订阅者，实现 Observer 接口
 * 

 * author: shixinzhang
 * 

 * 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.然后小弟去老大那登记，老大有消息了就射穿云箭：

    @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.运行结果：
《观察者模式 : 一支穿云箭，千军万马来相见》

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