SpringMVC异步处理操作(Callable和DeferredResult)

更新时间：2021年01月20日 09:29:29 作者：coder_rad

这篇文章主要介绍了SpringMVC异步处理操作(Callable和DeferredResult)，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧

官方文档中说DeferredResult和Callable都是为了异步生成返回值提供基本的支持。简单来说就是一个请求进来，如果你使用了DeferredResult或者Callable，在没有得到返回数据之前，DispatcherServlet和所有Filter就会退出Servlet容器线程，但响应保持打开状态，一旦返回数据有了，这个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，控制器可以从不同的线程异步产生返回值。优点就是可以实现两个完全不相干的线程间的通信。

我们模拟如下场景：

由于消息队列和应用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;
 }
}

定义一个类来监听订单是否处理完，如果处理完了的话就设置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请求，所有的业务逻辑都会在这个线程里去执行，最后返回Http响应。但是tomcat等中间件，它们可以管理的线程数是有限的，当数量达到一定程度之后，再有请求进入，会被阻塞掉。

简单异步图示：

异步处理过程：当一个http请求进入后，tomcat等中间件的主线程调用副线程来执行业务逻辑，当副线程处理完成后，主线程再返回结果，在副线程处理整个业务逻辑的中，主线程会空闲出来去出来其他请求，也就是说采用上述这种模式处理http请求，服务器的吞吐量会有有明显的提升。使用异步返回，需使在web.xml将version配置为3.0版本的。

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

简单实现如下：

更为复杂的业务场景的异步返回如下所示：

Htpp请求通过线程一处理，并将消息发送到消息队列，应用2处于不同的服务器，其接收到消息并将消息返回，线程2监听到处理结果，将消息返回，线程一及线程二不知道对方的存在。这种业务情况，单开一个线程是无法解决的，需要使用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;
 }
}

伪队列监听类：

@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的其他功能，比如持久化、异步删除、集群数据同步等，其实是由额外的线程执行的。这不是本文讨论的重点，有个印象即可
2022-12-12
手写mybatis完整sql插件问题及实现思路
大家在使用mybatis的过程中，mysql日志功能一般不会直接放到数据库中执行的，今天小编重点给大家分享手写mybatis完整sql插件问题及实现思路，对mybatis完整sql插件相关知识感兴趣的朋友一起看看吧
2021-05-05
Java程序图形用户界面设计之按钮与布局
图形界面（简称GUI）是指采用图形方式显示的计算机操作用户界面。与早期计算机使用的命令行界面相比，图形界面对于用户来说在视觉上更易于接受，本篇精讲Java语言中关于图形用户界面的按钮和布局部分
2022-02-02
如何使用Java读取PPT文本和图片
这篇文章主要介绍了如何使用Java读取PPT文本和图片，本篇文章将介绍通过Java程序来读取PPT幻灯片中的文本及图片的方法。读取图片时，可读取文档中的所有图片，也可以读取指定幻灯片当中的图片,需要的朋友可以参考下
2019-07-07
WebFlux 服务编排使用优势详解
这篇文章主要为大家介绍了WebFlux 服务编排使用优势示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2023-05-05
FreeMarker如何调用Java静态方法及静态变量方法
这篇文章主要介绍了FreeMarker如何调用Java静态方法及静态变量方法,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
2023-12-12
使用java代码实现一个月内不再提醒,通用到期的问题
这篇文章主要介绍了使用java代码实现一个月内不再提醒,通用到期的问题，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2021-01-01
java配置数据库连接池的方法步骤
java配置数据库连接池的方法步骤，需要的朋友可以参考一下
2013-05-05
java 获取服务器真实IP的实例
这篇文章主要介绍了java 获取服务器真实IP的实例的相关资料,这里提供实现方法帮助大家学习理解这部分内容，需要的朋友可以参考下
2017-08-08