观察者模式（Observer Pattern）

观察者模式（Observer Pattern）:定义对象间一对多的关系。当对象的状态发生改变时，使其所依赖的对象得到通知并自动更新。

优点：
a. 观察者和被观察者之间抽象耦合。
b. 建立一套触发机制。
缺点：
a. 开发效率和运行效率。
b. 调试复杂，消息的通知是按顺序的，如果有一个观察者卡壳，会影响到整体效率，考虑使用异步解决。
使用场景：
a. 关联的行为场景。
b. 事件多级触发。
c. 跨系统的消息交换。如消息队列处理机制。
注意事项：
a. 广播链的问题：一个观察者有可能是被观察者，在观察者模式中最多只能出现一对既是观察者又是被观察者。
b. 异步处理的问题。
项目中真实的观察者模式：
a. 观察者和被观察者间的消息沟通：即观察者的update方法中接受两个参数，一个是被观察者自己，二是DTO(Data Transfer Object,数据传输对象)，若远程传输，可考虑XML格式。
b. 观察者的响应问题：观者者较多时，需考虑性能问题，解决方法：
a) 多线程。
b) 缓存技术，即同步结构。
c) 被观察者尽量自己做主：在doingSomething(boolean isNotifyObs)，做为判断是否向观察者发布消息。
订阅发布模型：如EJB 3.0中的消息驱动Bean便是观察者模式的升级版。
实践：
a． 文件系统。如新建一个文件，通知目录管理器增加目录，通知磁盘管理器减少磁盘空间。
b． 猫鼠游戏。猫叫一声，老鼠跑，主人醒等。
c． ATM机取钱。多次输入错误密码，吞卡时触发：一连续快拍，二通知监控系统，吞卡发生，三初始化ATM屏幕。前两个由观察者模式，后一个由异常完成。
d． 广播收音机。电台是被观察者，收音机是观察者。

package org.observer;

//观察者接口
public interface Observer {
	public void update();
}

package org.observer;

public class ConcreteObserver1 implements Observer {
	// 具体观察者的业务逻辑
	public void update() {
		System.out.println("我是ConcreteObserver1");
	}

}

package org.observer;

public class ConcreteObserver2 implements Observer {

	public void update() {
		System.out.println("我是ConcreteObserver2");
	}

}

package org.observer;

import java.util.Iterator;
import java.util.Vector;

//	被观察者的抽象类，功能：添加观察者，删除观察者，向所有观察者发布广播信息
//	类似JAVA中的事件驱动
public class Subject {
	private Vector<Observer> observers = new Vector<Observer>();

	public void addObserver(Observer o) {
		this.observers.add(o);
	}

	public void delObserver(Observer o) {
		this.observers.remove(o);
	}

	public void notifyObservers() {
		for (Observer o : this.observers) {
			o.update();
		}
	}
}

package org.observer;
//	被观察者，也有自己的方法接口
public interface ConcreteSubjectImp {

	public void firstMethod();

	public void secondMethod();

}

package org.observer;

public class ConcreteSubject1 extends Subject implements ConcreteSubjectImp {

	// 当调用第一个方法时，会向所有观察者发布消息
	public void firstMethod() {
		System.out.println("第一个方法");
		super.notifyObservers();
		System.out.println("-------------------------");
		System.out.println();
	}

	// 当调用第二个方法时，会向所有观察者发布消息
	public void secondMethod() {
		System.out.println("第二个方法");
		super.notifyObservers();
		System.out.println("-------------------------");
		System.out.println();
	}
}

package org.observer;

public class Client {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		Observer concreteObserver1 = new ConcreteObserver1();
		Observer concreteObserver2 = new ConcreteObserver2();

		ConcreteSubject1 subject = new ConcreteSubject1();
		subject.addObserver(concreteObserver1);
		subject.addObserver(concreteObserver2);

		subject.firstMethod();
		subject.secondMethod();
	}

}

通过java.util中的类实现观察者模式

package org.observer.jdk;
//	被观察者，也有自己的方法接口
public interface ConcreteSubjectImp {

	public void firstMethod();

	public void secondMethod();

}

package org.observer.jdk;

import java.util.Observable;

public class ConcreteSubject1 extends Observable implements ConcreteSubjectImp {

	// 当调用第一个方法时，会向所有观察者发布消息
	public void firstMethod() {
		System.out.println("第一个方法");
		super.setChanged();
		super.notifyObservers("第一个方法");
		System.out.println("-------------------------");
		System.out.println();
	}

	// 当调用第二个方法时，会向所有观察者发布消息
	public void secondMethod() {
		System.out.println("第二个方法");
		super.setChanged();
		super.notifyObservers("第二个方法");
		System.out.println("-------------------------");
		System.out.println();
	}
}

package org.observer.jdk;

import java.util.Observable;
import java.util.Observer;

public class ConcreteObserver1 implements Observer {
	
	public void update(Observable o, Object arg) {
		System.out.println("我是ConcreteObserver1"+"-----"+arg.toString());
	}

}

package org.observer.jdk;

import java.util.Observable;
import java.util.Observer;

public class ConcreteObserver2 implements Observer {

	public void update(Observable o, Object arg) {
		System.out.println("我是ConcreteObserver2" + "-----" + arg.toString());
	}

}

package org.observer.jdk;

public class Client {

	public static void main(String[] args) {
		ConcreteObserver1 concreteObserver1 = new ConcreteObserver1();
		ConcreteObserver2 concreteObserver2 = new ConcreteObserver2();

		ConcreteSubject1 subject = new ConcreteSubject1();
		subject.addObserver(concreteObserver1);
		subject.addObserver(concreteObserver2);

		subject.firstMethod();
		subject.secondMethod();
	}

}