快捷導(dǎo)航

SpringBoot異步調(diào)用相同類的解決方案

更新時間：2025年02月14日 11:15:12 作者：平凡的夢

在SpringBoot中,同一個類中調(diào)用帶有@Async注解的方法時,異步調(diào)用會失效,因為直接通過this調(diào)用方法時,并沒有通過Spring的代理對象,下面給大家分享SpringBoot異步調(diào)用相同類的解決方案,感興趣的朋友一起看看吧

在之前的文章中，我們學(xué)習(xí)了Spring Boot中的異步調(diào)用機(jī)制，以及如何使用@Async注解來實現(xiàn)方法的異步執(zhí)行。然而，在實際開發(fā)中，我們可能會遇到這樣一個問題：在同一個類中調(diào)用帶有@Async注解的方法時，異步調(diào)用竟然失效了！這究竟是為什么呢？今天，我們就來深入探討一下這個問題，并給出幾種可行的解決方案。

一、問題介紹

在Spring Boot中，@Async注解被廣泛應(yīng)用于實現(xiàn)方法的異步執(zhí)行。通常，我們只需要在方法上添加@Async注解，并在啟動類上添加@EnableAsync注解，就可以實現(xiàn)方法的異步調(diào)用了。然而，當(dāng)我們在同一個類中調(diào)用帶有@Async注解的方法時，卻發(fā)現(xiàn)異步調(diào)用并沒有生效，方法仍然是同步執(zhí)行的。

原因分析

這個問題的根源在于Spring的AOP（面向切面編程）代理機(jī)制。在Spring中，@Async注解的實現(xiàn)依賴于AOP代理。當(dāng)我們在一個類中調(diào)用另一個方法時，如果直接通過this來調(diào)用（即類內(nèi)部調(diào)用），那么實際上并沒有通過Spring的代理對象來調(diào)用該方法，因此@Async注解也就無法生效了。

二、解決方案

2.1 將異步方法拆分到另一個Bean中

這是最簡單也是最推薦的一種解決方案。我們可以將帶有@Async注解的異步方法拆分到另一個Bean中，然后在原類中注入這個Bean，并通過調(diào)用這個Bean的方法來實現(xiàn)異步執(zhí)行。

步驟：

‌創(chuàng)建異步方法所在的Bean‌：

@Service
public class AsyncService {
    @Async
    public void asyncMethod() {
        // 異步方法的實現(xiàn)
        System.out.println("Async method starts");
        try { Thread.sleep(1000); } catch (InterruptedException e) {}
        System.out.println("Async method ends");
    }
}

‌在原類中注入異步Bean并調(diào)用‌：

@Service
public class MyService {
    @Autowired
    private AsyncService asyncService;
    public void myMethod() {
        System.out.println("My method starts");
        asyncService.asyncMethod();
        System.out.println("My method ends");
    }
}

實現(xiàn)效果：

當(dāng)調(diào)用myMethod時，asyncMethod會在獨立的線程中異步執(zhí)行。
控制臺輸出順序：My method starts -> My method ends -> Async method starts -> Async method ends（注意這里的順序可能會因為線程調(diào)度而有所差異）。

2.2 自注入當(dāng)前Bean

如果出于某種原因，我們不想將異步方法拆分到另一個Bean中，那么可以考慮使用自注入的方式。即在原類中注入自己，然后通過注入的實例來調(diào)用異步方法。

步驟： ‌在原類中注入自己‌：

@Service
public class MyService {
    @Autowired
    private MyService self;
    public void myMethod() {
        System.out.println("My method starts");
        self.asyncMethod();
        System.out.println("My method ends");
    }
    @Async
    public void asyncMethod() {
        // 異步方法的實現(xiàn)
        System.out.println("Async method starts");
        try { Thread.sleep(1000); } catch (InterruptedException e) {}
        System.out.println("Async method ends");
    }
}

‌注意‌：使用自注入需要確保沒有循環(huán)依賴的問題。通常，如果只是方法調(diào)用的話，可能不會有問題。但為了避免潛在的風(fēng)險，我們可以使用@Lazy注解來延遲Bean的加載。

實現(xiàn)效果：

當(dāng)調(diào)用myMethod時，asyncMethod會在獨立的線程中異步執(zhí)行。
控制臺輸出順序與上一種方案類似。

2.3 使用AopContext獲取代理對象

另一種解決方案是使用AopContext來獲取當(dāng)前類的代理對象，并通過代理對象來調(diào)用異步方法。但這種方法需要開啟exposeProxy選項，并且代碼可能不夠直觀。

步驟：

‌在啟動類上開啟exposeProxy‌：

@SpringBootApplication
@EnableAsync
@EnableAspectJAutoProxy(exposeProxy = true)
public class MyApplication {
    public static void main(String[] args) {
        SpringApplication.run(MyApplication.class, args);
    }
}

‌在方法中使用AopContext獲取代理對象‌：

@Service
public class MyService {
    public void myMethod() {
        System.out.println("My method starts");
        ((MyService) AopContext.currentProxy()).asyncMethod();
        System.out.println("My method ends");
    }
    @Async
    public void asyncMethod() {
        // 異步方法的實現(xiàn)
        System.out.println("Async method starts");
        try { Thread.sleep(1000); } catch (InterruptedException e) {}
        System.out.println("Async method ends");
    }
}

實現(xiàn)效果：

當(dāng)調(diào)用myMethod時，asyncMethod會在獨立的線程中異步執(zhí)行。
控制臺輸出順序與前面兩種方案類似。

‌注意‌：使用AopContext獲取代理對象的方法需要確保AOP代理已經(jīng)正確暴露，并且代碼中存在類型轉(zhuǎn)換，可能不夠安全。因此，在實際開發(fā)中需要謹(jǐn)慎使用。

2.4 使用ApplicationContext獲取Bean實例

還有一種方法是使用ApplicationContext來獲取Bean實例，并通過該實例來調(diào)用異步方法。但這種方法可能會有循環(huán)依賴的問題，或者代碼看起來不夠直觀。

步驟： ‌在類中注入ApplicationContext‌：

@Service
public class MyService {
    @Autowired
    private ApplicationContext applicationContext;
    public void myMethod() {
        System.out.println("My method starts");
        MyService myService = applicationContext.getBean(MyService.class);
        myService.asyncMethod();
        System.out.println("My method ends");
    }
    @Async
    public void asyncMethod() {
        // 異步方法的實現(xiàn)
        System.out.println("Async method starts");
        try { Thread.sleep(1000); } catch (InterruptedException e) {}
        System.out.println("Async method ends");
    }
}

實現(xiàn)效果：