SpringBoot事件监听器@EventListener的实现

汤龙

目录

• 1.概述
• 2.事件驱动架构基础
• 3.使用示例
• 4.事件监听器的灵活性和配置
• 5.SpringBoot内置的监听器

1.概述

• 在 Spring 框架中，@EventListener是一个用于处理应用程序事件的注解。它提供了一种方便的方式来监听和响应各种事件，使得代码可以基于事件驱动的方式进行架构。通过@EventListener注解，可以将一个方法标记为事件监听器，当对应的事件被发布时，该方法就会被自动调用。

2.事件驱动架构基础

• 事件（Event）：事件是对应用程序中某个动作或者状态变化的抽象表示。例如，用户注册成功、订单已支付、文件上传完成等都可以看作是事件。在Spring 中，事件通常是一个继承自ApplicationEvent的类。
• 事件发布者（Publisher）：负责发布事件的组件。它会在特定的业务逻辑执行过程中，创建并发布事件。例如，在用户注册服务类中，当用户注册成功后，会发布一个UserRegisteredEvent。
• 事件监听器（Listener）：通过@EventListener注解标记的方法所在的类就是事件监听器。它会订阅感兴趣的事件，当事件发布时，监听器中的相应方法就会被触发，执行自定义的逻辑，如发送欢迎邮件、更新用户积分等。

3.使用示例

• 定义事件类：首先需要定义一个事件类，继承自ApplicationEvent。例如，定义一个用户注册成功的事件类：
• 这里UserRegisteredEvent类继承自ApplicationEvent，并且包含了一个User对象，用于传递用户相关的信息。
• 发布事件：在业务逻辑中，当用户注册成功后，发布事件。假设在一个UserService类中有一个用户注册方法：

1. import org.springframework.context.ApplicationEventPublisher;
2. import org.springframework.stereotype.Service;
4. @Service
5. public class UserService {
6. private final ApplicationEventPublisher eventPublisher;
8. public UserService(ApplicationEventPublisher eventPublisher) {
9. this.eventPublisher = eventPublisher;
10. }
12. public void registerUser(User user) {
13. // 实际的用户注册逻辑，如保存用户信息到数据库等
14. //...
15. // 注册成功后发布事件
16. UserRegisteredEvent event = new UserRegisteredEvent(this, user);
17. eventPublisher.publishEvent(event);
18. }
19. }

复制代码

• 这里UserService类通过构造函数注入了ApplicationEventPublisher，在用户注册成功后，创建UserRegisteredEvent并发布。
• 监听事件：使用@EventListener注解来监听事件。例如，创建一个监听器类来发送欢迎邮件给新注册用户：

1. import org.springframework.context.event.EventListener;
2. import org.springframework.stereotype.Component;
4. @Component
5. public class WelcomeEmailListener {
6. @EventListener
7. public void sendWelcomeEmail(UserRegisteredEvent event) {
8. User user = event.getUser();
9. // 发送欢迎邮件的逻辑，如调用邮件发送服务
10. System.out.println("发送欢迎邮件给用户: " + user.getEmail());
11. }
12. }

复制代码

• 在这个WelcomeEmailListener类中，sendWelcomeEmail方法使用@EventListener注解标记，当UserRegisteredEvent事件被发布时，该方法就会被调用，从而实现发送欢迎邮件的逻辑。

4.事件监听器的灵活性和配置

• 监听多个事件：一个@EventListener注解的方法可以监听多个事件。可以通过方法参数的类型来指定要监听的事件。例如：

1. import org.springframework.context.event.EventListener;
2. import org.springframework.stereotype.Component;
4. @Component
5. public class MultipleEventListener {
6. @EventListener
7. public void handleEvents(UserRegisteredEvent userEvent, OrderPlacedEvent orderEvent) {
8. if (userEvent!= null) {
9. System.out.println("处理用户注册事件");
10. // 用户注册事件相关逻辑
11. }
12. if (orderEvent!= null) {
13. System.out.println("处理订单放置事件");
14. // 订单放置事件相关逻辑
15. }
16. }
17. }

复制代码

• 在这个例子中，handleEvents方法可以同时监听UserRegisteredEvent和OrderPlacedEvent事件，根据传入的参数类型来区分是哪个事件，并执行相应的逻辑。
• 异步监听事件：可以通过配置让事件监听器以异步方式执行，提高应用程序的性能和响应速度。在 Spring Boot 中，可以通过@EnableAsync注解来启用异步支持，然后在@EventListener注解中添加async = true属性。例如：

1. import org.springframework.context.annotation.Configuration;
2. import org.springframework.scheduling.annotation.EnableAsync;
4. @Configuration
5. @EnableAsync
6. public class AsyncConfig {
7. // 配置类内容
8. }

复制代码

• 然后在监听器方法中：

1. import org.springframework.context.event.EventListener;
2. import org.springframework.scheduling.annotation.Async;
3. import org.springframework.stereotype.Component;
5. @Component
6. public class AsyncEventListener {
7. @Async
8. @EventListener
9. public void handleAsyncEvent(UserRegisteredEvent event) {
10. // 异步执行的逻辑，如发送短信通知等，不会阻塞主线程
11. System.out.println("异步处理用户注册事件");
12. }
13. }

复制代码

5.SpringBoot内置的监听器

• Spring中内置监听器例如：ApplicationReadyEvent监听器、ApplicationStartedEvent监听器、ServletWebServerInitializedEvent监听器等。这些监听器可以通过实现 ApplicationListenner<> 泛型接口 泛型参数必须是 ApplicationEvent本身或者子类。
• 在这个例子中实现了 ApplicationReadyEvent 监听器，ApplicationReadyEvent是 Spring Boot 中一个非常重要的事件。它在 Spring 应用程序完全准备好接收请求之后触发，这意味着所有的 Spring bean 都已经被初始化，配置文件已经加载，并且应用程序上下文已经完全刷新。

1. import org.springframework.boot.context.event.ApplicationReadyEvent;
2. import org.springframework.context.ApplicationListener;
3. import org.springframework.stereotype.Component;
5. @Component
6. public class ApplicationReadyEventListener implements ApplicationListener<ApplicationReadyEvent> {
7. @Override
8. public void onApplicationEvent(ApplicationReadyEvent event) {
9. System.out.println("应用程序已准备好，可以开始接收请求啦！");
10. // 在这里可以进行数据库连接检查、缓存预热等操作
11. // 例如，这里加载一些redis缓存啦。什么什么的.......
12. }
13. }

复制代码

到此这篇关于SpringBoot事件监听器@EventListener的实现的文章就介绍到这了,更多相关SpringBoot @EventListener内容请搜索晓枫资讯以前的文章或继续浏览下面的相关文章希望大家以后多多支持晓枫资讯！ 

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

游秀艷

感谢楼主，顶。

卢方方

感谢楼主分享。