脑子不够,笔头来凑!我也不是什么大鸟,职场闯荡三年半,依旧觉得自己像个小白。幸好虽一把年纪,打怪升级,芳心依旧。矫情…

今天工作中测试使用 minio 上传大文件给 OOM ,可我本地本地测试没问题啊。当时就觉得哪里又又又又写了 bug,还是个低级的,查了半天发现是:测试环境服务封装在 docker 里面,容器设置了最大堆内存 1G,大文件超过 1G 了,我本地 mac 是 16G 的。So,这就能合理解释为啥子本地不报错,测试内存溢出了。

上传代码(部分)长这个酱紫:

String path = "./large-file.zip";
File file = new File(path);
InputStream inputStream = new FileInputStream(file)
minioClient.putObject(bucketName, file.getName(), inputStream,"application/octet_stream");

也是第一次搞对象存储,好些不知道。那会就想着输入流建立了管道,怎么还把内存给读爆了,(这里是老大提醒的)minio 内部设计的要从管道中读到全部数据再上传,那这个设计也太二了。

先将文件全部读到内存,再上传,要是文件再大点,这得要多大内存啊。

So 继续搜了搜,还真有分片上传。

版本是 7.0.2

<dependency>
    <groupId>io.minio</groupId>
    <artifactId>minio</artifactId>
    <version>7.0.2</version>
</dependency>

分片上传:

try(InputStream inputStream = new FileInputStream(file)) {
  // 设定每片大小 10M
  PutObjectOptions options = new PutObjectOptions(-1, 10 * 1024 * 1024);
  options.setContentType("application/octet-stream");
  minioClient.putObject(bucketName, fileName, inputStream, options);
  return true;
} catch (Exception e) {
	return false;
}

但是在后面的版本中就没找到 PutObjectOptions 类了,可能重新设计了分片上传的 api。但确定的一点是,分片上传的功能是有的。

Logo

权威|前沿|技术|干货|国内首个API全生命周期开发者社区

更多推荐