欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

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í)吧

在Java中使用Spring Boot實(shí)現(xiàn)異步請(qǐng)求和異步調(diào)用是一個(gè)常見的需求,可以提高應(yīng)用程序的性能和響應(yīng)能力。以下是實(shí)現(xiàn)這兩種異步操作的基本方法:

一、異步請(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)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • 淺談Java Fork/Join并行框架

    淺談Java Fork/Join并行框架

    這篇文章主要介紹了淺談Java Fork/Join并行框架,小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧
    2017-09-09
  • 基于spring同名bean覆蓋問題的解決

    基于spring同名bean覆蓋問題的解決

    這篇文章主要介紹了spring同名bean覆蓋問題的解決方案,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2021-09-09
  • SPFA 算法實(shí)例講解

    SPFA 算法實(shí)例講解

    下面小編就為大家?guī)硪黄猄PFA 算法實(shí)例講解。小編覺得挺不錯(cuò)的,現(xiàn)在就分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧
    2017-07-07
  • java的主要特性學(xué)習(xí)總結(jié)

    java的主要特性學(xué)習(xí)總結(jié)

    在本篇文章里小編給大家分享了一篇關(guān)于java的主要特性學(xué)習(xí)總結(jié)內(nèi)容,有興趣的朋友們可以參考下。
    2020-05-05
  • SpringBoot使用Sharding-JDBC實(shí)現(xiàn)數(shù)據(jù)分片和讀寫分離的方法

    SpringBoot使用Sharding-JDBC實(shí)現(xiàn)數(shù)據(jù)分片和讀寫分離的方法

    本文主要介紹了SpringBoot使用Sharding-JDBC實(shí)現(xiàn)數(shù)據(jù)分片和讀寫分離,文中通過示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2021-10-10
  • Java解析JSON的六種方案

    Java解析JSON的六種方案

    這篇文章介紹了 6 種 JSON 解析方案,包括 Jackson、Gson、FastJSON、JsonPath、、手動(dòng)解析,分別闡述了它們的功能特點(diǎn)、代碼示例、高級(jí)功能、優(yōu)缺點(diǎn)及適用場景,感興趣的小伙伴跟著小編一起來看看吧
    2025-01-01
  • Java的優(yōu)先隊(duì)列PriorityQueue原理及實(shí)例分析

    Java的優(yōu)先隊(duì)列PriorityQueue原理及實(shí)例分析

    這篇文章主要介紹了Java的優(yōu)先隊(duì)列PriorityQueue原理解析,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
    2019-12-12
  • JAVA值傳遞和引用傳遞方式

    JAVA值傳遞和引用傳遞方式

    文章總結(jié):在Java中,處理不可變集合時(shí),直接修改操作會(huì)拋出異常,正確的做法是使用可變集合類型,如ArrayList,或者通過流操作(stream().filter())來實(shí)現(xiàn)修改,理解Java方法參數(shù)的傳遞方式(值傳遞)是關(guān)鍵,這決定了如何正確地修改對(duì)象的狀態(tài)
    2024-11-11
  • Windows同時(shí)安裝兩個(gè)版本JDK并實(shí)現(xiàn)動(dòng)態(tài)切換JAVA8或JAVA11的方法

    Windows同時(shí)安裝兩個(gè)版本JDK并實(shí)現(xiàn)動(dòng)態(tài)切換JAVA8或JAVA11的方法

    這篇文章主要給大家介紹了關(guān)于Windows同時(shí)安裝兩個(gè)版本JDK并實(shí)現(xiàn)動(dòng)態(tài)切換JAVA8或JAVA11的相關(guān)資料,文中通過圖文介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
    2022-11-11
  • 關(guān)于Java多線程編程鎖優(yōu)化的深入學(xué)習(xí)

    關(guān)于Java多線程編程鎖優(yōu)化的深入學(xué)習(xí)

    本篇文章是關(guān)于Java多線程編程鎖優(yōu)化的深入學(xué)習(xí)總結(jié)內(nèi)容,對(duì)Java鎖優(yōu)化有興趣的朋友跟著學(xué)習(xí)下吧。
    2018-01-01

最新評(píng)論