1. 概述
事件是框架中最容易被忽视的功能之一,但同时也是一个很有用的功能。像Spring其他特性一样,事件发布是 ApplicationContext
提供的功能之一。
事件通知是一个很有用的功能,使用事件机制可以将互相耦合的代码进行解耦,方便功能的新增或修改。
Spring允许创建和发布自定义事件,默认情况下,事件都是 同步 执行的。这样有很多好处,比如事件的监听器和发布者在同一个事务内,能够很方便的处理一些业务。
创建一个简单的事件类,使用一个 String
变量来存储事件数据。
现在来创建事件发布者。发布者创建事件对象,并把事件发送给所有的监听器。
要发布事件,发布者可以简单的注入 ApplicationEventPublisher
然后使用它的 publishEvent()
方法:
或者,发布者也可以实现 ApplicationEventPublisherAware
接口。通常情况下使用 @Autowired
注入会更简单。
最后,来创建事件监听器。
监听器的唯一要求是一个bean并实现 ApplicationListener
接口:
上面已经说过,默认情况下事件都是 同步执行
的,在所有的监听器完成对事件的处理之前, doStuffAndPublishAnEvent()
方法会一直堵塞。
如果需要指定监听器的执行顺序,可以实现 Ordered
接口设置每个执行器的优先级。
在某些情况下,同步处理事件并不是我们想要的效果,我们可能需要异步处理事件。
在 AbstractApplicationContext
中存在一个 ApplicationEventMulticaster
对事件进行广播,默认情况下框架初始化了一个 SimpleApplicationEventMulticaster
:
SimpleApplicationEventMulticaster
是如何进行事件广播的呢?
如果存在 Executor
,那么事件就会进行异步处理,否则就是同步。
所以需要异步的处理事件,那么就需要手动创建一个name为 applicationEventMulticaster
的bean,然后为它设置一个 TaskExecutor
,例如:
事件、发布者和监听器和前面定义相同,这样监听器就会在单独的线程中异步处理事件。
但是,这样配置的话,所有发布的事件都会以异步的方式进行处理,显然太简单粗暴了,下面介绍一种更加友好的方式。
首先,删除刚刚的 AsynchronousSpringEventsConfig
配置类,然后在Application主类上加上 @EnableAsync
注解,来让程序支持异步方法的调用,最后在监听器的 onApplicationEvent
方法上加上 @Async
注解。
从Spring4.2开始,事件监听器不再需要实现 ApplicationListener
接口,可以通过 @EventListener
注解在一个bean的任意public方法上注册:
如果方法需要监听多个事件或者你不想在方法上定义参数,那么你可以在注解里设置事件类型,例如:
注解的 condition
属性可以定义一个SpEL表达式来对事件进行过滤,表达式匹配才能调用特定事件的监听方法。
如果处理完成一个事件后需要发布一个事件,那么你可以在方法上返回相应的事件,例如:
如果需要返回多个事件,那么可以返回事件的集合。
监听器的异步处理可以通过 @Async
注解来实现。
当使用异步事件监听时,需要注意以下限制:
如果异步事件监听器抛出 Exception
,不会将其传播到调用方。可以查看 AsyncUncaughtExceptionHandler
来获取更多详细信息。
异步事件监听方法无法通过返回值来发布后续事件。如果你确实需要发布后续事件,可以注入 ApplicationEventPublisher
来手动发布。
如果需要指定监听器的执行顺序,可以在方法上使用 @Order
注解。
不是所有的事件都必须继承 ApplicationEvent
, ApplicationEventPublisher
中有2种方式进行事件的发布。
通过查看实现类代码可以发现,发送的Object类型的事件最后会被包装为一个 PayloadApplicationEvent
,而 PayloadApplicationEvent
继承了 ApplicationEvent
。
所以我们可以发布任何Object事件。
很多时候,只有事务提交之后我们才会发布相应的事件处理其他逻辑,比如用户注册之后,发送邮件或者短信。从Spring 4.2开始,框架提供了一个很方便的注解来实现此功能(4.2之前也可以通过自己写代码实现),即 @TransactionalEventListener
。
@TransactionalEventListener
是对 @EventListener
的一个扩展,允许将事件的监听器绑定到事务的某个阶段。可以绑定到以下事务阶段:
AFTER_COMMIT (默认),事务提交后
AFTER_ROLLBACK ,事务回滚后
AFTER_COMPLETION ,事务完成,包括提交后和回滚后
BEFORE_COMMIT ,事务提交前
只有当上下文存在事务,并且事务提交前,才会调用此监听器的方法。
默认情况下,如果上下文不存在事务,则根本不会发送事件,我们可以通过设置 @TransactionalEventListener
的 fallbackExecution
为true来实现。