添加@EnableAsync注解后报循环依赖,注入失败咋办

举报
码农飞哥 发表于 2021/05/29 12:12:04 2021/05/29
【摘要】 情景再现 在PayService类中注入了payNotifyService的实例,而在PayNotifyService类中又注入了payService的实例。而PayNotifyService类中又有一个加了@Async 注解的方法A。 今天在公司项目中想将一个耗时的流程放在异步线程中执行,然后,按照操作手册,熟练了在异步方法上添加了@Async 注解,在对应模块的启...

情景再现

在PayService类中注入了payNotifyService的实例,而在PayNotifyService类中又注入了payService的实例。而PayNotifyService类中又有一个加了@Async 注解的方法A。
今天在公司项目中想将一个耗时的流程放在异步线程中执行,然后,按照操作手册,熟练了在异步方法上添加了@Async 注解,在对应模块的启动类中添加了@EnableAsync,妥妥的,准备跑一波看看效果。结果傻眼了。
报错啦!!!!!!

Exception encountered during context initialization - cancelling refresh attempt: org.springframework.beans.factory.BeanCurrentlyInCreationException: Error creating bean with name ‘payNotifyService’: Bean with name ‘payNotifyService’ has been injected into other beans [PayService] in its raw version as part of a circular reference, but has eventually been wrapped. This means that said other beans do not use the final version of the bean. This is often the result of over-eager type matching - consider using ‘getBeanNamesOfType’ with the ‘allowEagerInit’ flag turned off, for example.

粗一看 ,这循环注入了嘛!奇怪了。没加@EnableAsync之前项目跑了好好的,加了这个注解之后就报错了,咋回事呢,小老弟。事不宜迟,google走一波。

原因分析

众所周知,在SpringBoot项目中添加@EnableAsync是使@Async 注解生效的。之前没加这个注解的时候异步方法都是没有生效的。而我们Async 是通过AOP生成代理类来实现异步执行的。所以

  • 之前的情况是:
  1. 分别生成PayNotifyService类的实例A和PayService类的实例B,
  2. 通过@Autowired注解将实例注入到对应的类中。所以启动没问题。
  • 现在的情况是:
    前面两步的情况一样,但是当我们Spring的IOC容器检查到@Async 注解之后,会通过AOP这个方法所在的类生成一个代理类。注入的时候发现该Bean已经被其他对象注入了,所以这就出现了问题了。

解决办法

针对上面分析的原因,我们对应的有两种解决办法,

  • 第一种方法
    @Autowired注解和@Lazy 搭配使用,使之注入的是代理类的Bean,而不是原始的Bean。
    例如这样:
 @Autowired @Lazy private payNotifyService payNotifyService;

  
 
  • 1
  • 2
  • 3
  • 第二种方法
    将拥有@Async 注解的方法集中到一个类中,统一管理,也使得代码清晰易懂,便于维护,个人比较推荐这种方式。
  • 第三种方法
    使用基于 Setter 的注入,不通过@Autowired注解注入,而通过setter方法注入,这种方法,治标不治本,个人不建议。

扩展:异步调用获取返回结果:
如果我们想获取异步调用的返回结果?该如何处理呢?
答案就是在将方法的返回参数类型定义成Future<Object>,例如:

@Async
public Future<String> doTaskOne() throws Exception { System.out.println("开始做任务一"); long start = System.currentTimeMillis(); Thread.sleep(random.nextInt(10000)); long end = System.currentTimeMillis(); System.out.println("完成任务一,耗时:" + (end - start) + "毫秒"); return new AsyncResult<>("任务一完成");
}

  
 
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9

如上,是一个通过@Async修饰的异步方法。我们将真正需要的结果封装在Futrue中,实际返回时我们只需要通过new AsyncResult<>(”任务一完成“)
外部方法调用该异步方法,获取返回结果只需要如下:

 doTaskOne().get()

  
 
  • 1

文章来源: feige.blog.csdn.net,作者:码农飞哥,版权归原作者所有,如需转载,请联系作者。

原文链接:feige.blog.csdn.net/article/details/101708646

【版权声明】本文为华为云社区用户转载文章,如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。