Observer模式

定义Observer接口：

 

public interface Observer
{
	/*
	 * 观察者的回调方法，带有一个参数。  
	 * */
	public void watch(Object c);
}

 定义Subject接口：

 

public interface Subject
{
	/*
	 * 为 Subject 添加Observer
	 * 
	 * */
	public void addObserver(Observer o);

	
	/*
	 * 为 Subject 删除Observer
	 * 
	 * */
	public void deleteObserver(Observer o);

	
	/*
	 * 通知所有Observer执行回调方法，并附带一个参数。
	 * 
	 * */
	public void notifyAllObserver(Object o);
}

 ObserverA实现Observer：

 

public class ObserverA implements Observer
{
	@Override
	public void watch(Object c)
	{
		System.out.println("Observer A has save \"" + c + "\" to database.");
	}
}

 ObserverB实现Observer，同ObserverA，省略。

 

 SubjectA实现Subject：

 

public class SubjectA implements Subject
{
	Set<Observer> observers = new HashSet<Observer>();
	@Override
	public void addObserver(Observer o)
	{
		this.observers.add(o);
	}

	@Override
	public void deleteObserver(Observer o)
	{
		this.observers.add(o);
	}

	@Override
	public void notifyAllObserver(Object o)
	{
		for(Observer observer : observers)
		{
			observer.watch(o);
		}
	}
}

 测试代码：

 

public class TestMain
{
	public static void main(String[] args)
	{
		Observer A = new ObserverA();
		Observer B = new ObserverB();
		Subject subject = new SubjectA();
		subject.addObserver(A);
		subject.addObserver(B);
		subject.notifyAllObserver("Some Messages");
	}

}

     如网上商店中商品在名称、价格等方面有变化，如果系统能自动通知会员，将是网上商店区别传统商店的一大特色。这就需要在商品product中加入Observer这样角色，以便product细节发生变化时，Observer能自动观察到这种变化,并能进行及时的update或notify动作。

  Java API 中有对Observer模式的独立实现，Observer实现java.util.observer接口，Subject继承java.util.Observable类，重写相应的方法即可实现Observer模式。