点赞再看,养成习惯,微信搜索「小大白日志」关注这个搬砖人。

文章不定期同步公众号,还有各种一线大厂面试原题、我的学习系列笔记。

spring事件发布与监听的应用场景

当处理完一段代码逻辑,接下来需要同时执行多个任务,有什么好方法呢?如果在微服务项目中,当属MQ莫属了;但如果是单机,spring为我们也提供了[事件发布-监听]机制去处理这种逻辑,主要有@EventListener型和@TransactionalEventListener型两种方式

@EventListener型发布与监听

一般有【实体类+事件类+事件发布类+事件监听类】,以下模拟“添加新用户”后,需要同时进行多个任务为例(异步)

//实体类
@Data
public class User {
private String name;
private String operate;
}
//事件类
@Setter
@Getter
public class UserEvent extends ApplicationEvent{ //事件类必须继承ApplicationEvent
private User user;
public UserEvent(Object source) {
super(source);
}
}
//事件发布类
@Service
@Slf4j
public class UserServiceImpl {
@Autowired
private ApplicationEventPublisher applicationEventPublisher; public void addUser(){
User user=new User();
user.setName("afei");
user.setOperate("add");
UserEvent userEvent=new UserEvent(this);
userEvent.setUser(user);
insertUser(user);//user入库
applicationEventPublisher.publishEvent(userEvent);//"事件发布类"发布UserEvent事件以便给"事件监听类"监听到
log.info("{},发布[添加新用户]事件成功...",Thread.currentThread().getName());
} public void insertUser(User user){}
}
//事件监听类
@Component //必须让spring扫描到
@Slf4j
public class UserListerner { /*
*执行多任务
*/
@Async //@Async可以开启一个异步任务(启动类要加@EnableAsync),因为监听默认是同步的:监听到UserEvent类事件后,执行本方法代码,然后返回原链路继续执行原来的代码;有了@Async就可以以线程的方式异步执行本方法
@EventListener(value = UserEvent.class,condition = "#userEvent.user.operate=='add'") //只监听userEvent.user.operate='add'的UserEvent事件,#userEvent与afterAddUser()方法的参数名一致
public void afterAddUser(UserEvent userEvent){
try {
Thread.sleep(300); //停300ms,方便观察异步线程
} catch (InterruptedException e) {
e.printStackTrace();
}
User user=userEvent.getUser();
log.info("{},监听到[添加新用户]事件:{}",Thread.currentThread().getName(),user.toString());
//去数据库查询出user并执行多个任务:发邮件、送体验卡..
bussinessOperate(getUserByUserName(user.getUserName());
}
void bussinessOperate(User user){}
}
//启动类
@EnableAsync //开启对异步任务的支持,开启@EnableAsync之后@Async才能使用
@SpringBootApplication
public class DemoTestApplication { public static void main(String[] args) {
SpringApplication.run(DemoTestApplication.class, args);
} }
//测试类
public class TestEvent extends BaseTest{
@Autowired
UserServiceImpl userService; @Test
public void test(){
userService.addUser();
}
}
//测试基础类
@Slf4j
@RunWith(SpringRunner.class)
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
public class BaseTest {
@Before
public void before(){
log.info("单元测试before...");
} @After
public void after(){
log.info("单元测试after...");
}
}

运行后结果:

@TransactionalEventListener型发布与监听

虽然上面@EventListener型解决了单机下多任务的发布监听,但是上面"事件发布"后如果没有提交当前事务,则"事件监听"就去数据库里查询user并执行多个任务,user不存在会报空指针,解决方法是用@TransactionalEventListener保证在"事件发布"后提交了当前事务,才会去执行“事件监听”

//除了事件监听类有点不同,其他代码均与上面一致,事件监听类:
@Component
@Slf4j
public class UserListerner { //@EventListener //单纯监听UserEvent类事件
@Async //@Async可以开启一个异步任务(启动类要@EnableAsync),因为监听默认是同步的:监听到UserEvent类事件后,执行下面的代码,然后返回原链路继续执行原来的代码
@TransactionalEventListener(phase= TransactionPhase.AFTER_COMMIT,fallbackExecution = true) //phase默认为TransactionPhase.AFTER_COMMIT,它指定了在事件发布的相关事务提交后才会去执行以下监听方法;fallbackExecution默认为false,指如果"事件发布"不存在事务,则不会执行监听方法,如果为true则不管“事件发布”有没有事务,都会执行以下监听方法
public void afterAddUser(UserEvent userEvent){
try {
Thread.sleep(300);
} catch (InterruptedException e) {
e.printStackTrace();
}
User user=userEvent.getUser();
log.info("{},监听到[添加新用户]事件:{}",Thread.currentThread().getName(),user.toString());
//业务操作:发邮件、送体验卡...
bussinessOperate();
} void bussinessOperate(){}
}

OK,如果文章哪里有错误或不足,欢迎各位留言。

创作不易,各位的「三连」是二少创作的最大动力!我们下期见!

spring中的事件发布与监听的更多相关文章

  1. JavaEE开发之Spring中的事件发送与监听以及使用@Profile进行环境切换

    本篇博客我们就来聊一下Spring框架中的观察者模式的应用,即事件的发送与监听机制.之前我们已经剖析过观察者模式的具体实现,以及使用Swift3.0自定义过通知机制.所以本篇博客对于事件发送与监听的底 ...

  2. spring 自定义事件发布及监听(简单实例)

    前言: Spring的AppilcaitionContext能够发布事件和注册相对应的事件监听器,因此,它有一套完整的事件发布和监听机制. 流程分析: 在一个完整的事件体系中,除了事件和监听器以外,还 ...

  3. Spring知识点回顾(07)事件发布和监听

    Spring知识点回顾(07)事件发布和监听 1.DemoEvent extends ApplicationEvent { public DemoEvent(Object source, String ...

  4. SpringBoot系列——事件发布与监听

    前言 日常开发中,我们经常会碰到这样的业务场景:用户注册,注册成功后需要发送邮箱.短信提示用户,通常我们都是这样写: /** * 用户注册 */ @GetMapping("/userRegi ...

  5. Spring事件发布与监听机制

    我是陈皮,一个在互联网 Coding 的 ITer,微信搜索「陈皮的JavaLib」第一时间阅读最新文章,回复[资料],即可获得我精心整理的技术资料,电子书籍,一线大厂面试资料和优秀简历模板. 目录 ...

  6. SpringBoot | 第三十二章:事件的发布和监听

    前言 今天去官网查看spring boot资料时,在特性中看见了系统的事件及监听章节.想想,spring的事件应该是在3.x版本就发布的功能了,并越来越完善,其为bean和bean之间的消息通信提供了 ...

  7. 关于JAVA中事件分发和监听机制实现的代码实例-绝对原创实用

    http://blog.csdn.net/5iasp/article/details/37054171 文章标题:关于JAVA中事件分发和监听机制实现的代码实例 文章地址: http://blog.c ...

  8. Android中Button的五种监听事件

    简单聊一下Android中Button的五种监听事件: 1.在布局文件中为button添加onClick属性,Activity实现其方法2.匿名内部类作为事件监听器类3.内部类作为监听器4.Activ ...

  9. 三种方式实现观察者模式 及 Spring中的事件编程模型

    观察者模式可以说是众多设计模式中,最容易理解的设计模式之一了,观察者模式在Spring中也随处可见,面试的时候,面试官可能会问,嘿,你既然读过Spring源码,那你说说Spring中运用的设计模式吧, ...

随机推荐

  1. Linux 环境Skywalking部署Elasticsearch

    一.环境准备 1.Java jdk 11+(安装教程可参考https://www.cnblogs.com/sportsky/p/15973713.html) 2.elasticsearch 二.环境搭 ...

  2. springBoot 多配置文件切换之profile

    说明: 我们平时工作,有开发环境,和生产环境,利用springboot的多profile配置,可以很轻松切换配置. 实现方式1(推荐): 配置文件命名遵循:application-{开发模式}.pro ...

  3. MySQL 中有哪些不同的表格?

    共有 5 种类型的表格: 1.MyISAM 2.Heap 3.Merge 4.INNODB 5.ISAM

  4. 转载:TCP协议如何保证可靠传输

    转载至:https://www.cnblogs.com/xiaokang01/p/10033267.html TCP协议如何保证可靠传输 概述: TCP协议保证数据传输可靠性的方式主要有: (校 序  ...

  5. Spring 的 jdbcTemplate 操作

    1.Spring框架是一站式框架 (1)针对 JavaEE 三层,每一层都有解决技术 (2)在 dao 层,使用 jdbcTemplate 2.Spring对不同的持久化层的技术都进行了封装 (1)j ...

  6. 数字电路的多路复用(MUX)

    学习文章:https://mp.weixin.qq.com/s/1pfLfvkAPyhEMLvfnyDy0g 最基本--2选1的MUX结构: 可以看作是:assign Y=S?B:A; 下面使用MUX ...

  7. css 垂直居中方法汇总

    查看原文可以有更好的排版效果哦 前言 居中是平时工作中的最常见的一种需求,各种图片居中或者各种弹窗,水平居中还好,特别是垂直居中,很多初学者表示太难写了,现在列举一些常用的方法. 实战 这里只讲述cs ...

  8. XUtils 开发框架

    xUtils简介 xUtils 包含了很多实用的android工具. xUtils 最初源于Afinal框架,进行了大量重构,使得xUtils支持大文件上传,更全面的http请求协议支持(10种谓词) ...

  9. Android优化应用启动速度

    一.应用的启动 启动方式 通常来说,在安卓中应用的启动方式分为两种:冷启动和热启动. 1.冷启动:当启动应用时,后台没有该应用的进程,这时系统会重新创建一个新的进程分配给该应用,这个启动方式就是冷启动 ...

  10. vue中判断页面滚动开始和结束

    参考链接:https://www.jianshu.com/p/adad39705ced    和  https://blog.csdn.net/weixin_44309374/article/deta ...