你好呀,我是歪歪。
这周我在 Spring 的 github 上闲逛的时候,一个 issues 引起了我的兴趣。
这篇文章,是我顺着这个 issues 往下写,始于它,但是不止于它:
https://github.com/spring-projects/spring-framework/pull/27818
这个 issues 标题翻译过来,就是说希望 @Async 这个注解能够支持占位符或 SpEL 表达式。
而我关注到这个 issues 的原因,完全是因为我之前写过 @Async 相关的文章,看着眼熟,就随手点进来看了一下。
在这个问题里面,提到了一个编号为 27775 的 issues:
https://github.com/spring-projects/spring-framework/issues/27775
这个说的是个啥事儿呢?
估计你看一眼我截图中标注的地方也就看出来了,他想把线程池的名称放到配置文件里面去。而这个需求我觉得并不奇怪,基于 Spring 框架来说,是一个很合理的需求。
搞个 Demo
我还是先给你搞个 Demo,验收一下它想要干啥。
首先注入了一个名称为 why 的线程池。
然后有一个被 @Async 注解修饰的方法,而这个注解指定了一个值为 why 的 value,表明要使用名称为 why 的这个线程池:
最后在启动类上加上 @EnableAsync 注解,把项目启动起来。
调用下面的链接,发起调用:
输出结果如下:
支持一波
好的,现在需求就很明确了:目前不支持,有人在社区提出该需求,想要 Spring 支持该功能。
然后这个叫 sbrannen 的哥们出来了:
他说了两句话:
- 1.如果提供的 BeanFactory 是 ConfigurableBeanFactory,我们似乎可以通过修改
org.springframework.aop.interceptor.AsyncExecutionAspectSupport.findQualifiedExecutor(BeanFactory,String)
的代码,使用 EmbeddedValueResolver 来支持。 - 可以看一下
org.springframework.context.annotation.CommonAnnotationBeanPostProcessor.setBeanFactory(BeanFactory)
,这是一个对应的例子。
第一句话中,他提到的 findQualifiedExecutor 方法,也就是需要修改的地方的代码,在我的 5.3.16 版本中是这样的:
他说的 “for an example” 就是我框起来的部分。
这里面关键的地方有两个:
- ConfigurableBeanFactory
- EmbeddedValueResolver
首先 ConfigurableBeanFactory ,在 Spring 里面是一个非常重要的类,但是不是本文重点,一句话带过:你可以把它理解为是一个巨大的、功能齐全的工厂接口。
从注解上可以知道这个类是用来解析占位符和表达式。相当于是 Spring 给你封装好的一个工具类吧。
EmbeddedValueResolver 里面就这一个方法:
而这个方法里面调用了一个 resolveEmbeddedValue 方法:
org.springframework.beans.factory.support.AbstractBeanFactory#resolveEmbeddedValue
这个方法就是 Spring 里面解析表达式的核心代码。
我给你演示一下。
首先我们加一点代码:
是不是很清晰了。
入參是 ${user.age} 表达式,出参是配置文件中对应的 18。
关于如何解析的所有秘密都藏在这一行代码里面:
你以为我要给你详细讲解吗?
不可能的,指个路而已,自己看去吧。
现在我要开始拐弯了,拐回到这个老哥的回复上:
现在我先带你捋一捋啊。
首先,有个老铁说:你这个 Spring 的 @Async 注解能不能支持表达式呀,比如这样式儿的 @Async("${thread-pool.name}")
然后官方出来回复说:没问题啊,我们可以修改 findQualifiedExecutor
方法,在里面使用 EmbeddedValueResolver 这个工具类来支持。比如就像是下面这个类中的 setBeanFactory 方法一样:
接着我带你去看了一下这个方法,然后知道了 EmbeddedValueResolver 的用法。
好的,那么现在问题来了:在 findQualifiedExecutor
方法中,我们怎么使用呢?
兜兜转转一大圈,现在就回到最开始的那个 issues 里面:
这个老哥说他基于 sbrannen,也就是官方人员的提示.提交了这次修改。
怎么修改的呢?
看他的 Files changed:
修改了三个文件,其中一个测试类。
剩下两个,一个是 @Async 注解:
这里面只是修改了 Javadoc,表示这个注解支持表达式的方式进行配置。
另外一个是 AsyncExecutionAspectSupport 这个类:
在 findQualifiedExecutor 方法里面加了五行代码,就完成了这个功能。
最后,官方在 review 代码的时候,又删除一行代码: