博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Spring event 使用完全指南
阅读量:5977 次
发布时间:2019-06-20

本文共 2047 字,大约阅读时间需要 6 分钟。

hot3.png

说明

此篇文章以 Spring 4.2+ 为例,在此版本之前略微有不同。 笔者自2014年起开始接触和使用 Spring event,根据 Spring event 的原理开发了 JFinal-event: ,方便 JFinal 用户使用,JFinal event 2.x 也同步成 Spring 4.2.x+ 的使用方式,不再需要创建多个 Listener 类,使用更加简单方便。

使用

创建 Event 事件监听

Spring 4.2+ 中不再需要单独编写监听器类,只需要在 Spring Bean 的方法上标记 @EventListener 注解即可。

示例:多个监听器,监听 Account 创建,完成不同的业务逻辑。

/** * 账号监听,处理账号创建成功的后续逻辑 */@Componentpublic class AccountListener {	/**	 * 1. 发送邮件、短信	 */    @EventListener    public void processAccountCreatedEvent1(AccountCreatedEvent event) {        // TODO    }    /**     * 2. 添加积分等,@Order(100) 用来设定执行顺序     */    @EventListener    @Order(100)    public void processAccountCreatedEvent2(AccountCreatedEvent event) {        // TODO    }    /**     * 3. 创建 lucene 索引等,@Async 用来标记为异步线程池中执行     */    @EventListener    @Async    public void processAccountCreatedEvent3(AccountCreatedEvent event) {        // TODO    }}

发送 Event 事件

示例:mybatis中发送账号创建事件。

注意:如果你是使用的 jpa,jpa 也有对应的事件机制,不需要像下面手动处理。

/** * 注入 ApplicationEventPublisher */@Autowiredprivate ApplicationEventPublisher publisher;@Overridepublic boolean save(Account account) {	// 伪代码,数据库保存成功	if (true) {		publisher.publishEvent(new AccountCreatedEvent(account));	}	return false;}

idea 中的快捷跳转按钮

spring-event.mp4.gif

@EventListener 注解属性说明

@EventListener(value = {AccountCreatedEvent.class, AccountUpdatedEvent.class}, condition = "#event.account.age > 10")public void processAccountCreatedEvent2(AccountEvent event) {	// TODO}
  • valueclasses 作用相同,表示监听的一个或一组事件,用于支持方法中同一个父类的事件,例如 AccountEvent;
  • condition 表达式,支持 Spring el,用来做 event 中的变量或者方法判断。

监听执行顺序

可以使用 @Order(100) 注解来标记事件的监听执行顺序,异步的情况下只保证按顺序将监听器丢入进线程池,具体执行得看线程的心情 -.-

监听异步执行

使用 @Async 标记即可,注意前提条件是:使用 @EnableAsync 开启 Spring 异步。

Spring boot 配置异步

本节以 中的异步配置为基础讲解。

异步配置

  • @EnableAsync 开启异步。
  • @EnableScheduling 开启定时任务。
  • MicaAsyncProperties 为异步线程池的配置。

QQ20190409-164911@2x.png

异步配置项

QQ20190409-164945@2x.png

配置项 默认值 说明
mica.async.core-pool-size 2 异步核心线程数,默认:2
mica.async.keep-alive-seconds 300 线程存活时间,默认:300
mica.async.max-pool-size 50 异步最大线程数,默认:50
mica.async.queue-capacity 10000 队列容量,默认:10000

关注我们

如梦技术-公众号.jpg

扫描上面二维码,更多精彩内容每天推荐!

转载于:https://my.oschina.net/qq596392912/blog/3035273

你可能感兴趣的文章
钱趣多风控新举措:源头选择与物理隔离
查看>>
puppet最新源码包安装学习笔记
查看>>
烂泥:kickstart无人值守安装CentOS6.5
查看>>
Windows Phone 8 开发资源汇总
查看>>
互联网趋势关键词:交流,为价值付费,资源整合
查看>>
阿里钉钉,马云旗下的又一个千亿美金产品?
查看>>
Oracle 11gR2学习之三(创建用户及表空间、修改字符集和Oracle开机启动)
查看>>
熟练掌握Word2003中的突出显示功能
查看>>
编码过程中的问题总结
查看>>
网页与APP中那些优美的登陆表单
查看>>
快速幂取模模板
查看>>
Git:配置
查看>>
神经系统知识普及
查看>>
Spring可扩展Schema标签
查看>>
c++ STL unique , unique_copy函数
查看>>
http://miicaa.yopwork.com/help/overall/
查看>>
浅谈关于特征选择算法与Relief的实现
查看>>
mybatis-spring 项目简介
查看>>
Wireshark抓取RTP包,还原语音
查看>>
Behavioral模式之Memento模式
查看>>