0
0

【SpringBoot3】Spring Boot Event 自定义事件的发布与监听

一、基本概况

1、什么是SpringBoot自定义事件

Spring Boot自定义事件是Spring框架中事件处理机制的一种扩展，它允许开发者在Spring Boot应用程序中定义、发布和监听自己的事件。这些事件可以用于在应用程序的不同组件之间进行通信，实现解耦和异步处理。通过自定义事件，开发者可以更加灵活地处理业务逻辑，提高系统的可扩展性和可维护性。

自定义事件通常继承自Spring的

  1. ApplicationEvent

类，并包含与事件相关的数据。开发者可以定义事件监听器来监听这些事件，并在事件发生时执行相应的逻辑。事件监听器可以通过实现

  1. ApplicationListener

接口或使用

  1. @EventListener

注解来创建。当事件被发布时，Spring容器会负责调用所有注册了对该事件感兴趣的监听器。

因此，Spring Boot自定义事件提供了一种强大的机制，允许开发者在不直接依赖其他组件的情况下进行通信和协作，从而实现更加松耦合和可扩展的系统设计。

2、SpringBoot自定义事件是主要作用

Spring Boot自定义事件在软件开发中起着非常重要的作用，主要体现在以下几个方面：

  1. 解耦：自定义事件允许应用程序的不同部分在不需要直接相互了解的情况下进行通信。这有助于降低模块间的耦合度，使得代码更加清晰、可维护，并方便扩展。
  2. 异步处理：通过事件机制，可以将某些操作异步化，提高系统的响应性能。例如，在用户注册成功后发送欢迎邮件或短信，这些操作可以通过事件监听器异步执行，不会阻塞主线程。
  3. 业务逻辑灵活性：自定义事件提供了一种灵活的方式来处理业务逻辑。通过定义不同的事件和监听器，可以轻松地添加、修改或删除业务逻辑，而无需修改与之无关的代码。
  4. 系统通知：当系统中发生重要事件时，可以使用自定义事件来通知其他部分。例如，当数据库中的某个表发生更改时，可以发布一个事件来通知其他服务或组件进行相应的处理。
  5. 可扩展性：由于自定义事件的解耦特性，它们使得系统更加容易扩展。新的功能或模块可以通过监听特定的事件来集成到现有系统中，而无需对现有代码进行大量修改。
  6. 日志记录和审计：自定义事件也可用于记录系统中发生的重要操作或事件，以便进行日志记录和审计。这对于系统的安全性和可追溯性非常重要。
  7. 状态管理：在某些场景下，自定义事件可用于管理系统的状态。例如，当某个长时间运行的任务完成时，可以发布一个事件来更新系统的状态或触发其他相关操作。

3、SpringBoot自定义事件相关核心类

在Spring Boot中，自定义事件处理涉及的核心类主要包括以下几个：

  1. ApplicationEvent：这是所有Spring事件类的基类。自定义事件需要继承这个类，并可以在其中添加自己的属性和方法。
  2. ApplicationEventPublisher：事件发布者接口，提供了publishEvent方法来发布事件。通常你会注入这个接口的实例来发布自定义事件。
  3. ApplicationListener：事件监听器接口，需要实现这个接口并提供要监听的事件类型。当指定类型的事件被发布时，监听器的onApplicationEvent方法会被调用。
  4. EventListener：这是一个注解，用于简化事件监听器的创建。你可以将这个注解添加到任何方法上，使其成为指定类型事件的监听器。
  5. ConfigurableApplicationContext：这是Spring应用上下文的接口，它扩展了ApplicationContext接口并添加了生命周期管理和其他功能。ApplicationEventPublisher通常是通过这个接口的实现类（如AnnotationConfigApplicationContext）来获取的。
  6. TransactionalEventListener：事务事件监听，可监听事务提交前、提交后、事务回滚、事务完成（成功或失败）

在实际开发中，你通常不会直接使用

  1. ConfigurableApplicationContext

，而是通过注入

  1. ApplicationEventPublisher

来发布事件，并通过实现

  1. ApplicationListener

接口或使用

  1. @EventListener

注解来创建事件监听器。这些核心类提供了构建自定义事件处理机制所需的基本构建块。

此外，还有一些与事件处理相关的支持类，如

  1. EventListenerMethodProcessor

，它是Spring内部用于处理

  1. @EventListener

注解的方法的类。但通常情况下，你不需要直接与这些内部类打交道。

二、使用步骤

在Spring Boot中，自定义事件的发布与监听主要依赖于Spring Framework的事件发布-订阅机制。以下是创建、发布和监听自定义事件的基本步骤：

1. 定义自定义事件

首先，你需要定义一个继承自

  1. ApplicationEvent

的自定义事件类。这个类可以包含任何你希望在事件触发时传递的数据。

  1. importorg.springframework.context.ApplicationEvent;publicclassCustomEventextendsApplicationEvent{privateString message;publicCustomEvent(Object source,String message){super(source);this.message = message;}publicStringgetMessage(){return message;}}

2. 发布自定义事件

要发布事件，你需要获取

  1. ApplicationEventPublisher

的实例，然后调用它的

  1. publishEvent

方法。这通常在Spring管理的Bean中完成。

  1. importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.context.ApplicationEventPublisher;importorg.springframework.stereotype.Component;@ComponentpublicclassEventPublisher{@AutowiredprivateApplicationEventPublisher applicationEventPublisher;publicvoiddoStuffAndPublishAnEvent(finalString message){System.out.println("Publishing custom event. ");CustomEvent customEvent =newCustomEvent(this, message);
  2.         applicationEventPublisher.publishEvent(customEvent);}}

3. 监听自定义事件

要监听事件，你需要创建一个实现

  1. ApplicationListener

接口的类，并指定要监听的事件类型。你也可以使用

  1. @EventListener

注解来简化监听器的创建。

使用

  1. ApplicationListener

接口：

  1. importorg.springframework.context.ApplicationListener;importorg.springframework.stereotype.Component;@ComponentpublicclassCustomEventListenerimplementsApplicationListener<CustomEvent>{@OverridepublicvoidonApplicationEvent(CustomEvent event){System.out.println("Received custom event - "+ event.getMessage());}}

或者使用

  1. @EventListener

注解：

  1. importorg.springframework.context.event.EventListener;importorg.springframework.stereotype.Component;@ComponentpublicclassCustomEventListener{@EventListenerpublicvoidhandleCustomEvent(CustomEvent event){System.out.println("Received custom event - "+ event.getMessage());}}

4. 触发事件发布

最后，你需要在某个地方触发事件发布。这通常是通过调用上面创建的

  1. EventPublisher

类的

  1. doStuffAndPublishAnEvent

方法来完成的。

  1. @AutowiredprivateEventPublisher eventPublisher;publicvoidsendEvent(){
  2.     eventPublisher.doStuffAndPublishAnEvent("Hello, world!");}

这就是在Spring Boot 3中创建、发布和监听自定义事件的基本流程。注意，虽然Spring Boot 3可能在某些细节上与之前的版本有所不同，但事件处理的核心机制自Spring Framework的早期版本以来一直相对稳定。确保你正在查看与你正在使用的Spring Boot版本相对应的文档和示例。

三、使用代码示例

示例1：不定义事件，直接发布Object对象，同步

1）定义发送事件对象

  1. publicclassUserEntity{privatelong id;privateString name;privateString msg;}

2）定义事件监听器

可以添加条件condition，限制监听具体的事件

  1. @Slf4j@ComponentpublicclassRegisterListener{@EventListener(condition ="#entity.id != null and #entity.async==false ")publicvoidhandlerEvent(UserEntity entity){try{// 休眠5秒TimeUnit.SECONDS.sleep(5);}catch(InterruptedException e){
  2.             e.printStackTrace();}
  3.         log.info("handlerEvent: {}", entity);}}

3）定义发送接口以及实现类

  1. publicinterfaceIRegisterService{publicvoidregister(String name);}
  1. @ServicepublicclassRegisterServiceImplimplementsIRegisterService{@ResourceprivateApplicationEventPublisher applicationEventPublisher;@Overridepublicvoidregister(String name){UserEntity entity =newUserEntity();
  2.         entity.setName(name);
  3.         entity.setId(1L);
  4.         entity.setMsg("新用户注册同步调用");
  5.         applicationEventPublisher.publishEvent(entity);}}

4）测试Controller类，进行测试

  1. @Slf4j@ControllerpublicclassTestController{@ResourceprivateIRegisterService registerService;@RequestMapping("test")@ResponseBodypublicvoidtest1(String name){
  2.         registerService.register(name);
  3.         log.info("执行同步调用结束");}}

在浏览器中输入地址：http://localhost/test?name=nik

控制台输出：

  1. handlerEvent: UserEntity(id=1, name=nik, msg=新用户注册同步调用)
  2. 执行同步调用结束

示例2：异步发布

1）在启动类添加异步注解 

  1. @EnableAsync

2）在监听方法上添加注解 

  1. @Async
  1. @Async@EventListener(condition ="#entity.name != null and #entity.async ")publicvoidhandlerEventAsync(UserEntity entity){try{TimeUnit.SECONDS.sleep(5);}catch(InterruptedException e){
  2.         e.printStackTrace();}
  3.     log.info("handlerEventAsync: {}", entity);}

3）在service中添加异步发送方法

  1. @OverridepublicvoidregisterAsyn(String name){UserEntity entity =newUserEntity();
  2.     entity.setName(name);
  3.     entity.setId(1L);
  4.     entity.setMsg("新用户注册异步调用");
  5.     entity.setAsync(true);
  6.     applicationEventPublisher.publishEvent(entity);}

4）测试

  1. @RequestMapping("test")@ResponseBodypublicvoidtest(String name){
  3.     registerService.registerAsyn(name);
  4.     log.info("执行异步调用结束");}

控制台输出：

  1. 执行异步调用结束
  2. handlerEventAsync: UserEntity(id=1, name=nik, msg=新用户注册异步调用)

示例3：在事务提交后发布事件

比如，用户注册成功后给用户发送成功短信，那么注册成功必然是注册方法事务提交成功后才代表成功。

Spring提供了注解

  1. @TransactionalEventListener

监听事务事件，在

  1. @EventListener

基础上增加了属性phase，包含以下四个值：

  • AFTER_COMMIT，事务提交成功后，默认
  • BEFORE_COMMIT，事务提交前
  • AFTER_ROLLBACK，事务回滚后
  • AFTER_COMPLETION，事务完成，AFTER_COMMIT 或 AFTER_ROLLBACK

1）自定义事务处理事件

  1. publicclassRegisterCommitEventextendsApplicationEvent{@Getter@SetterprivateString msg;@Getter@SetterprivateString name;publicRegisterCommitEvent(UserEntity source){super(source);this.msg = source.getMsg();this.name = source.getName();}}

2）在处理方法上添加事务注解，

  1. @Transactional
  1. @Override@TransactionalpublicvoidregisterCommit(String name){UserEntity entity =newUserEntity();
  2.     entity.setName(name);
  3.     entity.setMsg("新用户注册事务提交事件");RegisterCommitEvent registerEvent =newRegisterCommitEvent(entity);
  4.     userDao.save(entity);// 发送事件
  5.     applicationEventPublisher.publishEvent(registerEvent);}

3）添加事务事件监听

  1. @Async@TransactionalEventListener(phase =TransactionPhase.AFTER_COMMIT)publicvoidhandlerEventCmmit(RegisterCommitEvent event){try{TimeUnit.SECONDS.sleep(5);}catch(InterruptedException e){
  2.         e.printStackTrace();}
  3.     log.info("handlerEventCmmit: {}", event);}

4）测试

  1. @RequestMapping("test")@ResponseBodypublicvoidtest(String name){
  3.     registerService.registerCommit(name);
  4.     log.info("执行事务调用结束");}

控制台输出：

  1. 执行事务调用结束
  2. handlerEventCmmit: RegisterCommitEvent[source=UserEntity(id=0, name=nik, msg=新用户注册事务提交事件)]

总结

Spring ApplicationEvent事件处理机制使用起来简单方便，可以对程序进行有效解耦。

虽然可以发送任意类型的对象，但是在实际业务中容易产生混乱，建议根据实际业务，定义好各类事件，并在监听方法中实现异步处理。

标签： spring boot java spring
本文转载自: https://blog.csdn.net/wlddhj/article/details/136466064
版权归原作者 顽石九变 所有， 如有侵权，请联系我们删除。
登录后发布评论

“【SpringBoot3】Spring Boot Event 自定义事件的发布与监听”的评论:

还没有评论
关于作者
...
overfit同步小助手
文章同步
相关阅读

网络安全法-网络运行安全

使用selenium/drissionpage时如何阻止chrome自动跳转http到https

docker desktop 里部署的Open WebUI 管理员密码忘记了的处理方法

在ubuntu20.04中搭建onsite比赛运行环境

利用开源的低代码表单设计器FcDesigner高效管理和渲染复杂表单结构

Kafka学习笔记

【前端】浏览器输入url到页面呈现发生了什么？