Spring的事件处理

package com.mine.event.entity;

/**
  *
  * @author 2014-11-3 下午06:59:26 
  * @version V1.0  
 */
public class User {

	private Integer id;
	
	private String name;
	
	public int getId() {
		return id;
	}

	public void setId(Integer id) {
		this.id = id;
	}

	public String getName() {
		return name;
	}

	public User(Integer id, String name) {
		super();
		this.id = id;
		this.name = name;
	}

	public void setName(String name) {
		this.name = name;
	}

}

然后是事件源

package com.mine.event.event;

import com.mine.event.basic.event.BasicEvent;

/**
  * 用户相关事件
  * @author 2014-11-3 下午07:06:09 
  * @version V1.0  
 */
public class UserEvent extends BasicEvent{

	/** * 序列化ID */
	private static final long serialVersionUID = 7117267688533263478L;

	public UserEvent(Object object) {
		super(object);
	}
	
}

package com.mine.event.event;

import com.mine.event.basic.event.BasicEvent;

public class TEvent extends BasicEvent {

	public TEvent(Object object) {
		super(object);
	}

}

package com.mine.event.service;

import com.mine.event.basic.enums.EventTypeEnum;
import com.mine.event.basic.event.BasicEvent;
import com.mine.event.basic.service.BasicService;
import com.mine.event.entity.User;
import com.mine.event.event.UserEvent;

public class UserService extends BasicService<UserEvent> {

	/**
	 * 增加用户
	 * 
	 * @author 2014-11-3 下午07:18:16
	 * @param user
	 */
	public void addUser(User user) {
		this.addSingleObj(user);
	}
	
	/**
	 * 根据事件类型进行相应的处理
	 */
	@Override
	public void notifyEvent(BasicEvent event) {
			
			//如果UserEvent有自定义的属性或方法，下面需要调用的，则需要强制转换为UserEvent	
//			UserEvent userEvent = (UserEvent) event;
			
			EventTypeEnum typeEnum = event.getEventTypeEnum();
			
			User user = (User)event.getEventObject();
			if (user == null) {
				return;
			}
			switch (typeEnum) {
				case ADD:
					System.out.println("ADD:" + user.getName());
					break;
				case MODIFY:
					System.out.println("MODIFY:" + event.getEventObject());
					break;
				case DEL:
					System.out.println("DEL:" + event.getEventObject());
					break;
				default:
					System.out.println("其它");
					break;
			}
	}

	@Override
	public Class fetchCurrentEvent() {
		return UserEvent.class;
	}
}

package com.mine.event.service;

import com.mine.event.basic.enums.EventTypeEnum;
import com.mine.event.basic.event.BasicEvent;
import com.mine.event.basic.service.BasicService;
import com.mine.event.entity.User;
import com.mine.event.event.TEvent;

public class UserServiceTemp  extends BasicService<TEvent>{

	/**
	 * 增加用户
	 * 
	 * @author 2014-11-3 下午07:18:16
	 * @param user
	 * @modificationHistory=========================逻辑或功能性重大变更记录
	 * @modify by user: {修改人} 2014-11-3
	 * @modify by reason:{原因}
	 */
	public void addUser(User user) {
		this.addSingleObj(user);
	}
	
	/**
	 * 根据事件类型进行相应的处理
	 */
	public void notifyEvent(BasicEvent event) {
			
			//如果UserEvent有自定义的属性或方法，下面需要调用的，则需要强制转换为UserEvent	
//			UserEvent userEvent = (UserEvent) event;
			
			EventTypeEnum typeEnum = event.getEventTypeEnum();
			
			User user = (User)event.getEventObject();
			if (user == null) {
				return;
			}
			switch (typeEnum) {
				case ADD:
					System.out.println("UserServiceTempADD:" + user.getName());
					break;
				case MODIFY:
					System.out.println("MODIFY:" + event.getEventObject());
					break;
				case DEL:
					System.out.println("DEL:" + event.getEventObject());
					break;
				default:
					System.out.println("其它");
					break;
			}
	}

	public Class fetchCurrentEvent() {
		return TEvent.class;
	}
}

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xmlns:aop="http://www.springframework.org/schema/aop"
	xmlns:tx="http://www.springframework.org/schema/tx"
	xsi:schemaLocation="
		http://www.springframework.org/schema/beans
		http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
		http://www.springframework.org/schema/tx
		http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
		http://www.springframework.org/schema/aop
		http://www.springframework.org/schema/aop/spring-aop-3.0.xsd">
		
	<bean class="org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor" />
	<bean id="userServiceImpl" class="com.mine.event.service.UserService" />
	<bean id="userServiceTemp" class="com.mine.event.service.UserServiceTemp" />
</beans>

package com.mine.event.test;

import java.util.Collection;

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

import com.mine.event.basic.service.BasicService;
import com.mine.event.entity.User;
import com.mine.event.service.UserService;

public class TestUserEvent {
	
	public static void main(String[] args) {
		
		User user = new User(1,"name_1");
		
		ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml");
		
		UserService userService = applicationContext.getBean("userServiceImpl",UserService.class);
		
		userService.addUser(user);
		
		Collection<BasicService> collection = applicationContext.getBeansOfType(BasicService.class).values();
		
		//通过Spring可以获得所有加载到Spring上下文中的一个类的子类。
		System.out.println("获取BasicService的所有加载到Spring上下文当中的所有子类个数"+collection.size());
	}
}