观察者(Observer)模式的定义:指多个对象间存在一对多的依赖关系,当一个对象的状态发生改变时,所有依赖于它的对象都得到通知并被自动更新。这种模式有时又称作发布-订阅模式、模型-视图模式,它是对象行为型模式。
实现观察者模式时要注意具体目标对象和具体观察者对象之间不能直接调用,否则将使两者之间紧密耦合起来,这违反了面向对象的设计原则。
观察者模式的主要角色如下。
结构图:
代码:
public class ObserverPattern { public static void main(String[] args) { Subject subject = new ConcreteSubject(); Observer obs1 = new ConcreteObserver1(); Observer obs2 = new ConcreteObserver2(); subject.add(obs1); subject.add(obs2); subject.notifyObserver(); } } //抽象目标 abstract class Subject { protected List<Observer> observers = new ArrayList<Observer>(); //增加观察者方法 public void add(Observer observer) { observers.add(observer); } //删除观察者方法 public void remove(Observer observer) { observers.remove(observer); } public abstract void notifyObserver(); //通知观察者方法 } //具体目标 class ConcreteSubject extends Subject { public void notifyObserver() { System.out.println("具体目标发生改变..."); System.out.println("--------------"); for (Object obs : observers) { ((Observer) obs).response(); } } } //抽象观察者 interface Observer { void response(); //反应 } //具体观察者1 class ConcreteObserver1 implements Observer { public void response() { System.out.println("具体观察者1作出反应!"); } } //具体观察者1 class ConcreteObserver2 implements Observer { public void response() { System.out.println("具体观察者2作出反应!"); } }
通过前面的分析与应用实例可知观察者模式适合以下几种情形。
在 Java 中,通过 java.util.Observable 类和 java.util.Observer 接口定义了观察者模式,只要实现它们的子类就可以编写观察者模式实例。
Observable 类是抽象目标类,它有一个 Vector 向量,用于保存所有要通知的观察者对象,下面来介绍它最重要的 3 个方法。
Observer 接口是抽象观察者,它监视目标对象的变化,当目标对象发生变化时,观察者得到通知,并调用 void update(Observable o,Object arg) 方法,进行相应的工作。
利用 Observable 类和 Observer 接口实现原油期货的观察者模式实例。
分析:当原油价格上涨时,空方伤心,多方局兴;当油价下跌时,空方局兴,多方伤心。本实例中的抽象目标(Observable)类在 Java
中已经定义,可以直接定义其子类,即原油期货(OilFutures)类,它是具体目标类,该类中定义一个 SetPriCe(float price)
方法,当原油数据发生变化时调用其父类的 notifyObservers(Object arg)
方法来通知所有观察者;另外,本实例中的抽象观察者接口(Observer)在 Java 中已经定义,只要定义其子类,即具体观察者类(包括多方类
Bull 和空方类 Bear),并实现 update(Observable o,Object arg) 方法即可
public class CrudeOilFutures { public static void main(String[] args) { OilFutures oil = new OilFutures(); Observer bull = new Bull(); //多方 Observer bear = new Bear(); //空方 oil.addObserver(bull); oil.addObserver(bear); oil.setPrice(10); oil.setPrice(-8); } } //具体目标类:原油期货 class OilFutures extends Observable { private float price; public float getPrice() { return this.price; } public void setPrice(float price) { super.setChanged(); //设置内部标志位,注明数据发生变化 super.notifyObservers(price); //通知观察者价格改变了 this.price = price; } } //具体观察者类:多方 class Bull implements Observer { public void update(Observable o, Object arg) { Float price = ((Float) arg).floatValue(); if (price > 0) { System.out.println("油价上涨" + price + "元,多方高兴了!"); } else { System.out.println("油价下跌" + (-price) + "元,多方伤心了!"); } } } //具体观察者类:空方 class Bear implements Observer { public void update(Observable o, Object arg) { Float price = ((Float) arg).floatValue(); if (price > 0) { System.out.println("油价上涨" + price + "元,空方伤心了!"); } else { System.out.println("油价下跌" + (-price) + "元,空方高兴了!"); } } }