SpringMVC異步處理操作(Callable和DeferredResult)

更新時間：2021年01月20日 09:29:29 作者：coder_rad

這篇文章主要介紹了SpringMVC異步處理操作(Callable和DeferredResult)，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧

官方文檔中說DeferredResult和Callable都是為了異步生成返回值提供基本的支持。簡單來說就是一個請求進來，如果你使用了DeferredResult或者Callable，在沒有得到返回數據之前，DispatcherServlet和所有Filter就會退出Servlet容器線程，但響應保持打開狀態(tài)，一旦返回數據有了，這個DispatcherServlet就會被再次調用并且處理，以異步產生的方式，向請求端返回值。

這么做的好處就是請求不會長時間占用服務連接池，提高服務器的吞吐量。

Callable

@GetMapping("/callable")
 public Callable<String> testCallable() throws InterruptedException {
  log.info("主線程開始！");
  Callable<String> result = new Callable<String>() {
   @Override
   public String call() throws Exception {
    log.info("副線程開始！");
    Thread.sleep(1000);
    log.info("副線程結束！");
    return "SUCCESS";
   }
  };
  log.info("主線程結束！");
  return result;
 }

輸出的結果如下：

主線程開始!

主線程結束!

副線程開始!

副線程結束!

主線程會提前返回，可以處理其他請求，等待有結果之后再輸出結果

DeferredResult

一旦啟用了異步請求處理功能，控制器就可以將返回值包裝在DeferredResult，控制器可以從不同的線程異步產生返回值。優(yōu)點就是可以實現兩個完全不相干的線程間的通信。

我們模擬如下場景：

由于消息隊列和應用2的部分太繁瑣，我們使用一個類來代替

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
@Component
public class MockQueue {
 private String placeOrder;
 private String completeOrder;
 private Logger logger = LoggerFactory.getLogger(getClass());
 public String getPlaceOrder() {
  return placeOrder;
 }
 public void setPlaceOrder(String placeOrder) throws Exception {
  new Thread(() -> {
   logger.info("接到下單請求, " + placeOrder);
   try {
    Thread.sleep(1000);
   } catch (Exception e) {
    e.printStackTrace();
   }
   this.completeOrder = placeOrder;
   logger.info("下單請求處理完畢," + placeOrder);
  }).start();
 }
 public String getCompleteOrder() {
  return completeOrder;
 }
 public void setCompleteOrder(String completeOrder) {
  this.completeOrder = completeOrder;
 }
}

定義一個Controller即線程1的部分

import org.apache.commons.lang.RandomStringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.context.request.async.DeferredResult;
@RestController
public class AsyncController {
 @Autowired
 private MockQueue mockQueue;
 @Autowired
 private DeferredResultHolder deferredResultHolder;
 private Logger logger = LoggerFactory.getLogger(getClass());
 @RequestMapping("/order")
 public DeferredResult<String> order() throws Exception {
  logger.info("主線程開始");
  String orderNumber = RandomStringUtils.randomNumeric(8);
  mockQueue.setPlaceOrder(orderNumber);
  DeferredResult<String> result = new DeferredResult<>();
  deferredResultHolder.getMap().put(orderNumber, result);
  return result;
 }
}

定義一個類，用來線程1和線程2之間通信的，使用@Component默認為單例，方便通信。

import java.util.HashMap;
import java.util.Map;
import org.springframework.stereotype.Component;
import org.springframework.web.context.request.async.DeferredResult;
@Component
public class DeferredResultHolder {
 private Map<String, DeferredResult<String>> map = new HashMap<String, DeferredResult<String>>();
 public Map<String, DeferredResult<String>> getMap() {
  return map;
 }
 public void setMap(Map<String, DeferredResult<String>> map) {
  this.map = map;
 }
}

定義一個類來監(jiān)聽訂單是否處理完，如果處理完了的話就設置deferredResultHolder中的DeferredResult的值，就會返回結果了。

import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationListener;
import org.springframework.context.event.ContextRefreshedEvent;
import org.springframework.stereotype.Component;
@Component
public class QueueListener implements ApplicationListener<ContextRefreshedEvent> {
 @Autowired
 private MockQueue mockQueue;
 @Autowired
 private DeferredResultHolder deferredResultHolder;
 private Logger logger = LoggerFactory.getLogger(getClass());
 @Override
 public void onApplicationEvent(ContextRefreshedEvent event) {
  new Thread(() -> {
   while (true) {
    if (StringUtils.isNotBlank(mockQueue.getCompleteOrder())) {
     String orderNumber = mockQueue.getCompleteOrder();
     logger.info("返回訂單處理結果:"+orderNumber);
     deferredResultHolder.getMap().get(orderNumber).setResult("place order success");
     mockQueue.setCompleteOrder(null);
    }else{
     try {
      Thread.sleep(100);
     } catch (InterruptedException e) {
      e.printStackTrace();
     }
    }
   }
  }).start();
 }
}

補充：springmvc使用異步處理請求

同步請求圖示：

同步處理的圖示如上：HTTP請求，tomcat或其他中間件會有一個相應的線程來處理這個Http請求，所有的業(yè)務邏輯都會在這個線程里去執(zhí)行，最后返回Http響應。但是tomcat等中間件，它們可以管理的線程數是有限的，當數量達到一定程度之后，再有請求進入，會被阻塞掉。

簡單異步圖示：

異步處理過程：當一個http請求進入后，tomcat等中間件的主線程調用副線程來執(zhí)行業(yè)務邏輯，當副線程處理完成后，主線程再返回結果，在副線程處理整個業(yè)務邏輯的中，主線程會空閑出來去出來其他請求，也就是說采用上述這種模式處理http請求，服務器的吞吐量會有有明顯的提升。使用異步返回，需使在web.xml將version配置為3.0版本的。

在servlet及所有的filter中配置異步支持。

簡單實現如下：

更為復雜的業(yè)務場景的異步返回如下所示：

Htpp請求通過線程一處理，并將消息發(fā)送到消息隊列，應用2處于不同的服務器，其接收到消息并將消息返回，線程2監(jiān)聽到處理結果，將消息返回，線程一及線程二不知道對方的存在。這種業(yè)務情況，單開一個線程是無法解決的，需要使用DeferredResult類。

簡單的實現代碼如下：

controller層：

@Controller
@RequestMapping("/test/")
@Slf4j
public class TestController {
 
 @Autowired
 private MockQueue mockQueue;
 
 @Autowired
 private DeferredResultHolder deferredResultHolder;
 
 @RequestMapping("order")
 @ResponseBody
 public DeferredResult<String> test() throws InterruptedException {
  log.info("主線程開始");
  String orderNo = RandomUtils.nextInt() + "";
  mockQueue.setPlaceOrder(orderNo);
  DeferredResult<String> result = new DeferredResult<String>();
  deferredResultHolder.getMap().put(orderNo, result);
  log.info("主線程結束");
  return result;
 }
}

偽消息隊列類：

@Slf4j
@Component
public class MockQueue {
 
 private String placeOrder;
 
 private String compeleteOrder;
 
 public String getPlaceOrder() {
  return placeOrder;
 }
 
 public void setPlaceOrder(String placeOrder) throws InterruptedException {
  new Thread(()->{ log.info("收到下單的請求");
   this.placeOrder = placeOrder;
   try {
    Thread.sleep(1000);
   } catch (InterruptedException e) {
    e.printStackTrace();
   }
   this.compeleteOrder = placeOrder;
   log.info("完成下單的請求");}).start();
 
 }
 
 public String getCompeleteOrder() {
  return compeleteOrder;
 }
 
 public void setCompeleteOrder(String compeleteOrder) {
  this.compeleteOrder = compeleteOrder;
 }
}

偽隊列監(jiān)聽類：

@Slf4j
@Component
public class QueueListener implements ApplicationListener{
 @Autowired
 private MockQueue mockQueue;
 @Autowired
 private DeferredResultHolder deferredResultHolder;
 
 @Override
 public void onApplicationEvent(ApplicationEvent applicationEvent) {
  new Thread(() ->{
   while (true){
    if(StringUtils.isNotBlank(mockQueue.getCompeleteOrder())){
     String orderNum = mockQueue.getCompeleteOrder();
     log.info("返回訂單處理結果" + orderNum);
     deferredResultHolder.getMap().get(orderNum).setResult("success");
     mockQueue.setCompeleteOrder(null);
    }else {
     try {
      Thread.sleep(100);
     } catch (InterruptedException e) {
      e.printStackTrace();
     }
    }
   }
  }).start();
 }
}

容器類：

@Component
public class DeferredResultHolder {
 private Map<String,DeferredResult<String>> map = new HashMap<String,DeferredResult<String>>();
 
 public Map<String, DeferredResult<String>> getMap() {
  return map;
 }
 
 public void setMap(Map<String, DeferredResult<String>> map) {
  this.map = map;
 }
}

以上為個人經驗，希望能給大家一個參考，也希望大家多多支持腳本之家。如有錯誤或未考慮完全的地方，望不吝賜教。

您可能感興趣的文章:

SpringAMQP的使用方式案例詳解
這篇文章主要介紹了SpringAMQP的使用方式,本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友參考下吧
2024-01-01
聊聊Redis的單線程模型
Redis是單線程，主要是指Redis的網絡IO和讀寫是由一個線程來完成的，但Redis的其他功能，比如持久化、異步刪除、集群數據同步等，其實是由額外的線程執(zhí)行的。這不是本文討論的重點，有個印象即可
2022-12-12
手寫mybatis完整sql插件問題及實現思路
大家在使用mybatis的過程中，mysql日志功能一般不會直接放到數據庫中執(zhí)行的，今天小編重點給大家分享手寫mybatis完整sql插件問題及實現思路，對mybatis完整sql插件相關知識感興趣的朋友一起看看吧
2021-05-05
Java程序圖形用戶界面設計之按鈕與布局
圖形界面（簡稱GUI）是指采用圖形方式顯示的計算機操作用戶界面。與早期計算機使用的命令行界面相比，圖形界面對于用戶來說在視覺上更易于接受，本篇精講Java語言中關于圖形用戶界面的按鈕和布局部分
2022-02-02
如何使用Java讀取PPT文本和圖片
這篇文章主要介紹了如何使用Java讀取PPT文本和圖片，本篇文章將介紹通過Java程序來讀取PPT幻燈片中的文本及圖片的方法。讀取圖片時，可讀取文檔中的所有圖片，也可以讀取指定幻燈片當中的圖片,需要的朋友可以參考下
2019-07-07
WebFlux 服務編排使用優(yōu)勢詳解
這篇文章主要為大家介紹了WebFlux 服務編排使用優(yōu)勢示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪
2023-05-05
FreeMarker如何調用Java靜態(tài)方法及靜態(tài)變量方法
這篇文章主要介紹了FreeMarker如何調用Java靜態(tài)方法及靜態(tài)變量方法,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
2023-12-12
使用java代碼實現一個月內不再提醒,通用到期的問題
這篇文章主要介紹了使用java代碼實現一個月內不再提醒,通用到期的問題，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
2021-01-01
java配置數據庫連接池的方法步驟
java配置數據庫連接池的方法步驟，需要的朋友可以參考一下
2013-05-05
java 獲取服務器真實IP的實例
這篇文章主要介紹了java 獲取服務器真實IP的實例的相關資料,這里提供實現方法幫助大家學習理解這部分內容，需要的朋友可以參考下
2017-08-08