Spring的事件監(jiān)聽(tīng)機(jī)制示例詳解

更新時(shí)間：2018年11月29日 11:19:09 作者：jy的blog

這篇文章主要給大家介紹了關(guān)于Spring的事件監(jiān)聽(tīng)機(jī)制的相關(guān)資料，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

前言

最近公司在重構(gòu)廣告系統(tǒng)，其中核心的打包功由廣告系統(tǒng)調(diào)用，即對(duì)apk打包的調(diào)用和打包完成之后的回調(diào)，需要提供相應(yīng)的接口給廣告系統(tǒng)。因此，為了將apk打包的核心流程和對(duì)接廣告系統(tǒng)的業(yè)務(wù)解耦，利用了spring的事件監(jiān)聽(tīng)特性來(lái)滿足需求。以下說(shuō)明spring的事件機(jī)制的相關(guān)內(nèi)容。

首先spring事件分為事件發(fā)布者(EventPublisher)、事件監(jiān)聽(tīng)者(EventListener),還包括一個(gè)事件廣播者(這個(gè)是spring實(shí)現(xiàn)相關(guān)，這一節(jié)不討論)。使用spring事件機(jī)制，需要自定義事件發(fā)布者和監(jiān)聽(tīng)者。

1.觀察者模式

Spring的事件監(jiān)聽(tīng)（也稱事件驅(qū)動(dòng)）是觀察者模式的一種實(shí)現(xiàn)，比較常見(jiàn)的有發(fā)布-訂閱模型。通常我們利用消息隊(duì)列來(lái)實(shí)現(xiàn)不同系統(tǒng)之間的解耦，如用戶注冊(cè)完成后，可以向消息隊(duì)列發(fā)布一條消息，然后訂閱了此topic的子系統(tǒng)（如郵件服務(wù)，積分服務(wù)）收到發(fā)布的消息之后，就會(huì)做相應(yīng)的處理。這樣做的好處是避免了在注冊(cè)服務(wù)里耦合其他服務(wù)的代碼，并且，執(zhí)行子系統(tǒng)的業(yè)務(wù)將會(huì)異步執(zhí)行，互不影響。下圖是一個(gè)經(jīng)典的觀察者模式的結(jié)構(gòu)。

以下為上述觀察者模式的java簡(jiǎn)單實(shí)現(xiàn)：

（1）Subject.java

package observerPattern;

import java.util.ArrayList;
import java.util.List;

/**
 * Created by jy on 2018/11/28.
 */
public abstract class Subject {

 //維護(hù)一個(gè)所有觀察者集合
 private List<Observer> list = new ArrayList<>();

 //新注冊(cè)一個(gè)觀察者
 public void attach(Observer observer){
 list.add(observer);
 System.out.println("新注冊(cè)一個(gè)觀察者");
 }

 //刪除一個(gè)已注冊(cè)的觀察者
 public void detach(Observer observer){
 list.remove(observer);
 System.out.println("刪除一個(gè)已注冊(cè)的觀察者");
 }


 //通知所有已經(jīng)注冊(cè)的觀察者
 public void notifyObservers(String state){
 for (int i = 0; i < list.size(); i++) {
 list.get(i).update(state);
 }
 }
}

(2)Observer.java

package observerPattern;

/**
 * Created by jy on 2018/11/28.
 */
public interface Observer {

 // 抽象出的更新行為
 public void update(String state);
}

(3)ConcreteSubject.java

package observerPattern;

/**
 * Created by jy on 2018/11/28.
 */
public class ConcreteSubject extends Subject{

 //真實(shí)主題內(nèi)維護(hù)一個(gè)狀態(tài)
 private String state;

 public String getState() {
 return state;
 }

 public void change(String state){
 this.state = state;
 System.out.println("真實(shí)主題狀態(tài)變化為:"+state);
 this.notifyObservers(state);
 }
}

(4)ConcreteObserver.java

package observerPattern;

/**
 * Created by jy on 2018/11/28.
 */
public class ConcreteObserver implements Observer {

 //具體觀察者的狀態(tài)
 private String observerState;

 @Override
 public void update(String state) {
 //這里可以根據(jù)傳遞過(guò)來(lái)的主題的狀態(tài)作出相應(yīng)的業(yè)務(wù)
 observerState = state;
 System.out.println("觀察者的狀態(tài)跟著變化為："+observerState);
 }
}

(5)Main.java

package observerPattern;

/**
 * Created by jy on 2018/11/28.
 */
public class Main {
 public static void main(String[] args) {
 //真實(shí)主題
 ConcreteSubject concreteSubject = new ConcreteSubject();
 //真實(shí)觀察者
 ConcreteObserver concreteObserver = new ConcreteObserver();
 //觀察者先注冊(cè)
 concreteSubject.attach(concreteObserver);

 //改變真實(shí)主題狀態(tài)
 concreteSubject.change("2");

 }
}

結(jié)果：在執(zhí)行了main方法之后，我們可以看到控制臺(tái)輸出結(jié)果，表明，真實(shí)觀察者的狀態(tài)是會(huì)根據(jù)真實(shí)主題的狀態(tài)變化而變化的：

2. Spring事件監(jiān)聽(tīng)

spring也對(duì)事件驅(qū)動(dòng)模型提供了支持，該模型主要由三部分組成：

（1）事件（ApplicationEvent）：繼承了jdk的EventObject，在spring項(xiàng)目中可以繼承ApplicationEvent，來(lái)自定義自己的事件。

spring容器內(nèi)部對(duì)ApplicationEvent有著下面幾個(gè)實(shí)現(xiàn)，通過(guò)名字可以很清楚事件所描述的行為。

（2）發(fā)布者（ApplicationEventPublisher）：實(shí)現(xiàn)這個(gè)接口，就可以使得spring組件有發(fā)布事件的能力。

可以看到，ApplicationContext實(shí)現(xiàn)了此接口，因此，可以spring組件可以通過(guò)實(shí)現(xiàn)ApplicationContextAware接口，注入ApplicationContext，然后，通過(guò)ApplicationContext的publishEvent()方法來(lái)實(shí)現(xiàn)事件傳播，

當(dāng)然，也可以直接實(shí)現(xiàn)ApplicationEventPublisher接口，重寫(xiě)publishEvent()方法，同樣可以實(shí)現(xiàn)事件傳播。

通過(guò)閱讀源碼發(fā)現(xiàn)，在AbstractApplicationContext類中，定義了針對(duì)觀察者的增加，get，注冊(cè)等方法。下面代碼中的addApplicationListener()是向ApplicationEventMulticaster類中維護(hù)的一個(gè)set中添加listener。這個(gè)set存儲(chǔ)了該發(fā)布者所有的觀察者（listener）。

@Override
 public void addApplicationListener(ApplicationListener<?> listener) {
 Assert.notNull(listener, "ApplicationListener must not be null");
 //listener傳入持有的一個(gè)的applicationEventMulticaster類中
 if (this.applicationEventMulticaster != null) {
 this.applicationEventMulticaster.addApplicationListener(listener);
 }
 this.applicationListeners.add(listener);
 }

//省略部分代碼

protected void registerListeners() {
 // Register statically specified listeners first.
 for (ApplicationListener<?> listener : getApplicationListeners()) {
 getApplicationEventMulticaster().addApplicationListener(listener);
 }

 // Do not initialize FactoryBeans here: We need to leave all regular beans
 // uninitialized to let post-processors apply to them!
 String[] listenerBeanNames = getBeanNamesForType(ApplicationListener.class, true, false);
 for (String listenerBeanName : listenerBeanNames) {
 getApplicationEventMulticaster().addApplicationListenerBean(listenerBeanName);
 }

 // Publish early application events now that we finally have a multicaster...
 Set<ApplicationEvent> earlyEventsToProcess = this.earlyApplicationEvents;
 this.earlyApplicationEvents = null;
 if (earlyEventsToProcess != null) {
 for (ApplicationEvent earlyEvent : earlyEventsToProcess) {
 getApplicationEventMulticaster().multicastEvent(earlyEvent);
 }
 }
 }

在AbstractApplicationContext中publishEvent：

protected void publishEvent(Object event, @Nullable ResolvableType eventType) {
 //.....
 // Multicast right now if possible - or lazily once the multicaster is initialized
 if (this.earlyApplicationEvents != null) {
 this.earlyApplicationEvents.add(applicationEvent);
 }
 else {
 getApplicationEventMulticaster().multicastEvent(applicationEvent, eventType); //事件廣播
 //....
 }

具體的發(fā)布事件的方法都在上面提到的ApplicationEventMulticaster這個(gè)類型的類中去實(shí)現(xiàn)的，在AbstractApplicationContext中，會(huì)先嘗試從ConfigurableListableBeanFactory中去加載這個(gè)類，如果不存在，則會(huì)默認(rèn)new 一個(gè)SimpleApplicationEventMulticaster：

protected void initApplicationEventMulticaster() {
 ConfigurableListableBeanFactory beanFactory = getBeanFactory();
 if (beanFactory.containsLocalBean(APPLICATION_EVENT_MULTICASTER_BEAN_NAME)) { //嘗試加載
 this.applicationEventMulticaster =
  beanFactory.getBean(APPLICATION_EVENT_MULTICASTER_BEAN_NAME, ApplicationEventMulticaster.class);
 if (logger.isTraceEnabled()) {
 logger.trace("Using ApplicationEventMulticaster [" + this.applicationEventMulticaster + "]");
 }
 }
 else {
 this.applicationEventMulticaster = new SimpleApplicationEventMulticaster(beanFactory); //不存在則默認(rèn)使用SimpleApplicationEventMulticaster
 beanFactory.registerSingleton(APPLICATION_EVENT_MULTICASTER_BEAN_NAME, this.applicationEventMulticaster);

看看SimpleApplicationEventMulticaster 是怎么廣播事件的，由代碼可知，在線程池不為空的情況下，異步發(fā)布特定類型的事件。

@Override
 public void multicastEvent(final ApplicationEvent event, @Nullable ResolvableType eventType) {
 ResolvableType type = (eventType != null ? eventType : resolveDefaultEventType(event));
 for (final ApplicationListener<?> listener : getApplicationListeners(event, type)) {
 Executor executor = getTaskExecutor();
 if (executor != null) {
 executor.execute(() -> invokeListener(listener, event));
 }
 else {
 invokeListener(listener, event);
 }
 }
 //....

將invokeListener方法點(diǎn)擊到最后，發(fā)現(xiàn)調(diào)用了listener的onApplicationEvent(),實(shí)現(xiàn)了事件的發(fā)布。

private void doInvokeListener(ApplicationListener listener, ApplicationEvent event) {
 try {
 listener.onApplicationEvent(event);
 }
 catch (ClassCastException ex) {
 //....
 }
 }

（3）事件訂閱者（ApplicationListener）：實(shí)現(xiàn)這個(gè)接口，就可以監(jiān)聽(tīng)ApplicationListener發(fā)布的特定的事件。