SpringBoot項(xiàng)目集成MinIO全過程

更新時(shí)間：2024年08月27日 09:11:58 作者：幼zi園小霸王

這篇文章主要介紹了SpringBoot項(xiàng)目集成MinIO全過程,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教

一. MinIO的下載安裝以及基本使用

1. 下載地址：https://dl.min.io/server/minio/release/windows-amd64/minio.exe

2. 下載好后需要手動(dòng)創(chuàng)建data文件夾用于存儲(chǔ)MinIO中的數(shù)據(jù)。

3. 鍵入cmd

4. 設(shè)置MinIO的一些變量

set MINIO_ROOT_USER=admin
set MINIO_ROOT_PASSWORD=admin123
set MINIO_ACCESS_KEY=admin
set MINIO_SECRET_KEY=admin123

下面是我踩的坑，如果只設(shè)置了MINIO_ROOT_USER和MINIO_ROOT_PASSWORD的值，而不設(shè)置MINIO_ACCESS_KEY和MINIO_SECRET_KEY的值，當(dāng)啟動(dòng)minio服務(wù)的時(shí)候就會(huì)報(bào)以下異常：

所以一定要設(shè)置好后面兩個(gè)變量的值。

5. 啟動(dòng)minio服務(wù)

> minio.exe server data

啟動(dòng)后就會(huì)出現(xiàn)minio服務(wù)的地址，按住ctrl再點(diǎn)擊即可訪問該網(wǎng)址。

6.進(jìn)入登錄頁面后，輸入對(duì)應(yīng)的用戶名和密碼，也就是之前設(shè)置的MINIO_ROOT_USER和MINIO_ROOT_PASSWORD的值。

7. 進(jìn)入主界面后，點(diǎn)擊左側(cè)導(dǎo)航欄中的Buckets，然后點(diǎn)擊Create Bucket。

8. 創(chuàng)建好之后，點(diǎn)擊左側(cè)導(dǎo)航欄中的Object Browser就可以看到創(chuàng)建好的桶了。

9. 進(jìn)入該桶，點(diǎn)擊upload,上傳一個(gè)文件，桶的默認(rèn)權(quán)限是private,所以外界訪問不到，需要修改訪問權(quán)限為public，但是要注意安全問題。

10. 點(diǎn)擊左側(cè)導(dǎo)航欄中的Buckets，進(jìn)入該桶，修改權(quán)限為public，這樣外界就可以訪問上傳的文件了。

二. SpringBoot集成MinIO

1.引入依賴

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

2. 編寫配置文件

server:
 port: 8081
spring:
 # 配置文件上傳大小限制
 servlet:
  multipart:
   max-file-size: 200MB
   max-request-size: 200MB
minio:
 host: http://127.0.0.1:9000
 url: ${minio.host}/${minio.bucket}/
 access-key: minioadmin
 secret-key: minioadmin
 bucket: public

3. 添加配置文件

package com.suwell.serv.ocr.component;
?
import io.minio.MinioClient;
import io.minio.ObjectStat;
import io.minio.PutObjectOptions;
import io.minio.Result;
import io.minio.messages.Bucket;
import io.minio.messages.Item;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.springframework.util.Assert;
import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.util.UriUtils;
?
import javax.servlet.http.HttpServletResponse;
import java.io.InputStream;
import java.net.URLEncoder;
import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import java.util.List;
?
?
@Component
public class MinioConfig implements InitializingBean {
?
    @Value(value = "${minio.bucket}")
    private String bucket;
?
    @Value(value = "${minio.host}")
    private String host;
?
    @Value(value = "${minio.url}")
    private String url;
?
    @Value(value = "${minio.access-key}")
    private String accessKey;
?
    @Value(value = "${minio.secret-key}")
    private String secretKey;
?
    private MinioClient minioClient;
?
    @Override
    public void afterPropertiesSet() throws Exception {
        Assert.hasText(url, "Minio url 為空");
        Assert.hasText(accessKey, "Minio accessKey為空");
        Assert.hasText(secretKey, "Minio secretKey為空");
        this.minioClient = new MinioClient(this.host, this.accessKey, this.secretKey);
    }
?
?
?
    /**
     * 上傳
     */
    public String putObject(MultipartFile multipartFile) throws Exception {
        // bucket 不存在，創(chuàng)建
        if (!minioClient.bucketExists(this.bucket)) {
            minioClient.makeBucket(this.bucket);
        }
        try (InputStream inputStream = multipartFile.getInputStream()) {
            // 上傳文件的名稱
            String fileName = multipartFile.getOriginalFilename();
            // PutObjectOptions，上傳配置(文件大小，內(nèi)存中文件分片大小)
            PutObjectOptions putObjectOptions = new PutObjectOptions(multipartFile.getSize(), PutObjectOptions.MIN_MULTIPART_SIZE);
            // 文件的ContentType
            putObjectOptions.setContentType(multipartFile.getContentType());
            minioClient.putObject(this.bucket, fileName, inputStream, putObjectOptions);
            // 返回訪問路徑
            return this.url + UriUtils.encode(fileName, StandardCharsets.UTF_8);
        }
    }
?
    /**
     * 文件下載
     */
    public void download(String fileName, HttpServletResponse response){
        // 從鏈接中得到文件名
        InputStream inputStream;
        try {
            MinioClient minioClient = new MinioClient(host, accessKey, secretKey);
            ObjectStat stat = minioClient.statObject(bucket, fileName);
            inputStream = minioClient.getObject(bucket, fileName);
            response.setContentType(stat.contentType());
            response.setCharacterEncoding("UTF-8");
            response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(fileName, "UTF-8"));
            byte[] buffer = new byte[1024];
            int length;
            while ((length = inputStream.read(buffer)) > 0) {
                response.getOutputStream().write(buffer, 0, length);
            }
            inputStream.close();
        } catch (Exception e){
            e.printStackTrace();
            System.out.println("有異常：" + e);
        }
    }
?
    /**
     * 列出所有存儲(chǔ)桶名稱
     *
     * @return
     * @throws Exception
     */
    public List<String> listBucketNames()
            throws Exception {
        List<Bucket> bucketList = listBuckets();
        List<String> bucketListName = new ArrayList<>();
        for (Bucket bucket : bucketList) {
            bucketListName.add(bucket.name());
        }
        return bucketListName;
    }
?
    /**
     * 查看所有桶
     *
     * @return
     * @throws Exception
     */
    public List<Bucket> listBuckets()
            throws Exception {
        return minioClient.listBuckets();
    }
?
    /**
     * 檢查存儲(chǔ)桶是否存在
     *
     * @param bucketName
     * @return
     * @throws Exception
     */
    public boolean bucketExists(String bucketName) throws Exception {
        boolean flag = minioClient.bucketExists(bucketName);
        if (flag) {
            return true;
        }
        return false;
    }
?
    /**
     * 創(chuàng)建存儲(chǔ)桶
     *
     * @param bucketName
     * @return
     * @throws Exception
     */
    public boolean makeBucket(String bucketName)
            throws Exception {
        boolean flag = bucketExists(bucketName);
        if (!flag) {
            minioClient.makeBucket(bucketName);
            return true;
        } else {
            return false;
        }
    }
?
    /**
     * 刪除桶
     *
     * @param bucketName
     * @return
     * @throws Exception
     */
    public boolean removeBucket(String bucketName)
            throws Exception {
        boolean flag = bucketExists(bucketName);
        if (flag) {
            Iterable<Result<Item>> myObjects = listObjects(bucketName);
            for (Result<Item> result : myObjects) {
                Item item = result.get();
                // 有對(duì)象文件，則刪除失敗
                if (item.size() > 0) {
                    return false;
                }
            }
            // 刪除存儲(chǔ)桶，注意，只有存儲(chǔ)桶為空時(shí)才能刪除成功。
            minioClient.removeBucket(bucketName);
            flag = bucketExists(bucketName);
            if (!flag) {
                return true;
            }
?
        }
        return false;
    }
?
    /**
     * 列出存儲(chǔ)桶中的所有對(duì)象
     *
     * @param bucketName 存儲(chǔ)桶名稱
     * @return
     * @throws Exception
     */
    public Iterable<Result<Item>> listObjects(String bucketName) throws Exception {
        boolean flag = bucketExists(bucketName);
        if (flag) {
            return minioClient.listObjects(bucketName);
        }
        return null;
    }
?
    /**
     * 列出存儲(chǔ)桶中的所有對(duì)象名稱
     *
     * @param bucketName 存儲(chǔ)桶名稱
     * @return
     * @throws Exception
     */
    public List<String> listObjectNames(String bucketName) throws Exception {
        List<String> listObjectNames = new ArrayList<>();
        boolean flag = bucketExists(bucketName);
        if (flag) {
            Iterable<Result<Item>> myObjects = listObjects(bucketName);
            for (Result<Item> result : myObjects) {
                Item item = result.get();
                listObjectNames.add(item.objectName());
            }
        }
        return listObjectNames;
    }
?
    /**
     * 刪除一個(gè)對(duì)象
     *
     * @param bucketName 存儲(chǔ)桶名稱
     * @param objectName 存儲(chǔ)桶里的對(duì)象名稱
     * @throws Exception
     */
    public boolean removeObject(String bucketName, String objectName) throws Exception {
        boolean flag = bucketExists(bucketName);
        if (flag) {
            List<String> objectList = listObjectNames(bucketName);
            for (String s : objectList) {
                if(s.equals(objectName)){
                    minioClient.removeObject(bucketName, objectName);
                    return true;
                }
            }
        }
        return false;
    }
?
    /**
     * 文件訪問路徑
     *
     * @param bucketName 存儲(chǔ)桶名稱
     * @param objectName 存儲(chǔ)桶里的對(duì)象名稱
     * @return
     * @throws Exception
     */
    public String getObjectUrl(String bucketName, String objectName) throws Exception {
        boolean flag = bucketExists(bucketName);
        String url = "";
        if (flag) {
            url = minioClient.getObjectUrl(bucketName, objectName);
        }
        return url;
    }
?
}

4. 編寫測試類進(jìn)行測試

package com.suwell.serv.ocr.controller;
?
import com.suwell.serv.ocr.component.MinioConfig;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
?
import javax.servlet.http.HttpServletResponse;
import java.util.List;
?
@RestController
@CrossOrigin
@RequestMapping("/test")
public class MinioController {
?
    @Autowired
    MinioConfig minioConfig;
?
    // 上傳
    @PostMapping("/upload")
    public Object upload(@RequestParam("file") MultipartFile multipartFile) throws Exception {
        return this.minioConfig.putObject(multipartFile);
    }
?
    // 下載文件
    @GetMapping("/download")
    public void download(@RequestParam("fileName")String fileName, HttpServletResponse response) {
        this.minioConfig.download(fileName,response);
    }
?
    // 列出所有存儲(chǔ)桶名稱
    @PostMapping("/list")
    public List<String> list() throws Exception {
        return this.minioConfig.listBucketNames();
    }
?
    // 創(chuàng)建存儲(chǔ)桶
    @PostMapping("/createBucket")
    public boolean createBucket(String bucketName) throws Exception {
        return this.minioConfig.makeBucket(bucketName);
    }
?
    // 刪除存儲(chǔ)桶
    @PostMapping("/deleteBucket")
    public boolean deleteBucket(String bucketName) throws Exception {
        return this.minioConfig.removeBucket(bucketName);
    }
?
    // 列出存儲(chǔ)桶中的所有對(duì)象名稱
    @PostMapping("/listObjectNames")
    public List<String> listObjectNames(String bucketName) throws Exception {
        return this.minioConfig.listObjectNames(bucketName);
    }
?
    // 刪除一個(gè)對(duì)象
    @PostMapping("/removeObject")
    public boolean removeObject(String bucketName, String objectName) throws Exception {
        return this.minioConfig.removeObject(bucketName, objectName);
    }
?
    // 文件訪問路徑
    @PostMapping("/getObjectUrl")
    public String getObjectUrl(String bucketName, String objectName) throws Exception {
        return this.minioConfig.getObjectUrl(bucketName, objectName);
    }
}

5. 使用postman進(jìn)行本地測試