使用Spring Event优雅实现业务需求。

文章目录

  • 一. 什么是Spring Event
  • 二. 为什么要用Spring Event
  • 三. 使用Spring Event实现邮件发送

一. 什么是Spring Event

从英文释义来看,Event=事件,Spring即在Spring框架下。那么这就是一个Spring框架事件,结合生活实际来看,发生了一个事件需要被应急响应。

举个例子,我们发生了火灾事件,那么该事件需要被火警接线员知情(即有人拨打119电话告诉一声),出警(接线员通知消防员进行响应),灭火(消防员实际需要做的事情),善后(做完最主要的动作之后需要做的事情),最后撤退(结束)。

这里的每一件事都是关联在一起的,而对于第一个发现火情的人需要参与每一个环节吗,答案是不需要,他只需要拿起电话拨打119并告诉接线员发生火情的地点,后续的事情就开始运转起来了。

这就是Spring Event事件通知机制的原理:

  1. 定义一个事件
  2. 定义一个事件监听
  3. 定义一个事件推送

二. 为什么要用Spring Event

假设我们推翻Event事件通知机制,继续回到我们上述的火警事件中,没有火警接线员(没有事件监听),发现火情的人打119发现没有人接听了,这个时候就需要让发现火情的人吭哧吭哧跑到消防队办公室,大喊一声哪里有火情快去灭火。

这里就会引申出两个问题:

  1. 事件发现者除了发现火情,还需要关注实际处理问题的人住处在哪里
  2. 等到通知消防队员,火情可能都已经过去了

回到我们写代码的设计模式原则,我们知道代码之间需要高内聚低耦合。所以解耦是很重要的,即多方之间互不影响。而引入事件机制就只需要关注事件本身,至于具体谁去处理,谁去处理就让后续流程来决定。

三. 使用Spring Event实现邮件发送

  1. 自定义邮箱事件:定义相关事件所需要的属性
/*** <自定义邮箱事件>*/
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;}}
  1. 设置事件推送(这里使用了异步非阻塞发送,详见监听器)
/*** 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));}}
  1. 事件监听器(使用@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());}
}
  1. 测试事件发布
@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事件发布机制相关推荐

  1. Spring的事件发布机制

    一:Spring的事件发布 ApplicationContext提供了针对Bean的事件传播功能,其中的主角是publishEvent()方法,通过这个方法可以将事件通知给系统内的监听器(需实现App ...

  2. Spring事件发布机制

    目录 前言 一.事件驱动机制 二.Spring的事件发布机制 三.Spring事件使用实例 四.Spring事件驱动的实现原理 总结: 前言 在设计模式中有一种设计模式叫做观察者设计模式,观察者模式的 ...

  3. Spring IoC 源码系列(三)Spring 事件发布机制原理分析

    在 IoC 容器启动流程中有一个 finishRefresh 方法,具体实现如下: protected void finishRefresh() {clearResourceCaches();init ...

  4. spring中事件发布设计与实现

    spring中的事件发布框架依赖于三个抽象,ApplicationEvent,ApplicationListener,ApplicationEventPublisher.ApplicationEven ...

  5. Spring Boot使用ApplicationEvent来实现事件发布订阅功能(美女一个都不能少,都要通知到) - 第420篇

    历史文章(累计400+篇文章) <国内最全的Spring Boot系列之一> <国内最全的Spring Boot系列之二> <国内最全的Spring Boot系列之三&g ...

  6. 【转载】SpringBoot 事件发布监听机制使用

    前言 这一篇从应用角度来跟大伙讲讲 这个 spring 事件监听机制 ,顺便涉及到那些我认为大家应该一块了解的,我也会展开说说. 文章内容(包括不限于) : 1. 对比观察者模式 2. 应用场景的分析 ...

  7. spring事件通知机制详解

    优势 解耦 对同一种事件有多种处理方式 不干扰主线(main line) 起源 要讲spring的事件通知机制,就要先了解一下spring中的这些接口和抽象类: ApplicationEventPub ...

  8. Spring事件发布

    Spring 事件发布 Author: xiaolu 概要: Spring的ApplicationContext在BeanFactory的基础上,支持事件的发布(包括同步-默认,和异步事件). 事件发 ...

  9. Spring事件发布与监听

    最近算是把spring整体的又过了一遍,发现很多东西虽然用的多,但是有些思想理解的不够透彻,在此记录下, 顺便感叹下,spring源码看了大部分,这才没过多久又忘了 TnT . 一.事件监听相关概念介 ...

最新文章

  1. 蚂蚁爬杆问题php,PHP实现的蚂蚁爬杆路径算法代码_php技巧
  2. linux下的lamp环境的搭建!!!
  3. linux的零碎知识
  4. 20211209 为什么Barbalat引理推论中必须有导数一致有界,才能得到导数趋于0
  5. String.equals用法注意
  6. java web 连接linux_如何将javaweb项目部署到linux下
  7. SQL 数据发现和分类
  8. 怎么在jquery里清空文本框的内容
  9. android 相机权限_暴力破姐权限,吹爆这款软件...
  10. [转]Go语言(golang)开源项目大全
  11. 深入理解LSTM神经网络
  12. Java 在命令行编译Java源码
  13. 从“NVIDIA禁令”看如何正确选择NVIDIA GPU卡
  14. 关于产品的一些思考——豌豆荚之应用下载
  15. ACE_TAO 014 ACE_Event_Handler
  16. 日本使用ips细胞制作“类器官”的最新进展
  17. Oracle锁3:DDL锁
  18. 基于Ad hoc的多跳通信
  19. 我的物联网项目(二十七) 分布式锁粗心导致大量阻塞
  20. 五大领域总目标指南_五大领域总目标和各年龄段目标 -

热门文章

  1. 利用 MQL5 云网络加速计算
  2. 计算机考试保护大熊猫,2019年6月大学英语四级翻译题:大熊猫
  3. 玩转【斗鱼直播APP】系列之框架搭建
  4. OpenStack虚拟机部署K8S集群,使用Cinder提供PV报错:mount: special device does not exist
  5. DynamicDet
  6. PyTorch 从零训练卷积神经网络(Convent)
  7. 性能度量 - 对学习器泛化能力的评估
  8. 怎么样用虚拟主机搭建网站呢?
  9. python命令行窗口最大化快捷键_PyCharm 在Windows的有用快捷键详解
  10. 设置Tomcat的UTF-8编码