快捷導(dǎo)航

Spring中ApplicationListener的使用解析

更新時間：2023年12月25日 10:59:57 作者：云川之下

這篇文章主要介紹了Spring中ApplicationListener的使用解析,ApplicationContext事件機(jī)制是觀察者設(shè)計模式的實現(xiàn),通過ApplicationEvent類和ApplicationListener接口,需要的朋友可以參考下

背景

ApplicationContext事件機(jī)制是觀察者設(shè)計模式的實現(xiàn)，通過ApplicationEvent類和ApplicationListener接口，可以實現(xiàn)ApplicationContext事件處理；

如果容器中存在ApplicationListener的Bean，當(dāng)ApplicationContext調(diào)用publishEvent方法時，對應(yīng)的Bean會被觸發(fā)。

spring內(nèi)置事件

ContextRefreshedEvent ApplicationContext 被初始化或刷新時，該事件被觸發(fā)。這也可以在 ConfigurableApplicationContext接口中使用 refresh() 方法來發(fā)生。此處的初始化是指：所有的Bean被成功裝載，后處理Bean被檢測并激活，所有Singleton Bean 被預(yù)實例化，ApplicationContext容器已就緒可用
ContextStartedEvent 當(dāng)使用 ConfigurableApplicationContext （ApplicationContext子接口）接口中的 start() 方法啟動 ApplicationContext 時，該事件被發(fā)布。你可以調(diào)查你的數(shù)據(jù)庫，或者你可以在接受到這個事件后重啟任何停止的應(yīng)用程序。
ContextStoppedEvent 當(dāng)使用 ConfigurableApplicationContext 接口中的 stop() 停止 ApplicationContext 時，發(fā)布這個事件。你可以在接受到這個事件后做必要的清理的工作。
ContextClosedEvent 當(dāng)使用 ConfigurableApplicationContext 接口中的 close() 方法關(guān)閉 ApplicationContext 時，該事件被發(fā)布。一個已關(guān)閉的上下文到達(dá)生命周期末端；它不能被刷新或重啟。
RequestHandledEvent 這是一個 web-specific 事件，告訴所有 bean HTTP 請求已經(jīng)被服務(wù)。只能應(yīng)用于使用DispatcherServlet的Web應(yīng)用。在使用Spring作為前端的MVC控制器時，當(dāng)Spring處理用戶請求結(jié)束后，系統(tǒng)會自動觸發(fā)該事件。

同樣事件可以自定義、監(jiān)聽也可以自定義，完全根據(jù)自己的業(yè)務(wù)邏輯來處理。

ApplicationListener源碼

@FunctionalInterface
public interface ApplicationListener<E extends ApplicationEvent> extends EventListener {
    /**
     * Handle an application event.
     * @param event the event to respond to
     */
    void onApplicationEvent(E event);
}

ContextRefreshedEvent事件的監(jiān)聽

以Spring的內(nèi)置事件ContextRefreshedEvent為例，當(dāng)ApplicationContext被初始化或刷新時，會觸發(fā)ContextRefreshedEvent事件，下面我們就實現(xiàn)一個ApplicationListener來監(jiān)聽此事件的發(fā)生。

@Component
public class MyListener implements ApplicationListener<ContextRefreshedEvent> {
    @Override
    public void onApplicationEvent(ContextRefreshedEvent event) {
        System.out.println("容器中初始化Bean數(shù)量:" + event.getApplicationContext().getBeanDefinitionCount());
    }
}

啟動服務(wù)，可以看到

在這里插入圖片描述

至此，便完成了一個事件及監(jiān)聽類的實現(xiàn)和實例化。

自定義事件及監(jiān)聽，以發(fā)送郵件為例

自定義郵件通知事件類：EmailEvent

package com.lw.coodytest.event;
import org.springframework.context.ApplicationEvent;
/**
 * @Classname EmailEvent
 * @Description 郵件通知事件
 * @Author lw
 * @Date 2019-12-20 11:05
 */
public class EmailEvent extends ApplicationEvent {
    private String email;
    private String content;
    public EmailEvent(Object source){
        super(source);
    }
    public EmailEvent(Object source, String email, String content){
        super(source);
        this.email = email;
        this.content = content;
    }
    public String getEmail() {
        return email;
    }
    public void setEmail(String email) {
        this.email = email;
    }
    public String getContent() {
        return content;
    }
    public void setContent(String content) {
        this.content = content;
    }
}

自定義郵件通知監(jiān)聽類：EmailListener:

package com.lw.coodytest.event;
import org.springframework.context.ApplicationEvent;
/**
 * @Classname EmailEvent
 * @Description 郵件通知事件
 * @Author lw
 * @Date 2019-12-20 11:05
 */
public class EmailEvent extends ApplicationEvent {
    private String email;
    private String content;
    public EmailEvent(Object source){
        super(source);
    }
    public EmailEvent(Object source, String email, String content){
        super(source);
        this.email = email;
        this.content = content;
    }
    public String getEmail() {
        return email;
    }
    public void setEmail(String email) {
        this.email = email;
    }
    public String getContent() {
        return content;
    }
    public void setContent(String content) {
        this.content = content;
    }
}

注意：onApplicationEvent方法的入?yún)?，必須是自定義的那個類型

單元測試類：

package com.lw.coodytest.junit;
import com.lw.coodytest.event.EmailEvent;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
import org.springframework.web.context.WebApplicationContext;
/**
 * @Classname ListenerTest
 * @Description 監(jiān)聽測試類
 * @Author lw
 * @Date 2019-12-20 11:12
 */
@RunWith(SpringRunner.class)
@SpringBootTest
public class ListenerTest {
    @Autowired
    private WebApplicationContext webapplicationcontext;
    @Test
    public void testListener(){
        EmailEvent emailEvent = new EmailEvent("object", "172572575@qq.com", "###listener");
        webapplicationcontext.publishEvent(emailEvent);
    }
}

監(jiān)聽器通過@Component注解進(jìn)行實例化，并在onApplicationEvent中打印相關(guān)信息：執(zhí)行測試類，可以看到

在這里插入圖片描述