Springboot怎么集成minio实现文件存储

2023-06-29 12:06:37 221人浏览八月长安

摘要

本篇内容主要讲解“SpringBoot怎么集成miNIO实现文件存储”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“springboot怎么集成minio实现文件存储”吧!MinIO 是一款基于G

本篇内容主要讲解“SpringBoot怎么集成miNIO实现文件存储”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“springboot怎么集成minio实现文件存储”吧!

MinIO 是一款基于Go语言的高性能对象存储服务，它采用了Apache License v2.0开源协议，非常适合于存储大容量非结构化的数据，例如图片、视频、日志文件、备份数据和容器/虚拟机镜像等。

1. 安装部署

1.1 linux 简单部署

wget https://dl.min.io/server/minio/release/linux-amd64/miniochmod +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 &#

Springboot怎么集成minio实现文件存储

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

Springboot怎么集成minio实现文件存储

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 整合

添加相关依赖

<!--        引入minio依赖--><dependency>    <groupId>io.minio</groupId>    <artifactId>minio</artifactId>    <version>8.0.3</version></dependency>

添加相关配置信息

默认安装不指定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容器中，使用的时候直接获取即可。

@Configurationpublic class MinIoConfig {    @Value("${minio.endpoint}")    private String endpoint;    @Value("${minio.accessKey}")    private String accessKey;    @Value("${minio.secretKey}")    private String secretKey;        @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<String, String> 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();    }}

测试相关接口

Springboot怎么集成minio实现文件存储