• 精尽Spring MVC源码分析 - 一个请求的旅行过程


    我们先来了解一个请求是如何被 Spring MVC 处理的,由于整个流程涉及到的代码非常多,所以本文的重点在于解析整体的流程,主要讲解 DispatcherServlet 这个核心类,弄懂了这个流程后,才能更好的理解具体的源码,回过头再来看则会更加的豁然开朗

    整体流程图

    Spring MVC 处理请求的流程大致如上图所示

    1. 用户的浏览器发送一个请求,这个请求经过互联网到达了我们的服务器。Servlet 容器首先接待了这个请求,并将该请求委托给 DispatcherServlet 进行处理。
    2. DispatcherServlet 将该请求传给了处理器映射组件 HandlerMapping,并获取到适合该请求的 HandlerExecutionChain 拦截器和处理器对象。
    3. 在获取到处理器后,DispatcherServlet 还不能直接调用处理器的逻辑,需要进行对处理器进行适配。处理器适配成功后,DispatcherServlet 通过处理器适配器 HandlerAdapter 调用处理器的逻辑,并获取返回值 ModelAndView 对象。
    4. 之后,DispatcherServlet 需要根据 ModelAndView 解析视图。解析视图的工作由 ViewResolver 完成,若能解析成功,ViewResolver 会返回相应的 View 视图对象。
    5. 在获取到具体的 View 对象后,最后一步要做的事情就是由 View 渲染视图,并将渲染结果返回给用户。

    以上就是 Spring MVC 处理请求的全过程,上面的流程进行了一定的简化,主要涉及到最核心的组件,还有许多其他组件没有表现出来,不过这并不影响大家对主过程的理解。

    组件预览

    在上一篇《WebApplicationContext 容器的初始化》文档讲述 FramworkServlet 的 onRefresh 方法时,该方法由 DispatcherServlet 去实现,会初始化九大组件,如何初始化的这里暂时不展开讨论,默认会从 spring-webmvc 下面的 DispatcherServlet.properties 文件中读取组件的实现类,感兴趣可以先阅读一下源码,后续会依次描述

    那么接下来就简单介绍一下 DispatcherServlet 和九大组件:

     

    Spring MVC 对各个组件的职责划分得比较清晰。DispatcherServlet 负责协调,其他组件则各自做分内之事,互不干扰。经过这样的职责划分,代码会便于维护。同时对于源码阅读者来说,也会很友好。可以降低理解源码的难度,使大家能够快速理清主逻辑。这一点值得我们学习。

    ThemeResolver 和 FlashMapManager 组件在该系列文档中不会进行讲解,因为几乎接触不到,感兴趣的可以去 Google 一下,嘻嘻~ 笔者没接触过

    FrameworkServlet

    虽然在上面的整体流程图中,我们看到请求是直接被 DispatcherServlet 所处理,但是实际上,FrameworkServlet 才是真正的入口,再来回顾一个 DispatcherServlet 的类图,如下:

     

    FrameworkServlet 覆盖了 HttpServlet 的以下方法:

    • doGet(HttpServletRequest request, HttpServletResponse response)
    • doPost(HttpServletRequest request, HttpServletResponse response)
    • doPut(HttpServletRequest request, HttpServletResponse response)
    • doDelete(HttpServletRequest request, HttpServletResponse response)
    • doOptions(HttpServletRequest request, HttpServletResponse response)
    • doTrace(HttpServletRequest request, HttpServletResponse response)
    • service(HttpServletRequest request, HttpServletResponse response)

    这些方法分别处理不同 HTTP 请求类型的请求,最终都会调用另一个 processRequest(HttpServletRequest request, HttpServletResponse response) 方法

    其中 doGet、doPost、doPut和doDelete 四个方法是直接调用 processRequest 方法的

    service

    service(HttpServletRequest request, HttpServletResponse response) 方法,用于处理请求,方法如下:

    1. @Override
    2. protected void service(HttpServletRequest request, HttpServletResponse response)
    3. throws ServletException, IOException {
    4. // <1> 获得请求方法
    5. HttpMethod httpMethod = HttpMethod.resolve(request.getMethod());
    6. // <2> 处理 PATCH 请求
    7. if (httpMethod == HttpMethod.PATCH || httpMethod == null) {
    8. processRequest(request, response);
    9. }
    10. // <3> 处理其他类型的请求
    11. else {
    12. super.service(request, response);
    13. }
    14. }
    1. 获得 HttpMethod 请求方法
    2. 若请求方法是 PATCH ,调用 processRequest(HttpServletRequest request, HttpServletResponse response) 方法,处理请求。因为 HttpServlet 默认没提供处理 Patch 请求类型的请求 ,所以只能通过覆盖父类的 service 方法来实现
    3. 如果是其他类型的请求,则直接调用父类的 service 方法,该方法如下:// HttpServlet.java protected void service(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { String method = req.getMethod(); if (method.equals(METHOD_GET)) { long lastModified = getLastModified(req); if (lastModified == -1) { // servlet doesn't support if-modified-since, no reason // to go through further expensive logic doGet(req, resp); } else { long ifModifiedSince = req.getDateHeader(HEADER_IFMODSINCE); if (ifModifiedSince < lastModified) { // If the servlet mod time is later, call doGet() // Round down to the nearest second for a proper compare // A ifModifiedSince of -1 will always be less maybeSetLastModified(resp, lastModified); doGet(req, resp); } else { resp.setStatus(HttpServletResponse.SC_NOT_MODIFIED); } } } else if (method.equals(METHOD_HEAD)) { long lastModified = getLastModified(req); maybeSetLastModified(resp, lastModified); doHead(req, resp); } else if (method.equals(METHOD_POST)) { doPost(req, resp); } else if (method.equals(METHOD_PUT)) { doPut(req, resp); } else if (method.equals(METHOD_DELETE)) { doDelete(req, resp); } else if (method.equals(METHOD_OPTIONS)) { doOptions(req,resp); } else if (method.equals(METHOD_TRACE)) { doTrace(req,resp); } else { // Note that this means NO servlet supports whatever method was requested, anywhere on this server. String errMsg = lStrings.getString("http.method_not_implemented"); Object[] errArgs = new Object[1]; errArgs[0] = method; errMsg = MessageFormat.format(errMsg, errArgs); resp.sendError(HttpServletResponse.SC_NOT_IMPLEMENTED, errMsg); } } 可能你会有疑惑,为什么不在 service(HttpServletRequest request, HttpServletResponse response) 方法,直接调用 processRequest(HttpServletRequest request, HttpServletResponse response) 方法就好了?因为针对不同的请求方法,处理略微有所不同,父类 HttpServlet 已经处理了。

    doOptions

    doOptions(HttpServletRequest request, HttpServletResponse response)方法,用于处理 OPTIONS 类型的请求,方法如下:

    1. @Override
    2. protected void doOptions(HttpServletRequest request, HttpServletResponse response)
    3. throws ServletException, IOException {
    4. // 如果 dispatchOptionsRequest 为 true ,则处理该请求,默认为 true
    5. if (this.dispatchOptionsRequest || CorsUtils.isPreFlightRequest(request)) {
    6. // 处理请求
    7. processRequest(request, response);
    8. // 如果响应 Header 包含 "Allow" ,则不需要交给父方法处理
    9. if (response.containsHeader("Allow")) {
    10. // Proper OPTIONS response coming from a handler - we're done.
    11. return;
    12. }
    13. }
    14. // Use response wrapper in order to always add PATCH to the allowed methods
    15. // 调用父方法,并在响应 Header 的 "Allow" 增加 PATCH 的值
    16. super.doOptions(request, new HttpServletResponseWrapper(response) {
    17. @Override
    18. public void setHeader(String name, String value) {
    19. if ("Allow".equals(name)) {
    20. value = (StringUtils.hasLength(value) ? value + ", " : "") + HttpMethod.PATCH.name();
    21. }
    22. super.setHeader(name, value);
    23. }
    24. });
    25. }

    使用场景:AJAX 进行跨域请求时的预检,需要向另外一个域名的资源发送一个HTTP OPTIONS请求头,用以判断实际发送的请求是否安全

    doTrace

    doTrace(HttpServletRequest request, HttpServletResponse response)方法,用于处理 TRACE 类型的请求,方法如下:

    1. protected void doTrace(HttpServletRequest request, HttpServletResponse response)
    2. throws ServletException, IOException {
    3. // 如果 dispatchTraceRequest 为 true ,则处理该请求,默认为 false
    4. if (this.dispatchTraceRequest) {
    5. // 处理请求
    6. processRequest(request, response);
    7. // 如果响应的内容类型为 "message/http" ,则不需要交给父方法处理
    8. if ("message/http".equals(response.getContentType())) {
    9. // Proper TRACE response coming from a handler - we're done.
    10. return;
    11. }
    12. }
    13. // 调用父方法
    14. super.doTrace(request, response);
    15. }

    回显服务器收到的请求,主要用于测试或诊断,笔者目前还没接触过

    processRequest

    processRequest(HttpServletRequest request, HttpServletResponse response) 方法,用于处理请求,方法如下:

    1. protected final void processRequest(HttpServletRequest request, HttpServletResponse response)
    2. throws ServletException, IOException {
    3. // <1> 记录当前时间,用于计算处理请求花费的时间
    4. long startTime = System.currentTimeMillis();
    5. // <2> 记录异常,用于保存处理请求过程中发送的异常
    6. Throwable failureCause = null;
    7. // <3> TODO
    8. LocaleContext previousLocaleContext = LocaleContextHolder.getLocaleContext();
    9. LocaleContext localeContext = buildLocaleContext(request);
    10. // <4> TODO
    11. RequestAttributes previousAttributes = RequestContextHolder.getRequestAttributes();
    12. ServletRequestAttributes requestAttributes = buildRequestAttributes(request, response, previousAttributes);
    13. // <5> TODO
    14. WebAsyncManager asyncManager = WebAsyncUtils.getAsyncManager(request);
    15. asyncManager.registerCallableInterceptor(FrameworkServlet.class.getName(), new RequestBindingInterceptor());
    16. // <6> TODO
    17. initContextHolders(request, localeContext, requestAttributes);
    18. try {
    19. // <7> 执行真正的逻辑
    20. doService(request, response);
    21. }
    22. catch (ServletException | IOException ex) {
    23. failureCause = ex; // <8> 记录抛出的异常
    24. throw ex;
    25. }
    26. catch (Throwable ex) {
    27. failureCause = ex; // <8> 记录抛出的异常
    28. throw new NestedServletException("Request processing failed", ex);
    29. }
    30. finally {
    31. // <9> TODO
    32. resetContextHolders(request, previousLocaleContext, previousAttributes);
    33. // <10> TODO
    34. if (requestAttributes != null) {
    35. requestAttributes.requestCompleted();
    36. }
    37. // <11> 如果日志级别为 DEBUG,则打印请求日志
    38. logResult(request, response, failureCause, asyncManager);
    39. // <12> 发布 ServletRequestHandledEvent 请求处理完成事件
    40. publishRequestHandledEvent(request, response, startTime, failureCause);
    41. }
    42. }

    <1> 记录当前时间,用于计算处理请求花费的时间

    <2> 记录异常,用于保存处理请求过程中发送的异常

    <7> 【核心】调用 doService(HttpServletRequest request, HttpServletResponse response) 抽象方法,执行真正的逻辑,由 DispatcherServlet 实现,所以这就是 DispatcherServlet 处理请求的真正入口

    <8> 记录执行过程抛出的异常,最终在 finally 的代码段中使用。

    <11> 如果日志级别为 DEBUG,则打印请求日志

    <12> 调用 publishRequestHandledEvent 方法,通过 WebApplicationContext 发布 ServletRequestHandledEvent 请求处理完成事件,目前好像 Spring MVC 没有监听这个事件,可以自己写一个监听器用于获取请求信息,示例如下:

    1. @Component
    2. @Log4j2
    3. public class ServletRequestHandledEventListener implements ApplicationListener<ServletRequestHandledEvent>{
    4. @Override
    5. public void onApplicationEvent(ServletRequestHandledEvent event) {
    6. log.info("请求描述:{}", event.getDescription());
    7. log.info("请求路径:{}", event.getRequestUrl());
    8. log.info("开始时间:{}", event.getTimestamp());
    9. log.info("请求耗时:{}", event.getProcessingTimeMillis());
    10. log.info("状 态 码:{}", event.getStatusCode());
    11. log.info("失败原因:{}", event.getFailureCause());
    12. }
    13. }

    到这里,FrameworkServlet 算是讲完了,接下来就要开始讲 DispatcherServlet 这个核心类了

    DispatcherServlet

    org.springframework.web.servlet.DispatcherServlet核心类,作为 Spring MVC 的核心类,承担调度器的角色,协调各个组件进行工作,处理请求,一起来揭开这神秘的面纱吧

    静态代码块

    1. private static final String DEFAULT_STRATEGIES_PATH = "DispatcherServlet.properties";
    2. private static final Properties defaultStrategies;
    3. static {
    4. // Load default strategy implementations from properties file.
    5. // This is currently strictly internal and not meant to be customized by application developers.
    6. try {
    7. ClassPathResource resource = new ClassPathResource(DEFAULT_STRATEGIES_PATH, DispatcherServlet.class);
    8. defaultStrategies = PropertiesLoaderUtils.loadProperties(resource);
    9. }
    10. catch (IOException ex) {
    11. throw new IllegalStateException("Could not load '" + DEFAULT_STRATEGIES_PATH + "': " + ex.getMessage());
    12. }
    13. }

    会从 DispatcherServlet.properties 文件中加载默认的组件实现类,将相关配置加载到 defaultStrategies 中,文件如下:

    1. ### org.springframework.web.servlet.DispatcherServlet.properties
    2. # Default implementation classes for DispatcherServlet's strategy interfaces.
    3. # Used as fallback when no matching beans are found in the DispatcherServlet context.
    4. # Not meant to be customized by application developers.
    5. org.springframework.web.servlet.LocaleResolver=org.springframework.web.servlet.i18n.AcceptHeaderLocaleResolver
    6. org.springframework.web.servlet.ThemeResolver=org.springframework.web.servlet.theme.FixedThemeResolver
    7. org.springframework.web.servlet.HandlerMapping=org.springframework.web.servlet.handler.BeanNameUrlHandlerMapping,\
    8. org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerMapping
    9. org.springframework.web.servlet.HandlerAdapter=org.springframework.web.servlet.mvc.HttpRequestHandlerAdapter,\
    10. org.springframework.web.servlet.mvc.SimpleControllerHandlerAdapter,\
    11. org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter
    12. org.springframework.web.servlet.HandlerExceptionResolver=org.springframework.web.servlet.mvc.method.annotation.ExceptionHandlerExceptionResolver,\
    13. org.springframework.web.servlet.mvc.annotation.ResponseStatusExceptionResolver,\
    14. org.springframework.web.servlet.mvc.support.DefaultHandlerExceptionResolver
    15. org.springframework.web.servlet.RequestToViewNameTranslator=org.springframework.web.servlet.view.DefaultRequestToViewNameTranslator
    16. org.springframework.web.servlet.ViewResolver=org.springframework.web.servlet.view.InternalResourceViewResolver
    17. org.springframework.web.servlet.FlashMapManager=org.springframework.web.servlet.support.SessionFlashMapManager
    18. # Default implementation classes for DispatcherServlet's strategy interfaces.
    19. # Used as fallback when no matching beans are found in the DispatcherServlet context.
    20. # Not meant to be customized by application developers.
    21. org.springframework.web.servlet.LocaleResolver=org.springframework.web.servlet.i18n.AcceptHeaderLocaleResolver
    22. org.springframework.web.servlet.ThemeResolver=org.springframework.web.servlet.theme.FixedThemeResolver
    23. org.springframework.web.servlet.HandlerMapping=org.springframework.web.servlet.handler.BeanNameUrlHandlerMapping,\
    24. org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerMapping
    25. org.springframework.web.servlet.HandlerAdapter=org.springframework.web.servlet.mvc.HttpRequestHandlerAdapter,\
    26. org.springframework.web.servlet.mvc.SimpleControllerHandlerAdapter,\
    27. org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter
    28. org.springframework.web.servlet.HandlerExceptionResolver=org.springframework.web.servlet.mvc.method.annotation.ExceptionHandlerExceptionResolver,\
    29. org.springframework.web.servlet.mvc.annotation.ResponseStatusExceptionResolver,\
    30. org.springframework.web.servlet.mvc.support.DefaultHandlerExceptionResolver
    31. org.springframework.web.servlet.RequestToViewNameTranslator=org.springframework.web.servlet.view.DefaultRequestToViewNameTranslator
    32. org.springframework.web.servlet.ViewResolver=org.springframework.web.servlet.view.InternalResourceViewResolver
    33. org.springframework.web.servlet.FlashMapManager=org.springframework.web.servlet.support.SessionFlashMapManager

    可以看到各个组件的默认实现类

    构造方法

    1. /** MultipartResolver used by this servlet. multipart 数据(文件)处理器 */
    2. @Nullable
    3. private MultipartResolver multipartResolver;
    4. /** LocaleResolver used by this servlet. 语言处理器,提供国际化的支持 */
    5. @Nullable
    6. private LocaleResolver localeResolver;
    7. /** ThemeResolver used by this servlet. 主题处理器,设置需要应用的整体样式 */
    8. @Nullable
    9. private ThemeResolver themeResolver;
    10. /** List of HandlerMappings used by this servlet. 处理器匹配器,返回请求对应的处理器和拦截器们 */
    11. @Nullable
    12. private List<HandlerMapping> handlerMappings;
    13. /** List of HandlerAdapters used by this servlet. 处理器适配器,用于执行处理器 */
    14. @Nullable
    15. private List<HandlerAdapter> handlerAdapters;
    16. /** List of HandlerExceptionResolvers used by this servlet. 异常处理器,用于解析处理器发生的异常 */
    17. @Nullable
    18. private List<HandlerExceptionResolver> handlerExceptionResolvers;
    19. /** RequestToViewNameTranslator used by this servlet. 视图名称转换器 */
    20. @Nullable
    21. private RequestToViewNameTranslator viewNameTranslator;
    22. /** FlashMapManager used by this servlet. FlashMap 管理器,负责重定向时保存参数到临时存储(默认 Session)中 */
    23. @Nullable
    24. private FlashMapManager flashMapManager;
    25. /** List of ViewResolvers used by this servlet. 视图解析器,根据视图名称和语言,获取 View 视图 */
    26. @Nullable
    27. private List<ViewResolver> viewResolvers;
    28. public DispatcherServlet() {
    29. super();
    30. setDispatchOptionsRequest(true);
    31. }
    32. public DispatcherServlet(WebApplicationContext webApplicationContext) {
    33. super(webApplicationContext);
    34. setDispatchOptionsRequest(true);
    35. }

    定义了九个组件,在组件预览中已经做过简单介绍了

    构造方法中都会设置 dispatchOptionsRequest 为 true,在父类 FrameworkServlet 中可以看到,如果请求是 OPTIONS 则会处理请求

    onRefresh

    onRefresh(ApplicationContext context) 方法,初始化 Spring MVC 的各个组件,方法如下:

    1. @Override
    2. protected void onRefresh(ApplicationContext context) {
    3. initStrategies(context);
    4. }
    5. /**
    6. * Initialize the strategy objects that this servlet uses.
    7. * <p>May be overridden in subclasses in order to initialize further strategy objects.
    8. */
    9. protected void initStrategies(ApplicationContext context) {
    10. // 初始化 MultipartResolver
    11. initMultipartResolver(context);
    12. // 初始化 LocaleResolver
    13. initLocaleResolver(context);
    14. // 初始化 ThemeResolver
    15. initThemeResolver(context);
    16. // 初始化 HandlerMapping
    17. initHandlerMappings(context);
    18. // 初始化 HandlerAdapter
    19. initHandlerAdapters(context);
    20. // 初始化 HandlerExceptionResolver
    21. initHandlerExceptionResolvers(context);
    22. // 初始化 RequestToViewNameTranslator
    23. initRequestToViewNameTranslator(context);
    24. // 初始化 ViewResolver
    25. initViewResolvers(context);
    26. // 初始化 FlashMapManager
    27. initFlashMapManager(context);
    28. }

    创建 Servlet WebApplicationContext 容器后会触发该方法,在《WebApplicationContext 容器的初始化》的 FrameworkServlet小节的 onRefresh 方法中提到过

    可以看到每个方法会初始化构造方法中的每个组件

    1. doService

    doService(HttpServletRequest request, HttpServletResponse response)方法,DispatcherServlet 的处理请求的入口方法,代码如下:

    1. @Override
    2. protected void doService(HttpServletRequest request, HttpServletResponse response) throws Exception {
    3. // <1> 如果日志级别为 DEBUG,则打印请求日志
    4. logRequest(request);
    5. // Keep a snapshot of the request attributes in case of an include,
    6. // to be able to restore the original attributes after the include.
    7. // <2> 保存当前请求中相关属性的一个快照
    8. Map<String, Object> attributesSnapshot = null;
    9. if (WebUtils.isIncludeRequest(request)) {
    10. attributesSnapshot = new HashMap<>();
    11. Enumeration<?> attrNames = request.getAttributeNames();
    12. while (attrNames.hasMoreElements()) {
    13. String attrName = (String) attrNames.nextElement();
    14. if (this.cleanupAfterInclude || attrName.startsWith(DEFAULT_STRATEGIES_PREFIX)) {
    15. attributesSnapshot.put(attrName, request.getAttribute(attrName));
    16. }
    17. }
    18. }
    19. // Make framework objects available to handlers and view objects.
    20. // <3> 设置 Spring 框架中的常用对象到 request 属性中
    21. request.setAttribute(WEB_APPLICATION_CONTEXT_ATTRIBUTE, getWebApplicationContext());
    22. request.setAttribute(LOCALE_RESOLVER_ATTRIBUTE, this.localeResolver);
    23. request.setAttribute(THEME_RESOLVER_ATTRIBUTE, this.themeResolver);
    24. request.setAttribute(THEME_SOURCE_ATTRIBUTE, getThemeSource());
    25. // <4> FlashMap 的相关配置
    26. if (this.flashMapManager != null) {
    27. FlashMap inputFlashMap = this.flashMapManager.retrieveAndUpdate(request, response);
    28. if (inputFlashMap != null) {
    29. request.setAttribute(INPUT_FLASH_MAP_ATTRIBUTE, Collections.unmodifiableMap(inputFlashMap));
    30. }
    31. request.setAttribute(OUTPUT_FLASH_MAP_ATTRIBUTE, new FlashMap());
    32. request.setAttribute(FLASH_MAP_MANAGER_ATTRIBUTE, this.flashMapManager);
    33. }
    34. try {
    35. // <5> 执行请求的分发
    36. doDispatch(request, response);
    37. }
    38. finally {
    39. // <6> 异步处理相关
    40. if (!WebAsyncUtils.getAsyncManager(request).isConcurrentHandlingStarted()) {
    41. // Restore the original attribute snapshot, in case of an include.
    42. if (attributesSnapshot != null) {
    43. restoreAttributesAfterInclude(request, attributesSnapshot);
    44. }
    45. }
    46. }
    47. }
    1. 调用logRequest(HttpServletRequest request) 方法,如果日志级别为 DEBUG,则打印请求日志
    2. 保存当前请求中相关属性的一个快照,作为异步处理的属性值,防止被修改,暂时忽略
    3. 设置 Spring 框架中的常用对象到 request 属性中,例如 webApplicationContext、localeResolver、themeResolver
    4. FlashMap 的相关配置,暂时忽略
    5. 【重点】调用 doDispatch(HttpServletRequest request, HttpServletResponse response) 方法,执行请求的分发
    6. 异步处理相关,暂时忽略

    2. doDispatch【核心】

    doDispatch(HttpServletRequest request, HttpServletResponse response) 方法,行请求的分发,在开始看具体的代码实现之前,我们再来回味下这张图片:

     

    这张图,更多的反应的是 DispatcherServlet 的 doDispatch(...) 方法的核心流程,方法如下:

    1. protected void doDispatch(HttpServletRequest request, HttpServletResponse response) throws Exception {
    2. HttpServletRequest processedRequest = request;
    3. HandlerExecutionChain mappedHandler = null;
    4. boolean multipartRequestParsed = false;
    5. // <1> 获取异步管理器
    6. WebAsyncManager asyncManager = WebAsyncUtils.getAsyncManager(request);
    7. try {
    8. ModelAndView mv = null;
    9. Exception dispatchException = null;
    10. try {
    11. // <2> 检测请求是否为上传请求,如果是则通过 multipartResolver 将其封装成 MultipartHttpServletRequest 对象
    12. processedRequest = checkMultipart(request);
    13. multipartRequestParsed = (processedRequest != request);
    14. // Determine handler for the current request.
    15. // <3> 获得请求对应的 HandlerExecutionChain 对象(HandlerMethod 和 HandlerInterceptor 拦截器们)
    16. mappedHandler = getHandler(processedRequest);
    17. if (mappedHandler == null) { // <3.1> 如果获取不到,则根据配置抛出异常或返回 404 错误
    18. noHandlerFound(processedRequest, response);
    19. return;
    20. }
    21. // Determine handler adapter for the current request.
    22. // <4> 获得当前 handler 对应的 HandlerAdapter 对象
    23. HandlerAdapter ha = getHandlerAdapter(mappedHandler.getHandler());
    24. // Process last-modified header, if supported by the handler.
    25. // <4.1> 处理有Last-Modified请求头的场景
    26. String method = request.getMethod();
    27. boolean isGet = "GET".equals(method);
    28. if (isGet || "HEAD".equals(method)) { // 不清楚为什么要判断方法类型为'HEAD'
    29. // 获取请求中服务器端最后被修改时间
    30. long lastModified = ha.getLastModified(request, mappedHandler.getHandler());
    31. if (new ServletWebRequest(request, response).checkNotModified(lastModified) && isGet) {
    32. return;
    33. }
    34. }
    35. // <5> 前置处理 拦截器
    36. // 注意:该方法如果有一个拦截器的前置处理返回false,则开始倒序触发所有的拦截器的 已完成处理
    37. if (!mappedHandler.applyPreHandle(processedRequest, response)) {
    38. return;
    39. }
    40. // Actually invoke the handler.
    41. // <6> 真正的调用 handler 方法,也就是执行对应的方法,并返回视图
    42. mv = ha.handle(processedRequest, response, mappedHandler.getHandler());
    43. // <7> 如果是异步
    44. if (asyncManager.isConcurrentHandlingStarted()) {
    45. return;
    46. }
    47. // <8> 无视图的情况下设置默认视图名称
    48. applyDefaultViewName(processedRequest, mv);
    49. // <9> 后置处理 拦截器
    50. mappedHandler.applyPostHandle(processedRequest, response, mv);
    51. }
    52. catch (Exception ex) {
    53. dispatchException = ex; // <10> 记录异常
    54. }
    55. catch (Throwable err) {
    56. // As of 4.3, we're processing Errors thrown from handler methods as well,
    57. // making them available for @ExceptionHandler methods and other scenarios.
    58. dispatchException = new NestedServletException("Handler dispatch failed", err);
    59. }
    60. // <11> 处理正常和异常的请求调用结果
    61. processDispatchResult(processedRequest, response, mappedHandler, mv, dispatchException);
    62. }
    63. catch (Exception ex) {
    64. // <12> 已完成处理 拦截器
    65. triggerAfterCompletion(processedRequest, response, mappedHandler, ex);
    66. }
    67. catch (Throwable err) {
    68. // <12> 已完成处理 拦截器
    69. triggerAfterCompletion(processedRequest, response, mappedHandler, new NestedServletException("Handler processing failed", err));
    70. }
    71. finally {
    72. // <13.1> Asyn
    73. if (asyncManager.isConcurrentHandlingStarted()) {
    74. // Instead of postHandle and afterCompletion
    75. if (mappedHandler != null) {
    76. mappedHandler.applyAfterConcurrentHandlingStarted(processedRequest, response);
    77. }
    78. }
    79. // <13.1> 如果是上传请求则清理资源
    80. else {
    81. // Clean up any resources used by a multipart request.
    82. if (multipartRequestParsed) {
    83. cleanupMultipart(processedRequest);
    84. }
    85. }
    86. }
    87. }
    1. 获得 WebAsyncManager 异步处理器,暂时忽略
    2. 【文件】调用 checkMultipart(HttpServletRequest request) 方法,检测请求是否为上传请求,如果是则通过 multipartResolver 组件将其封装成 MultipartHttpServletRequest 对象,便于获取参数信息以及文件
    3. 【处理器匹配器】调用 getHandler(HttpServletRequest request) 方法,通过 HandlerMapping 组件获得请求对应的 HandlerExecutionChain 处理器执行链,包含 HandlerMethod 处理器和 HandlerInterceptor 拦截器们如果获取不到对应的执行链,则根据配置抛出异常或返回 404 错误
    4. 【处理器适配器】调用 getHandlerAdapter(Object handler) 方法,获得当前处理器对应的 HandlerAdapter 适配器对象
    5. 处理有 Last-Modified 请求头的场景,暂时忽略
    6. 【拦截器】调用 HandlerExecutionChain 执行链的 applyPreHandle(HttpServletRequest request, HttpServletResponse response) 方法,拦截器的前置处理如果出现拦截器前置处理失败,则会调用拦截器的已完成处理方法(倒序)
    7. 【重点】调用 HandlerAdapter 适配器的 handle(HttpServletRequest request, HttpServletResponse response, Object handler) 方法,真正的执行处理器,也就是执行对应的方法(例如我们定义的 Controller 中的方法),并返回视图
    8. 如果是异步,则直接 return,注意,还是会执行 finally 中的代码
    9. 调用 applyDefaultViewName(HttpServletRequest request, ModelAndView mv) 方法,ModelAndView 不为空,但是没有视图,则设置默认视图名称,使用到了 viewNameTranslator 视图名称转换器组件
    10. 【拦截器】调用 HandlerExecutionChain 执行链的 applyPostHandle(HttpServletRequest request, HttpServletResponse response, ModelAndView mv) 方法,拦截器的后置处理倒序
    11. 记录异常,注意,此处仅仅记录,不会抛出异常,而是统一交给 <11> 处理
    12. 【处理执行结果】调用 processDispatchResult(HttpServletRequest request, HttpServletResponse response, HandlerExecutionChain mappedHandler, ModelAndView mv, Exception exception) 方法,处理正常异常的请求调用结果,包含页面渲染
    13. 【拦截器】如果上一步发生了异常,则调用 triggerAfterCompletion(HttpServletRequest request, HttpServletResponse response, HandlerExecutionChain mappedHandler, Exception ex) 方法,即调用 HandlerInterceptor 执行链的 triggerAfterCompletion(HttpServletRequest request, HttpServletResponse response, Exception ex) 方法,拦截器已完成处理倒序
    14. finally 代码块,异步处理,暂时忽略,如果是涉及到文件的请求,则清理相关资源

    上面将 DispatcherServlet 处理请求的整个流程步骤都列出来了,涉及到的组件分别在后续的文档中将分开进行分析

    2.1 checkMultipart

    checkMultipart(HttpServletRequest request) 方法,检测请求是否为上传请求,如果是则通过 multipartResolver 组件将其封装成 MultipartHttpServletRequest 对象

    1. protected HttpServletRequest checkMultipart(HttpServletRequest request) throws MultipartException {
    2. // 如果该请求是一个涉及到 multipart (文件)的请求
    3. if (this.multipartResolver != null && this.multipartResolver.isMultipart(request)) {
    4. if (WebUtils.getNativeRequest(request, MultipartHttpServletRequest.class) != null) {
    5. if (request.getDispatcherType().equals(DispatcherType.REQUEST)) {
    6. logger.trace("Request already resolved to MultipartHttpServletRequest, e.g. by MultipartFilter");
    7. }
    8. }
    9. else if (hasMultipartException(request)) {
    10. logger.debug("Multipart resolution previously failed for current request - " +
    11. "skipping re-resolution for undisturbed error rendering");
    12. }
    13. else {
    14. try {
    15. // 将 HttpServletRequest 请求封装成 MultipartHttpServletRequest 对象,解析请求里面的参数以及文件
    16. return this.multipartResolver.resolveMultipart(request);
    17. }
    18. catch (MultipartException ex) {
    19. if (request.getAttribute(WebUtils.ERROR_EXCEPTION_ATTRIBUTE) != null) {
    20. logger.debug("Multipart resolution failed for error dispatch", ex);
    21. // Keep processing error dispatch with regular request handle below
    22. }
    23. else {
    24. throw ex;
    25. }
    26. }
    27. }
    28. }
    29. // If not returned before: return original request.
    30. return request;
    31. }

    2.2 getHandler

    getHandler(HttpServletRequest request) 方法,通过 HandlerMapping 组件获得请求对应的 HandlerExecutionChain 处理器执行链,包含 HandlerMethod 处理器和 HandlerInterceptor 拦截器们

    1. @Nullable
    2. protected HandlerExecutionChain getHandler(HttpServletRequest request) throws Exception {
    3. if (this.handlerMappings != null) {
    4. for (HandlerMapping mapping : this.handlerMappings) {
    5. HandlerExecutionChain handler = mapping.getHandler(request);
    6. if (handler != null) {
    7. return handler;
    8. }
    9. }
    10. }
    11. return null;
    12. }

    2.3 getHandlerAdapter

    getHandlerAdapter(Object handler) 方法,获得当前处理器对应的 HandlerAdapter 适配器对象

    1. protected HandlerAdapter getHandlerAdapter(Object handler) throws ServletException {
    2. if (this.handlerAdapters != null) {
    3. for (HandlerAdapter adapter : this.handlerAdapters) {
    4. if (adapter.supports(handler)) {
    5. return adapter;
    6. }
    7. }
    8. }
    9. throw new ServletException("No adapter for handler [" + handler +
    10. "]: The DispatcherServlet configuration needs to include a HandlerAdapter that supports this handler");
    11. }

    2.4 applyDefaultViewName

    applyDefaultViewName(HttpServletRequest request, ModelAndView mv) 方法,ModelAndView 不为空,但是没有视图,则设置默认视图名称

    1. private void applyDefaultViewName(HttpServletRequest request, @Nullable ModelAndView mv) throws Exception {
    2. if (mv != null && !mv.hasView()) {
    3. String defaultViewName = getDefaultViewName(request);
    4. if (defaultViewName != null) {
    5. mv.setViewName(defaultViewName);
    6. }
    7. }
    8. }
    9. @Nullable
    10. protected String getDefaultViewName(HttpServletRequest request) throws Exception {
    11. // 使用到了 `viewNameTranslator` 视图名称转换器组件
    12. return (this.viewNameTranslator != null ? this.viewNameTranslator.getViewName(request) : null);
    13. }

    2.5 processDispatchResult

    processDispatchResult(HttpServletRequest request, HttpServletResponse response, HandlerExecutionChain mappedHandler, ModelAndView mv, Exception exception) 方法,处理正常异常的请求调用结果,方法如下:

    1. private void processDispatchResult(HttpServletRequest request, HttpServletResponse response,
    2. @Nullable HandlerExecutionChain mappedHandler, @Nullable ModelAndView mv,
    3. @Nullable Exception exception) throws Exception {
    4. // <1> 标记是否为处理生成异常的 ModelAndView 对象
    5. boolean errorView = false;
    6. // <2> 如果该请求出现异常
    7. if (exception != null) {
    8. // 情况一,从 ModelAndViewDefiningException 中获得 ModelAndView 对象
    9. if (exception instanceof ModelAndViewDefiningException) {
    10. logger.debug("ModelAndViewDefiningException encountered", exception);
    11. mv = ((ModelAndViewDefiningException) exception).getModelAndView();
    12. }
    13. // 情况二,处理异常,生成 ModelAndView 对象
    14. else {
    15. Object handler = (mappedHandler != null ? mappedHandler.getHandler() : null);
    16. mv = processHandlerException(request, response, handler, exception);
    17. // 标记 errorView
    18. errorView = (mv != null);
    19. }
    20. }
    21. // Did the handler return a view to render?
    22. // <3> 是否进行页面渲染
    23. if (mv != null && !mv.wasCleared()) {
    24. // <3.1> 渲染页面
    25. render(mv, request, response);
    26. // <3.2> 清理请求中的错误消息属性
    27. // 因为上述的情况二中 processHandlerException 会通过 WebUtils 设置错误消息属性,所以这里得清理一下
    28. if (errorView) {
    29. WebUtils.clearErrorRequestAttributes(request);
    30. }
    31. }
    32. else {
    33. if (logger.isTraceEnabled()) {
    34. logger.trace("No view rendering, null ModelAndView returned.");
    35. }
    36. }
    37. // <4> 如果是异步
    38. if (WebAsyncUtils.getAsyncManager(request).isConcurrentHandlingStarted()) {
    39. // Concurrent handling started during a forward
    40. return;
    41. }
    42. // <5> 已完成处理 拦截器
    43. if (mappedHandler != null) {
    44. mappedHandler.triggerAfterCompletion(request, response, null);
    45. }
    46. }
    1. 标记是否为处理生成异常的 ModelAndView 对象
    2. 如果该请求出现异常情况一,从 ModelAndViewDefiningException 中获得 ModelAndView 对象情况二,调用 processHandlerException(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) 方法,处理异常,生成 ModelAndView 对象
    3. 如果 ModelAndView 不为空且没有被清理,例如你现在使用最多的 @ResponseBody 这里就为空,不需要渲染调用 render(ModelAndView mv, HttpServletRequest request, HttpServletResponse response) 方法,渲染页面如果是上面第 2 步中情况二生成的 ModelAndView 对象,则需要清理请求中的错误消息属性,因为上述的情况二会通过 WebUtils 设置错误消息属性,所以这里得清理一下
    4. 如果是异步请求,则直接 return
    5. 正常情况下,调用 triggerAfterCompletion(HttpServletRequest request, HttpServletResponse response, HandlerExecutionChain mappedHandler, Exception ex) 方法,即调用 HandlerInterceptor 执行链的 triggerAfterCompletion(HttpServletRequest request, HttpServletResponse response, Exception ex) 方法,拦截器已完成处理倒序

    2.5.1 processHandlerException

    processHandlerException(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) 方法,处理异常,生成 ModelAndView 对象

    1. @Nullable
    2. protected ModelAndView processHandlerException(HttpServletRequest request, HttpServletResponse response,
    3. @Nullable Object handler, Exception ex) throws Exception {
    4. // Success and error responses may use different content types
    5. // 移除 PRODUCIBLE_MEDIA_TYPES_ATTRIBUTE 属性
    6. request.removeAttribute(HandlerMapping.PRODUCIBLE_MEDIA_TYPES_ATTRIBUTE);
    7. // Check registered HandlerExceptionResolvers...
    8. // <a> 遍历 HandlerExceptionResolver 数组,解析异常,生成 ModelAndView 对象
    9. ModelAndView exMv = null;
    10. if (this.handlerExceptionResolvers != null) {
    11. // 遍历 HandlerExceptionResolver 数组
    12. for (HandlerExceptionResolver resolver : this.handlerExceptionResolvers) {
    13. // 解析异常,生成 ModelAndView 对象
    14. exMv = resolver.resolveException(request, response, handler, ex);
    15. // 生成成功,结束循环
    16. if (exMv != null) {
    17. break;
    18. }
    19. }
    20. }
    21. // <b> 情况一,生成了 ModelAndView 对象,进行返回
    22. if (exMv != null) {
    23. // ModelAndView 对象为空,则返回 null
    24. if (exMv.isEmpty()) {
    25. request.setAttribute(EXCEPTION_ATTRIBUTE, ex);
    26. return null;
    27. }
    28. // We might still need view name translation for a plain error model...
    29. // 没有视图则设置默认视图
    30. if (!exMv.hasView()) {
    31. String defaultViewName = getDefaultViewName(request);
    32. if (defaultViewName != null) {
    33. exMv.setViewName(defaultViewName);
    34. }
    35. }
    36. // 打印日志
    37. if (logger.isTraceEnabled()) {
    38. logger.trace("Using resolved error view: " + exMv, ex);
    39. }
    40. if (logger.isDebugEnabled()) {
    41. logger.debug("Using resolved error view: " + exMv);
    42. }
    43. // 设置请求中的错误消息属性
    44. WebUtils.exposeErrorRequestAttributes(request, ex, getServletName());
    45. return exMv;
    46. }
    47. // <c> 情况二,未生成 ModelAndView 对象,则抛出异常
    48. throw ex;
    49. }

    <a> 处,遍历 HandlerExceptionResolver 数组,调用 HandlerExceptionResolver#resolveException(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) 方法,解析异常,生成 ModelAndView 对象

    <b> 处,情况一,生成了 ModelAndView 对象,逻辑比较简单

    <c> 处,情况二,未生成 ModelAndView 对象,则抛出异常

    2.5.2 render

    render(ModelAndView mv, HttpServletRequest request, HttpServletResponse response) 方法,渲染 ModelAndView,方法如下:

    1. protected void render(ModelAndView mv, HttpServletRequest request, HttpServletResponse response) throws Exception {
    2. // Determine locale for request and apply it to the response.
    3. // <1> 解析 request 中获得 Locale 对象,并设置到 response 中
    4. Locale locale = (this.localeResolver != null ? this.localeResolver.resolveLocale(request) : request.getLocale());
    5. response.setLocale(locale);
    6. // 获得 View 对象
    7. View view;
    8. String viewName = mv.getViewName();
    9. // 情况一,使用 viewName 获得 View 对象
    10. if (viewName != null) {
    11. // We need to resolve the view name.
    12. // <2.1> 使用 viewName 获得 View 对象
    13. view = resolveViewName(viewName, mv.getModelInternal(), locale, request);
    14. if (view == null) { // 获取不到,抛出 ServletException 异常
    15. throw new ServletException("Could not resolve view with name '" + mv.getViewName() +
    16. "' in servlet with name '" + getServletName() + "'");
    17. }
    18. }
    19. // 情况二,直接使用 ModelAndView 对象的 View 对象
    20. else {
    21. // No need to lookup: the ModelAndView object contains the actual View object.
    22. // <2.2> 直接使用 ModelAndView 对象的 View 对象
    23. view = mv.getView();
    24. if (view == null) { // 获取不到,抛出 ServletException 异常
    25. throw new ServletException("ModelAndView [" + mv + "] neither contains a view name nor a " +
    26. "View object in servlet with name '" + getServletName() + "'");
    27. }
    28. }
    29. // Delegate to the View object for rendering.
    30. // 打印日志
    31. if (logger.isTraceEnabled()) {
    32. logger.trace("Rendering view [" + view + "] ");
    33. }
    34. try {
    35. // <3> 设置响应的状态码
    36. if (mv.getStatus() != null) {
    37. response.setStatus(mv.getStatus().value());
    38. }
    39. // <4> 渲染页面
    40. view.render(mv.getModelInternal(), request, response);
    41. }
    42. catch (Exception ex) {
    43. if (logger.isDebugEnabled()) {
    44. logger.debug("Error rendering view [" + view + "]", ex);
    45. }
    46. throw ex;
    47. }
    48. }
    1. 调用 LocaleResolver 的 resolveLocale(HttpServletRequest request) 方法,从 request 中获得 Locale 对象,并设置到 response 中
    2. 获得 View 对象,有两种情况调用 resolveViewName 方法,使用 viewName 通过获得 View 对象,方法如下:@Nullable protected View resolveViewName(String viewName, @Nullable Map<String, Object> model, Locale locale, HttpServletRequest request) throws Exception { if (this.viewResolvers != null) { // 遍历 ViewResolver 数组 for (ViewResolver viewResolver : this.viewResolvers) { // 根据 viewName + locale 参数,解析出 View 对象 View view = viewResolver.resolveViewName(viewName, locale); // 解析成功,直接返回 View 对象 if (view != null) { return view; } } } return null; } 直接使用 ModelAndView 对象的 View 对象
    3. 设置响应的状态码
    4. 调用 View 的 render(Map<String, ?> model, HttpServletRequest request, HttpServletResponse response) 方法,渲染视图

    总结

    本文对 Spring MVC 处理请求的整个过程进行了分析,核心就是通过 DispatcherServlet 协调各个组件工作,处理请求,因为 DispatcherServlet 是一个 Servlet,在 Servlet 容器中,会将请求交由它来处理。

    通过本文对 DispatcherServlet 是如何处理请求已经有了一个整体的认识,不过在整个处理过程中涉及到的各个 Spring MVC 组件还没有进行分析,对于许多细节存在疑惑,不要慌,那么接下来会对每一个 Spring MVC 组件进行分析。这样,便于我们对 Spring MVC 的理解,然后再回过头来思考 DispatcherServlet 这个类,能够更好的将这些组件串联在一起。先整体,后局部,逐步逐步抽丝剥茧,看清理透。

     

  • 相关阅读:
    前端如何开始深度学习,那不妨试试JAX
    springboot和springcloudAlibaba的版本对应关系
    clickonce 程序发布到ftp在使用cnd 加速https 支持下载,会不会报错
    python自动化系列之python操作pptx文件
    打造自己的3D模型AI 自动纹理工具
    Jetpack:004-如何使用文本组件
    gRPC(五)进阶:通过TLS建立安全连接
    python setup.py 打包缺少静态资源
    Redis实现消息队列
    游戏开发30课 cocoscreator骨骼贴图布局设置
  • 原文地址:https://blog.csdn.net/m0_67698950/article/details/125627337