spring event的事件驱动模型的最佳实践@EventListener
文章目录
- 1.spring下使用event模型
- 1.1 定义event
- 1.2 event的监听处理类。监听类实现ApplicationListener 里onApplicationEvent方法即可
- 1.3 发布事件
- 2.evnet模型的注意点
- 3. 一种更优雅的方式——@EventListener
- 3.1 发布事件
- 3.2 定义事件源
- 3.3 监听事件@EventListener
- 3.4 监听事件时的事务隔离
我们知道观察者模式可以实现代码的解耦,而spring的event模型就是这种设计模式的极佳体现。一个事件包含:事件发布、监听、和事件源。在spring中我们可以通过ApplicationContext的publishEvent方法去发布事件;通过实现ApplicationListener接口来自定义自己的监听器;继承ApplicationEvent类来实现事件源。下面以一个实例来说明:
1.spring下使用event模型
1.1 定义event
/*** event的基类** @author 94977* @create 2018/7/22*/
public abstract class BaseEvent extends ApplicationEvent {public BaseEvent(Object source) {super(source);}
}
public class FaceEvent extends BaseEvent {/*** @author 94977* @time 2018/7/22 15:50* @param * @param null* @return* @description 必须要实现的构造方法*/public FaceEvent(User user) {super(user);}
}
1.2 event的监听处理类。监听类实现ApplicationListener 里onApplicationEvent方法即可
@Component
public class FaceEventListener implements ApplicationListener {@Overridepublic void onApplicationEvent(ApplicationEvent event) {if(event instanceof FaceEvent){User user = (User) event.getSource();LOGGER.info("===> 收到人脸事件: {}",user);// .....System.out.println("人脸事件处理结束。。。");}}
}
当然通过event instanceof FaceEvent判断事件源来处理的方式不是很优雅。有更好的方式,接口ApplicationListener支持泛型,可以通过泛型来判断处理的事件源。如下只处理FaceEvent源。
@Component
public class FaceEventListener extends BaseEventListener implements ApplicationListener<FaceEvent> {@Overridepublic void onApplicationEvent(FaceEvent event) {User user = (User) event.getSource();LOGGER.info("===> 收到人脸事件: {}",user);// .....System.out.println("人脸事件处理结束。。。");}
}
如果要实现有序的监听,实现SmartApplicationListener 接口即可
1.3 发布事件
@Service
public class FaceHandler {@Autowiredprivate ApplicationContext applicationContext;public void handle(){User user = new User();user.setAge(34);user.setUsername("人脸事件");user.setHobby("抓拍");//发布事件applicationContext.publishEvent(new FaceEvent(user));//进行其他业务处理}
以上即可。
2.evnet模型的注意点
- 事件没要处理的监听器,就会被抛弃。
- 一个事件可以同时被多个监听处理类监听处理。
- 以上处理事件都是同步的,如果发布事件处的业务存在事务,监听器处理也会在相同的事务中。这个一定要注意!如果对于事件的处理不想受到影响,可以onApplicationEvent方法上加@Aync支持异步(参考taskExecutor的使用)。
- 原理部分可以参考 博客 事件体系
3. 一种更优雅的方式——@EventListener
3.1 发布事件
我们可以通过工具类发布来避免在代码耦合注入ApplicationContext,工具类实现ApplicationEventPublisherAware 接口,具体可参考spring的aware学习。
这里有一个小细节,如果通过注入ApplicationContext的方式来发布事件,idea在代码左边会有一个类似耳机的小图标,点击可以跳到监听此发布事件的监听者位置,用工具类发布事件就没有此提示了。
3.2 定义事件源
public abstract class BaseEvent<T> extends ApplicationEvent {private static final long serialVersionUID = 895628808370649881L;protected T eventData;public BaseEvent(Object source, T eventData){super(source);this.eventData = eventData;}public BaseEvent(T eventData){super(eventData);}public T getEventData() {return eventData;}public void setEventData(T eventData) {this.eventData = eventData;}
}
需要发布的事件继承此BaseEvent
public class FaceEvent extends BaseEvent<User> {public FaceEvent(User user) {super(user);}public FaceEvent(Object source, User user){super(source,user);}}
如果代码结构较复杂,多处发布相同的事件,建议发布事件时将this作为source传递,便于通过分析日志确定发布源。
3.3 监听事件@EventListener
在spring4.2中我们可以以更加简洁的方式来监听event的发布,监听事件我们不必再实现ApplicationListener接口了,只要在方法上添加注解@EventListener即可:
@EventListenerpublic void onApplicationEvent(FaceEvent event) {User user = (User) event.getSource();String name = Thread.currentThread().getName();LOGGER.info("===> 收到人脸事件: {},线程名为: {}",user,name);}
会根据方法参数类型来自动监听相应事件的发布。
如果要监听多个事件类型的发布,可以在@EventListener(classes = {FaceEvent.class,ArmEvent.class})指定,spring会多次调用此方法来处理多个事件。但是注意此时,方法参数不能有多个,否则会发生转换异常,可以将使用多个事件的父类作为唯一的方法参数来接收处理事件,但除非必要否则并不推荐监听多个事件的发布。
- 如果有多个监听器监听同一事件,我们可以在方法上使用spring的@order注解来定义多个监听器的顺序,如:
@EventListener@Order(4)public void onApplicationEvent(FaceEvent event) {User user = (User) event.getSource();LOGGER.info("===> A 收到人脸事件: {}",user);}@EventListener({FaceEvent.class,ArmEvent.class})@Order(3)public void onApplicationEvent3(Object event) {if(event instanceof FaceEvent){LOGGER.info("===> B 收到人脸事件: {}",((FaceEvent) event).getEventData());}else if(event instanceof ArmEvent){ArmEvent armEvent = (ArmEvent) event;LOGGER.info("===> B 收到臂膀事件: {}",armEvent.getEventData());}}
这真的是很方便。
- @EventListener还有一个属性,condition()里可以使用SPEL表达式来过滤监听到事件,即只有符合某种条件的才进行接收处理。暂时还用不到。
3.4 监听事件时的事务隔离
- @TransactionalEventListener和@EventListener都可以监听事件,但前者可以对发布事件和监听事件进行一些事务上的隔离。@TransactionalEventListenerr指不和发布事件的方法在同一个事务内,发布事件的方法事务结束后才会执行本监听方法,监听逻辑内发生异常不会回滚发布事件方法的事务。
@Transactional(rollbackFor = Exception.class)public void handle(){User user = new User();user.setAge(34);user.setUsername("人脸事件");user.setHobby("抓拍");//处理完上面的逻辑后,发布事件EventPublisherUtil.publishEvent(new FaceEvent(user));//数据库添加操作Integer integer = deviceAlarmService.addDevice();}
可以看到发布事件的方法处在事务控制中,我们使用@TransactionalEventListener来监听事件:
@TransactionalEventListener(fallbackExecution = true)public void onApplicationEvent(FaceEvent event) {User user = event.getEventData();LOGGER.info("===> A 收到人脸事件: {}}",user);//@TransactionalEventListener指不和发布事件的在同一个事务内,发布事件的方法事务结束后才会执行本方法// ,本方法发生异常不会回滚发布事件的事务,throw new RuntimeException("监听事件抛出异常");}
运行结果,addDevice正常在数据库插入数据,但是修改为@EventListener监听则插入数据失败。
- @TransactionalEventListener有一个属性为fallbackExecution,默认为false,指发布事件的方法没有事务控制时,监听器不进行监听事件,此为默认情况! fallbackExecution=true,则指发布事件的方法没有事务控制时,监听方法仍可以监听事件进行处理。
/*** Whether the event should be processed if no transaction is running.*/boolean fallbackExecution() default false;
- 刚才我们说到使用@TransactionalEventListener会在发布事件的方法事务结束后执行监听方法,但其实我们还可以进行细化的控制。它有一个属性为TransactionPhase,默认为TransactionPhase.AFTER_COMMIT,即事务提交后。还可以根据需要选择AFTER_COMPLETION、BEFORE_COMMIT、AFTER_ROLLBACK。
但仍需注意,如果fallbackExecution=false,且发布事件的方法没有事务控制时,监听器根本不会监听到事件,此处的TransactionPhase也就没有意义了。
spring event的事件驱动模型的最佳实践@EventListener相关推荐
- Spring Batch在大型企业中的最佳实践
在大型企业中,由于业务复杂.数据量大.数据格式不同.数据交互格式繁杂,并非所有的操作都能通过交互界面进行处理.而有一些操作需要定期读取大批量的数据,然后进行一系列的后续处理.这样的过程就是" ...
- 「PowerBI」使用TabularEditor进行PowerBIDeskTop模型开发最佳实践
前面系列文章介绍的场景,设定的工具使用对象是Sqlserver和Azure 的SSAS数据模型开发,其实TabularEditor亦可以有限度地使用在PowerBIDeskTop的模型开发上,本文简单 ...
- [转] Spring XML配置十二个最佳实践
Spring是一个强大的JAVA应用框架,广泛地应用于JAVA的应用程序.为Plain Old Java Objects(POJOs)提供企业级服务.Spring利用依赖注入机制来简化工作,同时提高易 ...
- spring事件驱动模型--观察者模式在spring中的应用
spring中的事件驱动模型也叫作发布订阅模式,是观察者模式的一个典型的应用,关于观察者模式在之前的博文中总结过,http://www.cnblogs.com/fingerboy/p/5468994. ...
- Spring Boot 几条最佳实践!
点击上方"朱小厮的博客",选择"设为星标" 回复"1024"获取独家整理的学习资料 Spring Boot是最流行的用于开发微服务的Java ...
- Spring Boot 最流行的 16 条最佳实践!
点击上方 IT牧场 ,选择 置顶或者星标技术干货每日送达! 来源:http://t.cn/EJWZNra Spring Boot是最流行的用于开发微服务的Java框架.在本文中,我将与你分享自2016 ...
- 两年摸爬滚打 Spring Boot,总结了这 16 条最佳实践
转载自 两年摸爬滚打 Spring Boot,总结了这 16 条最佳实践 Spring Boot是最流行的用于开发微服务的Java框架.在本文中,我将与你分享自2016年以来我在专业开发中使用Sp ...
- Spring Boot 生产中的 16 条最佳实践
来源:www.e4developer.com/2018/08/06/ Spring Boot是最流行的用于开发微服务的Java框架.在本文中,我将与你分享自2016年以来我在专业开发中使用Spring ...
- Spring Validation最佳实践及其实现原理,参数校验没那么简单!
点击上方"方志朋",选择"设为星标" 回复"666"获取新整理的面试文章 作者:六点半起床 juejin.im/post/685654110 ...
最新文章
- vue 定义全局函数
- python filename 以txt截尾_What?PPT里也能运行Python?
- [家里蹲大学数学杂志]第034期中山大学2008年数学分析考研试题参考解答
- gulp基础使用方法记录
- 利用STM32制作红外测温仪之硬件设计
- Java根据出生年月日获取到当前日期的年月日
- c语言知5个学生的4门成绩,用C 语言数组解题 :已知5个学生的4门课的成绩,要求求出全部学生的门成绩并分别求出每门课的平均成绩...
- 11条规则教你如何玩转数据库设计
- eyoucms如何调用指定栏目下的推荐文章
- 外贸沟通中,老外最喜欢的聊天工具你了解?各国客户最常用的即时聊天APP整理及配套8个英语类工具推荐
- HC-05嵌入式蓝牙串口通讯
- liscov替换原则
- echarts数字云
- 独家访谈N位品牌操盘手:深度揭秘品牌自播方法论
- 离散型Hopfield神经网络(DHNN)
- JavaScript就这么回事(好收藏,哪天忘了可以查一查)
- 计算机及网络方面的杂志,计算机类省级期刊
- 来吧 兄弟萌 我们一起学做粥
- javashop源码,javashop电商系统源码授权
- 5v供电的数字功放芯片有哪些
热门文章
- 按位异或运算和求反运算解析
- IDEA2021配置Tomcat
- think php a方法,ThinkPHP之A方法实例讲解_PHP
- python大乐透2019143_[新浪彩票]老梁大乐透第19143期:前区大号走强
- java+卡有型号吗,第一次写java代码,就卡主了,真是惨,有木有大腿来帮忙调试一下...
- c语言由高到低的运算符,求解C语言关系运算符优先极由高到低列表(同级请用括号)...
- Eclipse4.8.0无法打开 Eclipse MarketPlace
- 七十一、Python | Leetcode字符串系列(上篇)
- 二十九、Node.js连接Mysql和MongoDB数据库CURD操作
- 做时间序列预测有必要用深度学习吗?梯度提升回归树媲美甚至超越多个DNN模型...