SpringBoot中異步調用時的注意事項

更新時間：2023年11月10日 09:32:30 作者：著力

這篇文章主要介紹了SpringBoot中異步調用時的注意事項,調用的異步方法,不能為同一個類的方法(包括同一個類的內部類),簡單來說,因為Spring在啟動掃描時會為其創(chuàng)建一個代理類,而同類調用時,還是調用本身的代理類的,所以和平常調用是一樣的,需要的朋友可以參考下

一，使用方法

1，啟動類上加@EnableAsync注解，開啟異步

2，在需要異步執(zhí)行的方法上加@Async(“threadpool”)注解,(threadpool)可以為空

二，注意事項

（1）在默認情況下，未設置TaskExecutor時，默認是使用SimpleAsyncTaskExecutor這個線程池，但此線程不是真正意義上的線程池，因為線程不重用，每次調用都會創(chuàng)建一個新的線程?？赏ㄟ^控制臺日志輸出可以看出，每次輸出線程名都是遞增的。所以最好我們來自定義一個線程池。

（2）調用的異步方法，不能為同一個類的方法（包括同一個類的內部類），簡單來說，因為Spring在啟動掃描時會為其創(chuàng)建一個代理類，而同類調用時，還是調用本身的代理類的，所以和平常調用是一樣的。其他的注解如@Cache等也是一樣的道理，說白了，就是Spring的代理機制造成的。所以在開發(fā)中，最好把異步服務單獨抽出一個類來管理。

三，什么情況下會導致@Async異步方法會失效？

（1）調用同一個類下注有@Async異步方法：在spring中像@Async和@Transactional、cache等注解本質使用的是動態(tài)代理，其實Spring容器在初始化的時候Spring容器會將含有AOP注解的類對象“替換”為代理對象（簡單這么理解），那么注解失效的原因就很明顯了，就是因為調用方法的是對象本身而不是代理對象，因為沒有經過Spring容器，那么解決方法也會沿著這個思路來解決。

（2）調用的是靜態(tài)(static )方法

（3）調用(private)私有化方法

四，解決3中問題1的方式

（其它2,3兩個問題自己注意下就可以了）

將要異步執(zhí)行的方法單獨抽取成一個類，原理就是當你把執(zhí)行異步的方法單獨抽取成一個類的時候，這個類肯定是被Spring管理的，其他Spring組件需要調用的時候肯定會注入進去，這時候實際上注入進去的就是代理類了。其實我們的注入對象都是從Spring容器中給當前Spring組件進行成員變量的賦值，由于某些類使用了AOP注解，那么實際上在Spring容器中實際存在的是它的代理對象。那么我們就可以通過上下文獲取自己的代理對象調用異步方法。

@Controller
@RequestMapping("/app")
public class EmailController {
    //獲取ApplicationContext對象方式有多種,這種最簡單,其它的大家自行了解一下
    @Autowired
    private ApplicationContext applicationContext;
    @RequestMapping(value = "/email/asyncCall", method = GET)
    @ResponseBody
    public Map<String, Object> asyncCall () {
        Map<String, Object> resMap = new HashMap<String, Object>();
        try{
            //這樣調用同類下的異步方法是不起作用的
            //this.testAsyncTask();
            //通過上下文獲取自己的代理對象調用異步方法
            EmailController emailController = (EmailController)applicationContext.getBean(EmailController.class);
            emailController.testAsyncTask();
            resMap.put("code",200);
        }catch (Exception e) {
            resMap.put("code",400);
            logger.error("error!",e);
        }
        return resMap;
    }
    //注意一定是public,且是非static方法
    @Async
    public void testAsyncTask() throws InterruptedException {
        Thread.sleep(10000);
        System.out.println("異步任務執(zhí)行完成！");
    }
}

開啟cglib代理，手動獲取Spring代理類,從而調用同類下的異步方法。

首先，在啟動類上加上@EnableAspectJAutoProxy(exposeProxy = true)注解。代碼實現，如下：

@Service
@Transactional(value = "transactionManager", readOnly = false, propagation = Propagation.REQUIRED, rollbackFor = Throwable.class)
public class EmailService {
    @Autowired
    private ApplicationContext applicationContext;
    @Async
    public void testSyncTask() throws InterruptedException {
        Thread.sleep(10000);
        System.out.println("異步任務執(zhí)行完成！");
    }
    public void asyncCallTwo() throws InterruptedException {
        //this.testSyncTask();
//        EmailService emailService = (EmailService)applicationContext.getBean(EmailService.class);
//        emailService.testSyncTask();
        boolean isAop = AopUtils.isAopProxy(EmailController.class);//是否是代理對象；
        boolean isCglib = AopUtils.isCglibProxy(EmailController.class);  //是否是CGLIB方式的代理對象；
        boolean isJdk = AopUtils.isJdkDynamicProxy(EmailController.class);  //是否是JDK動態(tài)代理方式的代理對象；
        //以下才是重點!!!
        EmailService emailService = (EmailService)applicationContext.getBean(EmailService.class);
        EmailService proxy = (EmailService) AopContext.currentProxy();
        System.out.println(emailService == proxy ? true : false);
        proxy.testSyncTask();
        System.out.println("end!!!");
    }