概念
观察者模式:又称发布(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();
}
}
输出结果
我福威镖局,辟邪剑谱重现江湖
我岳不群,有了剑谱,我就是五岳盟主! …… "欲练此功,必先自*" 咔@%#&* 神功在体,谁敢跟我夺五岳盟主^_^
我余沧海,江湖传闻的第一剑谱,是我的!………… 我擦,没抢到,晦气!
我林平之,这是我家祖传剑法!…… 先要自* &^*$*% 神功已成,我终于可以报仇了
适用环境
- 一个系统多个的对象对某些特定的对象的状态或者属性改变感兴趣,就可以采取该模式。
- 事件多级触发场景。
- 消息队列,事件总线处理机制
作用
最重要的作用就是解耦,将被观察者和观察者解耦,使其依赖性更小或者毫无依赖。
网友评论