12

我試圖使用'streaming'Apache Commons文件上傳API上傳大文件。SpringBoot:使用Apache Commons FileUpload上傳大文件流文件

我使用Apache Commons File Uploader而不是默認的Spring Multipart上傳器的原因是,當我們上傳非常大的文件大小(〜2GB)時,它失敗。我正在開發一個GIS應用程序,這種文件上傳很常見。

爲我的文件上傳控制器完整的代碼如下:

@Controller 
public class FileUploadController { 

    @RequestMapping(value="/upload", method=RequestMethod.POST) 
    public void upload(HttpServletRequest request) { 
     boolean isMultipart = ServletFileUpload.isMultipartContent(request); 
     if (!isMultipart) { 
      // Inform user about invalid request 
      return; 
     } 

     //String filename = request.getParameter("name"); 

     // Create a new file upload handler 
     ServletFileUpload upload = new ServletFileUpload(); 

     // Parse the request 
     try { 
      FileItemIterator iter = upload.getItemIterator(request); 
      while (iter.hasNext()) { 
       FileItemStream item = iter.next(); 
       String name = item.getFieldName(); 
       InputStream stream = item.openStream(); 
       if (item.isFormField()) { 
        System.out.println("Form field " + name + " with value " + Streams.asString(stream) + " detected."); 
       } else { 
        System.out.println("File field " + name + " with file name " + item.getName() + " detected."); 
        // Process the input stream 
        OutputStream out = new FileOutputStream("incoming.gz"); 
        IOUtils.copy(stream, out); 
        stream.close(); 
        out.close(); 

       } 
      } 
     }catch (FileUploadException e){ 
      e.printStackTrace(); 
     }catch (IOException e){ 
      e.printStackTrace(); 
     } 
    } 

    @RequestMapping(value = "/uploader", method = RequestMethod.GET) 
    public ModelAndView uploaderPage() { 
     ModelAndView model = new ModelAndView(); 
     model.setViewName("uploader"); 
     return model; 
    } 

} 

麻煩的是,getItemIterator(request)始終返回沒有任何元素的迭代器(即iter.hasNext())總是返回false

我application.properties文件如下:

spring.datasource.driverClassName=org.postgresql.Driver 
spring.datasource.url=jdbc:postgresql://localhost:19095/authdb 
spring.datasource.username=georbis 
spring.datasource.password=asdf123 

logging.level.org.springframework.web=DEBUG 

spring.jpa.hibernate.ddl-auto=update 

multipart.maxFileSize: 128000MB 
multipart.maxRequestSize: 128000MB 

server.port=19091 

的JSP視圖的/uploader如下:

<html> 
<body> 
<form method="POST" enctype="multipart/form-data" action="/upload"> 
    File to upload: <input type="file" name="file"><br /> 
    Name: <input type="text" name="name"><br /> <br /> 
    Press here to upload the file!<input type="submit" value="Upload"> 
    <input type="hidden" name="${_csrf.parameterName}" value="${_csrf.token}" /> 
</form> 
</body> 
</html> 

什麼可能我是做錯了什麼?

+4

你是否禁用了彈簧multipart支持,否則你的解決方案將無法工作,並且Spring已經解析了請求。將所有'multipart'屬性替換爲一個'multipart.enabled = false'來禁用默認處理。 –

+0

我沒有做任何特定的禁用彈簧多部分支持。我嘗試在我的'application.properties'文件中添加'multipart.enabled = false'。但是,一旦我這樣做,我每次上傳時都會收到'405'請求方法'POST'not supported'錯誤。 – balajeerc

+0

這將表明一個錯誤的映射或張貼到錯誤的url ...啓用調試日誌記錄,並查看您要發佈到哪個URL以及您的控制器方法匹配的URL。 –

回答

19

感謝M.Deinum的一些非常有幫助的評論,我設法解決了這個問題。我已經清理了一些我原來的帖子,並將其作爲完整答案供以後參考。

我做的第一個錯誤是沒有禁用Spring提供的默認MultipartResolver。這最終在解析器處理HttpServeletRequest,並因此在我的控制器可以採取行動之前消耗它。

禁用它的方式,這要歸功於M. Deinum如下:

multipart.enabled=false 

然而,仍然有另一個隱藏陷阱,在這之後等着我。當我禁用默認multipart解析器,我開始試圖讓上傳時收到以下錯誤:

Fri Sep 25 20:23:47 IST 2015 
There was an unexpected error (type=Method Not Allowed, status=405). 
Request method 'POST' not supported 

在我的安全配置,我已使CSRF保護。這必要,我發送以下方式我POST請求:

<html> 
<body> 
<form method="POST" enctype="multipart/form-data" action="/upload?${_csrf.parameterName}=${_csrf.token}"> 
    <input type="file" name="file"><br> 
    <input type="submit" value="Upload"> 
</form> 
</body> 
</html> 

我也修改了我的控制了一下:

@Controller 
public class FileUploadController { 
    @RequestMapping(value="/upload", method=RequestMethod.POST) 
    public @ResponseBody Response<String> upload(HttpServletRequest request) { 
     try { 
      boolean isMultipart = ServletFileUpload.isMultipartContent(request); 
      if (!isMultipart) { 
       // Inform user about invalid request 
       Response<String> responseObject = new Response<String>(false, "Not a multipart request.", ""); 
       return responseObject; 
      } 

      // Create a new file upload handler 
      ServletFileUpload upload = new ServletFileUpload(); 

      // Parse the request 
      FileItemIterator iter = upload.getItemIterator(request); 
      while (iter.hasNext()) { 
       FileItemStream item = iter.next(); 
       String name = item.getFieldName(); 
       InputStream stream = item.openStream(); 
       if (!item.isFormField()) { 
        String filename = item.getName(); 
        // Process the input stream 
        OutputStream out = new FileOutputStream(filename); 
        IOUtils.copy(stream, out); 
        stream.close(); 
        out.close(); 
       } 
      } 
     } catch (FileUploadException e) { 
      return new Response<String>(false, "File upload error", e.toString()); 
     } catch (IOException e) { 
      return new Response<String>(false, "Internal server IO error", e.toString()); 
     } 

     return new Response<String>(true, "Success", ""); 
    } 

    @RequestMapping(value = "/uploader", method = RequestMethod.GET) 
    public ModelAndView uploaderPage() { 
     ModelAndView model = new ModelAndView(); 
     model.setViewName("uploader"); 
     return model; 
    } 
} 

其中響應只是一個簡單的通用響應類型我使用:

public class Response<T> { 
    /** Boolean indicating if request succeeded **/ 
    private boolean status; 

    /** Message indicating error if any **/ 
    private String message; 

    /** Additional data that is part of this response **/ 
    private T data; 

    public Response(boolean status, String message, T data) { 
     this.status = status; 
     this.message = message; 
     this.data = data; 
    } 

    // Setters and getters 
    ... 
} 
1

請嘗試將spring.http.multipart.enabled=false加入application.properties文件中。

3

如果您使用的是最新版本的spring啓動(我正在使用2.0.0.M7),則屬性名稱已更改。 春季開始使用技術特定名稱

spring.servlet.multipart。maxFileSize爲= -1

spring.servlet.multipart.maxRequestSize = -1

spring.servlet.multipart.enabled =假

如果你要引起多種實現活躍StreamClosed例外,那麼最後一個選項允許你禁用默認的彈簧實現