關於觀察者模式總結

觀察者模式(發佈訂閱模式):在對象之間定義一對多的依賴,這樣一來,當一個對象改變狀態,依賴他的對象都會收到通知,並自動更新。java

使用場景:當一個對象狀態改變同時須要改變其餘對象,且不知道多少觀察者受影響。ide

觀察者模式包含如下幾個主要部分:this

  1. 抽象主題接口:該主題接口主要包含的功能有註冊/刪除觀察者、通知全部觀察者。
  2. 具體主題類:實現抽象的主題接口,將全部屬於它的觀察者保存在一個集合中,每一個主題能夠擁有任意數量的觀察者,當具體主題類內部狀態發生改變時,將通知全部登記過的觀察者。
  3. 抽象觀察者接口:爲全部觀察者定義一個通用的接口,當收到主題的通知時將更新本身。
  4. 具體觀察者類:存儲與主題狀態自恰的狀態,實現抽象觀察者接口所需的更新接口,以便自身與主題類的狀態相協調,同時能夠定義一個關於主題接口,指向本身訂閱具體主題對象的引用,方便本身註銷該主題。

觀察者模式中,爲分爲拉模型和推模型。code

  • 推模型:主題對象向觀察者推送主題的信息,無論觀察者是否須要,推送的信息包含:部分或所有信息
public interface DisplayElement {
	public void display();
}
public interface Subject {
	public void registerObserver(Observer o);
	public void removeObserver(Observer o);
	public void notifyObservers();
}
public interface Observer {
	public void update(float temperate,float humidity,float pressure);
}
public class WeatherData implements Subject {
	private ArrayList<Observer> observers;
	private float temperate;
	private float humidity;
	private float pressure;
	public WeatherData(){
		observers = new ArrayList<Observer>();
	}
	@Override
	public void registerObserver(Observer o) {
		// TODO Auto-generated method stub
		observers.add(o);
	}

	@Override
	public void removeObserver(Observer o) {
		// TODO Auto-generated method stub
		int i = observers.indexOf(o);
		if(i >= 0)
		{
			observers.remove(i);
		}
	}

	@Override
	public void notifyObservers() {
		// TODO Auto-generated method stub
		for (int i = 0; i < observers.size(); i++) {
			Observer observer =observers.get(i);
			observer.update(temperate, humidity, pressure);
		}
	}
	
	public void measurementsChanged(){
		notifyObservers();
	}
	
	public void setMeasurements(float temperate,float  humidity,float  pressure){
		this.temperate = temperate;
		this.humidity = humidity;
		this.pressure = pressure;
		measurementsChanged();
	}
}
public class CurrentConditionDisplay2 implements Observer,DisplayElement{
	private float temperate;
	private float humidity;
	private Observable observable;
	
	public CurrentConditionDisplay2(Observable weatherData) {
		this.observable = weatherData;
		this.observable.addObserver(this);
	}

	@Override
	public void display() {
		// TODO Auto-generated method stub
		System.out.println("Current conditions:"+temperate
				+" F degrees and "+humidity+" % humidity");
	}

	@Override
	public void update(Observable o, Object arg) {
		// TODO Auto-generated method stub
		 if (o instanceof WeatherData2) {
			 WeatherData2 weatherData2 = (WeatherData2) o;
			 this.humidity = weatherData2.getHumidity();
			 this.temperate = weatherData2.getTemperate();
			 display();
		}
	}



}
  • 拉模型:主題對象在通知觀察者時,只傳遞少許信息。由觀察者主動獲取信息,把主題對象經過update()傳遞給觀察者,觀察者根據本身的需求,經過該引用獲取數據。
public class WeatherData2 extends Observable {
	
	private float temperate;
	private float humidity;
	private float pressure;
	public WeatherData2(){
		
	}

	public void measurementsChanged(){
		setChanged();
		notifyObservers();
	}
	
	public void setMeasurements(float temperate,float  humidity,float  pressure){
		this.temperate = temperate;
		this.humidity = humidity;
		this.pressure = pressure;
		measurementsChanged();
	}
	public float getTemperate() {
		return temperate;
	}
	public void setTemperate(float temperate) {
		this.temperate = temperate;
	}
	public float getHumidity() {
		return humidity;
	}
	public void setHumidity(float humidity) {
		this.humidity = humidity;
	}
	public float getPressure() {
		return pressure;
	}
	public void setPressure(float pressure) {
		this.pressure = pressure;
	}
	
}
public class CurrentConditionDisplay2 implements Observer,DisplayElement{
	private float temperate;
	private float humidity;
	private Observable observable;
	
	public CurrentConditionDisplay2(Observable weatherData) {
		this.observable = weatherData;
		this.observable.addObserver(this);
	}

	@Override
	public void display() {
		// TODO Auto-generated method stub
		System.out.println("Current conditions:"+temperate
				+" F degrees and "+humidity+" % humidity");
	}

	@Override
	public void update(Observable o, Object arg) {
		// TODO Auto-generated method stub
		 if (o instanceof WeatherData2) {
			 WeatherData2 weatherData2 = (WeatherData2) o;
			 this.humidity = weatherData2.getHumidity();
			 this.temperate = weatherData2.getTemperate();
			 display();
		}
	}



}

        以上兩個例子中,推模式是用自定義接口,拉模式使用java內置觀察者模式,拉/推模式均可以用自定義接口或java內置實現的。server

相關文章
相關標籤/搜索