Spring Boot 使用WebAsyncTask異步返回結(jié)果
在Spring Boot中(Spring MVC)下請(qǐng)求默認(rèn)都是同步的,一個(gè)請(qǐng)求過(guò)去到結(jié)束都是由一個(gè)線程負(fù)責(zé)的,很多時(shí)候?yàn)榱四軌蛱岣咄掏铝?,需要將一些操作異步化,除了一些耗時(shí)的業(yè)務(wù)邏輯可以異步化,我們的查詢接口也是可以做到異步執(zhí)行。
一個(gè)請(qǐng)求到服務(wù)上,是用的web容器的線程接收的,比如線程http-nio-8084-exec-1
我們可以使用WebAsyncTask將這個(gè)請(qǐng)求分發(fā)給一個(gè)新的線程去執(zhí)行,http-nio-8084-exec-1可以去接收其他請(qǐng)求的處理。一旦WebAsyncTask返回?cái)?shù)據(jù)有了,就會(huì)被再次調(diào)用并且處理,以異步產(chǎn)生的方式,向請(qǐng)求端返回值。
示例代碼如下:
@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); /模擬長(zhǎng)時(shí)間任務(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ù)邏輯的線程不是同一個(gè),達(dá)到了我們的目的。
然后我做了一個(gè)并發(fā)測(cè)試,發(fā)現(xiàn)不停的在創(chuàng)建MvcAsync1這個(gè)線程,我就在想,難道沒(méi)有用線程池?
通過(guò)閱讀源碼才發(fā)現(xiàn)果真如此,WebAsyncManager是Spring MVC管理async processing的中心類。
默認(rèn)是使用SimpleAsyncTaskExecutor,這個(gè)會(huì)為每次請(qǐng)求創(chuàng)建一個(gè)新的線程
private AsyncTaskExecutor taskExecutor = new SimpleAsyncTaskExecutor(this.getClass().getSimpleName());
如果說(shuō)任務(wù)指定了executor,就用任務(wù)指定的,沒(méi)有就用默認(rèn)的SimpleAsyncTaskExecutor
AsyncTaskExecutor executor = webAsyncTask.getExecutor(); if (executor != null) { this.taskExecutor = executor; }
我們可以配置async 的線程池,不需要為每個(gè)任務(wù)單獨(dú)指定
通過(guò)configurer.setTaskExecutor(threadPoolTaskExecutor());來(lái)指定
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開(kāi)頭的了,而且也不會(huì)一直創(chuàng)建新的線程
可以看到輸出結(jié)果如下:
/login被調(diào)用 thread id is : http-nio-8084-exec-1 執(zhí)行成功 thread id is : YJH1
總結(jié)
以上所述是小編給大家介紹的Spring Boot 使用WebAsyncTask異步返回結(jié)果,希望對(duì)大家有所幫助,如果大家有任何疑問(wèn)請(qǐng)給我留言,小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)腳本之家網(wǎng)站的支持!
- springboot使用TaskScheduler實(shí)現(xiàn)動(dòng)態(tài)增刪啟停定時(shí)任務(wù)方式
- springboot使用ThreadPoolTaskExecutor多線程批量插入百萬(wàn)級(jí)數(shù)據(jù)的實(shí)現(xiàn)方法
- springboot使用線程池(ThreadPoolTaskExecutor)示例
- 使用spring-task定時(shí)任務(wù)動(dòng)態(tài)配置修改執(zhí)行時(shí)間
- Spring Task定時(shí)任務(wù)的配置和使用詳解
- 分布式調(diào)度器之Spring Task 的使用詳解
相關(guān)文章
java中1+1d/5和1+1/5的區(qū)別說(shuō)明
這篇文章主要介紹了java中1+1d/5和1+1/5的區(qū)別說(shuō)明,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-10-10長(zhǎng)度最小的子數(shù)組題目詳解(Java版)
這篇文章主要給大家介紹了關(guān)于長(zhǎng)度最小的子數(shù)組(Java版)的相關(guān)資料,這到題來(lái)自力扣,通過(guò)學(xué)習(xí)本文對(duì)大家理解這道題目有很大的幫助,需要的朋友可以參考下2023-12-12Java8實(shí)現(xiàn)FTP及SFTP文件上傳下載
這篇文章主要介紹了Java8實(shí)現(xiàn)FTP及SFTP文件上傳下載,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-09-09Java實(shí)現(xiàn)優(yōu)雅的參數(shù)校驗(yàn)方法詳解
這篇文章主要為大家詳細(xì)介紹了Java語(yǔ)言如何實(shí)現(xiàn)優(yōu)雅的參數(shù)校驗(yàn),文中的示例代碼講解詳細(xì),對(duì)我們學(xué)習(xí)Java有一定是幫助,需要的可以參考一下2022-06-06spring+html5實(shí)現(xiàn)安全傳輸隨機(jī)數(shù)字密碼鍵盤(pán)
這篇文章主要為大家詳細(xì)介紹了spring html5實(shí)現(xiàn)安全傳輸隨機(jī)數(shù)字密碼鍵盤(pán),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2017-04-04