Springboot怎么集成minio實現文件存儲

本篇內容主要講解“Springboot怎么集成minio實現文件存儲”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學習“Springboot怎么集成minio實現文件存儲”吧!

MinIO 是一款基于Go語言的高性能對象存儲服務，它采用了Apache License v2.0開源協議，非常適合于存儲大容量非結構化的數據，例如圖片、視頻、日志文件、備份數據和容器/虛擬機鏡像等。

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

添加相關依賴

<!--        引入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容器中，使用的時候直接獲取即可。

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

測試相關接口

如果不能訪問該地址 ，記得去開啟相關權限。

3. 問題記錄

S3 API Request made to Console port. S3 Requests should be sent to API port.

原因是配置文件里面用了Console 控制臺的端口，應該使用API端口：

到此，相信大家對“Springboot怎么集成minio實現文件存儲”有了更深的了解，不妨來實際操作一番吧！這里是億速云網站，更多相關內容可以進入相關頻道進行查詢，關注我們，繼續學習！