SpringBoot使用@Async注解可能會(huì)遇到的8大坑點(diǎn)匯總
正文
1、未啟用異步支持
Spring Boot默認(rèn)情況下不啟用異步支持，確保在主配置類上添加
@EnableAsync注解以啟用異步功能。
@SpringBootApplication
@EnableAsync
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}2、沒有配置線程池
如果沒有顯式地配置線程池，Spring Boot將使用默認(rèn)的SimpleAsyncTaskExecutor實(shí)現(xiàn)。
在生產(chǎn)環(huán)境，可能導(dǎo)致性能問題。建議使用自定義的線程池配置，推薦ThreadPoolTaskExecutor。
@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {
@Override
public Executor getAsyncExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(10); // 設(shè)置核心線程數(shù)
executor.setMaxPoolSize(100); // 設(shè)置最大線程數(shù)
executor.setQueueCapacity(10); // 設(shè)置隊(duì)列容量
executor.setThreadNamePrefix("Async-"); // 設(shè)置線程名前綴
executor.initialize();
return executor;
}
// 其他配置方法...
}3、異步方法在同一個(gè)類調(diào)用
異步方法必須是通過代理機(jī)制來觸發(fā)的，因此如果在同一個(gè)類中調(diào)用異步方法，它將無法通過代理機(jī)制工作。
可以嘗試將異步方法移到另一個(gè)Bean中，然后通過依賴注入進(jìn)行調(diào)用，這也是萬金油用法。
// 你的業(yè)務(wù)服務(wù)
@Service
public class MyService {
@Autowired
private AsyncService asyncService;
@Async
public void asyncMethod() {
// 異步方法邏輯...
asyncService.asyncMethod(); // 在另一個(gè)Bean中調(diào)用異步方法
}
}
// 你聲明的異步服務(wù)，這里面可以是你所有的異步方法，哪里調(diào)用直接注入即可。
@Service
public class AsyncService {
@Async
public void asyncMethod() {
// 異步方法邏輯...
}
}4、事務(wù)失效問題
@Async方法默認(rèn)不會(huì)繼承父方法的事務(wù)。如果需要事務(wù)支持，請(qǐng)確保異步方法和調(diào)用該方法的方法都被@Transactional注解標(biāo)記。
@Service
public class MyService {
@Autowired
private MyRepository myRepository;
@Async
@Transactional
public void asyncMethod() {
// 異步方法邏輯...
myRepository.save(entity);
}
}5、異常處理
異步方法中拋出的異常不能直接捕獲，因?yàn)檎{(diào)用者將無法獲取到異常。建議使用Future或CompletableFuture來捕獲異步方法的異常并進(jìn)行處理。
@Service
public class MyService {
@Async
public CompletableFuture<String> asyncMethod() {
try {
// 異步方法邏輯...
return CompletableFuture.completedFuture("Success");
} catch (Exception e) {
// 處理異常...
return CompletableFuture.failedFuture(e);
}
}
}
// 調(diào)用異步方法并處理異常
CompletableFuture<String> future = myService.asyncMethod();
future.exceptionally(ex -> {
// 異常處理邏輯...
return "Error";
});6、異步方法無返回結(jié)果
異步方法默認(rèn)情況下是沒有返回值的，如果需要獲取異步方法的執(zhí)行結(jié)果，依然要使用Future或CompletableFuture，可以將其設(shè)置為返回類型。
@Service
public class MyService {
@Async
public CompletableFuture<String> asyncMethod() {
// 異步方法邏輯...
return CompletableFuture.completedFuture("Result");
}
}
// 調(diào)用異步方法并獲取結(jié)果
CompletableFuture<String> future = myService.asyncMethod();
String result = future.get(); // 阻塞等待結(jié)果當(dāng)然，正常情況下我們不需要返回結(jié)果，而且我也不建議這么干，異步線程本身也最適合處理不需要返回值的一類任務(wù)。
7、循環(huán)調(diào)用問題
當(dāng)在同一個(gè)類中調(diào)用異步方法時(shí)，注意避免出現(xiàn)無限遞歸的循環(huán)調(diào)用。這可能會(huì)導(dǎo)致應(yīng)用程序卡死或內(nèi)存溢出。
@Service
public class MyService {
@Autowired
private MyService myService; // 自身依賴
@Async
public void asyncMethod() {
// 異步方法邏輯...
myService.asyncMethod(); // 會(huì)導(dǎo)致無限遞歸調(diào)用
}
}這個(gè)坑點(diǎn)一般人不會(huì)遇到，但如果某些業(yè)務(wù)場(chǎng)景是關(guān)于樹形結(jié)構(gòu)的遍歷、圖算法等等，還是有幾率出現(xiàn)這種情況的，這個(gè)坑點(diǎn)列出來僅供學(xué)習(xí)和了解。
8、異步方法順序問題
異步方法的執(zhí)行是非阻塞的，它們可能以任意順序完成。如果需要按照特定的順序處理結(jié)果，可以使用CompletableFuture的thenApply方法或者使用@Async的order屬性來指定順序。
@Service
public class MyService {
@Async("threadPoolTaskExecutor")
public CompletableFuture<String> asyncMethod1() {
// 異步方法1邏輯...
return CompletableFuture.completedFuture("Result1");
}
@Async("threadPoolTaskExecutor")
public CompletableFuture<String> asyncMethod2() {
// 異步方法2邏輯...
return CompletableFuture.completedFuture("Result2");
}
}
// 調(diào)用異步方法并處理結(jié)果順序
CompletableFuture<String> future1 = myService.asyncMethod1();
CompletableFuture<String> future2 = future1.thenCompose(
result1 -> myService.asyncMethod2());
String finalResult = future2.get(); // 阻塞等待最終結(jié)果總結(jié)
這里面，我個(gè)人認(rèn)為絕大多數(shù)人會(huì)遇到的坑點(diǎn)集中在沒有配置自定義線程池、異步方法在同一個(gè)類中調(diào)用、事務(wù)不起作用這幾個(gè)問題上。
所以，萬金油的寫法還是專門定義一個(gè)AsyncService，將異步方法都寫在里面，需要使用的時(shí)候，就在其他類將其注入即可。
以上就是SpringBoot使用@Async注解可能會(huì)遇到的8大坑點(diǎn)匯總的詳細(xì)內(nèi)容，更多關(guān)于SpringBoot @Async注解坑點(diǎn)的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
這篇文章主要介紹了快速排序算法在Java中的實(shí)現(xiàn)，簡(jiǎn)單介紹了快速排序的實(shí)現(xiàn)原理，分享了兩種實(shí)現(xiàn)代碼，具有一定參考價(jià)值，需要的朋友可以了解下。2017-11-11
jdk7 中HashMap的知識(shí)點(diǎn)總結(jié)
HashMap的原理是老生常談了，不作仔細(xì)解說。一句話概括為HashMap是一個(gè)散列表，它存儲(chǔ)的內(nèi)容是鍵值對(duì)(key-value)映射。這篇文章主要總結(jié)了關(guān)于jdk7 中HashMap的知識(shí)點(diǎn),需要的朋友可以參考借鑒，一起來看看吧。2017-01-01
在本篇文章里小編給大家分享的是一篇關(guān)于java中maven下載和安裝步驟說明內(nèi)容，對(duì)此有興趣的朋友們可以學(xué)習(xí)參考下。2021-02-02
Java工程mybatis實(shí)現(xiàn)多表查詢過程詳解
這篇文章主要介紹了Java工程mybatis實(shí)現(xiàn)多表查詢過程詳解,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-06-06
java中public class與class的區(qū)別詳解
以下是對(duì)java中public class與class的區(qū)別進(jìn)行了分析介紹，需要的朋友可以過來參考下2013-07-07
這篇文章主要介紹了Spring中@Scope注解用法解析,@Scope注解主要作用是調(diào)節(jié)Ioc容器中的作用域,在Spring IoC容器中主要有以下五種作用域,需要的朋友可以參考下2023-11-11
分布式面試分布式鎖實(shí)現(xiàn)及應(yīng)用場(chǎng)景
這篇文章主要為大家介紹了關(guān)于分布式的面試問題，分布式鎖的實(shí)現(xiàn)及應(yīng)用不同場(chǎng)景下的使用，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步2022-03-03
本文主要介紹了Java中RedisUtils工具類的使用，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-07-07
圖片壓縮通常涉及減少圖片的尺寸縮放、調(diào)整圖片的質(zhì)量(針對(duì)JPEG、PNG等)、使用特定的算法來減少圖片的數(shù)據(jù)量等,這篇文章主要介紹了Java圖片壓縮三種高效壓縮方案的相關(guān)資料,需要的朋友可以參考下2025-04-04
Java在java.math包中提供的API類BigDecimal，用來對(duì)超過16位有效位的數(shù)進(jìn)行精確的運(yùn)算。雙精度浮點(diǎn)型變量double可以處理16位有效數(shù)，但在實(shí)際應(yīng)用中，可能需要對(duì)更大或者更小的數(shù)進(jìn)行運(yùn)算和處理2022-12-12