到Spring 4.2為止，事件基礎(chǔ)設(shè)施得到了顯著改進，提供了基于注釋的模型以及發(fā)布任意事件的能力(也就是說，不一定是從ApplicationEvent擴展的對象)。當這樣的對象被發(fā)布時，我們將它包裝在一個事件中。
核心事件
ApplicationContext中的事件處理是通過ApplicationEvent類和ApplicationListener接口提供的。如果將實現(xiàn)一個Bean實現(xiàn)了ApplicationListener接口，那么每當ApplicationEvent發(fā)布到ApplicationContext時，就會通知該bean。本質(zhì)上，這是標準的觀察者設(shè)計模式。
到Spring 4.2為止，事件基礎(chǔ)設(shè)施得到了顯著改進，提供了基于注釋的模型以及發(fā)布任意事件的能力(也就是說，不一定是從ApplicationEvent擴展的對象)。當這樣的對象被發(fā)布時，我們將它包裝在一個事件中。
下表列出了Spring提供的標準事件:
Event | Explanation |
ContextRefreshedEvent | 在ApplicationContext被初始化或刷新時發(fā)布(例如，通過使用ConfigurableApplicationContext接口上的refresh()方法)。這里的“初始化”意味著加載了所有bean，檢測并激活了后處理器bean，預(yù)實例化了單例，并且ApplicationContext對象已經(jīng)準備好可以使用。只要上下文沒有關(guān)閉，就可以多次觸發(fā)刷新，前提是所選擇的ApplicationContext實際上支持這種“熱”刷新。 |
ContextStartedEvent | 通過使用ConfigurableApplicationContext接口上的start()方法啟動ApplicationContext時發(fā)布。在這里，“started”意味著所有生命周期bean都接收一個顯式的開始信號。通常，該信號用于在顯式停止之后重新啟動bean，但也可以用于啟動未配置為自動啟動的組件(例如，在初始化時尚未啟動的組件)。 |
ContextStoppedEvent | 當通過使用ConfigurableApplicationContext接口上的stop()方法停止ApplicationContext時發(fā)布。在這里，“stopped”意味著所有生命周期bean都接收一個明確的停止信號。停止的上下文可以通過start()調(diào)用重新啟動。 |
ContextClosedEvent | 使用ConfigurableApplicationContext接口上的close()方法或通過JVM關(guān)閉掛鉤關(guān)閉ApplicationContext時發(fā)布。在這里，“closed”意味著所有的單例bean都會被銷毀。一旦上下文被關(guān)閉，它就會到達生命的終點，并且不能被刷新或重啟。 |
RequestHandledEvent | 一個特定于web的事件，告訴所有bean一個HTTP請求已經(jīng)得到了服務(wù)。此事件在請求完成后發(fā)布。這個事件只適用于使用Spring的DispatcherServlet的web應(yīng)用程序。 |
ServletRequestHandledEvent | RequestHandledEvent的一個子類，用于添加特定于servlet的上下文信息。 |
以上事件發(fā)布時機：
public abstract class AbstractApplicationContext extends DefaultResourceLoader implements ConfigurableApplicationContext {
public void refresh() {
// ...
finishRefresh();
}
}public abstract class AbstractApplicationContext extends DefaultResourceLoader implements ConfigurableApplicationContext {
public void refresh() {
// ...
finishRefresh();
}
protected void finishRefresh() {
// 初始化LifecycleProcessor（DefaultLifecycleProcessor）
initLifecycleProcessor();
getLifecycleProcessor().onRefresh();
}
public void start() {
getLifecycleProcessor().start();
publishEvent(new ContextStartedEvent(this));
}
}
public class DefaultLifecycleProcessor implements LifecycleProcessor, BeanFactoryAware {
public void start() {
startBeans(false);
this.running = true;
}
}該事件與上面的started是對應(yīng)的
public abstract class AbstractApplicationContext extends DefaultResourceLoader implements ConfigurableApplicationContext {
public void stop() {
getLifecycleProcessor().stop();
publishEvent(new ContextStoppedEvent(this));
}
}
public class DefaultLifecycleProcessor implements LifecycleProcessor, BeanFactoryAware {
public void stop() {
stopBeans();
this.running = false;
}
}public abstract class AbstractApplicationContext extends DefaultResourceLoader implements ConfigurableApplicationContext {
public void close() {
synchronized (this.startupShutdownMonitor) {
doClose();
}
}
protected void doClose() {
publishEvent(new ContextClosedEvent(this));
}
}- ServletRequestHandledEvent
public abstract class FrameworkServlet {
protected final void processRequest(HttpServletRequest request, HttpServletResponse response) {
publishRequestHandledEvent(request, response, startTime, failureCause);
}
private void publishRequestHandledEvent(HttpServletRequest request, HttpServletResponse response, long startTime, @Nullable Throwable failureCause) {
if (this.publishEvents && this.webApplicationContext != null) {
// Whether or not we succeeded, publish an event.
long processingTime = System.currentTimeMillis() - startTime;
this.webApplicationContext.publishEvent(
new ServletRequestHandledEvent(this,
request.getRequestURI(), request.getRemoteAddr(),
request.getMethod(), getServletConfig().getServletName(),
WebUtils.getSessionId(request), getUsernameForRequest(request),
processingTime, failureCause, response.getStatus()));
}
}
}你還可以創(chuàng)建和發(fā)布自己的自定義事件。下面的例子展示了一個簡單的類，它擴展了Spring的ApplicationEvent基類:
public class BlockedListEvent extends ApplicationEvent {
private final String address;
private final String content;
public BlockedListEvent(Object source, String address, String content) {
super(source);
this.address = address;
this.content = content;
}
}要發(fā)布自定義的ApplicationEvent，需要調(diào)用ApplicationEventPublisher的publishEvent()方法。通常，這是通過創(chuàng)建一個實現(xiàn)ApplicationEventPublisherAware的類并將其注冊為Spring bean來完成的。下面的例子展示了這樣一個類:
public class EmailService implements ApplicationEventPublisherAware {
private List<String> blockedList;
private ApplicationEventPublisher publisher;
public void setBlockedList(List<String> blockedList) {
this.blockedList = blockedList;
}
public void setApplicationEventPublisher(ApplicationEventPublisher publisher) {
this.publisher = publisher;
}
public void sendEmail(String address, String content) {
if (blockedList.contains(address)) {
publisher.publishEvent(new BlockedListEvent(this, address, content));
return;
}
}
}在配置時，Spring容器檢測到EmailService實現(xiàn)了ApplicationEventPublisherAware，并自動調(diào)用
setApplicationEventPublisher()。實際上，傳入的參數(shù)是Spring容器本身。通過ApplicationEventPublisher接口與應(yīng)用程序上下文進行交互。
要接收自定義的ApplicationEvent，可以創(chuàng)建一個實現(xiàn)ApplicationListener的類，并將其注冊為Spring bean。下面的例子展示了這樣一個類:
public class BlockedListNotifier implements ApplicationListener<BlockedListEvent> {
private String notificationAddress;
public void setNotificationAddress(String notificationAddress) {
this.notificationAddress = notificationAddress;
}
public void onApplicationEvent(BlockedListEvent event) {
}
}請注意，ApplicationListener通常參數(shù)化為自定義事件的類型。這意味著onApplicationEvent()方法可以保持類型安全，避免任何向下轉(zhuǎn)換的需要。你可以注冊任意數(shù)量的事件監(jiān)聽器，但請注意，默認情況下，事件監(jiān)聽器是同步接收事件的。這意味著publishEvent()方法會阻塞，直到所有監(jiān)聽器都完成事件處理。這種同步和單線程方法的一個優(yōu)點是，當偵聽器接收到事件時，如果事務(wù)上下文可用，它將在發(fā)布者的事務(wù)上下文內(nèi)操作。
通過注解監(jiān)聽事件
可以使用@EventListener注解在托管bean的任何方法上注冊事件監(jiān)聽器。可以將BlockedListNotifier重寫為:
public class BlockedListNotifier {
private String notificationAddress;
public void setNotificationAddress(String notificationAddress) {
this.notificationAddress = notificationAddress;
}
@EventListener
public void processBlockedListEvent(BlockedListEvent event) {
}
}同時監(jiān)聽多個事件
@EventListener({ContextStartedEvent.class, ContextRefreshedEvent.class})
public void handleContextStart() {
}異步事件
如果希望特定的監(jiān)聽器異步處理事件，可以重用常規(guī)的@Async支持。如下面的例子所示:
@EventListener
@Async
public void processBlockedListEvent(BlockedListEvent event) {
}
在使用異步事件時，請注意以下限制：
- 如果異步事件監(jiān)聽器拋出異常，則異常不會傳播到調(diào)用者。
- 異步事件監(jiān)聽器方法無法通過返回值發(fā)布后續(xù)事件。如果你需要發(fā)布另一個事件作為處理的結(jié)果，注入一個ApplicationEventPublisher來手動發(fā)布事件。
事件監(jiān)聽順序
如果需要在調(diào)用另一個監(jiān)聽器之前調(diào)用一個監(jiān)聽器，可以在方法聲明中添加@Order注解，如下面的例子所示:
@EventListener
@Order(1)
public void processBlockedListEvent(BlockedListEvent event) {
}
通用的事件
你還可以使用泛型來進一步定義事件的結(jié)構(gòu)。考慮使用EntityCreatedEvent<T>，其中T是實際創(chuàng)建的實體的類型。例如，你可以創(chuàng)建以下監(jiān)聽器定義，只接收Person的EntityCreatedEvent:
@EventListener
public void onPersonCreated(EntityCreatedEvent<Person> event) {
}
由于類型擦除，只有當觸發(fā)的事件解析了事件監(jiān)聽器過濾的泛型參數(shù)(即類似于PersonCreatedEvent類擴展EntityCreatedEvent<Person>{…})時，才會起作用。
事件觸發(fā)原理
方式1：ApplicationEventPublisher
AbstractApplicationContext實現(xiàn)了ApplicationEventPublisher接口，那么只要ApplicationContext繼承自AbstractApplicationContext都可以直接發(fā)布事件：
public abstract class AbstractApplicationContext {
protected void publishEvent(Object event, @Nullable ResolvableType eventType) {
ApplicationEvent applicationEvent;
if (event instanceof ApplicationEvent) {
applicationEvent = (ApplicationEvent) event;
} else {
applicationEvent = new PayloadApplicationEvent<>(this, event);
if (eventType == null) {
eventType = ((PayloadApplicationEvent<?>) applicationEvent).getResolvableType();
}
}
if (this.earlyApplicationEvents != null) {
this.earlyApplicationEvents.add(applicationEvent);
} else {
getApplicationEventMulticaster().multicastEvent(applicationEvent, eventType);
}
if (this.parent != null) {
if (this.parent instanceof AbstractApplicationContext) {
((AbstractApplicationContext) this.parent).publishEvent(event, eventType);
} else {
this.parent.publishEvent(event);
}
}
}
}方式2：通過@EventListener注解
該注解是由EventListenerMethodProcessor處理器處理的。
public class EventListenerMethodProcessor implements SmartInitializingSingleton, ApplicationContextAware, BeanFactoryPostProcessor {
public void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) {
// 獲取容器中注冊的事件監(jiān)聽工廠，可以有多個
Map<String, EventListenerFactory> beans = beanFactory.getBeansOfType(EventListenerFactory.class, false, false);
}
public void afterSingletonsInstantiated() {
String[] beanNames = beanFactory.getBeanNamesForType(Object.class);
for (String beanName : beanNames) {
processBean(beanName, type);
}
}
private void processBean(final String beanName, final Class<?> targetType) {
Map<Method, EventListener> annotatedMethods = null;
try {
// 取得Bean內(nèi)帶有@EventListener注解的方法
annotatedMethods = MethodIntrospector.selectMethods(targetType, (MethodIntrospector.MetadataLookup<EventListener>) method ->
AnnotatedElementUtils.findMergedAnnotation(method, EventListener.class));
}
// 遍歷找到的所有@EventListener注解的方法
for (Method method : annotatedMethods.keySet()) {
// 遍歷所有的EventListenerFactory
for (EventListenerFactory factory : factories) {
// 判斷當前的事件監(jiān)聽工廠是否支持當前的方法
if (factory.supportsMethod(method)) {
Method methodToUse = AopUtils.selectInvocableMethod(method, context.getType(beanName));
// 創(chuàng)建對應(yīng)的事件監(jiān)聽程序
ApplicationListener<?> applicationListener = factory.createApplicationListener(beanName, targetType, methodToUse);
if (applicationListener instanceof ApplicationListenerMethodAdapter) {
((ApplicationListenerMethodAdapter) applicationListener).init(context, this.evaluator);
}
context.addApplicationListener(applicationListener);
break;
}
}
}
}
}
