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

Spring Boot 使用WebAsyncTask異步返回結(jié)果

 更新時(shí)間:2018年02月02日 15:39:37   作者:尹吉?dú)g  
這篇文章主要介紹了Spring Boot 使用WebAsyncTask異步返回結(jié)果的相關(guān)資料,需要的朋友可以參考下

在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)站的支持!

相關(guān)文章

  • java中1+1d/5和1+1/5的區(qū)別說(shuō)明

    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版)

    長(zhǎng)度最小的子數(shù)組題目詳解(Java版)

    這篇文章主要給大家介紹了關(guān)于長(zhǎng)度最小的子數(shù)組(Java版)的相關(guān)資料,這到題來(lái)自力扣,通過(guò)學(xué)習(xí)本文對(duì)大家理解這道題目有很大的幫助,需要的朋友可以參考下
    2023-12-12
  • Java8實(shí)現(xiàn)FTP及SFTP文件上傳下載

    Java8實(shí)現(xiàn)FTP及SFTP文件上傳下載

    這篇文章主要介紹了Java8實(shí)現(xiàn)FTP及SFTP文件上傳下載,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
    2020-09-09
  • java中的基礎(chǔ)運(yùn)算符

    java中的基礎(chǔ)運(yùn)算符

    這篇文章主要介紹了Java基本數(shù)據(jù)類型和運(yùn)算符,結(jié)合實(shí)例形式詳細(xì)分析了java基本數(shù)據(jù)類型、數(shù)據(jù)類型轉(zhuǎn)換、算術(shù)運(yùn)算符、邏輯運(yùn)算符等相關(guān)原理與操作技巧,需要的朋友可以參考下
    2021-08-08
  • Java List按照某字段去重的使用示例

    Java List按照某字段去重的使用示例

    在Java開(kāi)發(fā)中,我們經(jīng)常會(huì)面臨對(duì)List中對(duì)象屬性去重的需求,本文主要介紹了Java List按照某字段去重的使用示例,具有一定的參考價(jià)值,感興趣的可以了解一下
    2023-12-12
  • Java實(shí)現(xiàn)優(yōu)雅的參數(shù)校驗(yàn)方法詳解

    Java實(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-06
  • Java深入講解SPI的使用

    Java深入講解SPI的使用

    SPI英文全稱為Service Provider Interface,顧名思義,服務(wù)提供者接口,它是jdk提供給“服務(wù)提供廠商”或者“插件開(kāi)發(fā)者”使用的接口
    2022-06-06
  • Java 正確地從類路徑中獲取資源

    Java 正確地從類路徑中獲取資源

    Java 有能力從類路徑中查找獲取資源,可將資源放在 CLASSPATH 里,也可打包到 Jar 中。本文將具體講述獲取資源的步驟,感興趣的朋友可以了解下
    2021-05-05
  • spring+html5實(shí)現(xiàn)安全傳輸隨機(jī)數(shù)字密碼鍵盤(pán)

    spring+html5實(shí)現(xiàn)安全傳輸隨機(jī)數(shù)字密碼鍵盤(pán)

    這篇文章主要為大家詳細(xì)介紹了spring html5實(shí)現(xiàn)安全傳輸隨機(jī)數(shù)字密碼鍵盤(pán),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2017-04-04
  • java編程題之順時(shí)針打印矩陣

    java編程題之順時(shí)針打印矩陣

    這篇文章主要為大家詳細(xì)介紹了java編程題之順時(shí)針打印矩陣,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2019-03-03

最新評(píng)論