网友直呼:DeferredResult是Spring对Servlet异步处理的包装吗?- 第416篇
一、问题的还原
这个问题是来自前面一篇文章《Spring Boot使用Spring DeferredResult实现长轮询纵享新丝滑让你体验丝滑般的感觉 - 第414篇》的留言,没看过的可以关注公众号「SpringBoot」,回复关键词「DeferredResult」或者「414」进行查看。
我们在前面说道了对于Spring DeferredResult的使用很简单:
(1)声明一个变量DeferredResult,然后方法返回DeferredResult:
(2)客户端请求映射到控制器方法返回值为DeferredResult时,会立即释放Tomcat线程并将请求挂起,直到调用setResult()方法或者超时,才会响应客户端请求。
那么底层到底做了什么呢?到底是不是对Servlet异步处理的包装呢?今天悟纤将带你一探究竟。
二、悟纤带你一探究竟
2.1 一切的缘起DispatcherServlet
悟纤(Thinking):在Controller的这个方法中,很简单,好像没啥特殊的地方,那么这个核心的代码到哪里去了呐?
悟纤(灵光一闪):在类上不是使用了@RestController,这个是@Controller和@ResponseBody的组合注解,方法上又使用了@GetMapping注解,这不是标准的Spring MVC编码方式吗?
悟纤(回想):想啊想… 我记得师傅师傅和说过,Spring MVC有一个前端控制器来着,叫DispatcherServlet,所有的请求都会经过这个进行处理。
(这一块的知识要是不知道的话,那么要补补Spring MVC的知识了)
2.2 DispatcherServlet.doDispatch()
首先请求会进入到doService然后doDispatcher,这些都是spring mvc的知识,篇幅有限不展开细讲,看下doDispatcher:
说明:在这里获取到了处理器和处理器适配器。
接着往下看可以看到处理器的处理的代码是:
从List<HandlerAdapter>handlerAdapters 进行超找合适的适配器
{RequestMappingHandlerAdapter}、{HandlerFunctionAdapter} 、{HttpRequestHandlerAdapter}、{SimpleControllerHandlerAdapter}
这里找到的是RequestMappingHandlerAdapter,所以处理ha.handle()也就是
RequestMappingHandlerAdapter.handle()方法,进入到这个方法去看下:
2.3 RequestMappingHandlerAdapter.handle()
进入代码我们发现handler()是RequestMappingHandlerAdapter的父类AbstractHandlerMethodAdapter来实现了:
父类好像没有具体的实现而是交给了抽象方法handleInternal(),也就是子类RequestMappingHandlerAdapter来实现了:
这里最重要的方法是invokeHandlerMethod(request, response,handlerMethod),通过名字就是调用handler的方法,handler在这里不就是Controller这个类吗。
看下invokeHandlerMethod组装了一堆信息,然后调用了invocableMethod.invokeAndHandle(webRequest,mavContainer),这个invocableMethod是类ServletInvocableHandlerMethod的对象,进入到这个方法看下:
然后又进入到了handleReturnValue:
selectHandler(returnValue, returnType)
这个方法很重要,就是通过返回类型获取到的处理类
DeferredResult的处理类是DeferredResultMethodReturnValueHandler
这里找到的类是DeferredResultMethodReturnValueHandler:
到这里我们来梳理下核心的逻辑就是通过方法返回值的类型为DeferredResult来找到对应的Handler为DeferredResultMethodReturnValueHandler。
如果能找到这一部分的,那么下面的就简单了。
2.4 DeferredResultMethodReturnValueHandler
找到了对应的处理器就进入到了这个利器的handleReturnValue:
WebAsyncManager.startDeferredResultProcessing()核心的代码:
这里的核心就是:
(1)startAsyncProcessing(processingContext):开启异步处理。
(2)deferredResult.setResultHandler:设置deferredResult.setResult的回调。
2.5 startAsyncProcessing
startAsyncProcessing()这个方法最终是进入到了StandardServletAsyncWebRequest的startAsync():
熟悉的面孔,熟悉的代码。
自此网友的疑问就解答了。
2.6 调用setResult
当我们的异步任务执行完成后,会调用DeferredResult的setResult()方法:
设置了DeferredResultHandler,
因此会调用setConcurrentResultAndDispatch(WebAsyncManager):
this.asyncWebRequest.dispatch() 请求调度,就是模拟客户端再次向服务器端发起请求:
重新发起请求的话,就会回到了DispatcherServlet,到哪里进行处理呢?在RequestMappingHandlerAdapter的invokeHandlerMethod,有这么一段代码:
这里的我们要看下wrapConcurrentResult()这个方法:
构建了ConcurrentResultHandlerMethod,是ServletInvocableHandlerMethod的内部类,这里的逻辑创建了Callable,调用Callable的call()方法,得到返回结果,再使用返回值处理器处理返回值。
悟纤小结
(1)控制器中定义方法返回值为DeferredResult,由DeferredResultMethodReturnValueHandler处理返回结果,开启异步处理并设置DeferredResultHandler。
(2)务执行完成后调用setResult()方法,紧接着回调DeferredResultHandler的handleResult()设置结果并调度请求
(3)创建Callable对象并设置调用方法为call(),通过反射方式调用call()得到返回值,使用返回值处理器处理返回值。
购买完整视频,请前往:http://www.mark-to-win.com/TeacherV2.html?id=287