7.设计模式之观察者模式

1.  概述
      观察者（Observer）模式是对象的行为型模式，又叫做发表-订阅（Publish/Subscribe）模式、模型-视图（Model/View）模式、源-收听者（Source/Listener）模式或从属者（Dependents）模式。
观察者模式定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象。这个主题对象在状态发生变化时，会通知所有观察者对象，使它们能够自动更新自己。

2. 我的理解是，多个对象监听一个对象，当被监听对象的属性发生变化后，会通知观察者类进行更新。

 

 3. Example: 气象台每天上午和下午更新天气信息,小米的天气软件和锤子的天气软件都订阅了气象台的天气信息，如果天气发生了变化，这两个软件都会及时更新天气信息。用观察者模式实现

 

1. 订阅的主题类

/**
 * 	主题类
 * 
 * @author wangkechao.dream
 *
 */
public abstract class Subject {
	
	private List<Observer> observers = new ArrayList<Observer>();//注册的观察者
	
	//增加一个观察者
	 public void addObserver(Observer observer){
		 observers.add(observer);
	 }
	 //删除一个观察者
	  public void removeObserver(Observer observer){
		  observers.remove(observer);
	  }
	  //通知观察者
	  public void nofity(WeatherInfo weatherInfo){
		  for(Observer observer:observers){
			  observer.update(weatherInfo);
		  }
	  }
}

 2.主题的实现类

public class ConcreteSubject extends Subject{

	
	private String subjectstatus;//主题的状态

	public String getSubjectstatus() {
		return subjectstatus;
	}

	public void setSubjectstatus(String subjectstatus) {
		this.subjectstatus = subjectstatus;
	}
	
	
	@Override
	//1 表示需要更新
	public void nofity(WeatherInfo weatherInfo) {
		if("1".equals(subjectstatus)){
			super.nofity(weatherInfo);
		}
	}
}

 3.观察者类

public abstract class Observer {
	
	//更新
	abstract void update(WeatherInfo weatherInfo);

}

 4.观察者具体实现类

public class ConcreteObserver extends Observer{

	private String observerName;
	public ConcreteObserver(String observerName) {
		super();
		this.observerName = observerName;
	}
	void update(WeatherInfo weatherInfo) {
		System.out.println("软件"+observerName+"的天气更新为:");
		System.out.println("温度:"+weatherInfo.getTemperature());
		System.out.println("湿度:"+weatherInfo.getHumidity());
	}
}

 5. 定义一个天气信息

public class WeatherInfo {
	
	private double temperature;//温度
	
	private double humidity;//湿度

	public WeatherInfo(double temperature, double humidity) {
		super();
		this.temperature = temperature;
		this.humidity = humidity;
	}

	public double getTemperature() {
		return temperature;
	}

	public void setTemperature(double temperature) {
		this.temperature = temperature;
	}

	public double getHumidity() {
		return humidity;
	}

	public void setHumidity(double humidity) {
		this.humidity = humidity;
	}

}

 6. 运行起来吧

 

public class Main {
	
	public static void main(String[] args) {
		//定义多个观察者
		Observer miui = new ConcreteObserver("小米天气");
		Observer hammer = new ConcreteObserver("锤子天气");
	
		//订阅天气主题 
		ConcreteSubject subject = new ConcreteSubject();
		subject.addObserver(miui);
		subject.addObserver(hammer);
		
		//上午天气状况是这样的
		WeatherInfo weatherInfo = new WeatherInfo(38,204);
		
		//通知观察者更新天气
		subject.setSubjectstatus("1");
		subject.nofity(weatherInfo);
		
		//下午天气温度发生了变化
		weatherInfo.setTemperature(12);
		
		//通知观察者更新天气,并且此时小米天气取消了订阅
		System.out.println("-----小米取消订阅后-----");
		subject.removeObserver(miui);
		subject.setSubjectstatus("1");
		subject.nofity(weatherInfo);
	}
}

运行结果:

软件小米天气的天气更新为:
温度:38.0
湿度:204.0
软件锤子天气的天气更新为:
温度:38.0
湿度:204.0
-----小米取消订阅后-----
软件锤子天气的天气更新为:
温度:12.0
湿度:204.0

 

 

 

参考源文档 <http://blog.csdn.net/ncepustrong/article/details/9003761> ，此处致谢。

返回导航

 

本人也是初学，HY各位批评指导，共同进步