spring事件

 

spring事件

import org.springframework.context.ApplicationEvent;
public class EmailEvent extends ApplicationEvent {
 public EmailEvent(Object source) {
  super(source);
 }
}

 

import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;

public class CashedService implements ApplicationContextAware{
 
 private ApplicationContext applicationContext;
 public void setApplicationContext(ApplicationContext applicationContext)
   throws BeansException {
  this.applicationContext=applicationContext;
 }

 public void cashed(){   //自定义方法，发布事件
   applicationContext.publishEvent(new EmailEvent(new Object()));
 }

}

 

import org.springframework.context.ApplicationEvent;
import org.springframework.context.ApplicationListener;

public class ServiceListener implements ApplicationListener {
 public void onApplicationEvent(ApplicationEvent event) {
  if (event instanceof EmailEvent) {
   EmailEvent emailEvent=(EmailEvent) event;
   Object obj=(Object)emailEvent.getSource();
   //do other thing! ex:
   System.out.println("obj");   
  }
 }
}

bean配置

<bean id="cashedService" class="CashedService"></bean>
<bean id="serviceListner" class="ServiceListener"></bean>

客户端调用

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

public class TestClient {
 public static void main(String[] args) {
  ApplicationContext ac=new ClassPathXmlApplicationContext("applicationContext.xml");
  CashedService cashedService=(CashedService)ac.getBean("cashedService");
  cashedService.setApplicationContext(ac);
  cashedService.cashed();
 }
}