定义
定义对象的一种一对多的依赖关系，当一个对象的状态发生改变时，所有依赖于它的对象都得到通知并被自动更新。
观察者模式是行为型模式之一。包含观察者模式包括观察者与被观察者两个基本元素，观察者会注册到被观察者中，而被观察者会保持和观察者的对应关系。
如果被观察的对象产生一些观察者感兴趣的变更，则观察者会得到通知从而去执行相关的操作。
常见的观察者模式
提到观察者模式，首先会想到前端中常用的事件机制。例如为dom元素绑定事件：
$(document).click(function (e) {
console.dir(e);
});
这里的匿名function就是观察者，而document则是被观察者，.click(function)则是观察者注册的过程，此后document发生click事件时，被观察者则会收到通知，从而执行自己的逻辑console.dir(e)。
使用观察者模式
现在我们使用Java来模拟观察者模式。
先创建事件，包含事件源，通知目标，回调方法以及触发者等属性。
/**
* 事件
*/
public class Event {
private Object source; // 事件源
private Object target; // 通知目标
private Method callback; // 回调方法名称
private String trigger; // 触发者
private long time;
public Event(Object target, Method callback) {
this.target = target;
this.callback = callback;
}
// 省略getter、setter
}
定义事件类型，此处定义添加、删除两种类型。
/**
* 事件类型
*/
public enum EventType {
/**
* 添加
*/
ADD,
/**
* 删除
*/
RMOVE
}
定义抽象被观察者（主题），包含主题名称，保持与观察者引用映射的容器，以及事件触发的方法。
import java.lang.reflect.Method;
import java.util.HashMap;
import java.util.Map;
/**
* 抽象主题
* 定义主题通用的容器、事件注册及事件触发
*/
public class AbstractSubject {
protected String name;
protected Map<Enum,Event> eventMap = new HashMap<>(); // 注册容器
public AbstractSubject() {}
protected AbstractSubject(String name) {
this.name = name;
}
/**
* 事件注册
* @param eventType
* @param target
* @param callback
*/
public void addLisenter(Enum eventType, Object target, Method callback) {
eventMap.put(eventType, new Event(target, callback));
}
/**
* 事件触发
* @param eventType
*/
protected void trigger(Enum eventType) {
Event event = this.eventMap.get(eventType);
if(null == event) {
return;
}
event.setSource(this);
event.setTrigger(eventType.toString());
event.setTime(System.currentTimeMillis());
try {
event.getCallback().invoke(event.getTarget(), event);
} catch (Exception e1) {
e1.printStackTrace();
}
}
// 省略getter、setter
}
定义具体主题：
/**
* 主题，被观察者
*/
public class Subject extends AbstractSubject {
public Subject(String name) {
super.name = name;
}
public void add() {
trigger(EventType.ADD);
}
public void remove() {
trigger(EventType.RMOVE);
}
}
定义观察者，包含添加、删除事件对应的回调方法。
/**
* 观察者
*/
public class Observer {
public void onAdd(Event event) {
System.out.println("收到" + event.getTrigger() + "的添加事件");
}
public void onRemove(Event event) {
System.out.println("收到" + event.getTrigger() + "的删除事件");
}
}
测试类：
/**
* 测试类
*/
public class Test {
public static void main(String[] args) throws NoSuchMethodException {
// 观察者
Observer observer = new Observer();
// 观察者收到通知后执行的方法
Method onAdd = Observer.class.getMethod("onAdd", Event.class);
Method onRemove = Observer.class.getMethod("onRemove", Event.class);
// 被观察者
Subject subject = new Subject("目标1号");
// 事件绑定
subject.addLisenter(EventType.ADD, observer, onAdd);
subject.addLisenter(EventType.RMOVE, observer, onRemove);
// 被观察者触发事件
subject.add();
subject.remove();
}
}
其中，得到观察者和主题对象后，进行观察者的注册，然后主题执行动作触发事件，这是整个流程。
如果需要做成主题和观察者一对多的映射，则将Event的target改成集合类型，如下：
private List<Object> targets; // 通知目标
