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

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 &#

#下载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"

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

spring:
  # 配置文件上传大小限制
  servlet:
    multipart:
      max-file-size: 100MB
      max-request-size: 100MB

# minio 参数配置
minio:
  endpoint: http://127.0.01:9000
  accessKey: minioadmin
  secretKey: minioadmin

@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<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();
    }
}