本篇要说明的是Java内置的观察者模式;
涉及包:
import java.util.Observable; // 类import java.util.Observer; // 接口
还是使用以前的气象站例子来了解该模式:
UML类图
与我们之前写的主题的不同点为:
1)其中 Observable类 与 Observer接口 是Java已经帮我们写好的。
我们不需要再写 类似 registerObserver(), removeObserver(), notifyObservers()之类的方法了,
因为Observable类 已经提供了 addObserver(), deleteObserver(), nofifyObservers() 的方法。
2)主题如何通知
1-先调用setChanged(),标记状态已经改变的事实
2-然后调用两种nofityObserver()方法中的一个:
notifyObservers()
或
nofifyObservers(Object arg);//此方法可发送任何数据给每一个观察者。
3)订阅用户如何被通知
update(Observable o, Object arg);
参数1:主题本身当作第一个参数,好让观察者知道是哪个主题通知它的。
参数2:这个是nofityObservers(Object arg)传入的数据对象,没有则为空。
4)setChanged() 方法
该方法用以标记状态已经改变的事实,好让notifyObservers() 知道当它被调用时应用更新观察者。
如果调用notifyObservers()之前没有调用 setChanged(), 观察者就不会被通知。
原因(以下为伪代码):
setChanged(){changed = true;
}
nofityObservers(Object arg){
if (changed){
// 遍历通知所有观察者
}
changed = false;
}
notifyObservers(){
notifyObsrevers(null)
}
好处:可以自己决定什么条件通知观察者,而不是每次有变化时都通知。
clearChanged() 将 changed 置为 false;
hasChanged() 获取changed 当前状态;
代码:
WeatherData.java 主题实例类,继承于 Observable
import java.util.Observable;/***
* 现在不用再写 类似Subject主题之类的被观察类了
* 只要继承 Java内置的 Observable类即可,它相当于我们之前写的Subject
* 注意要 import util.Observable
* @author LiuJing
*
*/
public class WeatherData extends Observable {
private float temperature;
private float humidity;
private float pressure;
// 注意: 这里少 了原来的一个观察者的对象列表
public WeatherData(){
//注意:这里不维护需要自己记住的订阅者的列表了
}
public void measurementsChanged(){
setChanged();//在调用notifyObservers()之前,要先调用setChanged()表示状态已经改变
notifyObservers();
}
public void setMeasurements(float temperature, float humidity, float pressure)
{
this.temperature = temperature;
this.humidity = humidity;
this.pressure = pressure;
measurementsChanged();
}
public float getTemperature() {
return temperature;
}
public float getHumidity() {
return humidity;
}
public float getPressure() {
return pressure;
}
}
DisplayElement.java 显示接口,用以强制要求写 display()
public void display();
}
CurrentConditionsDisplay.java 显示1:当前布告板,显示实时温度,湿度
import java.util.Observer;
// 继承Java内置的Observer
public class CurrentConditionsDisplay implements Observer, DisplayElement {
private float temperature;
private float humidity;
Observable observable;// 相当于之前的 Subject
// 当前布告板 构造之时 订阅 了 主题
public CurrentConditionsDisplay(Observable observable) {
this.observable = observable;
this.observable.addObserver(this); // 订阅主题
}
public void display() {
// TODO Auto-generated method stub
System.out.println("1,当前布告板: 温度" + temperature + "度,湿度" + humidity + "%");
}
public void update(Observable obs, Object arg) {
// TODO Auto-generated method stub
if (obs instanceof WeatherData) {
WeatherData weatherData = (WeatherData)obs;
this.temperature = weatherData.getTemperature();
this.humidity = weatherData.getHumidity();
display();
}
}
}
StatisticsDisplay.java 显示2:数据统计,显示平均 最高 最低 气温
import java.util.Observer;
public class StatisticsDisplay implements Observer, DisplayElement {
private float maxTemp = 0.0f; // 最高温度
private float minTemp = 0.0f; // 最低温度
private float tempSum = 0.0f; // 温度更新和
private int numReadings; // 温度更新次数
Observable observerable; // 相当于 Subject
// 同 显示1
public StatisticsDisplay(Observable observable) {
this.observerable = observable;
this.observerable.addObserver(this);
}
// 显示
public void display() {
// TODO Auto-generated method stub
System.out.println("2,平均温度:" + (tempSum / numReadings) + ",最大温度:"
+ maxTemp + ",最小温度:" + minTemp);
}
public void update(Observable obs, Object arg) {
// TODO Auto-generated method stub
if (obs instanceof Observable) {
WeatherData weatherData = (WeatherData) obs;
float temp = weatherData.getTemperature();
tempSum += temp;
numReadings++;
// 设置最高温度
if (temp > maxTemp) {
maxTemp = temp;
}
// 设置最低温度
if (temp < minTemp) {
minTemp = temp;
}
display();
}
}
}
ForecastDisplay.java 显示3:天气预报,根据气压判断
import java.util.Observer;
public class ForecastDisplay implements Observer, DisplayElement {
private float currentPressure = 28.82f; // 当前气压
private float lastPressure; // 上一次的气压
Observable observable;
// 同显示1
public ForecastDisplay(Observable observable) {
this.observable = observable;
this.observable.addObserver(this);
}
// 显示
public void display() {
// TODO Auto-generated method stub
if (currentPressure > lastPressure) {
System.out.println("3,天气预报:温度正在持续上升!");
} else {
System.out.println("3,天气预报:注意气温下降了,可能有雨!");
}
}
// 更新
public void update(Observable obs, Object arg) {
// TODO Auto-generated method stub
if (obs instanceof WeatherData) {
WeatherData weatherData = (WeatherData) obs;
lastPressure = currentPressure;
currentPressure = weatherData.getPressure();
display();
}
}
}
Test.java 测试类
public static void main(String[] args) {
// TODO Auto-generated method stub
WeatherData weatherData = new WeatherData();
CurrentConditionsDisplay currentDisplay = new CurrentConditionsDisplay(weatherData);
StatisticsDisplay statisticsDisplay = new StatisticsDisplay(weatherData);
ForecastDisplay forecastDisplay = new ForecastDisplay(weatherData);
weatherData.setMeasurements(20, 65, 30.4f);
weatherData.setMeasurements(30, 70, 29.2f);
weatherData.setMeasurements(25, 90, 29.2f);
}
}
输出结果:
3,天气预报:温度正在持续上升!2,平均温度:20.0,最大温度:20.0,最小温度:0.0
1,当前布告板: 温度20.0度,湿度65.0%
3,天气预报:注意气温下降了,可能有雨!
2,平均温度:25.0,最大温度:30.0,最小温度:0.0
1,当前布告板: 温度30.0度,湿度70.0%
3,天气预报:注意气温下降了,可能有雨!
2,平均温度:25.0,最大温度:30.0,最小温度:0.0
1,当前布告板: 温度25.0度,湿度90.0%
结果差异:
1,与这之前的主题实现方法1》2》3不同,现在的输出结果顺序为 3》2》1
说明 我们不要依赖观察者被通知的次序
2,Observable是一个类
1-导致我们必须设计一个类来继承它,如果某类想同时具有Observable和另一个超类,将无法实现,Java不支持多重继承。
2-无法更改Observable已经实现好的方法