我有一个Spring Integration flow,它异步地将文件上传到sftp服务器,要上传的文件来自http端点。最初,我遇到了与讨论过的相同的问题,here很高兴它得到了解决。
在同样的线程中,我找到了这个注释。
在企业环境中,通常有一些大小无法缓冲到内存中的文件。可悲的是,InputStreamResource也不能工作。据我所知,您最好的选择是将内容复制到自己的临时文件(例如File#createTempFile)中,您可以在处理线程的末尾清理这些文件。
目前,我正在将文件输入流连接到InputStreamResource,以解决这个问题,它的工作非常完美。为什么评论说InputStreamResource也不能工作,AFAIK InputStream从不在内存中存储数据
InputStreamResource的inputStream在文件上传后会自动关闭吗?
当我们说大文件时,我们在这里谈论的是多少文件大小。目前,在我的例子中,2-5 Mb文件被上传到SFTP。
我真的需要关心将我的文件上传机制更改为类似于存储在临时文件夹中的机制吗?
代码示例:
@PostMapping("/upload")
public void sampleEndpoint(@NotEmpty @RequestParam MultipartFile file )
throws IOException {
Resource resource = new InputStreamResource(file.getInputStream());
sftpFileService.upload(resource);
}SftpFileService异步上传方法:
@Async
public void upload(Resource resource){
try{
messagingGateway.upload(resource);
}catch(Exception e){
e.printStackTrace();
}
}发布于 2021-03-01 15:24:34
2-5 Mb可能不是一个值得担心的大小。当文件大小为1-2Gb时,可能会出现此问题。尽管当您的服务发生多个并发上传时,您可能会遇到内存不足的问题。
InputStreamResource只是使用InputStream API来访问底层委托流的修饰器。不清楚它如何在异步环境中工作,因为MultipartFile在HTTP请求的末尾被删除。
另外,你没有显示任何代码来更好地理解情况.
https://stackoverflow.com/questions/66420510
复制相似问题