Spring MVC異步處理簡介

Sike 發布于2019-08-16 11:00 / 1774人閱讀

摘要：異步處理簡介地址相關系列文章異步處理詳解分析本文講到的所有特性皆是基于的，不是基于的。用于異步返回結果，使用自己的，使用負責處理它。配置執行異步操作需要用到，這個可以在用方法來提供相關文檔。

Spring MVC異步處理簡介

Github地址

相關系列文章：

Servlet 3.0 異步處理詳解

Servlet 3.1 Async IO分析

本文講到的所有特性皆是基于Servlet 3.0 Async Processing的，不是基于Servlet 3.1 Async IO的。

Callable

A Callable can be returned when the application wants to produce the return value asynchronously in a thread managed by Spring MVC.

用于異步返回結果，使用的是Spring MVC的AsyncTaskExecutor，Spring MVC使用CallableMethodReturnValueHandler負責處理它。

下面是例子CallableController：

@RestController
public class CallableController {

  @RequestMapping("callable-hello")
  public Callable hello() {
    return () -> new SlowJob("CallableController").doWork();
  }
}

用瀏覽器訪問：http://localhost:8080/callable-hello 查看返回結果。

DeferredResult

A DeferredResult can be returned when the application wants to produce the return value from a thread of its own choosing.

用于異步返回結果，使用的是client code自己的thread，Spring MVC使用DeferredResultMethodReturnValueHandler負責處理它。

下面是例子DeferredResultController：

@RestController
public class DeferredResultController {

  @Autowired
  @Qualifier("customExecutorService")
  private ExecutorService executorService;

  @RequestMapping("deferred-result-hello")
  public DeferredResult hello() {
    DeferredResult deferredResult = new DeferredResult<>();
    executorService.submit(() -> {
      try {
        deferredResult.setResult(new SlowJob("DeferredResultController").doWork());
      } catch (Exception e) {
        deferredResult.setErrorResult(e);
      }

    });
    return deferredResult;
  }

}

在這個例子里使用了ExecutorService（見ExecutorServiceConfiguration），你也可以根據實際情況采用別的機制來給DeferredResult.setResult。

用瀏覽器訪問：http://localhost:8080/deferred-result-hello 查看返回結果。

ListenableFuture or CompletableFuture/CompletionStage

A ListenableFuture or CompletableFuture/CompletionStage can be returned when the application wants to produce the value from a thread pool submission.

用于異步返回結果，使用client code自己的thread pool，Spring MVC使用DeferredResultMethodReturnValueHandler負責處理它。

下面是例子ListenableFutureController：

@RestController
public class ListenableFutureController {

  @Autowired
  @Qualifier("customExecutorService")
  private ExecutorService executorService;

  @RequestMapping("listenable-future-hello")
  public ListenableFutureTask hello() {

    ListenableFutureTask listenableFutureTask = new ListenableFutureTask<>(
        () -> new SlowJob("ListenableFutureController").doWork());
    executorService.submit(listenableFutureTask);
    return listenableFutureTask;
  }

}

用瀏覽器訪問：http://localhost:8080/listenable-future-hello 查看返回結果。

下面是例子CompletionFutureController

@RestController
public class CompletionFutureController {

  @RequestMapping("completable-future-hello")
  public CompletableFuture hello() {

    return CompletableFuture
        .supplyAsync(() -> new SlowJob("CompletionFutureController").doWork());
  }

}

用瀏覽器訪問：http://localhost:8080/completable-future-hello 查看返回結果。

ResponseBodyEmitter

A ResponseBodyEmitter can be returned to write multiple objects to the response asynchronously; also supported as the body within a ResponseEntity.

用于異步的寫入多個消息，使用的是client code自己的thread，Spring MVC使用ResponseBodyEmitterReturnValueHandler負責處理它。

下面是例子ResponseBodyEmitterController

@RestController
public class ResponseBodyEmitterController {

  @Autowired
  @Qualifier("customExecutorService")
  private ExecutorService executorService;

  @RequestMapping("response-body-emitter-hello")
  public ResponseBodyEmitter hello() {

    ResponseBodyEmitter emitter = new ResponseBodyEmitter();
    executorService.submit(() -> {
      try {
        for (int i = 0; i < 5; i++) {

          String hello = new SlowJob("ResponseBodyEmitterController").doWork();
          emitter.send("Count: " + (i + 1));
          emitter.send("
");
          emitter.send(hello);
          emitter.send("

");
        }
        emitter.complete();
      } catch (Exception e) {
        emitter.completeWithError(e);
      }

    });

    return emitter;
  }
}

用瀏覽器訪問：http://localhost:8080/response-body-emitter-hello 查看返回結果。

SseEmitter

An SseEmitter can be returned to write Server-Sent Events to the response asynchronously; also supported as the body within a ResponseEntity.

作用和ResponseBodyEmitter類似，也是異步的寫入多個消息，使用的是client code自己的thread，區別在于它使用的是Server-Sent Events。Spring MVC使用ResponseBodyEmitterReturnValueHandler負責處理它。

下面是例子SseEmitterController

@RestController
public class SseEmitterController {

  @Autowired
  @Qualifier("customExecutorService")
  private ExecutorService executorService;

  @RequestMapping("sse-emitter-hello")
  public ResponseBodyEmitter hello() {

    SseEmitter emitter = new SseEmitter();
    executorService.submit(() -> {
      try {
        for (int i = 0; i < 5; i++) {

          String hello = new SlowJob("SseEmitterController").doWork();
          StringBuilder sb = new StringBuilder();
          sb.append("Count: " + (i + 1)).append(". ").append(hello.replace("
", ""));
          emitter.send(sb.toString());
        }
        emitter.complete();
      } catch (Exception e) {
        emitter.completeWithError(e);
      }

    });

    return emitter;
  }
}

用瀏覽器訪問：http://localhost:8080/sse-emitter-hello 查看返回結果。

StreamingResponseBody

A StreamingResponseBody can be returned to write to the response OutputStream asynchronously; also supported as the body within a ResponseEntity.

用于異步write outputStream，使用的是Spring MVC的AsyncTaskExecutor，Spring MVC使用StreamingResponseBodyReturnValueHandler負責處理它。要注意，Spring MVC并沒有使用Servlet 3.1 Async IO（[Read|Write]Listener）。

下面是例子StreamingResponseBodyController

@RestController
public class StreamingResponseBodyController {

  @RequestMapping("streaming-response-body-hello")
  public StreamingResponseBody hello() {

    return outputStream -> {
      String hello = new SlowJob("CallableController").doWork();
      outputStream.write(hello.getBytes());
      outputStream.flush();
    };

  }
}

用瀏覽器訪問：http://localhost:8080/streaming-response-body-hello 查看返回結果。

配置MVC Async AsyncTaskExecutor

Spring MVC執行異步操作需要用到AsyncTaskExecutor，這個可以在用WebMvcConfigurer.configureAsyncSupport方法來提供（相關文檔）。
如果不提供，則使用SimpleAsyncTaskExecutor，SimpleAsyncTaskExecutor不使用thread pool，因此推薦提供自定義的AsyncTaskExecutor。

需要注意的是@EnableAsync也需要用到AsyncTaskExecutor，不過Spring MVC和它用的不是同一個。
順帶一提，EnableAsync默認也使用SimpleAsyncTaskExecutor，可以使用AsyncConfigurer.getAsyncExecutor方法來提供一個自定義的AsyncTaskExecutor。

例子見：MvcAsyncTaskExecutorConfigurer。

Interceptors

AsyncHandlerInterceptor，使用WebMvcConfigurer.addInterceptors注冊

CallableProcessingInterceptor[Adapter]，使用WebMvcConfigurer.configureAsyncSupport注冊

DeferredResultProcessingInterceptor[Adapter]，使用WebMvcConfigurer.configureAsyncSupport注冊

官方文檔：Intercepting Async Requests

WebAsyncManager

WebAsyncManager是Spring MVC管理async processing的中心類，如果你可以閱讀它的源碼來更多了解Spring MVC對于async processing的底層機制。

參考資料

Spring Web MVC Doc - Supported method return values

Spring Web MVC Doc - Asynchronous Request Processing

Spring Web MVC Doc - Configuring Asynchronous Request Processing

Configuring Spring MVC Async Threads

Spring MVC 3.2 Preview: Introducing Servlet 3, Async Support

Spring MVC 3.2 Preview: Techniques for Real-time Updates

Spring MVC 3.2 Preview: Making a Controller Method Asynchronous

Spring MVC 3.2 Preview: Adding Long Polling to an Existing Web Application

Spring MVC 3.2 Preview: Chat Sample

文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。

轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/70883.html

4.1、異步請求處理（TODO）

摘要：本部分示例見這個項目的分支下的中引進了基于異步請求處理的。同時主容器線程退出釋放并允許處理其他請求。對的調用返回，可以被用于異步處理之上的進一步控制。 ??本部分示例見這個項目的 mvc 分支下的 AsyncController.java ??Spring MVC 3.2 中引進了基于異步請求處理的 Servlet 3。除了返回一個值，一個控制器方法現在可以返回一個java.util...

AbnerMing 2019-08-14 15:53 評論0 收藏0
Spring核心 Spring簡介

摘要：基于工廠，會有多種應用上下文的實現的模塊在模塊中，面向切面編程提供了豐富的支持，該模塊是應用系統中開發切面的基礎，可以幫助應用對象解耦。的主頁安全對于許多應用都是一個非常關鍵的切面。簡化Java開發 JavaBean：Enterprise JavaBean、EJBJDO：Java數據對象、Java Data ObjectPOJO：Plain Old Java ObjectDI：依賴注...

sixgo 2019-08-15 10:42 評論0 收藏0
springmvc簡介和快速搭建

摘要：簡介和眾多其他框架一樣，它基于的設計理念，此外，它采用可松散耦合可插拔組件結構，比其他框架更具擴展性和靈活性。框架圍繞核心展開，是框架的總導演，總策劃，它負責截獲請求并將其分派給相應的處理器處理。 springmvc簡介 springmvc和眾多其他web框架一樣，它基于MVC的設計理念，此外，它采用可松散耦合可插拔組件結構，比其他MVC框架更具擴展性和靈活性。 springmvc通過...

Sike 2019-08-15 15:53 評論0 收藏0
后臺 - 收藏集 - 掘金

摘要：探究系統登錄驗證碼的實現后端掘金驗證碼生成類手把手教程后端博客系統第一章掘金轉眼間時間就從月份到現在的十一月份了。提供了與標準不同的工作方式我的后端書架后端掘金我的后端書架月前本書架主要針對后端開發與架構。 Spring Boot干貨系列總綱 | 掘金技術征文 - 掘金原本地址：Spring Boot干貨系列總綱博客地址：http://tengj.top/ 前言博主16年認識Spin...

CrazyCodes 2019-08-16 10:35 評論0 收藏0