求助， Java 接口上传 2G 以上大文件 EOFException: null

最近在写一个 web 端的私人网盘服务，测试发现上传 2G 以上大文件时后台会出现异常，请问有大佬做过相关的需求吗？怎么解决这类问题？

异常日志如下

ERROR 19593 --- [io-18073-exec-2] o.a.c.c.C.[.[.[/].[dispatcherServlet] : Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is org.springframework.web.multipart.MultipartException: Failed to parse multipart servlet request; nested exception is java.io.IOException: org.apache.tomcat.util.http.fileupload.impl.IOFileUploadException: Processing of multipart/form-data request failed. java.io.EOFException] with root cause

java.io.EOFException: null ...

我修改了好多参数也不好使

@Configuration @Slf4j public class EmbeddedTomcatConfig implements WebServerFactoryCustomizer {

@Override
public void customize(ConfigurableServletWebServerFactory factory) {
    log.info("Init EmbeddedTomcatConfig...");
    ((TomcatServletWebServerFactory)factory).addConnectorCustomizers(new TomcatConnectorCustomizer() {
        @Override
        public void customize(Connector connector) {
            Http11NioProtocol protocol = (Http11NioProtocol) connector.getProtocolHandler();
            protocol.setMaxConnections(3000);
            protocol.setMaxThreads(800);
            protocol.setAcceptCount(200);
            protocol.setSelectorTimeout(30000);
            protocol.setSessionTimeout(60000 * 2);
            protocol.setConnectionTimeout(60000 * 5);
            protocol.setDisableUploadTimeout(false);
            protocol.setConnectionUploadTimeout(60000 * 10);
        }
    });
}

}

application 参数

spring.servlet.multipart.max-request-size=-1 spring.servlet.multipart.max-file-size=-1 server.tomcat.max-swallow-size=-1 server.tomcat.max-http-form-post-size=-1

控制层

@ResponseBody
@ApiOperation(value = "上传文件",notes = "上传文件")
@RequestMapping(value = "/FilesUpload",method = RequestMethod.POST)
public BaseResponse uploadFiles(
        @RequestParam(required = true) MultipartFile files,
        HttpServletRequest request,
        HttpServletResponse response
) {
    if (files.isEmpty() || files.getSize() == 0) {
        response.setStatus(HttpServletResponse.SC_EXPECTATION_FAILED);
        return BaseResponse.initErrorBaseResponse("不能上传空文件!");
    }
    try {
        return BaseResponse.initSuccessBaseResponse(fileExecuteService.uploadFiles(files,request), "操作成功");
    } catch (Exception e) {
        response.setStatus(HttpServletResponse.SC_EXPECTATION_FAILED);
        return BaseResponse.initErrorBaseResponse(e.getMessage());
    }
}

shiyu6226

2022-12-09 14:33:08 +08:00

@zsj1029
@koloonps

实现方式是用的缓冲流写入的，实际运行过程中，内存使用一直保持在 500MB 上下，代码如下

private static boolean writeFileToLocal(String toLocalFilePath, MultipartFile file) throws Exception {
boolean flag = false;

BufferedOutputStream bufferedOutputStream = null;
BufferedInputStream bufferedInputStream = null;
try {
bufferedInputStream = new BufferedInputStream(file.getInputStream());
bufferedOutputStream = new BufferedOutputStream(new FileOutputStream(toLocalFilePath));

int index;
byte[] bytes = new byte[4096];
while ((index = bufferedInputStream.read(bytes)) != -1) {
bufferedOutputStream.write(bytes, 0, index);
bufferedOutputStream.flush();
}
flag = true;
} catch (IOException e) {
log.error("文件写入失败，" + e.getMessage());
if (new File(toLocalFilePath).exists()) {
new File(toLocalFilePath).delete();
}
throw new Exception(e.getMessage());
} finally {
if (bufferedOutputStream != null) {
try {
bufferedOutputStream.close();
} catch (IOException e) {
e.printStackTrace();
}
}
if (bufferedInputStream != null) {
try {
bufferedInputStream.close();
} catch (IOException e) {
e.printStackTrace();
}
}
System.gc();
}

aguesuka

2022-12-09 20:09:42 +08:00

从你发的代码看不出啥问题.
首先得把问题定位到行, 你发的错误中只有信息而没有异常栈, 因为你的 controller catch 到异常没有打印日志(注意要打印异常栈). 打印异常栈后, 再判断是不是在你的 service 中报的错.

如果是在 service 中, 那直接把 service 改成

```
private static void writeFileToLocal(String toLocalFilePath, MultipartFile file) throws IOException {
try(InputStream inputStream = file.getInputStream()){
Files.copy(inputStream, Path.of(toLocalFilePath), StandardCopyOption.REPLACE_EXISTING);
}
}
```
不要直接使用 inputstream, 不要吞异常, 不要 gc;