SpringMVC 如何实现异步处理及内置异步请求类介绍

简介: SpringMVC 如何实现异步处理及内置异步请求类介绍

异步请求类介绍

在 SpringMvc 中为了方便使用异步请求专门提供了以下几种类型:

  1. 专门来处理异步请求的,会将原来的 HttpServletRequest 类型做一层封装
  2. Spring MVC 异步请求处理过程中最核心的类型,管理着整个异步处理的过程
  3. WebAsyncUtils:异步工具类,用来获取 WebAsyncManager 以及创建 AsyncWebRequest 对象

在 SpringMvc 中,对异步请求的处理中提供了四个地方的支持:

  1. FrameworkServlet 中给当前请求的 WebAsyncManager 添加了 CallableProcessingInterceptor 类型的拦截器->RequestBindingInterceptor,目的是为了在请求处理前将当前请求的 LocaleContext、ServletRequestAttributes 设置到 LocaleContextHolder、RequestContextHolder 中,并在请求处理完成后恢复,添加过程在 FrameworkServlet#processRequest 方法中
WebAsyncManager asyncManager = WebAsyncUtils.getAsyncManager(request);  
asyncManager.registerCallableInterceptor(FrameworkServlet.class.getName(), new RequestBindingInterceptor());
  1. RequestMappingHandlerAdpater#invokeHandlerMethod 方法中提供了对异步请求的核心支持,其中做了时间跟异步处理相关的事情:

1、创建 AsyncWebRequest,并设置了超时时间

2、对当前请求的 WebAsyncManager 设置四个属性

3、如果当前请求是异步请求而且已经处理出了结果,则将异步结果与之前保存到 WebAsyncManager 里的 ModelAndViewContainer 取出来,并将 WebAsyncManager 异步执行结果取出,然后调用 ServletInvocableHandlerMethod#wrapConcurrentResult 方法创建 ConcurrentResultHandlerMethod 子类来替换 ServletInvocableHandlerMethod,创建出来的 ConcurrentResultHandlerMethod 并不执行请求,主要是判断异步处理的结果是不是异常类型,如果是则抛出,如果不是则使用返回值处理器 HandlerMethodReturnValueHandler 对其进行解析并将处理后的结果返回

4、如果 invokeAndHandler 方法执行完成后检查到当前请求已经启动了异步处理,则会直接返回 null

// 创建AsyncWebRequest异步请求对象
AsyncWebRequest asyncWebRequest = WebAsyncUtils.createAsyncWebRequest(request, response);
asyncWebRequest.setTimeout(this.asyncRequestTimeout);
// 创建WebAsyncManager异步请求管理器对象
WebAsyncManager asyncManager = WebAsyncUtils.getAsyncManager(request);
asyncManager.setTaskExecutor(this.taskExecutor);
asyncManager.setAsyncWebRequest(asyncWebRequest);
asyncManager.registerCallableInterceptors(this.callableInterceptors);
asyncManager.registerDeferredResultInterceptors(this.deferredResultInterceptors);
// 如果当前异步请求已经处理并得到结果,则将返回的结果放到mavContainer对象中,然后将invocable对象进行包装转换,转成需要的执行对象然后开始执行
if (asyncManager.hasConcurrentResult()) {
  Object result = asyncManager.getConcurrentResult();
  mavContainer = (ModelAndViewContainer) asyncManager.getConcurrentResultContext()[0];
  asyncManager.clearConcurrentResult();
  LogFormatUtils.traceDebug(logger, traceOn -> {
    String formatted = LogFormatUtils.formatValue(result, !traceOn);
    return "Resume with async result [" + formatted + "]";
  });
  // 转换具体的invocable执行对象
  invocableMethod = invocableMethod.wrapConcurrentResult(result);
}
// 执行调用
invocableMethod.invokeAndHandle(webRequest, mavContainer);
if (asyncManager.isConcurrentHandlingStarted()) {
  return null;
}
  1. 返回值处理器:一个有四个处理异步请求的返回值处理器,分别是 AsyncTaskMethodReturnValueHandler、CallableMethodReturnValueHandler、DeferredResultMethodReturnValueHandler、ListenableFutureReturnValueHandler,每一种对应一种类型的返回值,主要作用是使用 WebAsyncManager 启动异步处理.
  2. 在 DispatcherServlet#doDispatcher 方法中,当 HandlerAdpater 使用 handler 处理完请求时,会检查是否已经启动了异步处理器,如果启动了则不再往下处理,直接返回.
if (asyncManager.isConcurrentHandlingStarted()) {
  return null;
}

注意处理流程如下:首先在处理器中返回需要启动异步处理的类型时,相应的返回值处理器会调用 WebAsyncManager 相关方法启动异步处理,然后再 DispatcherServlet 中将原来请求直接返回,当异步处理完成后会重新发出一个相同的请求,这个是在 RequestMappingAdpater 中会使用特殊的 ServletInvoableHandlerMethod 来处理请求,处理方法是:如果是异步处理返回的结果是异常类型则抛出异常,否则直接返回异常处理结果,然后使用返回值处理器对其处理,接着返回 DispatcherServlet 中按正常流程往下处理.

WebAsyncTask、Callable 类型异步请求的处理过程及方法

当处理器方法返回 WebAsyncTask 或者 Callable 类型时,将自动启用异步处理,使用 WebAsyncTask 类型返回值的处理器 AsyncTaskMethodReturnValueHandler,如果返回值为 null,就会给 ModelAndViewContainer 设置为请求已处理,然后返回,如果返回值不为空,调用 WebAsyncManager#startCallableProcessing 方法处理请求,示例代码如下:

<servlet>
  <servlet-name>mvc-test</servlet-name>
  <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
  <!--SpringMVC配置文件-->
  <init-param>
    <param-name>contextConfigLocation</param-name>
    <param-value>classpath:applicationContext.xml</param-value>
  </init-param>
  <load-on-startup>1</load-on-startup>
  <async-supported>true</async-supported>
</servlet>
@Controller
public class AsyncTaskController {
    @ResponseBody
    @RequestMapping(value = "/webasynctask",produces = "text/plain; charset=UTF-8")
    public WebAsyncTask<String> webAsyncTask(){
        System.out.println("WebAsyncTask 处理器主线程进入");
        WebAsyncTask<String> task = new WebAsyncTask<String>(new Callable<String>() {
            @Override
            public String call() throws Exception {
                Thread.sleep(5*1000L);
                System.out.println("WebAsyncTask 处理执行中。。。");
                return "久等了";
            }
        });
        System.out.println("WebAsyncTask 处理器主线程退出");
        return task;
    }
}
public class AsyncCallableController {
    @ResponseBody
    @RequestMapping(value = "/callable",produces = "text/plain; charset=UTF-8")
    public Callable<String> callable(){
        System.out.println("Callable处理器主线程进入");
        Callable<String> callable = new Callable<String>() {
            @Override
            public String call() throws Exception {
                Thread.sleep(5 * 1000L);
                System.out.println("Callable处理执行中。。。");
                return "久等了";
            }
        };
        System.out.println("Callable处理器主线程退出");
        return callable;
    }
}

更多技术文章可以查看:vnjohn 个人博客

目录
相关文章
|
前端开发 Java API
Spring MVC相关异常类
Spring MVC相关异常类
70 0
|
7月前
|
Java 数据库 数据安全/隐私保护
基于SSM框架实现管科类考研自我管理系统(分前后台spring+springmvc+mybatis+maven+jsp+jquery)
基于SSM框架实现管科类考研自我管理系统(分前后台spring+springmvc+mybatis+maven+jsp+jquery)
|
7月前
ssm(Spring+Spring mvc+mybatis)Service层实现类——DeptServiceImpl
ssm(Spring+Spring mvc+mybatis)Service层实现类——DeptServiceImpl
|
7月前
ssm(Spring+Spring mvc+mybatis)Dao层实现类——DeptDaoImpl
ssm(Spring+Spring mvc+mybatis)Dao层实现类——DeptDaoImpl
|
7月前
|
缓存 前端开发 Java
【Spring底层原理高级进阶】轻松掌握 Spring MVC 的拦截器机制:深入理解 HandlerInterceptor 接口和其实现类的用法
【Spring底层原理高级进阶】轻松掌握 Spring MVC 的拦截器机制:深入理解 HandlerInterceptor 接口和其实现类的用法
|
前端开发 Java 定位技术
SpringMVC之ModelAndView类详细分析(全)
目录前言1. 方法2. 配置3. addObject 添加对象详解4. 重定向 前言 通过查看源码可以得知 这个类主要是 在web MVC框架中的模型和视图的Holder。 请注意,这些是完全不同的。 这个类仅仅保存了两者,使得控制器可以在一个返回值中同时返回模型和视图。 表示处理程序返回的模型和视图,由DispatcherServlet解析。 视图可以采用String视图名的形式,需要通过ViewResolver对象解析; 或者,可以直接指定一个View对象。 该模型是一个Map,允许使用多个按名称键控
284 0
SpringMVC之ModelAndView类详细分析(全)
|
前端开发
springmvc中model类和ModelAndView
springmvc中model类和ModelAndView
|
前端开发 Java 索引
Spring MVC Controller 方法参数 Map 的实现类是什么?
问题 题主问题描述如下: 在SpringBoot中,Controller的参数中有Map接口类型的,请问他的实现类是什么? 突发奇想,在SpringBoot中,Controller的参数中有Map接口类型的
411 0
Spring MVC Controller 方法参数 Map 的实现类是什么?
|
前端开发 Java API
Spring MVC框架:第二章:视图解析器和@RequestMapping注解使用在类级别及获取原生Servlet API对象
Spring MVC框架:第二章:视图解析器和@RequestMapping注解使用在类级别及获取原生Servlet API对象
286 0
springMvc45-自定义配置类
springMvc45-自定义配置类
81 0