SpringBoot實(shí)現(xiàn)異步調(diào)用的方法示例

更新時(shí)間：2025年01月13日 09:42:22 作者：summe學(xué)Java

本文介紹了在Java的SpringBoot中實(shí)現(xiàn)異步請(qǐng)求和異步調(diào)用的幾種方法,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

一、異步請(qǐng)求（Asynchronous Request）

異步請(qǐng)求允許客戶端發(fā)送請(qǐng)求后立即返回，而不需要等待服務(wù)器處理完成，異步調(diào)用允許在服務(wù)端異步執(zhí)行方法，不阻塞主線程。

二、在 Spring Boot 中，實(shí)現(xiàn)異步調(diào)用主要有以下幾種方法：

1. 使用 @Async 注解

步驟：

啟用異步支持：在主類上添加 @EnableAsync。
定義異步方法：在需要異步執(zhí)行的方法上使用 @Async 注解。
自定義線程池（可選）：提高異步任務(wù)的線程管理效率，以便異步方法能夠在獨(dú)立的線程中執(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 注解 實(shí)現(xiàn)異步調(diào)用
	 * taskExecutor為自定義線程池，指定自定義線程池
	 * @return
	 * @throws InterruptedException
	 */
	@Async("taskExecutor")
    public void async(){
		log.info("async異步任務(wù)開始: " + Thread.currentThread().getName());
		try {
			// 模擬耗時(shí)操作(實(shí)際工作中，此處寫業(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秒，可以看到控制臺(tái)打印的日志

線程池配置建議

CPU 密集型任務(wù)：建議核心線程數(shù)為 CPU 核心數(shù)的 n 倍，最大線程數(shù)為核心線程數(shù)的 2 倍。
IO 密集型任務(wù)：建議核心線程數(shù)設(shè)置為較大的值，最大線程數(shù)可以為核心線程數(shù)的 2 倍甚至更多。

合理配置線程池可以避免線程饑餓和死鎖等問題，提升系統(tǒng)的吞吐量。

2. 使用 Java 原生線程池

Spring 提供線程池，但可以直接使用 Java 原生的線程池來實(shí)現(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 原生線程池來實(shí)現(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 {
            	// 模擬耗時(shí)操作(實(shí)際工作中，此處寫業(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秒，可以看到控制臺(tái)打印的日志

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 來實(shí)現(xiàn)異步調(diào)用
	 */
	public void asyncExecutor() {
        taskExecutor.execute(() -> {
        	log.info("asyncExecutor異步任務(wù)開始:" + Thread.currentThread().getName());
            try {
            	// 模擬耗時(shí)操作(實(shí)際工作中，此處寫業(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秒，可以看到控制臺(tái)打印的日志

三、什么時(shí)候使用異步請(qǐng)求

異步請(qǐng)求在以下情況下特別有用：

長時(shí)間運(yùn)行的任務(wù)：例如文件上傳、復(fù)雜計(jì)算、大量數(shù)據(jù)處理等。
I/O操作：例如數(shù)據(jù)庫查詢、調(diào)用外部API、文件讀寫等。
資源密集型任務(wù)：例如圖像處理、視頻編碼等。

四、總結(jié)

方法	優(yōu)點(diǎn)	缺點(diǎn)
@Async 注解	簡單易用，與 Spring 集成良好	需要 Spring 容器管理的 Bean 才能生效
ExecutorService	更底層、更靈活	手動(dòng)管理線程池
TaskExecutor	Spring 提供的抽象，方便擴(kuò)展	配置稍顯復(fù)雜

這些示例展示了如何在Spring Boot中實(shí)現(xiàn)異步請(qǐng)求和異步調(diào)用。Spring Boot提供了`@Async`注解和`Java原生線程池`、`TaskExecutor`來實(shí)現(xiàn)這一功能，提高了應(yīng)用程序的并發(fā)處理能力，開發(fā)者可以根據(jù)不同的需求選擇合適的異步處理方式。

合理配置線程池，以確保最佳性能和資源利用，正確處理異步任務(wù)中的異常，以及在合適的場景中應(yīng)用異步處理技術(shù)，是開發(fā)高性能應(yīng)用的關(guān)鍵。

到此這篇關(guān)于SpringBoot實(shí)現(xiàn)異步調(diào)用的方法示例的文章就介紹到這了,更多相關(guān)SpringBoot 異步調(diào)用內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: