设计模式----观察者模式

        最近学习了下设计模式，整理下笔记，以后复习，也跟大家多交流交流，呵呵。。。
        观察者模式定义：定义了对象之间的一对多依赖，这样一来，当一个对象改变状态时，它的所有依赖者都会收到通知并自动更新
        改变的对象一般称之为主题，而所有依赖者称之为观察者，只要主题状态一有变化，观察者就会被通知。
        实现观察者模式的方法：一般以主题Subject和观察者Observer接口的类设计此模式
OK，不多说，上实例，以一个天气预报为例：一个WeatherData对象（角色：Subject，记录气象站数据，并更新布告板），N个布告板（角色：Observer，显示天气状况）
        当WeatherData对象状态改变的时候，布告板自动更新，正好符合观察者模式。

/**
 * 主题
 */
public interface Subject {
    /**
     * registerObserver和removeObserver方法，都需要一个观察者作为
     * 变量，改观察者是用来以注册和删除的
     * 
     */
	public void registerObserver(Observer o);
	public void removeObserver(Observer o);
	
	/**
	 * 当主题状态改变时，这个方法会被调用，以通知所有观察者
	 */
	public void notifyObservers();
}

/**
 *  观察者
 */
public interface Observer {
    /**
     * 
     * @param temp 天气温度
     * @param humidity 天气湿度
     * @param pressure 天气压力
     */
	public void update(float temp, float humidity, float pressure);
}

public interface DisplayElement {
	/**
	 * 当布告板需要显示的时候，调用此方法
	 */
	public void display();
}

WeatherData实现此主题接口

/**
 *  天气对象
 */
public class WeatherData implements Subject {
    /**
     * 观察者
     */
	private ArrayList observers;
	
	/**
     * 天气温度
     */
	private float temperature;
	
	/**
     * 天气湿度
     */
	private float humidity;
	
	/**
     * 天气压力
     */
	private float pressure;
	
	public WeatherData() {
		observers = new ArrayList();
	}
	
	public void registerObserver(Observer o) {
		observers.add(o);
	}
	
	public void removeObserver(Observer o) {
		int i = observers.indexOf(o);
		if (i >= 0) {
			observers.remove(i);
		}
	}
	
	public void notifyObservers() {
		for (int i = 0; i < observers.size(); i++) {
			Observer observer = (Observer)observers.get(i);
			observer.update(temperature, humidity, pressure);
		}
	}
	
	/**
	 * 当气象数据改变时，通知观察者
	 */
	public void measurementsChanged() {
		notifyObservers();
	}
	
	public void setMeasurements(float temperature, float humidity, float pressure) {
		this.temperature = temperature;
		this.humidity = humidity;
		this.pressure = pressure;
		measurementsChanged();
	}
	
	// other WeatherData methods here
	
	public float getTemperature() {
		return temperature;
	}
	
	public float getHumidity() {
		return humidity;
	}
	
	public float getPressure() {
		return pressure;
	}
}

/**
 *  当前天气状态布告板
 */
public class CurrentConditionsDisplay implements Observer, DisplayElement {
    /**
     * 天气温度
     */
    private float temperature;
	
    /**
     * 天气湿度
     */
    private float humidity;
    
	private Subject weatherData;
	
	public CurrentConditionsDisplay(Subject weatherData) {
		this.weatherData = weatherData;
		weatherData.registerObserver(this);
	}
	
	public void update(float temperature, float humidity, float pressure) {
		this.temperature = temperature;
		this.humidity = humidity;
		display();
	}
	
	public void display() {
		System.out.println("Current conditions: " + temperature 
			+ "F degrees and " + humidity + "% humidity");
	}
}

/**
 *  预测天气状态布告板
 */
public class ForecastDisplay implements Observer, DisplayElement {
    /**
     * 当前气压
     */
    private float currentPressure = 29.92f;  
	
    /**
     * 最新气压
     */
    private float lastPressure;
	private WeatherData weatherData;

	public ForecastDisplay(WeatherData weatherData) {
		this.weatherData = weatherData;
		weatherData.registerObserver(this);
	}

	public void update(float temp, float humidity, float pressure) {
                lastPressure = currentPressure;
		currentPressure = pressure;

		display();
	}

	public void display() {
		System.out.print("Forecast: ");
		if (currentPressure > lastPressure) {
			System.out.println("Improving weather on the way!");
		} else if (currentPressure == lastPressure) {
			System.out.println("More of the same");
		} else if (currentPressure < lastPressure) {
			System.out.println("Watch out for cooler, rainy weather");
		}
	}
}

/**
 *  测试
 */
public class WeatherStation {

	public static void main(String[] args) {
		WeatherData weatherData = new WeatherData();
	
		CurrentConditionsDisplay currentDisplay = 
			new CurrentConditionsDisplay(weatherData);
		ForecastDisplay forecastDisplay = new ForecastDisplay(weatherData);

		weatherData.setMeasurements(80, 65, 30.4f);
		weatherData.setMeasurements(82, 70, 29.2f);
		weatherData.setMeasurements(78, 90, 29.2f);
	}
}

        总结：其实观察者模式，就是让主题Subject更新观察者Observer数据，所以Observer需要有update方法，且必须将其引用交给主题Subject，这样两者就有个关联关系，Subject就可以更新Observer数据，即为通知了观察者，自动更新了数据，呵呵，以上内容纯属个人理解，如有雷同，纯属巧合。。。

评论

2 楼 jijun87120681 2011-12-30  

fvweieye 写道

楼主辛苦了，好人一生平安。完全同意楼主的观点。

 

1 楼 fvweieye 2011-12-30  

楼主辛苦了，好人一生平安。完全同意楼主的观点。