波哥带你探寻SpringBoot中优雅设计监听器的本质-CFANZ编程社区

波哥带你探寻SpringBoot中优雅设计监听器的本质_监听器

SpringBoot源码之监听器设计

1.观察者模式

监听器的设计会使用到Java设计模式中的观察者模式，所以在搞清楚SpringBoot中的监听器的设计之前我们还是非常有必要把观察者模式先弄清楚。

观察者模式又称为发布/订阅(Publish/Subscribe)模式,在对象之间定义了一对多的依赖，这样一来，当一个对象改变状态，依赖它的对象会收到通知并自动更新.

在java.util包中包含有基本的Observer接口和Observable抽象类.功能上和Subject接口和Observer接口类似.不过在使用上,就方便多了,因为许多功能比如说注册,删除,通知观察者的那些功能已经内置好了.

1.1 定义具体被观察者

package com.dpb.observer2;

import java.util.Observable;

/**
 * 目标对象
 * 继承 Observable
 * @author dengp
 *
 */
public class ConcreteSubject extends Observable {

  private int state; 

  public void set(int s){
    state = s;  //目标对象的状态发生了改变
    setChanged();  //表示目标对象已经做了更改
    notifyObservers(state);  //通知所有的观察者
  }

  public int getState() {
    return state;
  }

  public void setState(int state) {
    this.state = state;
  }
}

观察者只需要继承Observable父类。发送消息的方式执行如下两行代码即可

setChanged();  //表示目标对象已经做了更改
notifyObservers(state);  //通知所有的观察者

Observable源码对应的是：
波哥带你探寻SpringBoot中优雅设计监听器的本质_加载_02
波哥带你探寻SpringBoot中优雅设计监听器的本质_监听器_03

1.2 定义具体观察者

package com.dpb.observer2;

import java.util.Observable;
import java.util.Observer;
/**
 * 观察者模式：观察者(消息订阅者)
 * 实现Observer接口
 * @author dengp
 *
 */
public class ObserverA implements Observer {

  private int myState;

  @Override
  public void update(Observable o, Object arg) {
    myState = ((ConcreteSubject)o).getState();
  }
  public int getMyState() {
    return myState;
  }
  public void setMyState(int myState) {
    this.myState = myState;
  }
}

观察者也就是订阅者只需要实现Observer接口并重写相关update方法即可，在目标实现中我们发现触发的时候执行的就是观察者的update方法。

1.3 测试

package com.dpb.observer2;

public class Client {
  public static void main(String[] args) {
    //创建目标对象Obserable
    ConcreteSubject subject = new ConcreteSubject();

    //创建观察者
    ObserverA obs1 = new ObserverA();
    ObserverA obs2 = new ObserverA();
    ObserverA obs3 = new ObserverA();

    //将上面三个观察者对象添加到目标对象subject的观察者容器中
    subject.addObserver(obs1);
    subject.addObserver(obs2);
    subject.addObserver(obs3);

    //改变subject对象的状态
    subject.set(3000);
    System.out.println("===============状态修改了！");
    //观察者的状态发生了变化
    System.out.println(obs1.getMyState());
    System.out.println(obs2.getMyState());
    System.out.println(obs3.getMyState());

    subject.set(600);
    System.out.println("===============状态修改了！");
    //观察者的状态发生了变化
    System.out.println(obs1.getMyState());
    System.out.println(obs2.getMyState());
    System.out.println(obs3.getMyState());

    //移除一个订阅者
    subject.deleteObserver(obs2);
    subject.set(100);
    System.out.println("===============状态修改了！");
    //观察者的状态发生了变化
    System.out.println(obs1.getMyState());
    System.out.println(obs2.getMyState());
    System.out.println(obs3.getMyState());
  }
}

波哥带你探寻SpringBoot中优雅设计监听器的本质_spring_04
这样就实现了官方提供观察者模式.

2.SpringBoot中监听器的设计

然后我们来看下SpringBoot启动这涉及到的监听器这块是如何实现的。

2.1 初始化操作

通过前面的介绍我们知道在SpringApplication的构造方法中会加载所有声明在spring.factories中的监听器。

波哥带你探寻SpringBoot中优雅设计监听器的本质_spring_05

通过Debug模式我们可以看到加载的监听器有哪些。

波哥带你探寻SpringBoot中优雅设计监听器的本质_监听器_06

其实就是加载的spring.factories文件中的key为ApplicationListener的value

波哥带你探寻SpringBoot中优雅设计监听器的本质_spring_07

波哥带你探寻SpringBoot中优雅设计监听器的本质_监听器_08

通过对这些内置监听器的源码查看我们发现这些监听器都实现了 ApplicationEvent接口。也就是都会监听 ApplicationEvent发布的相关的事件。ApplicationContext事件机制是观察者设计模式的实现，通过ApplicationEvent类和ApplicationListener接口，可以实现ApplicationContext事件处理。

波哥带你探寻SpringBoot中优雅设计监听器的本质_加载_09