观察者模式

       观察者模式又称为“发布-订阅模式”。观察者模式定义了一种一对多的依赖关系，让多个观察者对象同时监听一个主题对象。这个主题对象在发生状态变化时，负责通知所有观察者对象，使观察者对象能自动更新自己。

Subject类一般用一个抽象类或者接口实现。它把所有对观察者对象的引用保存在一个聚集里边，每个主题都可以有任意数量的观察者。抽象主题提供一个接口，可以增加和删除观察者对象，并notify所有观察者。

       Observer类为抽象的观察者类，在得到subject的notify通知时更新自己。这个接口叫做更新接口。抽象观察者一般用一个抽象类或者接口实现，通常包含一个update()方法，用于更新自己。

       ConcreteSubject类，为具体的主题类，将有关的状态存入具体观察者对象；在具体主题的内部状态发生改变时，给所有“登记”过的观察者发出通知。

       ConcreteObserver类，为具体的观察者，实现抽象观察者的更新接口，具体观察者角色可以保存一个指向具体主题对象的引用。

优点：

观察者模式实现了观察者和目标之间的抽象耦合。 观察者模式实现了动态联动 观察者模式支持广播通信。被观察者会向所有的登记过的观察者发出通知。

缺点：

可能会引起无谓的操作。由于采用广播方式，不管观察者需不需要，每个观察者都会被调用update方法 。

实例代码：

抽象Subject接口

import java.util.ArrayList; import java.util.List; public interface ISubject { List<IObserver> observers = new ArrayList<IObserver>(); abstract void attach(IObserver observer); abstract void detach(IObserver observer); abstract void notifyObserver(); } 抽象Observer接口

public interface IObserver { abstract void update(); } ConcreteSubject

public class ConcreteSubject implements ISubject { private String state; public String getState() { return state; } public void setState(String state) { this.state = state; } @Override public void attach(IObserver observer) { observers.add(observer); } @Override public void detach(IObserver observer) { observers.remove(observer); } @Override public void notifyObserver() { for(IObserver observer : observers){ observer.update(); } } public void changeState(){ state = "state has Changed !"; } } ConcreteObserver public class ConcreteObserver implements IObserver{ ISubject subject; int observerId; public ConcreteObserver(ISubject subject, int id) { super(); this.subject = subject; this.observerId = id; } @Override public void update() { System.out.println("Observer"+observerId+": "+((ConcreteSubject)subject).getState()); } }

Client程序

public class TestUnit { @Test public void testObserver(){ ISubject subject = new ConcreteSubject(); subject.attach(new ConcreteObserver(subject,1)); subject.attach(new ConcreteObserver(subject,2)); subject.attach(new ConcreteObserver(subject,3)); ((ConcreteSubject)subject).changeState(); subject.notifyObserver(); } }