spring事件监听机制

//发布事件
context.publishEvent(event);

getApplicationEventMulticaster().multicastEvent(applicationEvent, eventType);

	@Override
	public void multicastEvent(final ApplicationEvent event, ResolvableType eventType) {
		ResolvableType type = (eventType != null ? eventType : resolveDefaultEventType(event));
		for (final ApplicationListener<?> listener : getApplicationListeners(event, type)) {
			Executor executor = getTaskExecutor();
			if (executor != null) {
				executor.execute(new Runnable() {
					@Override
					public void run() {
						invokeListener(listener, event);
					}
				});
			}
			else {
				invokeListener(listener, event);
			}
		}
	}

	protected void invokeListener(ApplicationListener<?> listener, ApplicationEvent event) {
		ErrorHandler errorHandler = getErrorHandler();
		if (errorHandler != null) {
			try {
				doInvokeListener(listener, event);
			}
			catch (Throwable err) {
				errorHandler.handleError(err);
			}
		}
		else {
			doInvokeListener(listener, event);
		}
	}

	@SuppressWarnings({"unchecked", "rawtypes"})
	private void doInvokeListener(ApplicationListener listener, ApplicationEvent event) {
		try {
			listener.onApplicationEvent(event);
		}
		catch (ClassCastException ex) {
			String msg = ex.getMessage();
			if (msg == null || matchesClassCastMessage(msg, event.getClass().getName())) {
				// Possibly a lambda-defined listener which we could not resolve the generic event type for
				// -> let‘s suppress the exception and just log a debug message.
				Log logger = LogFactory.getLog(getClass());
				if (logger.isDebugEnabled()) {
					logger.debug("Non-matching event type for listener: " + listener, ex);
				}
			}
			else {
				throw ex;
			}
		}
	}

package com.spring.event.event;

import org.springframework.context.ApplicationEvent;

import com.spring.event.bean.Notify;

/**
 * 自定义事件
 * @author sxq
 * @time 2018年8月31日 上午10:26:24
 *
 */
public class NotifyEvent extends ApplicationEvent {

	private int version;
	
	private Notify notify;
	public int getVersion() {
		return version;
	}

	public void setVersion(int version) {
		this.version = version;
	}

	/**
	 * serialVersionUID
	 */
	private static final long serialVersionUID = -6198589267233914254L;

	public NotifyEvent(Object source) {
		super(source);
		
	}
	public Notify getNotify() {
		return notify;
	}

	public void setNotify(Notify notify) {
		this.notify = notify;
	}

	public NotifyEvent(Object source,Notify notify) {
		this(source);
		this.notify = notify;
		
	}

}

package com.spring.event.listner;

import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;

import com.spring.event.event.NotifyEvent;

/**
 * 自定义监听器
 * @author sxq
 * @time 2018年8月31日 上午10:27:04
 *
 */
@Component
public class NotifyListenr implements ApplicationListener<NotifyEvent>{

	@Override
	public void onApplicationEvent(NotifyEvent event) {
		
		System.out.println(event.getNotify().toString());
		
		//监听事件后，处理后续事情
	}

}

	ApplicationContext context = new ClassPathXmlApplicationContext("spring.xml");
	Notify notify = new Notify("李四",21);
	NotifyEvent event = new NotifyEvent("NotifyEvent",notify);
	event.setVersion(100);	
	//发布事件
　　　　 context.publishEvent(event);