- 1.Spring事件与监听
- 2.Spring Boot 事件与监听
- 3.自已定义事件与监听
- 1.自定义事件(继承`ApplicationEvent`)
- 2.发布事件
- 3.事件监听
- 4.注册监听器
- 5.测试
- 4.基于注解的事件监听器
- 5.异步监听
- 6.监听器顺序
- 7.通用的事件
ApplicationContext中的事件处理是通过ApplicationEvent类和ApplicationListener接口提供的。
如果实现ApplicationListener接口的bean加载到上下文中。每次ApplicationEvent事件被发布到ApplicationContext,该bean会接受到通知。实际上这是标准的Observer设计模式。
下表描述了Spring提供的标准事件:
| ContextRefreshedEvent | 当ApplicationContext被初始化或刷新时发布(例如，通过使用ConfigurableApplicationContext接口上的refresh()方法)。在这里，“初始化”意味着加载了所有bean，检测并激活了后处理器bean，预实例化了单例，ApplicationContext对象已准备好使用。只要上下文没有关闭，就可以多次触发刷新，前提是所选的ApplicationContext实际上支持这样的“热”刷新。例如，XmlWebApplicationContext支持热刷新，但是GenericApplicationContext不支持 |
| ContextStartedEvent | 通过使用ConfigurableApplicationContext接口上的start()方法，在ApplicationContext启动时发布。在这里，“started”意味着所有生命周期bean都接收一个显式的开始信号。通常，此信号用于在显式停止后重新启动bean，但也可用于启动未配置为自动启动的组件(例如，在初始化时尚未启动的组件)。 |
| ContextStoppedEvent | 通过使用ConfigurableApplicationContext接口上的stop()方法，在ApplicationContext停止时发布。在这里，“stopped”意味着所有生命周期bean都接收到一个显式的停止信号。已停止的上下文可以通过start()调用重新启动。 |
| ContextRefreshedEvent | 在ApplicationContext被关闭时发布，关闭的方法是使用ConfigurableApplicationContext接口上的close()方法或通过JVM关闭钩子。在这里，“close”意味着所有的单例bean都将被销毁。一旦上下文被关闭，它将到达生命周期的尽头，并且不能被刷新或重新启动。 |
| RequestHandledEvent | 一个特定的web事件，告诉所有bean一个HTTP请求已经得到服务。此事件在请求完成后发布。这个事件只适用于使用Spring的DispatcherServlet的web应用程序。 |
| ServletRequestHandledEvent | RequestHandledEvent子类,添加了特定的Servlet上下文信息 |
除了Spring框架事件， SpringApplication还会发送一些额外的应用事件。
当应用程序运行时,事件按照如下顺序发送:
1.ApplicationStartingEvent:在应用运行开始发送,但是在所有处理之前。 除了监听器的注册和初始化。
2.ApplicationEnvironmentPreparedEvent:在context被创建之前,当Environment被context使用的时候触发执行
3.ApplicationContextInitializedEvent:当ApplicationContext已经准备好,并且ApplicationContextInitializers已经被调用，但是任何bean还没定义加载。
4.ApplicationPreparedEvent:在启动刷新之前,但是在bean定义加载之后。
5.ApplicationStartedEvent:在刷新上下文之后，但在调用任何应用程序和命令行运行程序之前。
6.AvailabilityChangeEvent:在应用LivenessState.CORRECT之后发送,表示应用是活动状态。
7.ApplicationReadyEvent:在调用了任意应用程序和命令行运行程序之后。
8.AvailabilityChangeEvent:在应用ReadinessState.ACCEPTING_TRAFFIC之后发送,表示应用是准备好为请求提供服务。
9.ApplicationFailedEvent:应用启动时出现异常。
上面的列表只包括绑定到SpringApplication的SpringApplicationEvents。除此之外，以下事件也会在ApplicationPreparedEvent之后和ApplicationStartedEvent之前发布:
1.一个WebServerInitializedEvent在WebServer准备好之后被发送。ServletWebServerInitializedEvent和ReactiveWebServerInitializedEvent分别是servlet和webflux变量。
2.当ApplicationContext刷新时，ContextRefreshedEvent被发送。
默认情况下，事件侦听器在同一线程中执行时，不应运行可能冗长的任务。如有需要可以使用ApplicationRunner 或者 CommandLineRunner
有些事件实际上是在ApplicationContext创建之前被触发的，所以不能将这些事件的侦听器注册为@Bean。
可以用SpringApplication.addListeners(…)方法或SpringApplicationBuilder.listeners(…)方法注册它们。 如果您希望自动注册这些侦听器，而不管应用程序是以何种方式创建的，那么您可以添加一个META-INF/spring.factories文件到你的项目，并通过使用org.springframework.context.ApplicationListener键引用你的listener(s)，如下所示:
org.springframework.context.ApplicationListener=com.example.project.MyListener
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;
}
public String getAddress() {
return address;
}
public String getContent() {
return content;
}
}
要发布一个自定义的ApplicationEvent，在ApplicationEventPublisher上调用publishEvent()方法。通常这是通过创建一个实现ApplicationEventPublisherAware的类并将其注册为Spring bean来完成的。
@Service
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)) {
System.out.println("EmailService发送邮件...");
publisher.publishEvent(new BlockedListEvent(this, address, content));
return;
}
}
}
在配置时，Spring容器检测到EmailService实现了ApplicationEventPublisherAware并自动调用setApplicationEventPublisher()。实际上传入的参数是Spring容器本身。你正在通过它的ApplicationEventPublisher接口与应用程序上下文交互。
要接收自定义的ApplicationEvent，你可以创建一个实现ApplicationListener的类，并将其注册为Spring bean。
public class BlockedListNotifier implements ApplicationListener<BlockedListEvent> {
private String notificationAddress;
public void setNotificationAddress(String notificationAddress) {
this.notificationAddress = notificationAddress;
}
@Override
public void onApplicationEvent(BlockedListEvent event) {
System.out.println("我是BlockedListNotifier准备向外发布消息了....");
}
}
ApplicationListener通常是用自定义事件的类型参数化的(在前面的示例中是BlockedListEvent)。
这意味着onApplicationEvent()方法可以保持类型安全，避免任何向下类型转换。你可以注册任意数量的事件监听器，但请注意在默认情况下，事件监听器是同步接收事件的。这意味着publishEvent()方法会一直阻塞，直到所有侦听器都完成了对事件的处理。这种同步和单线程方法的一个优点是，当侦听器接收到一个事件时，如果事务上下文可用，它将在发布者的事务上下文内 *** 作。 如果需要另一种事件发布策略，请参阅ApplicationEventMulticaster接口和SimpleApplicationEventMulticaster实现的配置选项。
1.代码方式注册:
@SpringBootApplication
public class SpringEventListenerApplication {
public static void main(String[] args) {
SpringApplication application = new SpringApplication(SpringEventListenerApplication.class);
application.addListeners(new BlockedListNotifier());
application.run(args);
}
}
2.配置文件注册resources/META-INF/spring.factories
org.springframework.context.ApplicationListener=com.example.springeventlistener.listener.BlockedListNotifier
@SpringBootTest
class SpringEventListenerApplicationTests {
@Autowired
private EmailService emailService;
@Test
void contextLoads() {
emailService.setBlockedList(Arrays.asList("[email protected]", "[email protected]", "[email protected]"));
emailService.sendEmail("[email protected]", "我是known.spammer要发邮件了");
}
}
EmailService发送邮件...
我是BlockedListNotifier准备向外发布消息了....
可以使用@EventListener注解在托管bean的任何方法上注册事件侦听器,BlockedListNotifier重写如下:
public class BlockedListNotifierAnnotation {
private String notificationAddress;
public void setNotificationAddress(String notificationAddress) {
this.notificationAddress = notificationAddress;
}
@EventListener
public void processBlockedListEvent(BlockedListEvent event) {
System.out.println("我是基于 @EventListener注解的监听！！！");
}
}
@Bean
public BlockedListNotifierAnnotation blockedListNotifierAnnotation() {
return new BlockedListNotifierAnnotation();
}
方法签名声明它监听的事件类型，但是这次使用了一个灵活的名称，并且没有实现特定的监听接口。
如果你的方法应该监听几个事件，或者你想要定义一个完全不带参数的方法，那么事件类型也可以在注解本身上指定。下面的例子展示了如何做到这一点:
@EventListener({ContextStartedEvent.class, ContextRefreshedEvent.class})
public void handleContextStart() {
// ...
}
还可以通过使用定义SpEL表达式的注解的condition属性来添加额外的运行时过滤，该注解应该与针对特定事件实际调用方法相匹配。
下面的例子展示了如何重写监听器，使其仅在事件的content属性等于my-event时才被调用:
@EventListener(condition = "#blEvent.content == 'my-event'")
public void processBlockedListEvent(BlockedListEvent blEvent) {
// notify appropriate parties via notificationAddress...
}
如果你需要发布一个事件作为处理另一个事件的结果，你可以改变方法签名来返回应该发布的事件，如下所示:
@EventListener
public ListUpdateEvent handleBlockedListEvent(BlockedListEvent event) {
// notify appropriate parties via notificationAddress and
// then publish a ListUpdateEvent...
}
监听处理完BlockedListEvent事件后,再发布一个ListUpdateEvent事件。如果要发布多个时间可以返回Collection或事件数组。但是这个特性不支持异步监听，接下来详细了解异步监听。
如果你希望特定的监听器异步处理事件，可以使用常规的@Async。下面的例子展示了如何做到这一点:
@EventListener
@Async
public void processBlockedListEvent(BlockedListEvent event) {
// BlockedListEvent 执行在单独的线程
}
使用异步事件时的以下限制:
1.:如果异步事件监听器抛出异常，则不会将其传播到调用方(详细信息参考AsyncUncaughtExceptionHandler)。
2.异步事件监听器方法不能通过返回值来发布后续事件。
3.如果需要发布另一个事件作为处理的结果，请注入ApplicationEventPublisher来手动发布事件。
如果你需要在另一个侦听器之前调用一个侦听器，你可以在方法声明中添加@Order注释，如下面的示例所示:
@EventListener
@Order(42)
public void processBlockedListEvent(BlockedListEvent event) {
// notify appropriate parties via notificationAddress...
}
你还可以使用泛型来进一步定义事件的结构。考虑使用EntityCreatedEvent，其中T是被创建的实际实体的类型。例如，你可以创建以下监听器定义来仅接收Person的EntityCreatedEvent:
@EventListener
public void onPersonCreated(EntityCreatedEvent<Person> event) {
// ...
}
由于类型擦除,不是所有的事件类型都是相同的结构,为了保证事件监听能获取正确的实体类型，可以按照如下方式:
public class EntityCreatedEvent<T> extends ApplicationEvent implements ResolvableTypeProvider {
public EntityCreatedEvent(T entity) {
super(entity);
}
@Override
public ResolvableType getResolvableType() {
return ResolvableType.forClassWithGenerics(getClass(), ResolvableType.forInstance(getSource()));
}
}
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）