观察者模式(一)

观察者模式(Observer)

● 观察者模式定义了一种一对多的依赖关系， 让多个观察者对象同时监听某一个主题对象。 这个主题对象在状态上发生变化时，会通知所有观察者对象， 让他们能够自动更新自己。


观察者模式的组成
-  抽象主题角色: 把所有对观察者对象的引用保存在一个集合中， 每个抽象主题角色都可以有任意数量的观察者。 抽象主题提供一个接口， 可以增加和删除观察者角色。 一般用一个抽象类或接口来实现。

-  抽象观察者角色： 为所有具体的观察者定义一个接口， 在得到主题的通知时更新自己。

------------------------

-  具体主题角色： 在具体主题内部状态改变时，给所有登记过的观察者发出通知。具体主题角色通常用一个子类实现。

-  具体观察者角色： 该角色实现抽象观察者角色所要求的更新接口， 以便使本身的状态与主题的状态相协调。 如果需要，具体观察者角色可以保存一个指向具体主题角色的引用。 通常可以用一个子类实现。

=== 重点就是主题和观察者角色
主题角色是被观察的， 观察者角色是观察别人的。



下面是具体实现代码:

抽象主题角色:

package com.lj.observer;


/**
 *  抽象主题角色
 *  被观察者
 *  这里由接口来实现
 * @author Administrator
 *
 */
public interface Watched
{	
	
	/**
	 * 添加一个观察者
	 * @param watcher
	 */
	public void addWatcher(Watcher watcher);
	
	/**
	 * 删除一个观察者
	 * @param watcher
	 */
	public void removeWatcher(Watcher watcher);
	
	
	/**
	 * 通知观察者们
	 * @param str
	 */
	public void notifyWatchers(String str);
}

抽象观察者:

package com.lj.observer;


/**
 * 抽象观察者角色, 是来观察别人的
 * @author Administrator
 *
 */
public interface Watcher
{	
	
	/**
	 * 观察到对象的变动， 并做出相应措施
	 * @param str
	 */
	public void update(String str);
}

具体主题角色:

package com.lj.observer;

import java.util.ArrayList;
import java.util.List;



/**
 * 具体主题角色
 * 具体被观察的对象
 * 
 * @author Administrator
 *
 */
public class ConcreteWatched implements Watched
{
	
	//这里必须有一个集合， 来承载所有观察者
	private List<Watcher> list=new ArrayList<Watcher>();
	
	
	
	@Override
	public void addWatcher(Watcher watcher)
	{
		list.add(watcher);
	}

	@Override
	public void removeWatcher(Watcher watcher)
	{	
		list.remove(watcher);
	}
	
	
	 
	@Override
	public void notifyWatchers(String str)
	{
		for(Watcher watcher:list){
			watcher.update(str);
		}
		
		
	}
	

}

具体观察者角色:

package com.lj.observer;


/**
 * 具体的观察者
 * 针对被观察者的行为，做出一系列举措
 * 
 * 相当于Listener一样。
 * @author Administrator
 *
 */
public class ConcreteWatcher implements Watcher
{

	@Override
	public void update(String str)
	{
		System.out.println("ConcreteWatcher-----"+str);
		
	}

}

最后是测试代码：

package com.lj.observer;

public class Test
{	
	public static void main(String[] args)
	{
		Watched watched_obj=new ConcreteWatched();
		
		Watcher watcher1=new ConcreteWatcher();
		Watcher watcher2=new ConcreteWatcher();
		
		watched_obj.addWatcher(watcher1);
		
		watched_obj.addWatcher(watcher2);
		
		watched_obj.notifyWatchers("hello");
		
		
	}
}