（二）设计模式-观察者模式

1、定义

观察者模式又叫做发布-订阅（Public/Subscribe）模式。

定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象。这个主题对象在状态发生变化时，会通知所有的观察者对象，使他们能够自动更新自己。

2、使用场景

老板回来。我不知道？

办公场景，同事小王，同事小明，前台小花，老板王老五，主要时这四个人物。小王长期喜欢理财炒股会在工作间隙看一些股票走势图，小明忙着考公务员会在工作间隙看一些作业习题，小王、小明和前台小花关系处得比较好，所以大家聊得比较好。

老板王老五经常出去跑业务有时候会不定期回到公司，所以小王和小明都比较担心老板回来撞见没做工作之内的事情而受到批评，所以小王和小明就和前台小花达成了一个共识，小花要是看到老板回来的时候麻烦通知一下。

3、代码结构UML图

抽象通知者：它把所有对观察者对象的引用保存在一个集合里，每个主题都可以有任何数量的观察者。抽象主题提供一个接口，可以添加和移除观察者对象。

抽象观察者：为所有的具体观察者定义一个接口，在得到主题通知时更新自己。

老板、小花：具体主题，将有管状态存入具体观察者对象；在具体主题的内部状态改变时，给所有登记过的观察者发出通知。

看股票观察者、做习题观察者：具体观察者，实现抽象观察者角色所要求的更新接口，以便使本身的状态与主题的状态相协调。

4、类的实现

(1)、Observable（抽象通知者）

interface Observable{
	void add(Observer o);
	void remover(Observer o);
	void notify();
	void setState(String state);
	String getState();
}
           

(2)、Observer（抽象观察者）

abstract Observer{
	protected String name;
	protected Observable obs;
	public Observer(String name,Observable obs){
		this.name=name;
		this.obs=obs;
	}
	public abstract void update();
}
           

(3)、Boss（具体通知类老板）

public class Boss implements Observable{
	private List<Observer> observers=new ArrayList<>();
	private String action;
	@Overrride
	public void add(Observer o){
		observers.add(O);
	}
	@Override
	public void remove(Observer o){
		observers.add(o);
	}
	@Override
	public void notify(){
		foreach(Observer o:observers){
			o.update();
		}
	}
	@Override
	public String getState(){
		return action;
	}
	@Override
	public void setState(String state){
		action=state;
	}
}
           

(4)、Staff（具体通知类 前台职员小花）

public class Staff implements Observable{
	private List<Observer> observers=new ArrayList<>();
	private String action;
	@Overrride
	public void add(Observer o){
		observers.add(O);
	}
	@Override
	public void remove(Observer o){
		observers.add(o);
	}
	@Override
	public void notify(){
		foreach(Observer o:observers){
			o.update();
		}
	}
	@Override
	public String getState(){
		return action;
	}
	@Override
	public void setState(String state){
		action=state;
	}
}
           

(5)、StockObserver（具体通知类小王）

public class StockObserver extends Observer{
	Observable o;
	String name;
	public StockObserver(String name,Observable o){
	this.o=o;
	this.name=name;
	}
	public void update(){
		System.out.println(o.getState()+" ," +name +" 关闭股票走势图，继续工作！");
	}
}
           

(6)、PracticeObserver（具体通知类小明）

public class PracticeObserver extends Observer{
	Observable o;
	String name;
	public PracticeObserver(String name,Observable o){
	this.o=o;
	this.name=name;
	}
	public void update(){
		System.out.println(o.getState()+" ," +name +" 关闭作业习题，继续工作！");
	}
}
           

5、客户端调用

public static void main(String[] args){
	Boss wlw=new Boss();
	// Staff xiaohua=new Staff();
	wlw=new Boss();
	StockObserver tongshi1=new StockObserver("小王",wlw);
	PracticeObserver tongshi2=new PracticeObserver("小明",wlw);
	wlw.add(tongshi1);	
	wlw.add(tongshi2);	
	wlw.setState("我王老五回来了");
	wlw.notify();
}
           

6、总结

观察者模式，将一个系统分割成一系列相互协作的类有一个很不很好的副作用，那就是需要维护相关对象间的一致性。我们不希望为了维持一致性而使各类紧密耦合，这样会给维护、扩展和重用都带来不便。而观察者模式的关键对象时主题Subject(Observable)和观察者Observer，一个Subject可以在任意数目的依赖它的Observer，一旦Subject的状态发生变化，所有的Observer都可以得到通知。Subject发出通知时，并不需要知道谁是它的观察者，也就时说观察者时谁，它根本不需要知道。而任何一个具体观察者不知道也不需要知道其他观察者的存在。

观察者所做的工作其实就是在解除耦合。让耦合双方都依赖于抽象，而不是依赖具体。从而使得各自的变化都不会影响另一边的变化。

参考：《大话设计模式》