快捷導(dǎo)航

Spring的事件機(jī)制知識(shí)點(diǎn)詳解及實(shí)例分析

更新時(shí)間：2021年12月19日 10:21:09 作者：javaroad

在本篇內(nèi)容里小編給大家分享的是一篇關(guān)于Spring的事件機(jī)制知識(shí)點(diǎn)詳解及實(shí)例分析，有需要的朋友么可以參考下。

同步事件和異步事件

同步事件: 在一個(gè)線程里,按順序執(zhí)行業(yè)務(wù),做完一件事再去做下一件事。
異步事件: 在一個(gè)線程里,做一個(gè)事的同事,可以另起一個(gè)新的線程執(zhí)行另一件事,這樣兩件事可以同時(shí)執(zhí)行。

用一個(gè)例子來(lái)解釋同步事件和異步事件的使用場(chǎng)景,有時(shí)候一段完整的代碼邏輯,可能分為幾部分,拿最常見(jiàn)的注冊(cè)來(lái)說(shuō),假設(shè)完整流程是,1.點(diǎn)擊注冊(cè)->2.檢驗(yàn)信息并存庫(kù)->3.發(fā)送郵件通知->4.返回給用戶.代碼這么寫(xiě)是正確,但不是最好的,缺點(diǎn)如下:

邏輯復(fù)雜,業(yè)務(wù)耦合，我們把校驗(yàn)數(shù)據(jù)并存庫(kù)和發(fā)送郵件寫(xiě)到一個(gè)大的業(yè)務(wù)方法里了，發(fā)送郵件我們可以看做一個(gè)相對(duì)獨(dú)立的業(yè)務(wù)方法。
效率低,假設(shè)2和3分別需要1秒的時(shí)候,那么用戶在點(diǎn)擊注冊(cè)2秒后才能看到響應(yīng)。

同步事件可以解決上面第一個(gè)問(wèn)題,我們把發(fā)郵件的方法獨(dú)立出來(lái),放到事件里執(zhí)行,這樣注冊(cè)的這個(gè)方法就可以只做2操作,完成之后發(fā)布一個(gè)事件去執(zhí)行3,可以很好的解決業(yè)務(wù)耦合的問(wèn)題.

異步事件可以完美解決以上兩個(gè)問(wèn)題,注冊(cè)方法執(zhí)行2操作,執(zhí)行之后發(fā)布一個(gè)異步事件,另起一個(gè)線程執(zhí)行3操作,注冊(cè)方法所在的線程可直接返回給用戶,這樣不僅實(shí)現(xiàn)了業(yè)務(wù)解耦還提高了效率,用戶點(diǎn)擊注冊(cè),1秒后就能看到響應(yīng).

Spring的事件機(jī)制

Spring 事件發(fā)送監(jiān)聽(tīng)涉及3個(gè)部分

ApplicationEvent：表示事件本身，自定義事件需要繼承該類(lèi),可以用來(lái)傳遞數(shù)據(jù),比如上述操作,我們需要將用戶的郵箱地址傳給事件監(jiān)聽(tīng)器.
ApplicationEventPublisherAware ：事件發(fā)送器,通過(guò)實(shí)現(xiàn)這個(gè)接口,來(lái)觸發(fā)事件. 　
ApplicationListener：事件監(jiān)聽(tīng)器接口,事件的業(yè)務(wù)邏輯封裝在監(jiān)聽(tīng)器里面.

接下來(lái)使用spring的異步事件機(jī)制來(lái)模擬上面的注冊(cè)流程.有配置文件和注解兩種方式。

使用配置文件的方式創(chuàng)建事件:

新建TestEvent:

public class TestEvent extends ApplicationEvent {
 
     private TestParam source;
 
     public TestEvent(TestParam source) {
         super(source);
         this.source = source;
     }
 }
 
 @Data
 public class TestParam {
     private String email;
 }

新建TestListener:

@Component
 public class TestListener implements ApplicationListener<TestEvent> {
 
     @Override
     public void onApplicationEvent(TestEvent testEvent) {
 
         TestParam param = (TestParam) testEvent.getSource();
         System.out.println(".......開(kāi)始.......");
         System.out.println("發(fā)送郵件:"+param.getEmail());
         System.out.println(".......結(jié)束.....");
     }
 }

新建 EventPublisher:

@Component
public class TestPublish implements ApplicationEventPublisherAware {

    private static ApplicationEventPublisher applicationEventPublisher;

    @Override
    public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {
        TestPublish.applicationEventPublisher = applicationEventPublisher;
    }

    public static void  publishEvent(ApplicationEvent communityArticleEvent) {
        applicationEventPublisher.publishEvent(communityArticleEvent);
    }
}

spring-context.xml中添加:

  <bean id="applicationEventAsyncMulticaster" class="org.springframework.context.event.SimpleApplicationEventMulticaster">
         <property name="taskExecutor">
             <bean class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
                 <property name="corePoolSize" value="5"/>
                 <property name="keepAliveSeconds" value="3000"/>
                 <property name="maxPoolSize" value="50"/>
                 <property name="queueCapacity" value="200"/>
             </bean>
         </property>
     </bean>

注意:如果加<propery name="taskExecutor",則使用異步方式執(zhí)行,否則為同步方式

使用注解方式創(chuàng)建事件

使用 @Async 需要在配置文件添加一下支持,線程池也是需要配置一下的

<!-- 開(kāi)啟@AspectJ AOP代理 -->
    <aop:aspectj-autoproxy proxy-target-class="true"/>

    <!-- 任務(wù)執(zhí)行器 -->
    <task:executor id="executor" pool-size="10"/>

    <!--開(kāi)啟注解調(diào)度支持 @Async -->
    <task:annotation-driven executor="executor" proxy-target-class="true"/>

TestListener中在方法中添加@Async

 @Component
 public class TestListener implements ApplicationListener<TestEvent> {
 
     @Async
     @Override
     public void onApplicationEvent(TestEvent testEvent) {
 
         TestParam param = (TestParam) testEvent.getSource();
         System.out.println(".......開(kāi)始.......");
         System.out.println("發(fā)送郵件:"+param.getEmail());
         System.out.println(".......結(jié)束.....");
     }
 }

Listener其實(shí)還可以做得更徹底一點(diǎn),使用注解@EventListener可代替實(shí)現(xiàn)ApplicationListener,原理是通過(guò)掃描這個(gè)注解來(lái)創(chuàng)建監(jiān)聽(tīng)器并自動(dòng)添加到ApplicationContext中.

新建自定義EventHandler:

 @Component
 public class TestEventHandler {
 
     @Async
     @EventListener
     public void handleTestEvent(TestEvent testEvent) {
 
         TestParam param = (TestParam) testEvent.getSource();
         System.out.println(".......開(kāi)始.......");
         System.out.println("發(fā)送郵件:"+param.getEmail());
         System.out.println(".......結(jié)束.....");
     }
 }

測(cè)試及控制臺(tái)的打印就不貼了,這里主要記錄一下具體的實(shí)現(xiàn)方法.

總結(jié):

使用spring事件機(jī)制能很好地幫助我們消除不同業(yè)務(wù)間的耦合關(guān)系,也可以提高執(zhí)行效率,應(yīng)該根據(jù)業(yè)務(wù)場(chǎng)景靈活選擇。

到此這篇關(guān)于Spring的事件機(jī)制知識(shí)點(diǎn)詳解及實(shí)例分析的文章就介紹到這了,更多相關(guān)Spring的事件機(jī)制詳解內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: