Spring的事件機制詳解

同步事件和異步事件

　　同步事件:在一個線程裏,按順序執行業務,作完一件事再去作下一件事.

      異步事件:在一個線程裏,作一個事的同事,能夠另起一個新的線程執行另外一件事,這樣兩件事能夠同時執行.

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

         　1.邏輯複雜,業務耦合,咱們把校驗數據並存庫和發送郵件寫到一個大的業務方法裏了,發郵件咱們能夠看作一個相對獨立的業務方法

　　　　2.效率低,假設2和3分別須要1秒的時候,那麼用戶在點擊註冊2秒後才能看到相應

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

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

Spring的事件機制

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

　　ApplicationEvent：表示事件自己，自定義事件須要繼承該類,能夠用來傳遞數據,好比上述操做,咱們須要將用戶的郵箱地址傳給事件監聽器.

　　ApplicationEventPublisherAware：事件發送器,經過實現這個接口,來觸發事件.

　　ApplicationListener：事件監聽器接口,事件的業務邏輯封裝在監聽器裏面.

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

配置文件的方式:

　　新建TestEvent:

 1 public class TestEvent extends ApplicationEvent {
 2 
 3     private TestParam source;
 4 
 5     public TestEvent(TestParam source) {
 6         super(source);
 7         this.source = source;
 8     }
 9 }
10 
11 @Data
12 public class TestParam {
13     private String email;
14 }

新建TestListener:

 1 @Component
 2 public class TestListener implements ApplicationListener<TestEvent> {
 3 
 4     @Override
 5     public void onApplicationEvent(TestEvent testEvent) {
 6 
 7         TestParam param = (TestParam) testEvent.getSource();
 8         System.out.println(".......開始.......");
 9         System.out.println("發送郵件:"+param.getEmail());
10         System.out.println(".......結束.....");
11     }
12 }

新建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中添加:

 1  <bean id="applicationEventAsyncMulticaster" class="org.springframework.context.event.SimpleApplicationEventMulticaster">
 2         <property name="taskExecutor">
 3             <bean class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
 4                 <property name="corePoolSize" value="5"/>
 5                 <property name="keepAliveSeconds" value="3000"/>
 6                 <property name="maxPoolSize" value="50"/>
 7                 <property name="queueCapacity" value="200"/>
 8             </bean>
 9         </property>
10     </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

 1 @Component
 2 public class TestListener implements ApplicationListener<TestEvent> {
 3 
 4  @Async  5     @Override
 6     public void onApplicationEvent(TestEvent testEvent) {
 7 
 8         TestParam param = (TestParam) testEvent.getSource();
 9         System.out.println(".......開始.......");
10         System.out.println("發送郵件:"+param.getEmail());
11         System.out.println(".......結束.....");
12     }
13 }

　Listener其實還能夠作得更完全一點,使用註解@EventListener可代替實現ApplicationListener,原理是經過掃描這個註解來建立監聽器並自動添加到ApplicationContext中.

新建自定義EventHandler:

 1 @Component
 2 public class TestEventHandler {
 3 
 4     @Async
 5     @EventListener
 6     public void handleTestEvent(TestEvent testEvent) {
 7 
 8         TestParam param = (TestParam) testEvent.getSource();
 9         System.out.println(".......開始.......");
10         System.out.println("發送郵件:"+param.getEmail());
11         System.out.println(".......結束.....");
12     }
13 } 

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

總結:

　　使用spring事件機制能很好地幫助咱們消除不一樣業務間的耦合關係,也能夠提升執行效率,應該根據業務場景靈活選擇.