[设计模式]之十六:观察者模式

//抽象出Notifier接口，保持所有被观察者对象的引用，并管理通知 notify
abstract class INotifier {
	private List<IObserver> observers = new ArrayList<>();
	
	public void attach(IObserver observer) {
		observers.add(observer);
	}
	
	public void detach(IObserver observer) {
		observers.remove(observer);
	}
	
	public void notifyObserver() {
		for (int i = 0; i < observers.size(); i++) {
			observers.get(i).update();
		}
	}
}
// 具体的通知者 管理控制具体的观察者对象  管理自己需要变化的状态
public class ConcreteNotifier extends INotifier {
	private String state;

	public String getState() {
		return state;
	}

	public void setState(String state) {
		this.state = state;
	}
	
}
//抽象观察者。观察者需要在得到通知后更新自己 所以需要更新方法
abstract class IObserver {
	// 更新接口
	public abstract void update();
}
//具体观察者 它会有一个状态  在update的时候从对应的notifier获取新状态
public class ConcreteObserver extends IObserver {

	private String name;
	private String observerState;
	private ConcreteNotifier notifier;

	public ConcreteObserver(ConcreteNotifier notifier, String name) {
		// TODO Auto-generated constructor stub
		this.notifier = notifier;
		this.name = name;
	}
	
	@Override
	public void update() {
		// TODO Auto-generated method stub
		observerState = notifier.getState();
		System.out.println("Observer " + name + "'s new state is " + observerState);
	}

}

//客户代码
public void start() {
    //创建通知者
	ConcreteNotifier notifier = new ConcreteNotifier();
	//添加观察者
	notifier.attach(new ConcreteObserver(notifier, "X"));
	notifier.attach(new ConcreteObserver(notifier, "Y"));
	//通知更新状态
	notifier.setState("hahaha");
    //告诉观察者开始改状态
	notifier.notifyObserver();
}
//输出
Observer X's new state is hahaha
Observer Y's new state is hahaha