Springboot集成minio实现文件存储的实现代码

MinIO 是一款基于Go语言的高性能对象存储服务，本文主要介绍了Springboot集成minio实现文件存储的实现代码，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下

1. 安装部署

1.1 Linux 简单部署

wget https://dl.min.io/server/minio/release/linux-amd64/minio chmod +x minio MINIO_ROOT_USER=admin MINIO_ROOT_PASSWORD=123456 ##启动并指定端口 ./minio server /mnt/data --console-address ":9001" ## 或者后台启动 nohup ./minio server /mnt/data  >  /opt/minio/minio.log 2>&1 &#

然后访问对应地址即可：云服务器的话记得去安全组打开对应端口，账号密码如图所示：

1.2 Docker 部署

#下载MinIO的Docker镜像 docker pull minio/minio #--console-address指定MinIO Console的运行端口 （否则会随机端口运行） 暴露端口9001或者9000 docker run -p 9090:9000 -p 9001:9001 --name minio \ -v /mydata/minio/data:/data \ -e MINIO_ROOT_USER=minioadmin \ -e MINIO_ROOT_PASSWORD=minioadmin \ -d minio/minio server /data --console-address ":9001"

2. Spring boot 整合

添加相关依赖

 io.miniominio8.0.3

添加相关配置信息

默认安装不指定Access key 和Secret key 的话都是minioadmin, Endpoint则为服务器API地址.

spring: # 配置文件上传大小限制 servlet: multipart: max-file-size: 100MB max-request-size: 100MB # minio 参数配置 minio: endpoint: http://127.0.01:9000 accessKey: minioadmin secretKey: minioadmin

注入客户端

将客户端注入Spring容器中，使用的时候直接获取即可。

@Configuration public class MinIoConfig { @Value("${minio.endpoint}") private String endpoint; @Value("${minio.accessKey}") private String accessKey; @Value("${minio.secretKey}") private String secretKey; /** * 注入minio 客户端 * * @return */ @Bean public MinioClient minioClient() { return MinioClient.builder() .endpoint(endpoint) .credentials(accessKey, secretKey) .build(); } }

编写相关业务代码

编写相关业务代码，上传图片后将相关的路径回传。

/** * 文件上传 （自定义文件名称） */ public MinIoUploadVo upload(String strDir, MultipartFile multipartFile) throws Exception { // bucket 不存在，创建 if (!this.bucketExists(strDir)) { this.makeBucket(strDir); } InputStream inputStream = multipartFile.getInputStream(); // 创建一个 headers Map headers = new HashMap<>(); // 添加请求头 文件的ContentType 动态配置 multipartFile.getContentType() headers.put("Content-Type", "application/octet-stream"); String fileName = multipartFile.getOriginalFilename(); String minFileName = minFileName(fileName); instance.putObject( PutObjectArgs.builder().bucket(strDir).object(minFileName).stream( inputStream, inputStream.available(), -1) // PutObjectOptions，上传配置(文件大小，内存中文件分片大小) .headers(headers) .build()); String url = endpoint.concat("/").concat(strDir).concat("/").concat(minFileName); // 返回生成文件名、访问路径 return new MinIoUploadVo(strDir, fileName, minFileName, url); }

上传文件接口

@RequestMapping(value = "/upload", method = RequestMethod.POST) public R upload(MultipartFile file, HttpServletRequest request) throws IOException { String strDir = request.getParameter("bucketName") == null ? "car" : request.getParameter("bucketName"); try { MinIoUploadVo uploadVo = minioService.upload(strDir, file); return R.ok().message("文件上传成功").data(uploadVo); } catch (Exception e) { log.error("上传文件失败，msg={}", e.getMessage()); e.printStackTrace(); return R.error(); } }

测试相关接口