java 事件驱动模型(事件发布和监听@EventListener)

2024-03-24 14:20

本文主要是介绍java 事件驱动模型(事件发布和监听@EventListener),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

一、需要了解的概念
1、Aware机制:
Spring 容器在创建 bean 的过程中,会检查 bean 是否实现了某些特定的 Aware 接口,如果实现了,则会在合适的时机调用相应的 setter 方法,将相关的对象注入到 bean 中。

2、ApplicationEvent:
是Spring框架中的一个核心类,它表示Spring应用中的事件。这个类基于观察者模式,为Bean与Bean之间的消息通信提供了支持,是业务解耦的一种实现。常用于标识继承的类为一个事件类。

3、ApplicationEventPublisherAware:
ApplicationEventPublisherAware接口使得 bean 能够访问 Spring 的 ApplicationEventPublisher(事件发布者)。这个发布者允许 bean 发布应用事件,这些事件随后会被注册为监听器的其他 bean 接收。常用于定义发布事件的方法,给业务需要的地方进行调用。

二、代码示例
1、声明一个事件

import org.springframework.context.ApplicationEvent;
// 定义事件--如:邮件事件
public class EmailEvent extends ApplicationEvent {public EmailEvent(Object source) {super(source);}
}

2、定义事件的发布方法

import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.ApplicationEventPublisherAware;
import org.springframework.stereotype.Component;// 定义发布事件方法,用于业务发布各种事件
@Component
public class EmailPublish implements ApplicationEventPublisherAware, ApplicationContextAware {// ApplicationEventPublisherAware实现了Aware接口,容器加载EmailPublish时,会促发Aware机制// 本例EmailPublish对象实现了ApplicationEventPublisherAware接口,所以在创建bean过程会调用setApplicationEventPublisher方法,setApplicationEventPublisher的入参ApplicationEventPublisher会自动从容器中传入,所以生成的DataEventPublish对象就包含了初始化好的applicationEventPublisher属性对象。// Spring 框架中的一个核心组件,俗称应用上下文,常用来获取和管理应用中的bean对象private ApplicationContext applicationContext;//  Spring 框架中的一个核心组件,它提供了事件发布的功能private ApplicationEventPublisher applicationEventPublisher;@Overridepublic void setApplicationContext(ApplicationContext applicationContext) throws BeansException {this.applicationContext = applicationContext;}@Overridepublic void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {this.applicationEventPublisher = applicationEventPublisher;}// 生明发布邮件事件的方法public void publishEmail(Object source) {// applicationEventPublisher.publishEvent为向运行容器中发布事件,参数指定了发布什么类型的事件// 发布EmailEvent事件,监听EmailEvent事件的地方会被执行applicationEventPublisher.publishEvent(new EmailEvent(source));}}

3、调用发布

@Service
public class EventServiceImpl implements EventService {
@Autowired
private EmailPublish publish;@Overridepublic void testPublishEvent(EvDto evDto) {System.out.println("进入service");// 调用发布邮件的事件方法publish.publishEmail(evDto);}
}

4、监听事件,处理业务

import com.alibaba.fastjson.JSON;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
// 监听事件,实现业务
@Component
public class EmailPublishListener {@Transactional(propagation = Propagation.NEVER)@EventListener(classes = {EmailEvent.class})public void listenerEvent(EmailEvent event){System.out.println("进入邮件监听方法");Object source = event.getSource();System.out.println("调用的入参数据:"+ JSON.toJSONString(source));// 执行业务...}
}

思路:
定义事件–定义发布方法–定义监听方法–调用发布

三、优势
本例的事件驱动模型是一种典型的观察者设计模式,它使得组件之间的解耦更为容易,也使得代码更加灵活和可扩展。通过发布和监听事件,你可以在不直接依赖其他组件的情况下实现组件间的通信和协作。
优点:
1、解耦:观察者设计模式实现了观察者与被观察者之间的解耦,降低了两者之间的耦合关系。这使得两者可以各自独立地改变,而不需要对另一方进行大量的修改。
2、灵活性和可扩展性:由于观察者设计模式允许动态地添加或删除观察者,因此系统具有很好的灵活性和可扩展性。新的观察者可以很容易地添加到系统中,而无需修改被观察者的代码。
3、事件驱动:观察者设计模式基于事件驱动,当被观察者状态发生改变时,会自动通知所有注册的观察者。这种机制使得系统响应更加及时和准确。

学海无涯苦作舟!!!

这篇关于java 事件驱动模型(事件发布和监听@EventListener)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/841852

相关文章

一文详解SpringBoot中控制器的动态注册与卸载

《一文详解SpringBoot中控制器的动态注册与卸载》在项目开发中,通过动态注册和卸载控制器功能,可以根据业务场景和项目需要实现功能的动态增加、删除,提高系统的灵活性和可扩展性,下面我们就来看看Sp... 目录项目结构1. 创建 Spring Boot 启动类2. 创建一个测试控制器3. 创建动态控制器注

Java操作Word文档的全面指南

《Java操作Word文档的全面指南》在Java开发中,操作Word文档是常见的业务需求,广泛应用于合同生成、报表输出、通知发布、法律文书生成、病历模板填写等场景,本文将全面介绍Java操作Word文... 目录简介段落页头与页脚页码表格图片批注文本框目录图表简介Word编程最重要的类是org.apach

Spring Boot中WebSocket常用使用方法详解

《SpringBoot中WebSocket常用使用方法详解》本文从WebSocket的基础概念出发,详细介绍了SpringBoot集成WebSocket的步骤,并重点讲解了常用的使用方法,包括简单消... 目录一、WebSocket基础概念1.1 什么是WebSocket1.2 WebSocket与HTTP

SpringBoot+Docker+Graylog 如何让错误自动报警

《SpringBoot+Docker+Graylog如何让错误自动报警》SpringBoot默认使用SLF4J与Logback,支持多日志级别和配置方式,可输出到控制台、文件及远程服务器,集成ELK... 目录01 Spring Boot 默认日志框架解析02 Spring Boot 日志级别详解03 Sp

java中反射Reflection的4个作用详解

《java中反射Reflection的4个作用详解》反射Reflection是Java等编程语言中的一个重要特性,它允许程序在运行时进行自我检查和对内部成员(如字段、方法、类等)的操作,本文将详细介绍... 目录作用1、在运行时判断任意一个对象所属的类作用2、在运行时构造任意一个类的对象作用3、在运行时判断

java如何解压zip压缩包

《java如何解压zip压缩包》:本文主要介绍java如何解压zip压缩包问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Java解压zip压缩包实例代码结果如下总结java解压zip压缩包坐在旁边的小伙伴问我怎么用 java 将服务器上的压缩文件解压出来,

SpringBoot中SM2公钥加密、私钥解密的实现示例详解

《SpringBoot中SM2公钥加密、私钥解密的实现示例详解》本文介绍了如何在SpringBoot项目中实现SM2公钥加密和私钥解密的功能,通过使用Hutool库和BouncyCastle依赖,简化... 目录一、前言1、加密信息(示例)2、加密结果(示例)二、实现代码1、yml文件配置2、创建SM2工具

Spring WebFlux 与 WebClient 使用指南及最佳实践

《SpringWebFlux与WebClient使用指南及最佳实践》WebClient是SpringWebFlux模块提供的非阻塞、响应式HTTP客户端,基于ProjectReactor实现,... 目录Spring WebFlux 与 WebClient 使用指南1. WebClient 概述2. 核心依

Spring Boot @RestControllerAdvice全局异常处理最佳实践

《SpringBoot@RestControllerAdvice全局异常处理最佳实践》本文详解SpringBoot中通过@RestControllerAdvice实现全局异常处理,强调代码复用、统... 目录前言一、为什么要使用全局异常处理?二、核心注解解析1. @RestControllerAdvice2

Spring IoC 容器的使用详解(最新整理)

《SpringIoC容器的使用详解(最新整理)》文章介绍了Spring框架中的应用分层思想与IoC容器原理,通过分层解耦业务逻辑、数据访问等模块,IoC容器利用@Component注解管理Bean... 目录1. 应用分层2. IoC 的介绍3. IoC 容器的使用3.1. bean 的存储3.2. 方法注