Springboot集成minio實現(xiàn)文件存儲的實現(xiàn)代碼
在我們平時做項目的時候,文件存儲是個很常見的需求。這時候我們就會用到對象存儲服務,平時我們可能會選擇OSS、AWS S3這類第三方服務。今天帶大家搭建一款自己的對象存儲服務,帶可視化管理,用起來也挺簡單。
MinIO 是一款基于Go語言的高性能對象存儲服務,它采用了Apache License v2.0開源協(xié)議,非常適合于存儲大容量非結構化的數(shù)據(jù),例如圖片、視頻、日志文件、備份數(shù)據(jù)和容器/虛擬機鏡像等。
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 參數(shù)配置
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();
}
}
編寫相關業(yè)務代碼
編寫相關業(yè)務代碼,上傳圖片后將相關的路徑回傳。
/**
* 文件上傳 (自定義文件名稱)
*/
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)建一個 headers
Map<String, String> headers = new HashMap<>();
// 添加請求頭 文件的ContentType 動態(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);
// 返回生成文件名、訪問路徑
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端口:

4. 項目地址
更多Demo案例可以前往我的個人倉庫查看 正在逐步更新中。
https://gitee.com/cl1429745331/java-coder
到此這篇關于Springboot集成minio實現(xiàn)文件存儲的實現(xiàn)代碼的文章就介紹到這了,更多相關Springboot minio文件存儲內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
Spring?Security認證器實現(xiàn)過程詳解
一些權限框架一般都包含認證器和決策器,前者處理登陸驗證,后者處理訪問資源的控制,這篇文章主要介紹了Spring?Security認證器實現(xiàn)過程,需要的朋友可以參考下2022-06-06
Spring Security靈活的PasswordEncoder加密方式解析
這篇文章主要介紹了Spring Security靈活的PasswordEncoder加密方式解析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-09-09
JavaWeb Struts文件上傳功能實現(xiàn)詳解
這篇文章主要為大家詳細介紹了JavaWeb Struts文件上傳功能實現(xiàn)過程,思路清晰,供大家參考,感興趣的小伙伴們可以參考一下2016-06-06
SpringBoot集成Flink-CDC實現(xiàn)對數(shù)據(jù)庫數(shù)據(jù)的監(jiān)聽問題
Flink CDC(Flink Change Data Capture)是一種基于數(shù)據(jù)庫日志的CDC技術,它實現(xiàn)了一個全增量一體化的數(shù)據(jù)集成框架,這篇文章主要介紹了SpringBoot集成Flink-CDC,實現(xiàn)對數(shù)據(jù)庫數(shù)據(jù)的監(jiān)聽,需要的朋友可以參考下2024-07-07
Java并發(fā)Futures和Callables類實例詳解
Callable對象返回Future對象,該對象提供監(jiān)視線程執(zhí)行的任務進度的方法, Future對象可用于檢查Callable的狀態(tài),然后線程完成后從Callable中檢索結果,這篇文章給大家介紹Java并發(fā)Futures和Callables類的相關知識,感興趣的朋友一起看看吧2024-05-05
Spring boot 應用實現(xiàn)動態(tài)刷新配置詳解
這篇文章主要介紹了spring boot 配置動態(tài)刷新實現(xiàn)詳解,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2021-09-09

