SpringBoot文件上传的使用以及原理

文件上传的使用

1. 前端构造一个有文件上传的表单

<form role="form" th:action="@{/form-layout-submit}" enctype="multipart/form-data" method="post">
    <div class="form-group">
        <label for="exampleInputEmail1">Email address</label>
        <input type="email" name="email" class="form-control" id="exampleInputEmail1"
               placeholder="Enter email">
    </div>
    <div class="form-group">
        <label for="exampleInputPassword1">Username</label>
        <input type="text" name="username" class="form-control" id="exampleInputPassword1"
               placeholder="Username">
    </div>
    <!--单文件上传-->
    <div class="form-group">
        <label for="exampleInputFile">Profile Photo</label>
        <input type="file" name="profile-photo" id="exampleInputFile">
        <p class="help-block">Upload your profile photo here</p>
    </div>
    <!--多文件上传-->
    <div class="form-group">
        <label for="exampleInputFile">Daily Photos</label>
        <input type="file" name="daily-photos" multiple>
        <p class="help-block">Upload your daily photos here</p>
    </div>
    <div class="checkbox">
        <label>
            <input type="checkbox"> Check me out
        </label>
    </div>
    <button type="submit" class="btn btn-primary">Submit</button>
</form>

2. 处理表单请求的controller

/**
 * 处理 form-layout 页面的 BASIC FORMS 表单提交
 *
 * @param email        email
 * @param userName     username
 * @param profilePhoto 单文件
 * @param dailyPhotos  多文件
 */
@PostMapping("/form-layout-submit")
public String formLayoutUpload(@RequestParam("email") String email,
                               @RequestParam("username") String userName,
                               @RequestPart("profile-photo") MultipartFile profilePhoto,
                               @RequestPart("daily-photos") MultipartFile[] dailyPhotos) {

    log.info("email: {} | username: {} | size of profile-photo: {} | count of daily-photos: {}",
            email, userName, profilePhoto.getSize(), dailyPhotos.length);

    return "form/form_layouts";
}

3. 提交表单后遇到的错误

  • 提交表单发现了报错了
org.apache.tomcat.util.http.fileupload.impl.FileSizeLimitExceededException: The field profile-photo exceeds its maximum permitted size of 1048576 bytes.

这是因为上传的内容超出了SpringBoot默认配置的上传文件的大小1MB

  • 由于所有的文件上传请求都是经过MultipartAutoConfiguration先自动配置了,然后由相应的解析器去处理的,这里点进该自动配置类的源码查看一下相应的修改上传文件大小限制的配置项,并去修改即可
@ConditionalOnProperty(prefix = "spring.servlet.multipart", name = "enabled", matchIfMissing = true)

通过该注解可以指导,在配置类中修改spring.servlet.multipart下的配置项即可

文件上传相关配置项

可以看到有一个max-file-size的配置项,默认是"1MB",说明修改该配置项为想要限制的大小即可,这里我改成10MB,而max-request-size是多文件上传时,总的一次提交的最大大小,默认是10MB,我改成100MB

spring:
  servlet:
    multipart:
      max-file-size: 10MB
      max-request-size: 100MB

4. 将上传的文件保存到本地

@PostMapping("/form-layout-submit")
public String formLayoutUpload(@RequestParam("email") String email,
                               @RequestParam("username") String userName,
                               @RequestPart("profile-photo") MultipartFile profilePhoto,
                               @RequestPart("daily-photos") MultipartFile[] dailyPhotos) throws IOException {

    log.info("email: {} | username: {} | size of profile-photo: {} | count of daily-photos: {}",
             email, userName, profilePhoto.getSize(), dailyPhotos.length);

    // 保存上传的文件到本地
    // 设置保存文件的目录 -- 不存在则创建保存目录
    File mediaDir = new File("media");
    if (!mediaDir.exists()) {
        mediaDir.mkdir();
        log.warn("创建上传文件的保存目录" + mediaDir.getName());
    }
    String mediaPath = mediaDir.getAbsolutePath();

    if (!profilePhoto.isEmpty()) {
        String originalFilename = profilePhoto.getOriginalFilename();
        profilePhoto.transferTo(new File(mediaPath + "/" + originalFilename));
        log.info("文件 " + originalFilename + " 已保存");
    }

    if (dailyPhotos.length > 0) {
        for (MultipartFile dailyPhoto : dailyPhotos) {
            if (!dailyPhoto.isEmpty()) {
                String originalFilename = dailyPhoto.getOriginalFilename();
                dailyPhoto.transferTo(new File(mediaPath + "/" + originalFilename));
                log.info("文件 " + originalFilename + " 已保存");
            }
        }
    }

    return "form/form_layouts";
}

文件上传原理分析

1. 先从doDispatch()开始看起

try {
    processedRequest = checkMultipart(request);
    multipartRequestParsed = (processedRequest != request);

    // Determine handler for the current request.
    mappedHandler = getHandler(processedRequest);
    if (mappedHandler == null) {
        noHandlerFound(processedRequest, response);
        return;
    }
    ...
}

可以看到,在选择使用哪个解析器去处理请求(也就是根据映射关系,找到请求的url对应的用@RequestMapping注解过的方法)之前,会先调用checkMultipart()检查一下当前的请求是否是一个文件上传的请求

2. 分析checkMultipart()

protected HttpServletRequest checkMultipart(HttpServletRequest request) throws MultipartException {
    if (this.multipartResolver != null && this.multipartResolver.isMultipart(request)) {
        if (WebUtils.getNativeRequest(request, MultipartHttpServletRequest.class) != null) {
            if (DispatcherType.REQUEST.equals(request.getDispatcherType())) {
                logger.trace("Request already resolved to MultipartHttpServletRequest, e.g. by MultipartFilter");
            }
        }
        else if (hasMultipartException(request)) {
            logger.debug("Multipart resolution previously failed for current request - " +
                         "skipping re-resolution for undisturbed error rendering");
        }
        else {
            try {
                return this.multipartResolver.resolveMultipart(request);
            }
            catch (MultipartException ex) {
                if (request.getAttribute(WebUtils.ERROR_EXCEPTION_ATTRIBUTE) != null) {
                    logger.debug("Multipart resolution failed for error dispatch", ex);
                    // Keep processing error dispatch with regular request handle below
                }
                else {
                    throw ex;
                }
            }
        }
    }
    // If not returned before: return original request.
    return request;
}
  1. 首先会判断this.multipartResolver是否存在,那么这个是怎么来的呢?可以看看文件上传解析器的自动配置类

  2. 文件上传解析器自动配置类MultipartAutoConfiguration中的一个方法StandardServletMultipartResolver()

    @Bean(name = DispatcherServlet.MULTIPART_RESOLVER_BEAN_NAME)
    @ConditionalOnMissingBean(MultipartResolver.class)
    public StandardServletMultipartResolver multipartResolver() {
        StandardServletMultipartResolver multipartResolver = new StandardServletMultipartResolver();
        multipartResolver.setResolveLazily(this.multipartProperties.isResolveLazily());
        return multipartResolver;
    }
    

    该方法用了@ConditionalOnMissingBean注解,所以如果我们没有写自定义的文件上传解析器的话,SpringBoot会自动往容器中注入StandardServletMultipartResolver这样一个标准的文件上传解析器

  3. 然后判断this.multipartResolver.isMultipart(request)

    这个就是确认当前的请求是否是文件上传请求

    isMultipart

    @Override
    public boolean isMultipart(HttpServletRequest request) {
        return StringUtils.startsWithIgnoreCase(request.getContentType(),
                                                (this.strictServletCompliance ? MediaType.MULTIPART_FORM_DATA_VALUE : "multipart/"));
    }
    

    判断逻辑很简单,就是判断请求的ContentType开头是否是multipart/,由于我们的表单设置的enctypemultipart/form-data,所以是一个文件上传的请求

  4. multipartResolver去解析文件上传的请求

    this.multipartResolver.resolveMultipart(request);
    

    resolveMultipart()

    @Override
    public MultipartHttpServletRequest resolveMultipart(HttpServletRequest request) throws MultipartException {
        return new StandardMultipartHttpServletRequest(request, this.resolveLazily);
    }
    

    该方法实际上就是将HttpServletRequestrequest封装成了StandardMultipartHttpServletRequestrequest,这样就得到了processedRequest了,这个request中有

3. multipartRequestParsed是如何变化的

multipartRequestParsed = (processedRequest != request);
  • 由于前面的checkMultipart()会返回一个封装过后的request,所以当返回的request和原本的request不相等是,就说明已经被multipartResolver()解析过了,现在的request就是一个multipartRequest了,后面的代码就可以通过multipartRequestParsed这个布尔值来判断是否要对文件上传请求作出额外的处理

4. 文件字段如何被解析的

  • 使用@RequestPart注解的字段是文件上传时的字段名,这个字段是如何被解析的呢?

  • 查看参数解析器中有什么解析器

    参数解析器中的解析器

    RequestParamMethodArgumentResolver解析被@RequestParam注解了的参数

    RequestPartMethodArgumentResolver解析被@RequestPart注解了的参数,所以在controller中用了该注解后就能够被识别成是文件上传字段

5. 如何根据注解获取到相应的文件上传字段

前面已经分析了,文件上传字段的注解是@RequestPart,而相应的解析器是RequestPartMethodArgumentResolver,所以我们需要先找到该解析器的执行流程先

  1. 找到该解析器的执行方法

    invocableMethod.invokeAndHandle(webRequest, mavContainer);
    
  2. 一路step into后,可以看到一个这样的方法 -- getMethodArgumentValues(),该方法会遍历我们controller中的参数

    for (int i = 0; i < parameters.length; i++) {
        MethodParameter parameter = parameters[i];
        parameter.initParameterNameDiscovery(this.parameterNameDiscoverer);
        args[i] = findProvidedArgument(parameter, providedArgs);
        if (args[i] != null) {
            continue;
        }
        if (!this.resolvers.supportsParameter(parameter)) {
            throw new IllegalStateException(formatArgumentError(parameter, "No suitable resolver"));
        }
        try {
            args[i] = this.resolvers.resolveArgument(parameter, mavContainer, request, this.dataBinderFactory);
        }
        catch (Exception ex) {
            // Leave stack trace for later, exception may actually be resolved and handled...
            if (logger.isDebugEnabled()) {
                String exMsg = ex.getMessage();
                if (exMsg != null && !exMsg.contains(parameter.getExecutable().toGenericString())) {
                    logger.debug(formatArgumentError(parameter, exMsg));
                }
            }
            throw ex;
        }
    }
    
    controller中的参数

    这里就是之前在controller中传入的4个参数,由于文件上传字段是数组中的第2和第3个,这里就先让for循环遍历到第2个元素

    遍历到文件上传参数

    然后就是找到相应的解析器,并调用解析器的解析方法开始解析

    解析方法

    @Override
    @Nullable
    public Object resolveArgument(MethodParameter parameter, @Nullable ModelAndViewContainer mavContainer,
                                  NativeWebRequest request, @Nullable WebDataBinderFactory binderFactory) throws Exception {
    
        HttpServletRequest servletRequest = request.getNativeRequest(HttpServletRequest.class);
        Assert.state(servletRequest != null, "No HttpServletRequest");
    
        RequestPart requestPart = parameter.getParameterAnnotation(RequestPart.class);
        boolean isRequired = ((requestPart == null || requestPart.required()) && !parameter.isOptional());
    
        String name = getPartName(parameter, requestPart);
        parameter = parameter.nestedIfOptional();
        Object arg = null;
    
        Object mpArg = MultipartResolutionDelegate.resolveMultipartArgument(name, parameter, servletRequest);
        if (mpArg != MultipartResolutionDelegate.UNRESOLVABLE) {
            arg = mpArg;
        }
        else {
            try {
                HttpInputMessage inputMessage = new RequestPartServletServerHttpRequest(servletRequest, name);
                arg = readWithMessageConverters(inputMessage, parameter, parameter.getNestedGenericParameterType());
                if (binderFactory != null) {
                    WebDataBinder binder = binderFactory.createBinder(request, arg, name);
                    if (arg != null) {
                        validateIfApplicable(binder, parameter);
                        if (binder.getBindingResult().hasErrors() && isBindExceptionRequired(binder, parameter)) {
                            throw new MethodArgumentNotValidException(parameter, binder.getBindingResult());
                        }
                    }
                    if (mavContainer != null) {
                        mavContainer.addAttribute(BindingResult.MODEL_KEY_PREFIX + name, binder.getBindingResult());
                    }
                }
            }
            catch (MissingServletRequestPartException | MultipartException ex) {
                if (isRequired) {
                    throw ex;
                }
            }
        }
    
        if (arg == null && isRequired) {
            if (!MultipartResolutionDelegate.isMultipartRequest(servletRequest)) {
                throw new MultipartException("Current request is not a multipart request");
            }
            else {
                throw new MissingServletRequestPartException(name);
            }
        }
        return adaptArgumentIfNecessary(arg, parameter);
    }
    

    该方法中会获取注解RequestPart requestPart = parameter.getParameterAnnotation(RequestPart.class);

    然后根据注解获取注解中的参数名String name = getPartName(parameter, requestPart);

    然后就根据这些信息开始解析参数了

    Object mpArg = MultipartResolutionDelegate.resolveMultipartArgument(name, parameter, servletRequest);
    

    resolveMultipartArgument

    @Nullable
    public static Object resolveMultipartArgument(String name, MethodParameter parameter, HttpServletRequest request)
        throws Exception {
    
        MultipartHttpServletRequest multipartRequest =
            WebUtils.getNativeRequest(request, MultipartHttpServletRequest.class);
        boolean isMultipart = (multipartRequest != null || isMultipartContent(request));
    
        if (MultipartFile.class == parameter.getNestedParameterType()) {
            if (!isMultipart) {
                return null;
            }
            if (multipartRequest == null) {
                multipartRequest = new StandardMultipartHttpServletRequest(request);
            }
            return multipartRequest.getFile(name);
        }
        else if (isMultipartFileCollection(parameter)) {
            if (!isMultipart) {
                return null;
            }
            if (multipartRequest == null) {
                multipartRequest = new StandardMultipartHttpServletRequest(request);
            }
            List<MultipartFile> files = multipartRequest.getFiles(name);
            return (!files.isEmpty() ? files : null);
        }
        else if (isMultipartFileArray(parameter)) {
            if (!isMultipart) {
                return null;
            }
            if (multipartRequest == null) {
                multipartRequest = new StandardMultipartHttpServletRequest(request);
            }
            List<MultipartFile> files = multipartRequest.getFiles(name);
            return (!files.isEmpty() ? files.toArray(new MultipartFile[0]) : null);
        }
        else if (Part.class == parameter.getNestedParameterType()) {
            if (!isMultipart) {
                return null;
            }
            return request.getPart(name);
        }
        else if (isPartCollection(parameter)) {
            if (!isMultipart) {
                return null;
            }
            List<Part> parts = resolvePartList(request, name);
            return (!parts.isEmpty() ? parts : null);
        }
        else if (isPartArray(parameter)) {
            if (!isMultipart) {
                return null;
            }
            List<Part> parts = resolvePartList(request, name);
            return (!parts.isEmpty() ? parts.toArray(new Part[0]) : null);
        }
        else {
            return UNRESOLVABLE;
        }
    }
    

    接下来就会根据参数类型去调用getFile(name)或者getFiles(name),本质上getFile()就是等价于getFiles().getFirst(),所以只用研究getFiles()即可

    getFiles()

    @Override
    public List<MultipartFile> getFiles(String name) {
        List<MultipartFile> multipartFiles = getMultipartFiles().get(name);
        if (multipartFiles != null) {
            return multipartFiles;
        }
        else {
            return Collections.emptyList();
        }
    }
    

    执行完毕后,files中的就是上传的文件了

    files中的内容

6. 总结

总体原理就是根据注解的类型以及注解中的参数,构造出一个映射,这个映射是以注解@RequestPart中的name为key,而上传的文件为value,根据这个映射就可以给相应的参数赋值,这样我们就可以从MultipartFile对象中调用相应方法对上传的文件做想要的操作了

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 218,941评论 6 508
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 93,397评论 3 395
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 165,345评论 0 356
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,851评论 1 295
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,868评论 6 392
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,688评论 1 305
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,414评论 3 418
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 39,319评论 0 276
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,775评论 1 315
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,945评论 3 336
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 40,096评论 1 350
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,789评论 5 346
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,437评论 3 331
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,993评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 33,107评论 1 271
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 48,308评论 3 372
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 45,037评论 2 355

推荐阅读更多精彩内容