Spring的事件機制知識點詳解及實例分析

Posted on by

同步事件和異步事件

  • 同步事件: 在一個線程裡,按順序執行業務,做完一件事再去做下一件事。
  • 異步事件: 在一個線程裡,做一個事的同事,可以另起一個新的線程執行另一件事,這樣兩件事可以同時執行。

用一個例子來解釋同步事件和異步事件的使用場景,有時候一段完整的代碼邏輯,可能分為幾部分,拿最常見的註冊來說,假設完整流程是,1.點擊註冊->2.檢驗信息並存庫->3.發送郵件通知->4.返回給用戶.代碼這麼寫是正確,但不是最好的,缺點如下:

邏輯復雜,業務耦合，我們把校驗數據並存庫和發送郵件寫到一個大的業務方法裡瞭，發送郵件我們可以看做一個相對獨立的業務方法。
效率低,假設2和3分別需要1秒的時候,那麼用戶在點擊註冊2秒後才能看到響應。

同步事件可以解決上面第一個問題,我們把發郵件的方法獨立出來,放到事件裡執行,這樣註冊的這個方法就可以隻做2操作,完成之後發佈一個事件去執行3,可以很好的解決業務耦合的問題.

異步事件可以完美解決以上兩個問題,註冊方法執行2操作,執行之後發佈一個異步事件,另起一個線程執行3操作,註冊方法所在的線程可直接返回給用戶,這樣不僅實現瞭業務解耦還提高瞭效率,用戶點擊註冊,1秒後就能看到響應.

Spring的事件機制

Spring 事件發送監聽涉及3個部分

  • ApplicationEvent：表示事件本身，自定義事件需要繼承該類,可以用來傳遞數據,比如上述操作,我們需要將用戶的郵箱地址傳給事件監聽器.
  • ApplicationEventPublisherAware ：事件發送器,通過實現這個接口,來觸發事件. 　
  • ApplicationListener：事件監聽器接口,事件的業務邏輯封裝在監聽器裡面.

接下來使用spring的異步事件機制來模擬上面的註冊流程.有配置文件和註解兩種方式。

使用配置文件的方式創建事件:

新建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(".......開始.......");
         System.out.println("發送郵件:"+param.getEmail());
         System.out.println(".......結束.....");
     }
 }

新建 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”,則使用異步方式執行,否則為同步方式

使用註解方式創建事件

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

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

    <!-- 任務執行器 -->
    <task:executor id="executor" pool-size="10"/>

    <!--開啟註解調度支持 @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(".......開始.......");
         System.out.println("發送郵件:"+param.getEmail());
         System.out.println(".......結束.....");
     }
 }

Listener其實還可以做得更徹底一點,使用註解@EventListener可代替實現ApplicationListener,原理是通過掃描這個註解來創建監聽器並自動添加到ApplicationContext中.

新建自定義EventHandler:

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

測試及控制臺的打印就不貼瞭,這裡主要記錄一下具體的實現方法.

總結:

使用spring事件機制能很好地幫助我們消除不同業務間的耦合關系,也可以提高執行效率,應該根據業務場景靈活選擇。

到此這篇關於Spring的事件機制知識點詳解及實例分析的文章就介紹到這瞭,更多相關Spring的事件機制詳解內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet！

推薦閱讀：