翔子 发表于 2014-10-2 21:52:34

java观察者模式

原文: http://blog.csdn.net/litoupu/article/details/8176447

Java 提供了 Observer 模式的默认实现,下面我们就看一下 Java 对 观察者模式的支持。
Java 对 观察者模式的支持 主要体现在 Observable 类和 Observer 接口。

(1) Observable 类代表 被观察者 (java.util.Observable)
      主要方法有:
      void setChanged(): 设置被观察者的状态已经被改变
      void addObserver(Observerobserver): 添加观察者
      int countObservers() : 返回所有观察者的数目
      void deleteObserver(Observerobserver):删除指定观察者
      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.
   实现过程:
<!--

Code highlighting produced by Actipro CodeHighlighter (freeware)
http://www.CodeHighlighter.com/

-->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();
      }
    }
}
<!--

Code highlighting produced by Actipro CodeHighlighter (freeware)
http://www.CodeHighlighter.com/

-->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();
    }
}
<!--

Code highlighting produced by Actipro CodeHighlighter (freeware)
http://www.CodeHighlighter.com/

-->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();
    }
}
<!--

Code highlighting produced by Actipro CodeHighlighter (freeware)
http://www.CodeHighlighter.com/

-->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());
    }
}
页: [1]
查看完整版本: java观察者模式