Java 提供了 Observer 模式的默认实现,下面我们就看一下 Java 对 观察者模式的支持。
Java 对 观察者模式的支持 主要体现在 Observable
类和 Observer
接口。
(1) Observable
类代表 被观察者 (java.util.Observable
)
主要方法有:
void setChanged()
: 设置被观察者的状态已经被改变
void addObserver(Observer observer)
: 添加观察者
int countObservers()
: 返回所有观察者的数目
void deleteObserver(Observer observer)
:删除指定观察者
void deleteObservers()
: 删除所有观察者
boolean hasChanged()
: 被观察者的状态是否被改变,如果是则返回true,否则返回false
void notifyObservers()
: 通知所有观察者(没有参数)
void notifyObservers(Object arg)
: 通知所有观察者(带参数,参数一般设定为被改变的属性)
void clearChanged()
:清除被观察者状态的改变(即调用 hasChanged() 时会返回 false)
(2) Observer
接口代表 观察者 (java.util.Observer
)
它只有一个抽象方法需要被具体的观察者类实现(很重要
):
void update(Observable observable, Object arg)
:当 被观察者 调用
notifyObservers(*)
方法
时,会根据被观察者的
hasChanged()
方法 来判断 它的状态是否被改变, 如果被观察者的状态被改变了,则
会调用 观察者 的
update
方法,参数
observable
为 被观察者对象,
arg
为调用
notifyObservers(
Object arg
)
时传入的参数
arg
,如果调用的是
notifyObservers()
方法,
则
arg
为 null(
注意
:应该把这个参数
arg
设定为 被观察者的 被改变的属性)。
实例
该实例模拟了烧水的过程,涉及三个对象,Heater(热水器),Display(显示器),Alarm(报警器).
模拟过程:为了便于运行,水的初始化温度为90,沸点为95,显示器依据热水器显示温度,显示器显示温度为95时,报警器开始报警。明显可以看出
Heater是subject ,Display 是它的
Obsrver,同时Display亦是suject,因为它要被报警器观察,所以Alarm是Display的Observer.
实现过程:
import java.util.Observable;
public class Heater extends Observable {
private int temperature;
public int getTemperature() {
return temperature;
}
public void setTemperature(int temperature) {
this.temperature = temperature;
}
public void boilWater() {
for (int i = 90; i < 100; i++) {
temperature = i;
this.setChanged();
this.notifyObservers();
}
}
}
public class testObserver {
public static void main(String[] args) {
Heater header = new Heater();
Display display = new Display();
Alarm alarm = new Alarm();
header.addObserver(display);
display.addObserver(alarm);
header.boilWater();
}
}
import java.util.Observable;
import java.util.Observer;
public class Alarm implements Observer {
public void makeAlarm() {
System.out.println("嘀嘀嘀水已经烧开 ");
}
public void update(Observable o, Object arg) {
makeAlarm();
}
}
import java.util.Observable;
import java.util.Observer;
public class Display extends Observable implements Observer {
private String status = "未开";
public void setStatus(String status) {
this.status = status;
}
public void displayTemputer(int temperature) {
if (temperature > 95) {
this.setStatus("沸腾");
this.setChanged();
this.notifyObservers();
}
System.out.println("状态:" + status + " 现在温度:" + temperature + "");
}
public void update(Observable o, Object arg) {
displayTemputer(((Heater) o).getTemperature());
}
}