minio分片上传

Posted 2023-04-13 Life Log

图1 分片上传时序图

分片上传为前端直传 minio，将一个文件切分成多块儿，分别上传。
优点: 上传分片可异步，适合大型文件，直传 minio 效率高。
缺点: 实现复杂，不适合上传小文件。

流程: 前端请求后端获取分片信息，获得 minio 生成的预上传地址，前端再将文件分片，发起异步请求向 minio 上传文件。
所有分片上传完成后需要执行合并操作，合并完成后上传的文件才能在 minio 可见，无法看见上传的分片。

图2 前端Console

---

图3 前端Network异步上传

可通过 API listParts，根据 uploadId 和 objectName 查询已上传的分片。

example地址: https://gitee.com/caseor/minio-example

Java操作MinIO实现文件的上传和删除。

 文章解决的问题：将本地Java项目resources目录下的一个PNG图片上传到MinIO，然后将上传的图片删除。

目录

一、MinIO的安装：

​二、安装与开启服务：

 三、MinIO的使用：

四、Java操作MinIO：

---

一、MinIO的安装：

官网地址：MinIO | High Performance, Kubernetes Native Object Storage

选择下载win serve版本即可：

 二、安装与开启服务：

1、找到下载的目录，并将那个.exe文件移动到你想安装的位置。

2、然后进入该目录的CMD命令行终端。

输入以下命令开启服务： 

 .\\minio.exe server exe文件的地址

  //这是我安装的位置
 .\\minio.exe server D:\\application\\MinIO

启动成功之后：

  输入对应网址打开管理端页面：

 三、MinIO的使用：

1、创建一个存储桶：

2、对新建的桶进行两个修改：

修改的目的：

其他应用能够仅通过URL就能访问图片，并且图片访问期限为永久。(如果不做修改，不能通过URL路径直接访问图片，并且提供的路径有时间限制，一段时间之后就不能访问了)

 

四、Java操作MinIO：

Maven依赖：

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

包括了对上传与删除操作：

import io.minio.*;
import io.minio.errors.*;
import lombok.Data;
import org.springframework.web.multipart.MultipartFile;

import java.io.IOException;
import java.security.InvalidKeyException;
import java.security.NoSuchAlgorithmException;
import java.text.SimpleDateFormat;
import java.util.Date;

@Data
public class MinIO 
    private String address; //IP地址
    private String userName; //用户名
    private String password; //密码
    private MinioClient minioClient;  //操作对象

    MinIO(String address, String userName, String password) 
        this.address = address;
        this.userName = userName;
        this.password = password;

    

    //获取操作对象：
    public MinioClient getMinioClient() 
        if (this.minioClient == null) 
            this.minioClient = MinioClient.builder()
                    .endpoint(this.getAddress())
                    .credentials(this.getUserName(), this.getPassword())
                    .build();
        
        return this.minioClient;
    

    //上传文件：
    public String upload(MultipartFile multipartFile, String bucketName) throws Exception 
        //一、设置文件存放的路径信息
        String fileName = multipartFile.getName();        //获取文件名称：
        String timeRandom = String.valueOf(System.currentTimeMillis());        //获取当前时间戳：
        fileName = timeRandom + "_" + fileName;         //拼接文件名：
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");  //格式化当前日期：
        String objectName = sdf.format(new Date()) + "/" + fileName;       //最后存储的路径：  格式为：时间/文件

        //二、上传文件
        this.getMinioClient().putObject(PutObjectArgs.builder().
                bucket(bucketName) //桶名称
                .object(objectName) //路径
                //以下为默认配置：
                .stream(multipartFile.getInputStream(), multipartFile.getSize(), -1)
                .contentType(multipartFile.getContentType())
                .build());

        //三、访问路径：
        return this.address + "/" + bucketName + "/" + objectName;
    

    //删除文件：
    public   void delete(String bucketName,String fileName) 
        /**
         * String bucketName = "test2";
         * String fileName = "/2023-04-07/16808560218465670_img.png";
         * address+bucketName+fileName 就是访问路径，删除需要后两个参数。
         */
        try 
            this.getMinioClient().removeObject(RemoveObjectArgs.builder().bucket(bucketName).object(fileName).build());
         catch (Exception e) 
            System.out.println("删除失败");
        
        System.out.println("删除成功");
    



    //查询某个桶是否存在：
    public Boolean isExit(String bucketName) throws Exception 
        boolean found =
             this.getMinioClient().bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());
        if (found) 
            System.out.println("存储桶存在！");
            return true;
         else 
            System.out.println("存储桶不存在！");
            return false;
        
    

Main函数调用：

public class Main 
    public static void main(String[] args) throws Exception 
        MinIO minIO = new MinIO("http://127.0.0.1:9000","minioadmin","minioadmin");
        String bucket = "test";

        //一、上传文件：
        //将file转化为MultipartFile （图片在项目的resources目录下，必须将文件转化为为MultipartFile类型）
        File file = new File("src/main/resources/img.png");
        FileInputStream fileInputStream = new FileInputStream(file);
        MultipartFile multipartFile = new MockMultipartFile(file.getName(), file.getName(),
                MediaType.IMAGE_PNG_VALUE //PNG类型的图片，所以用这个枚举。点击MediaType有对应类型
                , fileInputStream);

        String url = minIO.upload(multipartFile, bucket);//上传
        System.out.println("上传之后的URL为："+url);

        //二、删除刚刚上传的图片：
        String fileName = "/2023-04-07/1680857898025_img.png";
        minIO.delete(bucket,fileName);

    

 执行结果：