Spring Boot 使用WebAsyncTask異步返回結(jié)果
在Spring Boot中（Spring MVC）下請求默認都是同步的，一個請求過去到結(jié)束都是由一個線程負責(zé)的，很多時候為了能夠提高吞吐量，需要將一些操作異步化，除了一些耗時的業(yè)務(wù)邏輯可以異步化，我們的查詢接口也是可以做到異步執(zhí)行。
一個請求到服務(wù)上，是用的web容器的線程接收的，比如線程http-nio-8084-exec-1
我們可以使用WebAsyncTask將這個請求分發(fā)給一個新的線程去執(zhí)行，http-nio-8084-exec-1可以去接收其他請求的處理。一旦WebAsyncTask返回數(shù)據(jù)有了，就會被再次調(diào)用并且處理，以異步產(chǎn)生的方式，向請求端返回值。
示例代碼如下：
@RequestMapping(value="/login", method = RequestMethod.GET)
public WebAsyncTask<ModelAndView> longTimeTask(){
System.out.println("/login被調(diào)用 thread id is : " + Thread.currentThread().getName());
Callable<ModelAndView> callable = new Callable<ModelAndView>() {
public ModelAndView call() throws Exception {
Thread.sleep(1000); /模擬長時間任務(wù)
ModelAndView mav = new ModelAndView("login/index");
System.out.println("執(zhí)行成功 thread id is : " + Thread.currentThread().getName());
return mav;
}
};
return new WebAsyncTask<ModelAndView>(callable);
}
可以看到輸出結(jié)果如下：
/login被調(diào)用 thread id is : http-nio-8084-exec-1
執(zhí)行成功 thread id is : MvcAsync1
在執(zhí)行業(yè)務(wù)邏輯之前的線程和具體處理業(yè)務(wù)邏輯的線程不是同一個，達到了我們的目的。
然后我做了一個并發(fā)測試，發(fā)現(xiàn)不停的在創(chuàng)建MvcAsync1這個線程，我就在想，難道沒有用線程池？
通過閱讀源碼才發(fā)現(xiàn)果真如此，WebAsyncManager是Spring MVC管理async processing的中心類。
默認是使用SimpleAsyncTaskExecutor,這個會為每次請求創(chuàng)建一個新的線程
private AsyncTaskExecutor taskExecutor = new SimpleAsyncTaskExecutor(this.getClass().getSimpleName());
如果說任務(wù)指定了executor，就用任務(wù)指定的,沒有就用默認的SimpleAsyncTaskExecutor
AsyncTaskExecutor executor = webAsyncTask.getExecutor();
if (executor != null) {
this.taskExecutor = executor;
}
我們可以配置async 的線程池，不需要為每個任務(wù)單獨指定
通過configurer.setTaskExecutor(threadPoolTaskExecutor());來指定
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.web.context.request.async.TimeoutCallableProcessingInterceptor;
import org.springframework.web.servlet.config.annotation.AsyncSupportConfigurer;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurationSupport;
@Configuration
public class WebMvcConfig extends WebMvcConfigurationSupport {
@Override
public void configureAsyncSupport(final AsyncSupportConfigurer configurer) {
configurer.setDefaultTimeout(60 * 1000L);
configurer.registerCallableInterceptors(timeoutInterceptor());
configurer.setTaskExecutor(threadPoolTaskExecutor());
}
@Bean
public TimeoutCallableProcessingInterceptor timeoutInterceptor() {
return new TimeoutCallableProcessingInterceptor();
}
@Bean
public ThreadPoolTaskExecutor threadPoolTaskExecutor() {
ThreadPoolTaskExecutor t = new ThreadPoolTaskExecutor();
t.setCorePoolSize(10);
t.setMaxPoolSize(50);
t.setThreadNamePrefix("YJH");
return t;
}
}
配置完之后就可以看到輸出的線程名稱是YJH開頭的了，而且也不會一直創(chuàng)建新的線程
可以看到輸出結(jié)果如下：
/login被調(diào)用 thread id is : http-nio-8084-exec-1 執(zhí)行成功 thread id is : YJH1
總結(jié)
以上所述是小編給大家介紹的Spring Boot 使用WebAsyncTask異步返回結(jié)果，希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時回復(fù)大家的。在此也非常感謝大家對腳本之家網(wǎng)站的支持！
相關(guān)文章
Spring?Security權(quán)限注解啟動及邏輯處理使用示例
這篇文章主要為大家介紹了Spring?Security權(quán)限注解啟動及邏輯處理使用示例，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2023-07-07
Java static關(guān)鍵字詳細介紹與用法總結(jié)
這篇文章主要介紹了Java中static關(guān)鍵字的作用和用法詳細介紹,主要講了靜態(tài)方法、靜態(tài)變量、靜態(tài)類、static和final一塊用等內(nèi)容。需要的朋友可以參考下2017-04-04
在項目中我們肯定不能使用Spring自己生成的登錄頁面，而要用我們自己的登錄頁面，下面通過本文給大家分享spring security自定義登錄頁面的實現(xiàn)方法，一起看看吧2017-09-09
在jmeter的beanshell中用java獲取系統(tǒng)當(dāng)前時間的簡單實例
這篇文章介紹了在jmeter的beanshell中用java獲取系統(tǒng)當(dāng)前時間的簡單實例，有需要的朋友可以參考一下2013-09-09
詳解JavaFX桌面應(yīng)用開發(fā)-Group（容器組）
這篇文章主要介紹了JavaFX桌面應(yīng)用開發(fā)-Group（容器組），文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-04-04
詳解Spring-boot中讀取config配置文件的兩種方式
這篇文章主要介紹了詳解Spring-boot中讀取config配置文件的兩種方式，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-10-10
本文主要介紹了mybatis-plus自動填充插入更新時間有8小時時差，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2021-09-09
這篇文章主要介紹了java轉(zhuǎn)換字符串編碼格式的方法，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2018-08-08
JavaCV是一個開源的Java接口,它為幾個著名的計算機視覺庫(如OpenCV、FFmpeg)提供了Java封裝,這篇文章主要給大家介紹了關(guān)于JavaCV簡介與環(huán)境搭建的相關(guān)資料,需要的朋友可以參考下2024-04-04
教你使用eclipse?搭建Swt?環(huán)境的全過程
本文給大家分享使用eclipse?搭建Swt?環(huán)境的全過程，本文通過圖文并茂的形式給大家介紹的非常詳細，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2021-12-12