当前位置 : 主页 > 编程语言 > java >

Java设计模式:观察者模式(Observer Pattern)续

来源:互联网 收集:自由互联 发布时间:2022-09-02
本篇要说明的是Java内置的观察者模式; 涉及包: import java . util . Observable ; // 类 import java . util . Observer ; // 接口 还是使用以前的气象站例子来了解该模式: UML类图 与我们之前写的主题


本篇要说明的是Java内置的观察者模式;

涉及包:

import java.util.Observable; // 类
import java.util.Observer; // 接口


还是使用以前的气象站例子来了解该模式:

UML类图

Java设计模式:观察者模式(Observer Pattern)续_设计模式



与我们之前写的主题的不同点为:

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 interface DisplayElement {
public void display();
}

CurrentConditionsDisplay.java 显示1:当前布告板,显示实时温度,湿度


import java.util.Observable;
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.Observable;
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.Observable;
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 class Test {

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已经实现好的方法



上一篇:Ecplise 文档注释及生成
下一篇:没有了
网友评论