observer.jpg

前言

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 .

如需文章中所写代码，请移步GitHub查看