Spring 中的事件處理

Spring 中的事件處理

你已經(jīng)看到了在所有章節(jié)中 Spring 的核心是 ApplicationContext，它負責(zé)管理 beans 的完整生命周期。當(dāng)加載 beans 時，ApplicationContext 發(fā)布某些類型的事件。例如，當(dāng)上下文啟動時，ContextStartedEvent 發(fā)布，當(dāng)上下文停止時，ContextStoppedEvent 發(fā)布。

通過 ApplicationEvent 類和 ApplicationListener 接口來提供在 ApplicationContext 中處理事件。如果一個 bean 實現(xiàn) ApplicationListener，那么每次 ApplicationEvent 被發(fā)布到 ApplicationContext 上，那個 bean 會被通知。

Spring 提供了以下的標(biāo)準(zhǔn)事件：

由于 Spring 的事件處理是單線程的，所以如果一個事件被發(fā)布，直至并且除非所有的接收者得到的該消息，該進程被阻塞并且流程將不會繼續(xù)。因此，如果事件處理被使用，在設(shè)計應(yīng)用程序時應(yīng)注意。

監(jiān)聽上下文事件

為了監(jiān)聽上下文事件，一個 bean 應(yīng)該實現(xiàn)只有一個方法 onApplicationEvent() 的 ApplicationListener 接口。因此，我們寫一個例子來看看事件是如何傳播的，以及如何可以用代碼來執(zhí)行基于某些事件所需的任務(wù)。

讓我們在恰當(dāng)?shù)奈恢檬褂?Eclipse IDE，然后按照下面的步驟來創(chuàng)建一個 Spring 應(yīng)用程序：

這里是 HelloWorld.java 文件的內(nèi)容：

package com.tutorialspoint;
public class HelloWorld {
   private String message;
   public void setMessage(String message){
      this.message  = message;
   }
   public void getMessage(){
      System.out.println("Your Message : " + message);
   }
}

下面是 CStartEventHandler.java 文件的內(nèi)容：

package com.tutorialspoint;
import org.springframework.context.ApplicationListener;
import org.springframework.context.event.ContextStartedEvent;
public class CStartEventHandler 
   implements ApplicationListener<ContextStartedEvent>{
   public void onApplicationEvent(ContextStartedEvent event) {
      System.out.println("ContextStartedEvent Received");
   }
}

下面是 CStopEventHandler.java 文件的內(nèi)容：

package com.tutorialspoint;
import org.springframework.context.ApplicationListener;
import org.springframework.context.event.ContextStoppedEvent;
public class CStopEventHandler 
   implements ApplicationListener<ContextStoppedEvent>{
   public void onApplicationEvent(ContextStoppedEvent event) {
      System.out.println("ContextStoppedEvent Received");
   }
}

下面是 MainApp.java 文件的內(nèi)容：

package com.tutorialspoint;

import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class MainApp {
   public static void main(String[] args) {
      ConfigurableApplicationContext context = 
      new ClassPathXmlApplicationContext("Beans.xml");

      // Let us raise a start event.
      context.start();

      HelloWorld obj = (HelloWorld) context.getBean("helloWorld");

      obj.getMessage();

      // Let us raise a stop event.
      context.stop();
   }
}

下面是配置文件 Beans.xml 文件：

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
    http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">

   <bean id="helloWorld" class="com.tutorialspoint.HelloWorld">
      <property name="message" value="Hello World!"/>
   </bean>

   <bean id="cStartEventHandler" 
         class="com.tutorialspoint.CStartEventHandler"/>

   <bean id="cStopEventHandler" 
         class="com.tutorialspoint.CStopEventHandler"/>

</beans>

一旦你完成了創(chuàng)建源和 bean 的配置文件，我們就可以運行該應(yīng)用程序。如果你的應(yīng)用程序一切都正常，將輸出以下消息：

ContextStartedEvent Received
Your Message : Hello World!
ContextStoppedEvent Received