概念
观察者模式：又称发布(publish)-订阅(Subscribe)模式、模型(Model)-视图(View)模式、源(Source)-监听器(Listener)模式或从属者(Dependents)模式,是一种对象行为型模式。
定义对象间的一对多的依赖关系，当被观察者对象进行状态改变时，则所有依赖它的观察者对象都会得到通知并更新状态。
UML
观察者模式
角色
- 抽象主题(Subject)：又称抽象被观察者(Observable)，抽象主题维护一个集合，用来保存所有观察者对象的引用。提供一个接口，用来添加或删除观察者对象。
- 具体主题(ConcreteSubject)：又称具体被观察者(ConcreteObservable)，在具体主题状态发生改变时，给所有注册该主题的具体观察者对象发出通知。
- 抽象观察者(Observer)：观察者的抽象类，定义了一个update接口，得到主题更新的通知后，更新自己。
- 具体观察者(ConcreteObserver)：实现抽象观察者的update接口，给出具体的更新状态。
简单示例
笑傲江湖中辟邪剑谱一重出江湖，就引起了各大门派的觊觎，这就是典型的观察者模式啊。福威镖局被观察者、五岳剑派各大掌门等人为观察者，观察者模式开启。
抽象主题(Observable)
java.util库Observer源码
package java.util;
public class Observable {
private boolean changed = false;
private final ArrayList<Observer> observers;
public Observable() {
observers = new ArrayList<>();
}
public synchronized void addObserver(Observer o) {
if (o == null)
throw new NullPointerException();
if (!observers.contains(o)) {
observers.add(o);
}
}
public synchronized void deleteObserver(Observer o) {
observers.remove(o);
}
public void notifyObservers() {
notifyObservers(null);
}
public void notifyObservers(Object arg) {
Observer[] arrLocal;
synchronized (this) {
if (!hasChanged())
return;
arrLocal = observers.toArray(new Observer[observers.size()]);
clearChanged();
}
for (int i = arrLocal.length-1; i>=0; i--)
arrLocal[i].update(this, arg);
}
public synchronized void deleteObservers() {
observers.clear();
}
protected synchronized void setChanged() {
changed = true;
}
protected synchronized void clearChanged() {
changed = false;
}
public synchronized boolean hasChanged() {
return changed;
}
public synchronized int countObservers() {
return observers.size();
}
}
具体主题(ConcreteSubject)
福威镖局
package com.bamboolmc.designpattern.ObserverMode;
import java.util.Observable;
public class FuWeiBoard extends Observable{
//发布事件－－辟邪剑谱重现江湖
public void publishPiXie(){
System.out.println("我福威镖局，辟邪剑谱重现江湖");
//标志状态修改
setChanged();
//通知所有观察者
notifyObservers();
}
}
抽象观察者(Observer)
java.util库Observer接口源码
package java.util;
public interface Observer {
void update(Observable o, Object arg);
}
具体观察者(ConcreteObserver)
林平之、岳不群、余沧海
package com.bamboolmc.designpattern.ObserverMode;
import java.util.Observable;
import java.util.Observer;
public class LinPingzhi implements Observer {
public LinPingzhi() {
}
@Override
public void update(Observable o, Object arg) {
doSomething();
}
private void doSomething() {
System.out.println("我林平之，这是我家祖传剑法！…… 先要自＊ &^*$*% 神功已成，我终于可以报仇了");
}
}
package com.bamboolmc.designpattern.ObserverMode;
import java.util.Observable;
import java.util.Observer;
public class YuCanghai implements Observer {
public YuCanghai() {
}
@Override
public void update(Observable o, Object arg) {
doSomething();
}
private void doSomething() {
System.out.println("我余沧海，江湖传闻的第一剑谱，是我的！………… 我擦，没抢到，晦气！");
}
}
package com.bamboolmc.designpattern.ObserverMode;
import java.util.Observable;
import java.util.Observer;
public class YueBuqun implements Observer{
public YueBuqun() {
}
@Override
public void update(Observable o, Object arg) {
doSomething();
}
private void doSomething(){
System.out.println("我岳不群，有了剑谱，我就是五岳盟主！ …… \"欲练此功，必先自＊\" 咔@％＃&＊ 神功在体，谁敢跟我夺五岳盟主^_^");
}
}
观察者模式使用
package com.bamboolmc.designpattern.ObserverMode;
import java.util.Observable;
public class FuWeiBoard extends Observable{
//发布事件－－辟邪剑谱重现江湖
public void publishPiXie(){
System.out.println("我福威镖局，辟邪剑谱重现江湖");
//标志状态修改
setChanged();
//通知所有观察者
notifyObservers();
}
}
输出结果
我福威镖局，辟邪剑谱重现江湖
我岳不群，有了剑谱，我就是五岳盟主！ …… "欲练此功，必先自＊" 咔@％＃&＊ 神功在体，谁敢跟我夺五岳盟主^_^
我余沧海，江湖传闻的第一剑谱，是我的！………… 我擦，没抢到，晦气！
我林平之，这是我家祖传剑法！…… 先要自＊ &^*$*% 神功已成，我终于可以报仇了
适用环境
- 一个系统多个的对象对某些特定的对象的状态或者属性改变感兴趣,就可以采取该模式。
- 事件多级触发场景。
- 消息队列，事件总线处理机制
作用
最重要的作用就是解耦，将被观察者和观察者解耦，使其依赖性更小或者毫无依赖。
