SpringMVC異步處理的方法有哪些-創(chuàng)新互聯(lián)

這篇文章主要介紹SpringMVC異步處理的方法有哪些，文中介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們一定要看完！

成都創(chuàng)新互聯(lián)公司服務項目包括新興網站建設、新興網站制作、新興網頁制作以及新興網絡營銷策劃等。多年來，我們專注于互聯(lián)網行業(yè)，利用自身積累的技術優(yōu)勢、行業(yè)經驗、深度合作伙伴關系等，向廣大中小型企業(yè)、政府機構等提供互聯(lián)網行業(yè)的解決方案，新興網站推廣取得了明顯的社會效益與經濟效益。目前，我們服務的客戶以成都為中心已經輻射到新興省份的部分城市，未來相信會繼續(xù)擴大服務區(qū)域并繼續(xù)獲得客戶的支持與信任！

異步處理 demo

如果要啟用異步返回，需要開啟 @EnableAsync。如下的代碼中，使用 DeferredResult 進行異步處理。

請求進來后，首先創(chuàng)建 DeferredResult 對象，設置超時時間為 60 秒。然后指定DeferredResult 在異步完成和等待超時時的回調。同步的處理只需要創(chuàng)建異步任何，然后返回DeferredResult 即可。這樣 Spring MVC 處理完此次請求后，不會立即返回 response 給客戶端，會一直等待DeferredResult 處理完成。如果DeferredResult 沒有在 60 秒內處理完成，就會觸發(fā)超時，然后返回 response 給客戶端。

@RequestMapping(value = "/async/demo")
public DeferredResult<String> async(){
 // 創(chuàng)建 DeferredResult，設置超時時間 60s
 DeferredResult<String> deferredResult = new DeferredResult<>((long)60 * 1000);

 String uuid = UUID.randomUUID().toString();
 Runnable callback = () -> manager.remove(deferredResult, uuid);
 // 設置完成和超時的回調
 deferredResult.onCompletion(callback);
 deferredResult.onTimeout(callback);

 // 創(chuàng)建異步任務
 manager.addAsyncTask(deferredResult, uuid);

 // 同步返回 DeferredResult
 return deferredResult;
}

對于異步任務來說，需要持有DeferredResult 對象。在異步處理結束時，需要手動調用DeferredResult.setResult完成輸出。調用setResult 時，數(shù)據(jù)輸出寫到客戶端，然后觸發(fā)異步完成事件執(zhí)行回調。

task.getDeferredResult().setResult(ConfigJsonUtils.toJsonString(map));

使用 DeferredResult 進行異步處理

DeferredResult 這個類代表延遲結果。DeferredResult 可以用在異步任務中，其他線程能夠獲取DeferredResult并設置DeferredResult 的返回數(shù)據(jù)。通?？梢允褂镁€程池、隊列等配合DeferredResult 實現(xiàn)異步處理。

根據(jù)官方描述，Spring MVC 處理流程如下：

  1. 把 controller 返回的 DeferredResult 保存在內存隊列或集合當中；

  2. Spring MVC 調用 request.startAsync()，開啟異步；

  3. DispatcherServlet 和所有的 Filter 退出當前請求線程；

  4. 業(yè)務應用在異步線程中設置 DeferredResult 的返回值， Spring MVC 會再次發(fā)送請求；

  5. DispatcherServlet 再次被調用，并使用 DeferredResult 的返回值；

使用 Callable 進行異步處理

使用 Callable 進行異步處理與 DeferredResult 類似。不同的是，Callable 會交給系統(tǒng)指定的 TaskExecutor 執(zhí)行。

根據(jù)官方描述，Spring MVC 處理流程如下：

  1. controller 返回 Callable ；

  2. Spring MVC 調用 request.startAsync()，開啟異步，提交 Callable 到一個任務線程池 ；

  3. DispatcherServlet 和所有的 Filter 退出當前請求線程；

  4. 業(yè)務應用在異步線程中 返回值， Spring MVC 會再次發(fā)送請求；

  5. DispatcherServlet 再次被調用，并使用 Callable 的返回值；

@RequestMapping(value = "/async/demo")
public Callable<String> async(){
 Callable<String> callable = () -> String.valueOf(System.currentTimeMillis());
 // 同步返回
 return callable;
}

使用 ListenableFuture 進行異步處理

ListenableFuture 作為返回值，與DeferredResult 類似。也需要使用者自行處理異步線程，但不支持超時、完成回調，需要自行處理。

@RequestMapping(value = "/async/demo")
public ListenableFuture<String> async(){
 ListenableFutureTask<String> ListenableFuture= new ListenableFutureTask<>(() -> {
  return String.valueOf(System.currentTimeMillis());
 });
 Executors.newSingleThreadExecutor().submit(ListenableFuture);
 return ListenableFuture;
}

使用 ResponseBodyEmitter 進行異步處理

DeferredResult 和 Callable 都只能返回一個異步值。如果需要返回多個對象，就要使用 ResponseBodyEmitter。返回的每個對象都會被 HttpMessageConverter 處理并寫回輸出流。如果希望設置更多返回數(shù)據(jù)，如 header、status 等，可以把 ResponseBodyEmitter 作為 ResponseEntity 的實體數(shù)據(jù)返回。

@RequestMapping("/async/responseBodyEmitter")
public ResponseBodyEmitter responseBodyEmitter(){
 ResponseBodyEmitter responseBodyEmitter=new ResponseBodyEmitter();

 Executors.newSingleThreadExecutor().submit(() -> {
  try {
   responseBodyEmitter.send("demo");
   responseBodyEmitter.send("test");
   responseBodyEmitter.complete();
  } catch (Exception ignore) {}
 });

 return responseBodyEmitter;
}

使用 StreamingResponseBody 進行異步處理

如果希望跳過返回值的自動轉換，直接把輸出流寫入OutputStream，可以使用 StreamingResponseBody。也可以作為 ResponseEntity 的實體數(shù)據(jù)返回。

@RequestMapping("/async/streamingResponseBody")
public StreamingResponseBody streamingResponseBody(){
 StreamingResponseBody streamingResponseBody = outputStream -> {
  Executors.newSingleThreadExecutor().submit(() -> {
   try {
    outputStream.write("<html>streamingResponseBody</html>".getBytes());
   } catch (IOException ignore) {}
  });
 };
 return streamingResponseBody;
}

各種處理方式的對比


 可返回次數(shù)

數(shù)據(jù)轉換

回調

線程池


DeferredResult

1 次

有

完成、超時

自行處理

Callable

1 次

有

無

系統(tǒng)處理

ListenableFuture

1 次

有

無

自行處理

ResponseBodyEmitter

多次

有

無

自行處理

StreamingResponseBody

多次

無

無

自行處理

以上是“SpringMVC異步處理的方法有哪些”這篇文章的所有內容，感謝各位的閱讀！希望分享的內容對大家有幫助，更多相關知識，歡迎關注創(chuàng)新互聯(lián)行業(yè)資訊頻道！

當前題目：SpringMVC異步處理的方法有哪些-創(chuàng)新互聯(lián)
文章轉載：http://www.bm7419.com/article6/ceshog.html

成都網站建設公司_創(chuàng)新互聯(lián)，為您提供Google、電子商務、做網站、定制開發(fā)、App開發(fā)、網站設計

廣告

聲明：本網站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)

手機網站建設