?通俗的說(shuō)：我們向報(bào)社訂閱報(bào)紙，這個(gè)就是觀察者模式的實(shí)例，我們是觀察者(Observer)，報(bào)社就是主題(Subject)。

?

觀察者模式定義了對(duì)象之間的一對(duì)多依賴，這樣一來(lái)，當(dāng)一個(gè)對(duì)象改變狀態(tài)時(shí)，它的所有依賴者都會(huì)收到通知并自動(dòng)更新。

?

?現(xiàn)在我們?cè)O(shè)計(jì)一個(gè)氣象監(jiān)測(cè)站系統(tǒng)，此系統(tǒng)中的三個(gè)部分分別是氣象站(獲取實(shí)際氣象數(shù)據(jù))、布告板(顯示當(dāng)前的天氣狀況)

?

、WeatherData(跟蹤來(lái)自氣象站的數(shù)據(jù)，并更新布告板)，布告板可以提供擴(kuò)展。

?

系統(tǒng)設(shè)計(jì)類圖如下：

?

?

    /**
 * 主題
 * @author wengn
 *
 */
public interface Subject {
	public void registerObserver(Observer o);
	
	public void removeObserver(Observer o);
	
	public void notifyObserver();
}

/**
 * 觀察者
 * @author wengn
 *
 */
public interface Observer {
	public void update(float temp,float humidity,float pressure);
}

/**
 * 布告板接口
 * @author wengn
 *
 */
public interface DisplayElement {
	public void display();
}

/**
 * 主題實(shí)現(xiàn)類
 * @author Administrator
 *
 */
public class WeatherData implements Subject {
	private ArrayList observers;
	private float temperature;
	private float humidity;
	private float pressure;

	public WeatherData(){
		observers = new ArrayList();
	}
	
	public void notifyObserver() {
		for(int i=0;i<observers.size();i++){
			Observer o = (Observer)observers.get(i);
			o.update(temperature, humidity, pressure);
		}
	}

	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 measurementsChanged(){
		this.notifyObserver();
	}
	
	public void setMeasurements(float temperature,float humidity,float pressure){
		this.temperature = temperature;
		this.humidity = humidity;
		this.pressure = pressure;
		measurementsChanged();
	}
}

/**
 * 布告板實(shí)現(xiàn)類
 * @author wengn
 *
 */
public class CurrentConditionsDisplay implements Observer, DisplayElement {
	private float temperature;
	private float humidity;
	private Subject weatherData;
	
	public CurrentConditionsDisplay(Subject s){
		this.weatherData = s;
		weatherData.registerObserver(this);
	}

	public void update(float temp, float humidity, float pressure) {
		this.temperature = temp;
		this.humidity = humidity;
		display();
	}

	public void display() {
		System.out.println("show:"+temperature+"||"+humidity);
	}
}

/**
 * 測(cè)試類
 * @author wengn
 *
 */
public class Test {

	public static void main(String[] args) {
		WeatherData wd = new WeatherData();
		CurrentConditionsDisplay ccd = new CurrentConditionsDisplay(wd);
		wd.setMeasurements(0, 0, 0);
		wd.setMeasurements(1, 1, 1);
		wd.setMeasurements(2, 2, 2);
	}
}

  

?

? 附上java awt中觀察者模式的模擬代碼：

?

?

    package com.hanbing.awt;

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

public class MyAwt {
	public static void main(String[] args) {
		Button bt = new Button();
		MyActionLisenter lisenter = new MyActionLisenter();
		MyActionLisenter2 lisenter2 = new MyActionLisenter2();
		bt.addActionLisenter(lisenter);
		bt.addActionLisenter(lisenter2);
		bt.buttonPressed();
	}
}


class Button {
	private List<ActionLisenter> list = new ArrayList<ActionLisenter>();

	public void buttonPressed() {
		ActionEvent e = new ActionEvent(System.currentTimeMillis(), this);
		for (ActionLisenter lisenter:list) {
			lisenter.actionPerformed(e);
		}
	}

	public void addActionLisenter(ActionLisenter lisenter) {
		list.add(lisenter);
	}
}


interface ActionLisenter {
	public void actionPerformed(ActionEvent e);
}


class MyActionLisenter implements ActionLisenter {
	public void actionPerformed(ActionEvent e) {
		System.out.println("oh my god!!!");
	}
}


class MyActionLisenter2 implements ActionLisenter {
	public void actionPerformed(ActionEvent e) {
		System.out.println("oh my god2!!!");
	}
}


class ActionEvent {
	private long when;

	private Object source;

	public ActionEvent(long when, Object source) {
		super();
		this.when = when;
		this.source = source;
	}

	public long getWhen() {
		return when;
	}
	
	public Object getSource(){
		return source;
	}
}
  

?

設(shè)計(jì)模式之二觀察者模式