SpringBoot實現(xiàn)異步調(diào)用的方法示例
更新時間：2025年01月13日 09:42:22 作者：summe學(xué)Java
本文介紹了在Java的SpringBoot中實現(xiàn)異步請求和異步調(diào)用的幾種方法,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
在Java中使用Spring Boot實現(xiàn)異步請求和異步調(diào)用是一個常見的需求，可以提高應(yīng)用程序的性能和響應(yīng)能力。以下是實現(xiàn)這兩種異步操作的基本方法：
一、異步請求（Asynchronous Request）
異步請求允許客戶端發(fā)送請求后立即返回，而不需要等待服務(wù)器處理完成，異步調(diào)用允許在服務(wù)端異步執(zhí)行方法，不阻塞主線程。
二、在 Spring Boot 中，實現(xiàn)異步調(diào)用主要有以下幾種方法：
1. 使用 @Async 注解
步驟：
- 啟用異步支持：在主類上添加
@EnableAsync。 - 定義異步方法：在需要異步執(zhí)行的方法上使用
@Async注解。 - 自定義線程池（可選）：提高異步任務(wù)的線程管理效率，以便異步方法能夠在獨立的線程中執(zhí)行
示例代碼：
主類：
package com.work;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableAsync;
@SpringBootApplication(scanBasePackages = {"com.work.*"})
@EnableAsync
//@EnableScheduling
public class SpringBootWorkApplication {
public static void main(String[] args) {
SpringApplication.run(SpringBootWorkApplication.class, args);
}
}異步方法：
package com.work.service;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import lombok.extern.slf4j.Slf4j;
/**
* 異步調(diào)用service
* @author summer
*/
@Service
@Slf4j
public class AsyncService {
/**
* 使用 @Async 注解 實現(xiàn)異步調(diào)用
* taskExecutor為自定義線程池，指定自定義線程池
* @return
* @throws InterruptedException
*/
@Async("taskExecutor")
public void async(){
log.info("async異步任務(wù)開始: " + Thread.currentThread().getName());
try {
// 模擬耗時操作(實際工作中，此處寫業(yè)務(wù)邏輯處理)
Thread.sleep(30000);
} catch (InterruptedException e) {
e.printStackTrace();
}
log.info("async異步任務(wù)完成");
}
}自定義線程池（可選）：
package com.work.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.task.TaskExecutor;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
/**
* 自定義異步線程執(zhí)行線程池
* @author summer
*
*/
@Configuration
public class ExecutorConfig {
@Bean(name = "taskExecutor")
public TaskExecutor taskExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(5);
executor.setMaxPoolSize(10);
executor.setQueueCapacity(50);
executor.setThreadNamePrefix("TaskExecutor-");
executor.initialize();
return executor;
}
}
在 @Async("taskExecutor") 中指定自定義線程池。
調(diào)用：
package com.work.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import com.work.common.result.CommonResult;
import com.work.service.AsyncService;
import lombok.extern.slf4j.Slf4j;
/**
* 測試異步執(zhí)行Controller
* @author summer
*
*/
@RestController
@RequestMapping("/async")
@Slf4j
public class AsyncTestController {
@Autowired
private AsyncService asyncService;
@GetMapping("/async")
public CommonResult<String> async() {
asyncService.async();
log.info("async異步任務(wù)調(diào)用成功");
return CommonResult.success("async異步任務(wù)調(diào)用成功");
}
}異步方法休眠30秒，可以看到控制臺打印的日志
線程池配置建議
- CPU 密集型任務(wù)：建議核心線程數(shù)為 CPU 核心數(shù)的
n倍，最大線程數(shù)為核心線程數(shù)的 2 倍。 - IO 密集型任務(wù)：建議核心線程數(shù)設(shè)置為較大的值，最大線程數(shù)可以為核心線程數(shù)的 2 倍甚至更多。
合理配置線程池可以避免線程饑餓和死鎖等問題，提升系統(tǒng)的吞吐量。
2. 使用 Java 原生線程池
Spring 提供線程池，但可以直接使用 Java 原生的線程池來實現(xiàn)異步。
示例代碼：
package com.work.service;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import org.springframework.stereotype.Service;
import lombok.extern.slf4j.Slf4j;
/**
* 異步調(diào)用service
* @author summer
*
*/
@Service
@Slf4j
public class AsyncService{
/**
* 使用 Java 原生線程池來實現(xiàn)異步調(diào)用
*/
public void asyncThreadPool() {
ThreadPoolExecutor pool=new ThreadPoolExecutor(5, 10,
2, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(100),new ThreadPoolExecutor.CallerRunsPolicy());
pool.execute(() -> {
log.info("asyncThreadPool異步任務(wù)開始: " + Thread.currentThread().getName());
try {
// 模擬耗時操作(實際工作中，此處寫業(yè)務(wù)邏輯處理)
Thread.sleep(30000);
} catch (InterruptedException e) {
e.printStackTrace();
}
log.info("asyncThreadPool異步任務(wù)完成");
});
}
}
調(diào)用：
package com.work.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import com.work.common.result.CommonResult;
import com.work.service.AsyncService;
import lombok.extern.slf4j.Slf4j;
/**
* 測試異步執(zhí)行Controller
* @author summer
*
*/
@RestController
@RequestMapping("/async")
@Slf4j
public class AsyncTestController {
@Autowired
private AsyncService asyncService;
@GetMapping("/asyncThreadPool")
public CommonResult<String> asyncThreadPool() {
asyncService.asyncThreadPool();
log.info("asyncThreadPool異步任務(wù)調(diào)用成功");
return CommonResult.success("asyncThreadPool異步任務(wù)調(diào)用成功");
}
}
異步方法休眠30秒，可以看到控制臺打印的日志
3. 使用 Spring 的 TaskExecutor
TaskExecutor 是 Spring 提供的抽象接口，適合用來執(zhí)行異步任務(wù)。
配置 TaskExecutor：
package com.work.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.task.TaskExecutor;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
/**
* 自定義異步線程執(zhí)行線程池
* @author summer
*
*/
@Configuration
public class ExecutorConfig {
@Bean(name = "taskExecutor")
public TaskExecutor taskExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(5);
executor.setMaxPoolSize(10);
executor.setQueueCapacity(50);
executor.setThreadNamePrefix("TaskExecutor-");
executor.initialize();
return executor;
}
}示例代碼：
package com.work.service;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.task.TaskExecutor;
import org.springframework.stereotype.Service;
import lombok.extern.slf4j.Slf4j;
/**
* 異步調(diào)用service
* @author summer
*
*/
@Service
@Slf4j
public class AsyncService{
@Autowired
private TaskExecutor taskExecutor;
/**
* 使用 Spring 的 TaskExecutor 來實現(xiàn)異步調(diào)用
*/
public void asyncExecutor() {
taskExecutor.execute(() -> {
log.info("asyncExecutor異步任務(wù)開始:" + Thread.currentThread().getName());
try {
// 模擬耗時操作(實際工作中，此處寫業(yè)務(wù)邏輯處理)
Thread.sleep(30000);
} catch (InterruptedException e) {
e.printStackTrace();
}
log.info("asyncExecutor異步任務(wù)完成");
});
}
}
調(diào)用：
package com.work.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import com.work.common.result.CommonResult;
import com.work.service.AsyncService;
import lombok.extern.slf4j.Slf4j;
/**
* 測試異步執(zhí)行Controller
* @author summer
*
*/
@RestController
@RequestMapping("/async")
@Slf4j
public class AsyncTestController {
@Autowired
private AsyncService asyncService;
@GetMapping("/asyncExecutor")
public CommonResult<String> asyncExecutor() {
asyncService.asyncExecutor();
log.info("asyncExecutor異步任務(wù)調(diào)用成功");
return CommonResult.success("asyncExecutor異步任務(wù)調(diào)用成功");
}
}
異步方法休眠30秒，可以看到控制臺打印的日志
三、什么時候使用異步請求
異步請求在以下情況下特別有用：
- 長時間運行的任務(wù)：例如文件上傳、復(fù)雜計算、大量數(shù)據(jù)處理等。
- I/O操作：例如數(shù)據(jù)庫查詢、調(diào)用外部API、文件讀寫等。
- 資源密集型任務(wù)：例如圖像處理、視頻編碼等。
四、總結(jié)
方法 | 優(yōu)點 | 缺點 |
@Async 注解 | 簡單易用，與 Spring 集成良好 | 需要 Spring 容器管理的 Bean 才能生效 |
ExecutorService | 更底層、更靈活 | 手動管理線程池 |
TaskExecutor | Spring 提供的抽象，方便擴(kuò)展 | 配置稍顯復(fù)雜 |
這些示例展示了如何在Spring Boot中實現(xiàn)異步請求和異步調(diào)用。Spring Boot提供了`@Async`注解和`Java原生線程池`、`TaskExecutor`來實現(xiàn)這一功能，提高了應(yīng)用程序的并發(fā)處理能力，開發(fā)者可以根據(jù)不同的需求選擇合適的異步處理方式。
合理配置線程池，以確保最佳性能和資源利用，正確處理異步任務(wù)中的異常，以及在合適的場景中應(yīng)用異步處理技術(shù)，是開發(fā)高性能應(yīng)用的關(guān)鍵。
到此這篇關(guān)于SpringBoot實現(xiàn)異步調(diào)用的方法示例的文章就介紹到這了,更多相關(guān)SpringBoot 異步調(diào)用內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
這篇文章主要介紹了淺談Java Fork/Join并行框架，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-09-09
這篇文章主要介紹了spring同名bean覆蓋問題的解決方案，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-09-09
下面小編就為大家?guī)硪黄猄PFA 算法實例講解。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-07-07
在本篇文章里小編給大家分享了一篇關(guān)于java的主要特性學(xué)習(xí)總結(jié)內(nèi)容，有興趣的朋友們可以參考下。2020-05-05
SpringBoot使用Sharding-JDBC實現(xiàn)數(shù)據(jù)分片和讀寫分離的方法
本文主要介紹了SpringBoot使用Sharding-JDBC實現(xiàn)數(shù)據(jù)分片和讀寫分離，文中通過示例代碼介紹的非常詳細(xì)，具有一定的參考價值，感興趣的小伙伴們可以參考一下2021-10-10
這篇文章介紹了 6 種 JSON 解析方案,包括 Jackson、Gson、FastJSON、JsonPath、、手動解析,分別闡述了它們的功能特點、代碼示例、高級功能、優(yōu)缺點及適用場景,感興趣的小伙伴跟著小編一起來看看吧2025-01-01
Java的優(yōu)先隊列PriorityQueue原理及實例分析
這篇文章主要介紹了Java的優(yōu)先隊列PriorityQueue原理解析,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2019-12-12
文章總結(jié)：在Java中,處理不可變集合時,直接修改操作會拋出異常,正確的做法是使用可變集合類型,如ArrayList,或者通過流操作（stream().filter()）來實現(xiàn)修改,理解Java方法參數(shù)的傳遞方式（值傳遞）是關(guān)鍵,這決定了如何正確地修改對象的狀態(tài)2024-11-11
Windows同時安裝兩個版本JDK并實現(xiàn)動態(tài)切換JAVA8或JAVA11的方法
這篇文章主要給大家介紹了關(guān)于Windows同時安裝兩個版本JDK并實現(xiàn)動態(tài)切換JAVA8或JAVA11的相關(guān)資料,文中通過圖文介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2022-11-11
關(guān)于Java多線程編程鎖優(yōu)化的深入學(xué)習(xí)
本篇文章是關(guān)于Java多線程編程鎖優(yōu)化的深入學(xué)習(xí)總結(jié)內(nèi)容，對Java鎖優(yōu)化有興趣的朋友跟著學(xué)習(xí)下吧。2018-01-01