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、事件驱动:观察者设计模式基于事件驱动,当被观察者状态发生改变时,会自动通知所有注册的观察者。这种机制使得系统响应更加及时和准确。

学海无涯苦作舟!!!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/766461.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

独立服务器和云计算各有什么优势?

独立服务器和云计算都是在不同场景下应用广泛的计算解决方案。德迅云安全和您来探讨独立服务器和云计算的优势,并对比它们在性能、灵活性、可扩展性、成本效益和安全性等方面的差异,帮助读者更好地理解并选择适合自己需求的解决方案。 独立服务器和云计算…

jmeter之接口功能自动化

一、接口测试简述 接口:用来连接前端,后端还有移动端的程序模块。由于不同端的工作进度不一样,需要对最开始出来的接口进行接口测试。 接口分类:POST,GET,PUT,DELETE。 POST请求的数据是放在…

Linux系统下C++程序运行时的内存布局详解。【C++】

Linux系统下C程序的虚拟内存模型。 1.程序代码段存储内容生命周期初始化时机特点代码演示 2.只读初始化数据段存储内容生命周期初始化时机特点代码演示 3.读写初始化数据段存储内容生命周期初始化时机特点代码演示 4. 堆区(Heap)存储内容生命周期初始化时…

相交链表:寻找链表的公共节点

目录 一、公共节点 二、题目 三、思路 四、代码 五、代码解析 1.计算长度 2.等长处理 3.判断 六、注意点 1.leetcode的尿性 2.仔细观察样例 3.经验总结 一、公共节点 链表不会像两直线相交一样,相交之后再分开。 由于单链表只有一个next指针&#xff0…

Linux:Jenkins全自动持续集成持续部署(3)

在上一章部署好了之后,还需要点击一下才能进行部署,本章的效果是:当gitlab上的代码发生了变化后,我们不需要做任何事情不需要去点击构建按钮,Jenkins直接自动检测变化,然后自动去集成部署Linux:…

Dr4g0n

信息收集 # nmap -sn 192.168.56.0/24 -oN live.nmap Starting Nmap 7.94 ( https://nmap.org ) at 2024-03-04 08:52 CST Nmap scan report for 192.168.56.2 Host is up (0.00012s latency). MAC Address: 00:50:56:FE:B1:6F (VMware) Nmap scan report …

MATLAB下载+安装教程

下载 MATLAB: 访问 MathWorks 官方网站:MathWorks 官方网站在网站上找到 "Downloads"(下载)选项,并选择 MATLAB。登录或创建一个 MathWorks 帐号。选择您希望下载的 MATLAB 版本,并根据您的操作…

二进制源码部署mysql8.0.35

二进制部署mysql8.0.35 创建mysql用户 [rootzyq ~]#: useradd -r -s /sbin/nologin -M mysql [rootzyq ~]#: id mysql uid990(mysql) gid990(mysql) groups990(mysql)上传mysql文件 [rootzyq ~]#: ls anaconda-ks.cfg mysql-8.0.35-linux-glibc2.28-x86_64.tar.xz解压 [roo…

Uniapp manifest

manifest.json 应用配置 manifest.json 文件是应用的配置文件,用于指定应用的名称、图标、权限等。HBuilderX 创建的工程此文件在根目录,CLI 创建的工程此文件在 src 目录。 #配置项列表 属性类型默认值描述最低版本nameString应用名称appidString新建…

飞鸟写作靠谱吗 #知识分享#媒体

飞鸟写作是一个被广泛使用的论文写作工具,它不仅可以帮助用户快速完成论文写作,还可以进行查重和降重,确保论文的原创性。那么,飞鸟写作到底靠不靠谱呢?在我看来,飞鸟写作绝对是一个靠谱的工具。 首先&…

hadoop基本概念

一、概念 Hadoop 是一个开源的分布式计算和存储框架。 Hadoop 使用 Java 开发,所以可以在多种不同硬件平台的计算机上部署和使用。其核心部件包括分布式文件系统 (Hadoop DFS,HDFS) 和 MapReduce。 二、HDFS 命名节点 (NameNode) 命名节点 (NameNod…

【ai技术】(4):在树莓派上,使用qwen0.5b大模型+chatgptweb,搭建本地大模型聊天环境,速度飞快,非常不错!

1,视频地址 https://www.bilibili.com/video/BV1VK421i7CZ/ 2,下载镜像 raspberry-pi-os-64-bit https://blog.csdn.net/freewebsys/article/details/136921703 项目地址: https://www.raspberrypi.com/software/operating-systems/#rasp…

【数据挖掘】实验5:数据预处理(1)

实验5:数据预处理(1) 一:实验目的与要求 1:熟悉和掌握数据预处理,学习数据清洗、数据集成、数据变换、数据规约、R语言中主要数据预处理函数。 二:实验内容 【缺失值分析】 第一步&#xff1…

jmeter使用方法---自动化测试

HTTP信息头管理器 一个http请求会发送请求到服务器,请求里面包含:请求头、请求正文、请求体,请求头就是信息头Authorization头的主要用作http协议的认证。 Authorization的作用是当客户端访问受口令保护时,服务器端会发送401状态…

C语言UDP基础CS模型

CS模型UDP流程: 服务器: socket->bind->recvfrom->sendto->close 客户端: socket->sendto->recvfrom->close 代码说明: 1 未使用更先进的服务器模型,用基础单线程阻塞(recvfrom)作为演示 2 服务器使用while循环接收客户端消息 3 适用于同一网段的不…

使用 Flink + Faker Connector 生成测试数据压测 MySQL

博主历时三年精心创作的《大数据平台架构与原型实现:数据中台建设实战》一书现已由知名IT图书品牌电子工业出版社博文视点出版发行,点击《重磅推荐:建大数据平台太难了!给我发个工程原型吧!》了解图书详情,…

day06vue2学习

day06 路由的封装抽离 问题:所有的路由配置都堆在main.js中不太合适么?不好,会加大代码的复杂度 目标:将路由模块抽离出来。好处:差分模块,利于维护。 大致的做法就是,将路由相关的东西都提…

Python界面库Flet(1)介绍和快速使用

Python界面库Flet(1)快速上手使用 Author:Once Day Date:2024年3月19日 一位热衷于Linux学习和开发的菜鸟,试图谱写一场冒险之旅,也许终点只是一场白日梦… 漫漫长路,有人对你微笑过嘛… 全系列文章可参考专栏: Pyt…

【QT+QGIS跨平台编译】之九十:【QGIS_Crashhandler+Qt跨平台编译】(一套代码、一套框架,跨平台编译)

文章目录 一、QGIS_Crashhandler介绍二、QGIS下载三、文件分析四、pro文件五、编译实践一、QGIS_Crashhandler介绍 QGIS_Crashhandler模块是QGIS中的一个重要组成部分,它提供了QGIS程序的错误崩溃处理与跟踪。 二、QGIS下载 QGIS网址: QGIS Source Download 获取最新版本的…

RabbitMq高可用

消息队列高级 服务异步通信-高级篇1.消息可靠性1.1.生产者消息确认1.2.消息持久化1.3.消费者消息确认1.4.消费失败重试机制1.5.总结 2.死信交换机2.1.初识死信交换机2.2.TTL2.3.延迟队列 3.惰性队列3.1.消息堆积问题3.2.惰性队列 4.MQ集群4.1.集群分类4.2.普通集群4.3.镜像集群…