前言

我們現(xiàn)在很多時(shí)候開(kāi)發(fā)環(huán)境已經(jīng)在Spring的ApplicationContext容器中，已經(jīng)必須要自己再去使用jdk實(shí)現(xiàn)。

Spring認(rèn)為發(fā)布訂閱主題，其實(shí)可以理解為事件驅(qū)動(dòng)的編碼，先來(lái)實(shí)現(xiàn)以下Spring容器中的事件發(fā)布訂閱。

個(gè)人認(rèn)為事件驅(qū)動(dòng)的發(fā)布訂閱模型，也算是觀察者模式（不論是推還是拉的方式）。

spring事件驅(qū)動(dòng)（特別是SpringBoot擴(kuò)展后）可以很方便的進(jìn)行實(shí)現(xiàn)，那么肯定不會(huì)自己去使用Observer的模式。

1、Spring事件的發(fā)送方式

可以使用下面兩種方式，但其實(shí)都是一樣的，后面進(jìn)行分析：

• applicationContext.publishEvent(new UserEvent(user));
• applicationEventPublisher.publishEvent(new UserEvent(user));

@Service("eventUserService")
public class UserService implements ApplicationContextAware, 
    ApplicationEventPublisherAware {
 
    private ApplicationContext applicationContext;
    private ApplicationEventPublisher applicationEventPublisher;
 
    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        this.applicationContext = applicationContext;
    }
 
    @Override
    public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {
        this.applicationEventPublisher = applicationEventPublisher;
    }
 
    public String addUser(User user) {
        // 保存用戶
        user.setId(1L);
        user.setName("name-1");
        // 發(fā)生事件（發(fā)郵件、發(fā)短信、、、）
        applicationContext.publishEvent(new UserEvent(user));
        // 兩種發(fā)送方式一致
        applicationEventPublisher.publishEvent(new UserEvent(user));
        return "ok";
    }
 
}

2、Spring事件的接收方式

1）、繼承ApplicationListener 接口，實(shí)現(xiàn)onApplicationEvent方法

詳細(xì)見(jiàn)我寫(xiě)的Spring源碼分析：Spring源碼-事件監(jiān)聽(tīng)機(jī)制（實(shí)現(xiàn)EventListener接口）

總結(jié)

1、ApplicationContext發(fā)送事件是委托給了一個(gè)Spring容器在refresh時(shí)初始化的SimpleApplicationEventMulticaster

bean（由于沒(méi)有初始化內(nèi)部線程池對(duì)象，所以事件是同步發(fā)送的）。

2、發(fā)送前先獲取事件的ResolvableType類型（當(dāng)前為OrderEvent clazz）和事件源類型（當(dāng)前為String）

3、獲取監(jiān)聽(tīng)者列表。 先去自己Bean內(nèi)部先查詢緩存，否則從BeanFactory中獲取所有單利bean進(jìn)行匹配（再放入緩存ConturrentHashMap）。

4、監(jiān)聽(tīng)者列表循環(huán)（同步或異步）地調(diào)用我們自己寫(xiě)的監(jiān)聽(tīng)方法OnApplicationEvent。

相同和不同之處

相同：

1、ApplicationContext的refresh方法還是初始化了SimpleApplicationEventMulticaster

2、發(fā)送事件式還是先獲取ResolvableType類型，再獲取發(fā)送監(jiān)聽(tīng)列表

不同：

1、獲取監(jiān)聽(tīng)列表返回的已經(jīng)是處理過(guò)的列表。

2、添加了@EventListener注解的自定義名稱的方法，會(huì)在EventListenerMethodProcessor中的afterSingletonsInstantiated()方法中遍歷所有 ApplicationContext容器的單利bean。將所有添加了@EventListener的方法注入到ApplicationContext的applicationListeners和 初始化的SimpleApplicationEventMulticaster的defaultRetriever.applicationListeners中，在發(fā)送事件時(shí)候獲取監(jiān)聽(tīng)列表時(shí)用。

到此這篇關(guān)于Spring觀察者模式之事件發(fā)布訂閱實(shí)現(xiàn)和源碼詳解的文章就介紹到這了,更多相關(guān)Spring事件發(fā)布訂閱實(shí)現(xiàn)和源碼內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論