目录
一、简介
二、原理图
三、代码演示
四、源码分析
一、简介
#1.介绍
(1)servlet3.0: DeferredResult其实是基于Servlet3.0对异步的支持而来的
(2)tomcat: 涉及到web容器
(3)场景: 获取文件上传进度
--上传文件时后端采用MQ异步解析, 前端获取上传进度的方案
--方案1: 前端轮询, 即浏览器不断轮询controller的方法A,直到有值才停止, 由于频繁实际上会给server产生压力
--方案2: DeferredResult, 延迟的结果, 只需要用 DeferredResult 包装本来需要返回的值,然后设置一个超时时间和超时兜底值即可
二、原理图
image-20230130210746320.png
#1.优化tomcat线程池资源调度
(1)释放线程(关键): 请求的处理线程(tomcat线程池的process线程)不会等到DeferredResult.setResult()被调用才释放, 而是直接就释放了, tomcat线程回收, 同时可以响应其他的请求
(2)耗时长的业务 | 线程池无感知 | 轮询耗资源: tomcat线程池大小有限, 一些业务逻辑处理慢会逐渐占满tomcat线程, 如果放到线程池处理, 我们无法得知什么时候处理完, 常做的就是轮询, 显示这种方式会增加服务器的压力
(3)暂存请求 | 结果提前返回 | 兜底值: DeferredResult不管业务逻辑有无执行完毕, tomcat的处理线程就先释放, 此时不会给浏览器任何反应, 而是将请求暂存起来, 等后面有结果了在获取之前的请求, 响应结果给请求方, 这里还有个兜底, 如果超时了还没结果, 则会响应请求方兜底值
三、代码演示
image-20230130210709856.png
四、源码分析
image-20230131204733117.png
#1.如何告诉tomcat这是一个异步请求?
(1)tomcat 调用 SpringMvc 定义的DispatcherServlet#doDispatch来处理请求, 正常处理这个方法应该给浏览器直接返回我们 new 的那个 deferredResult, 但是显然没有那么简单
(2)当通过反射调用 controller 中的方法得到返回值的时候,需要根据返回值的类型调用不同的returnValueHandlers 来处理, Spring搞了个 returnValueHandler 是专门用来处理 DeferredResult 类型的返回值,即 DeferredResultMethodReturnValueHandler
(3)returnValueHandler的逻辑
--它调用了 tomcat 里面 Request#startAsync 方法,也传递了 timeout 的时间,这个操作是让 tomcat 明白当前请求是一个异步请求,这样 tomcat 就不会直接将 new 的那个 deferredResult 返回给客户端,也不会销毁当前的 request 和 response 。
--而是会将处理这个请求的 Processor 暂时保存起来(简单的理解为每个请求都有对应的一个 processor,这是 tomcat 里面的概念),放到 waitingProcessors 里面
#2.请求超时了怎么把默认值setResult到response?
(1)前面我们已经得知,异步请求已经被放到 waitingProcessors 里,且超时时间也已经设置上了,而 tomcat 会有一个线程,每隔 1 秒遍历 waitingProcessors 里面的 processor ,看看它们过期了没:
(2)如果发现过期了,那么会重新往 tomcat 里面线程池里面投掷任务,但是这个任务不太一样,可以看到 SocketEvent 是 TIMEOUT。