设计模式之观察者模式

    xiaoxiao2021-03-25  153

    前言

    Observer本来的意思是“观察者”,但是实际上Observer角色并非主动的去观察,而是被动的接收来自观察对象角色的通知,因此,Observer也被成为Publish-Subscribe(发布-订阅)模式。它定义了一种一对多的依赖关系,让多个观察者对象同时监听某一个主题对象。这个主题对象在状态上发生变化时,会通知所有观察者对象,使它们能够自动更新自己。对于观察者模式应用的也很多,例如大家最熟悉的MVC框架就是观察者模式的典型应用,消息推送,事件监听等都是观察者模式的最好诠释。

    在图解设计模式中是通过一个观察者观察一个会生成数值的对象,并将生成的数值通过不同的观察者显示出来。照例通过如下UML类图简单熟知下流程。

    观察者Observer

    Observer角色负责接收来自观察者对象角色的状态变化的通知,它表示“观察者”,具体的观察者会实现该接口,用于生成数字的观察对象角色类NumberGenerator类会调用update方法并且将生成的数字变化的通知发送给Observer。

    public interface Observer { public abstract void update(NumberGenerator generator); }

    观察对象NumberGenerator

    该类是用于生成数值的抽象类,提供了获取数值和生成数值的抽象方法,需要子类去实现。并且提供了一个存放观察数值变化的观察者对象的List。方法addObserver(Observer observer)和deleteObserver(Observer observer)用注册观察者和删除观察者,重要的一步就是当有数据变化时调用notifyObservers方法通知所有观察者。

    public abstract class NumberGenerator { private ArrayList observers=new ArrayList(); public void addObserver(Observer observer){ observers.add(observer); } public void deleteObserver(Observer observer){ observers.remove(observer); } public void notifyObservers(){ Iterator iterator=observers.iterator(); while (iterator.hasNext()){ Observer observer= (Observer) iterator.next(); observer.update(this); } } public abstract int getNumber(); public abstract void execute(); }

    具体的观察对象RandomNumberGenerator

    对于该具体观察者对象,它主要是用来生成随机数,并通过notifiObservers方法把每一次生成的结果通知给所有已注册的观察者

    public class RandomNumberGenerator extends NumberGenerator { private Random random = new Random(); private int number; @Override public int getNumber() { return number; } @Override public void execute() { for (int i = 0; i < 5; i++){ number=random.nextInt(30); notifyObservers(); } } }

    具体观察者

    具体观察者实现了观察者Observer接口,当update方法被调用时会去获取要观察的对象的最新数据,在此写了两个具体的观察者。

    public class DigitObserver implements Observer{ @Override public void update(NumberGenerator generator) { System.out.println("DigitObserver:"+generator.getNumber()); } } public class GraphObserver implements Observer{ @Override public void update(NumberGenerator generator) { System.out.println("GraphObserver:"+generator.getNumber()); } }

    测试类

    public class Main { public static void main(String[] args) { NumberGenerator generator=new RandomNumberGenerator(); Observer observer1=new DigitObserver(); Observer observer2=new GraphObserver(); generator.addObserver(observer1); generator.addObserver(observer2); generator.execute(); } }

    输出信息:

    DigitObserver:2 GraphObserver:2 DigitObserver:19 GraphObserver:19 DigitObserver:26 GraphObserver:26 DigitObserver:10 GraphObserver:10 DigitObserver:14 GraphObserver:14

    通过上面测试代码,你应该发现对于观察者对象可以有多个观察者对其作出响应,如某些订阅专栏,它可以被很多人订阅,当专栏有内容更新时,它会给每一个人发送推送,我们在订阅专栏后,并不需要我们一直去等待它的内容更新,而不能去做自己的事情。

    好了,今天的观察者模式到此结束。有问题欢迎留言指出,Have a wonderful day .

    转载请注明原文地址: https://ju.6miu.com/read-2645.html

    最新回复(0)