观察者(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作出反应!"); } }
测试结果为:
具体目标发生改变... -------------- 具体观察者1作出反应! 具体观察者2作出反应!
接下来再看一个关于上下课打铃,老师同学上下课的示例:
public class BellEventTest { public static void main(String[] args) { BellEventSource bell=new BellEventSource(); //铃(事件源) bell.addPersonListener(new TeachEventListener()); //注册监听器(老师) bell.addPersonListener(new StuEventListener()); //注册监听器(学生) bell.ring(true); //打上课铃声 System.out.println("------------"); bell.ring(false); //打下课铃声 } } //铃声事件类:用于封装事件源及一些与事件相关的参数 // EventObject: The root class from which all event state objects shall be derived. class RingEvent extends EventObject { private static final long serialVersionUID=1L; private boolean sound; //true表示上课铃声,false表示下课铃声 public RingEvent(Object source,boolean sound) { super(source); this.sound=sound; } public void setSound(boolean sound) { this.sound=sound; } public boolean getSound() { return this.sound; } } //目标类:事件源,铃 class BellEventSource { private List<BellEventListener> listener; //监听器容器 public BellEventSource() { listener=new ArrayList<BellEventListener>(); } //给事件源绑定监听器 public void addPersonListener(BellEventListener ren) { listener.add(ren); } //事件触发器:敲钟,当铃声sound的值发生变化时,触发事件。 public void ring(boolean sound) { String type=sound?"上课铃":"下课铃"; System.out.println(type+"响!"); RingEvent event=new RingEvent(this, sound); notifies(event); //通知注册在该事件源上的所有监听器 } //当事件发生时,通知绑定在该事件源上的所有监听器做出反应(调用事件处理方法) protected void notifies(RingEvent e) { BellEventListener ren=null; Iterator<BellEventListener> iterator=listener.iterator(); while(iterator.hasNext()) { ren=iterator.next(); ren.heardBell(e); } } } //抽象观察者类:铃声事件监听器 EventListener:A tagging interface that all event listener interfaces must extend. interface BellEventListener extends EventListener { //事件处理方法,听到铃声 public void heardBell(RingEvent e); } //具体观察者类:老师事件监听器 class TeachEventListener implements BellEventListener { public void heardBell(RingEvent e) { if(e.getSound()) { System.out.println("老师上课了..."); } else { System.out.println("老师下课了..."); } } } //具体观察者类:学生事件监听器 class StuEventListener implements BellEventListener { public void heardBell(RingEvent e) { if(e.getSound()) { System.out.println("同学们,上课了..."); } else { System.out.println("同学们,下课了..."); } } }
测试结果为:
上课铃响! 老师上课了... 同学们,上课了... ------------ 下课铃响! 老师下课了... 同学们,下课了...
通过前面的分析与应用实例可知观察者模式适合以下几种情形。
在 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)+"元,空方高兴了!"); } } }
测试结果如下:
油价上涨10.0元,空方伤心了!
油价上涨10.0元,多方高兴了!
油价下跌8.0元,空方高兴了!
油价下跌8.0元,多方伤心了!
原文:https://www.cnblogs.com/jing99/p/12610078.html