Spring 中的事件處理

Spring 中的事件處理

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

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

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

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

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

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

讓我們?cè)谇‘?dāng)?shù)奈恢檬褂?Eclipse IDE，然后按照下面的步驟來創(chuàng)建一個(gè) 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ùn)行該應(yīng)用程序。如果你的應(yīng)用程序一切都正常，將輸出以下消息：

ContextStartedEvent Received
Your Message : Hello World!
ContextStoppedEvent Received