快捷導(dǎo)航

Springboot集成minio實(shí)現(xiàn)文件存儲(chǔ)的實(shí)現(xiàn)代碼

更新時(shí)間：2022年03月15日 14:19:23 作者：、楽.

MinIO?是一款基于Go語(yǔ)言的高性能對(duì)象存儲(chǔ)服務(wù)，本文主要介紹了Springboot集成minio實(shí)現(xiàn)文件存儲(chǔ)的實(shí)現(xiàn)代碼，文中通過(guò)示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

在我們平時(shí)做項(xiàng)目的時(shí)候，文件存儲(chǔ)是個(gè)很常見(jiàn)的需求。這時(shí)候我們就會(huì)用到對(duì)象存儲(chǔ)服務(wù)，平時(shí)我們可能會(huì)選擇OSS、AWS S3這類(lèi)第三方服務(wù)。今天帶大家搭建一款自己的對(duì)象存儲(chǔ)服務(wù)，帶可視化管理，用起來(lái)也挺簡(jiǎn)單。

MinIO 是一款基于Go語(yǔ)言的高性能對(duì)象存儲(chǔ)服務(wù)，它采用了Apache License v2.0開(kāi)源協(xié)議，非常適合于存儲(chǔ)大容量非結(jié)構(gòu)化的數(shù)據(jù)，例如圖片、視頻、日志文件、備份數(shù)據(jù)和容器/虛擬機(jī)鏡像等。

1. 安裝部署

1.1 Linux 簡(jiǎn)單部署

wget https://dl.min.io/server/minio/release/linux-amd64/minio

chmod +x minio 

MINIO_ROOT_USER=admin MINIO_ROOT_PASSWORD=123456 

##啟動(dòng)并指定端口
./minio server /mnt/data --console-address ":9001"

## 或者后臺(tái)啟動(dòng)
nohup ./minio server /mnt/data  >  /opt/minio/minio.log 2>&1 &#

然后訪問(wèn)對(duì)應(yīng)地址即可：云服務(wù)器的話記得去安全組打開(kāi)對(duì)應(yīng)端口，賬號(hào)密碼如圖所示：

1.2 Docker 部署

#下載MinIO的Docker鏡像 
docker pull minio/minio 
#--console-address指定MinIO Console的運(yùn)行端口 （否則會(huì)隨機(jī)端口運(yùn)行） 暴露端口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 整合

添加相關(guān)依賴(lài)

<!--        引入minio依賴(lài)-->
<dependency>
    <groupId>io.minio</groupId>
    <artifactId>minio</artifactId>
    <version>8.0.3</version>
</dependency>

添加相關(guān)配置信息

默認(rèn)安裝不指定Access key 和Secret key 的話都是minioadmin, Endpoint則為服務(wù)器API地址.

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

# minio 參數(shù)配置
minio:
  endpoint: http://127.0.01:9000
  accessKey: minioadmin
  secretKey: minioadmin

注入客戶(hù)端

將客戶(hù)端注入Spring容器中，使用的時(shí)候直接獲取即可。

@Configuration
public class MinIoConfig {

    @Value("${minio.endpoint}")
    private String endpoint;
    @Value("${minio.accessKey}")
    private String accessKey;
    @Value("${minio.secretKey}")
    private String secretKey;

    /**
     * 注入minio 客戶(hù)端
     *
     * @return
     */
    @Bean
    public MinioClient minioClient() {

        return MinioClient.builder()
                .endpoint(endpoint)
                .credentials(accessKey, secretKey)
                .build();
    }
}

編寫(xiě)相關(guān)業(yè)務(wù)代碼

編寫(xiě)相關(guān)業(yè)務(wù)代碼，上傳圖片后將相關(guān)的路徑回傳。

/**
 * 文件上傳 （自定義文件名稱(chēng)）
 */
public MinIoUploadVo upload(String strDir, MultipartFile multipartFile) throws Exception {

    // bucket 不存在，創(chuàng)建
    if (!this.bucketExists(strDir)) {
        this.makeBucket(strDir);
    }
    InputStream inputStream = multipartFile.getInputStream();
    // 創(chuàng)建一個(gè) headers
    Map<String, String> headers = new HashMap<>();
    // 添加請(qǐng)求頭 文件的ContentType 動(dòng)態(tài)配置 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，上傳配置(文件大小，內(nèi)存中文件分片大小)
                    .headers(headers)
                    .build());
    String url = endpoint.concat("/").concat(strDir).concat("/").concat(minFileName);
    // 返回生成文件名、訪問(wèn)路徑
    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();
    }
}

測(cè)試相關(guān)接口

如果不能訪問(wèn)該地址，記得去開(kāi)啟相關(guān)權(quán)限。

3. 問(wèn)題記錄

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

原因是配置文件里面用了Console 控制臺(tái)的端口，應(yīng)該使用API端口：

4. 項(xiàng)目地址

更多Demo案例可以前往我的個(gè)人倉(cāng)庫(kù)查看正在逐步更新中。

https://gitee.com/cl1429745331/java-coder

到此這篇關(guān)于Springboot集成minio實(shí)現(xiàn)文件存儲(chǔ)的實(shí)現(xiàn)代碼的文章就介紹到這了,更多相關(guān)Springboot minio文件存儲(chǔ)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: