Spring Event事件发布机制
使用Spring Event优雅实现业务需求。
文章目录
- 一. 什么是Spring Event
- 二. 为什么要用Spring Event
- 三. 使用Spring Event实现邮件发送
一. 什么是Spring Event
从英文释义来看,Event=事件,Spring即在Spring框架下。那么这就是一个Spring框架事件,结合生活实际来看,发生了一个事件需要被应急响应。
举个例子,我们发生了火灾事件,那么该事件需要被火警接线员知情(即有人拨打119电话告诉一声),出警(接线员通知消防员进行响应),灭火(消防员实际需要做的事情),善后(做完最主要的动作之后需要做的事情),最后撤退(结束)。
这里的每一件事都是关联在一起的,而对于第一个发现火情的人需要参与每一个环节吗,答案是不需要,他只需要拿起电话拨打119并告诉接线员发生火情的地点,后续的事情就开始运转起来了。
这就是Spring Event事件通知机制的原理:
- 定义一个事件
- 定义一个事件监听
- 定义一个事件推送
二. 为什么要用Spring Event
假设我们推翻Event事件通知机制,继续回到我们上述的火警事件中,没有火警接线员(没有事件监听),发现火情的人打119发现没有人接听了,这个时候就需要让发现火情的人吭哧吭哧跑到消防队办公室,大喊一声哪里有火情快去灭火。
这里就会引申出两个问题:
- 事件发现者除了发现火情,还需要关注实际处理问题的人住处在哪里
- 等到通知消防队员,火情可能都已经过去了
回到我们写代码的设计模式原则,我们知道代码之间需要高内聚低耦合。所以解耦是很重要的,即多方之间互不影响。而引入事件机制就只需要关注事件本身,至于具体谁去处理,谁去处理就让后续流程来决定。
三. 使用Spring Event实现邮件发送
- 自定义邮箱事件:定义相关事件所需要的属性
/*** <自定义邮箱事件>*/
public class EmailEvent extends ApplicationEvent {// 标题private String subject;// 内容private String content;// 发件人private String sender;// 授权码private String authorizationCode;// 收件人private String receiver;/*** @param source*/public EmailEvent(Object source) {super(source);}public EmailEvent(Object source,String subject, String content, String receiver) {super(source);this.subject = subject;this.content = content;this.receiver = receiver;}public String getSubject() {return subject;}public void setSubject(String subject) {this.subject = subject;}public String getContent() {return content;}public void setContent(String content) {this.content = content;}public String getAuthorizationCode() {return authorizationCode;}public void setAuthorizationCode(String authorizationCode) {this.authorizationCode = authorizationCode;}public String getSender() {return sender;}public void setSender(String sender) {this.sender = sender;}public String getReceiver() {return receiver;}public void setReceiver(String receiver) {this.receiver = receiver;}}
- 设置事件推送(这里使用了异步非阻塞发送,详见监听器)
/*** ApplicationEventPublisher邮件推送*/
@Component
public class SendmaillEventPublisher {@Autowiredprivate ApplicationEventPublisher publisher;public void sendMailAsync(String subject, String content, String email) {publisher.publishEvent(new EmailEvent(this,subject, content, email));}}
- 事件监听器(使用@Async(“taskExecutor”)注解实现异步)
/*** 〈邮箱发送〉* 发送邮件*/
@Component
public class SendmailListener implements ApplicationListener<EmailEvent> {@Override@Async("taskExecutor")public void onApplicationEvent(EmailEvent emailEvent) {if (emailEvent == null) {return ;}System.out.println("开始发送邮件..." + emailEvent.getContent());// 除了发送邮件支持做一些其他的事情...模拟长时间处理事务try {Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("发送邮件结束..." + emailEvent.getContent());}
}
- 测试事件发布
@RestController
public class MailEventController {@AutowiredSendmaillEventPublisher publisher;/*** 异步邮件发送* @return*/@GetMapping("sendMailAsync")public String sendMailAsync(String content){publisher.sendMailAsync("subject", content, "xxx@xxx.com");publisher.sendMailAsync("subject", content, "xxx@xxx.com");return "success";}
}
以上就是一个简单的事件发布实现。
参考资料:
- Spring Event的同步和异步,以及实现机制
- Spring event 使用指南
- SpringBoot使用ApplicationEvent&Listener完成业务解耦
- 邮件发送spring boot+ApplicationEventPublisher+线程池异步实现邮件发送
- 接口回调
Spring Event事件发布机制相关推荐
- Spring的事件发布机制
一:Spring的事件发布 ApplicationContext提供了针对Bean的事件传播功能,其中的主角是publishEvent()方法,通过这个方法可以将事件通知给系统内的监听器(需实现App ...
- Spring事件发布机制
目录 前言 一.事件驱动机制 二.Spring的事件发布机制 三.Spring事件使用实例 四.Spring事件驱动的实现原理 总结: 前言 在设计模式中有一种设计模式叫做观察者设计模式,观察者模式的 ...
- Spring IoC 源码系列(三)Spring 事件发布机制原理分析
在 IoC 容器启动流程中有一个 finishRefresh 方法,具体实现如下: protected void finishRefresh() {clearResourceCaches();init ...
- spring中事件发布设计与实现
spring中的事件发布框架依赖于三个抽象,ApplicationEvent,ApplicationListener,ApplicationEventPublisher.ApplicationEven ...
- Spring Boot使用ApplicationEvent来实现事件发布订阅功能(美女一个都不能少,都要通知到) - 第420篇
历史文章(累计400+篇文章) <国内最全的Spring Boot系列之一> <国内最全的Spring Boot系列之二> <国内最全的Spring Boot系列之三&g ...
- 【转载】SpringBoot 事件发布监听机制使用
前言 这一篇从应用角度来跟大伙讲讲 这个 spring 事件监听机制 ,顺便涉及到那些我认为大家应该一块了解的,我也会展开说说. 文章内容(包括不限于) : 1. 对比观察者模式 2. 应用场景的分析 ...
- spring事件通知机制详解
优势 解耦 对同一种事件有多种处理方式 不干扰主线(main line) 起源 要讲spring的事件通知机制,就要先了解一下spring中的这些接口和抽象类: ApplicationEventPub ...
- Spring事件发布
Spring 事件发布 Author: xiaolu 概要: Spring的ApplicationContext在BeanFactory的基础上,支持事件的发布(包括同步-默认,和异步事件). 事件发 ...
- Spring事件发布与监听
最近算是把spring整体的又过了一遍,发现很多东西虽然用的多,但是有些思想理解的不够透彻,在此记录下, 顺便感叹下,spring源码看了大部分,这才没过多久又忘了 TnT . 一.事件监听相关概念介 ...
最新文章
- 蚂蚁爬杆问题php,PHP实现的蚂蚁爬杆路径算法代码_php技巧
- linux下的lamp环境的搭建!!!
- linux的零碎知识
- 20211209 为什么Barbalat引理推论中必须有导数一致有界,才能得到导数趋于0
- String.equals用法注意
- java web 连接linux_如何将javaweb项目部署到linux下
- SQL 数据发现和分类
- 怎么在jquery里清空文本框的内容
- android 相机权限_暴力破姐权限,吹爆这款软件...
- [转]Go语言(golang)开源项目大全
- 深入理解LSTM神经网络
- Java 在命令行编译Java源码
- 从“NVIDIA禁令”看如何正确选择NVIDIA GPU卡
- 关于产品的一些思考——豌豆荚之应用下载
- ACE_TAO 014 ACE_Event_Handler
- 日本使用ips细胞制作“类器官”的最新进展
- Oracle锁3:DDL锁
- 基于Ad hoc的多跳通信
- 我的物联网项目(二十七) 分布式锁粗心导致大量阻塞
- 五大领域总目标指南_五大领域总目标和各年龄段目标 -
热门文章
- 利用 MQL5 云网络加速计算
- 计算机考试保护大熊猫,2019年6月大学英语四级翻译题:大熊猫
- 玩转【斗鱼直播APP】系列之框架搭建
- OpenStack虚拟机部署K8S集群,使用Cinder提供PV报错:mount: special device does not exist
- DynamicDet
- PyTorch 从零训练卷积神经网络(Convent)
- 性能度量 - 对学习器泛化能力的评估
- 怎么样用虚拟主机搭建网站呢?
- python命令行窗口最大化快捷键_PyCharm 在Windows的有用快捷键详解
- 设置Tomcat的UTF-8编码