1.在linux上安裝并啟動docker
- 檢查linux內(nèi)核,必須是3.10以上
uname ‐r
- 安裝docker
yum install docker
- 啟動docker
systemctl start docker
2.在docker中拉取minio并啟動
- 搜索鏡像
docker search minio
- 拉取鏡像
docker pull minio/minio
- 啟動minio
docker run -p 9000:9000 -p 9090:9090 --name minio \
-d --restart=always \
-e MINIO_ACCESS_KEY=vinci \
-e MINIO_SECRET_KEY=123456\
-v /usr/local/minio/data:/data \
-v /usr/local/minio/config:/root/.minio \
minio/minio server /data --console-address ":9000" --address ":9090"
-p: 指定端口映射,格式為:主機端口:容器端口 (這里注意要映射兩個,否則API會訪問不到)
-e “MINIO_ROOT_USER=vinci” minio用戶名;
-e MINIO_SECRET_KEY=123456 minio 密碼
-d: 后臺運行容器,并返回容器ID;
-v: 綁定一個卷
這里可以看到minio已經(jīng)在docker里啟動起來了
接下來我們可以通過以下命令來查看 minio console和minio api 訪問端口
docker logs minio
- 訪問minio控制臺
在此步驟前記得開放端口號
我們接下來可以使用密碼和賬號登錄minio控制臺了
3.Spring Boot 整合 minio
在此之前我們可以先通過控制臺來創(chuàng)建一個bucket文章來源:http://www.zghlxwxcb.cn/news/detail-733719.html
- 集成minio
<dependency>
<groupId>io.minio</groupId>
<artifactId>minio</artifactId>
<version>8.4.0</version>
</dependency>
- 編寫minio配置類
/**
* @package: com.vinci.minio.config
* @className: MinioConfig
* @author: Vinci
* @description: minio配置類
* @date: 2023/10/27 13:10
*/
@Data
@Configuration
@ConfigurationProperties(prefix = "minio")
public class MinioConfig {
private String endpoint;
private String accessKey;
private String secretKey;
private String bucketName;
@Bean
public MinioClient minioClient(){
return MinioClient
.builder()
.endpoint(endpoint)
.credentials(accessKey, secretKey)
.build();
}
}
- 在application.properties中添加以下配置
minio.endpoint=http://108.13.21.28:9090/
minio.bucket-name=images
minio.access-key=xxxxx
minio.secret-key=xxxxx
注意 minio.endpoint 是minio API地址,不是控制臺地址
minio.bucket-name 是 bucket的名稱
minio.access-key 是用戶名
minio.secret-key是密碼文章來源地址http://www.zghlxwxcb.cn/news/detail-733719.html
- 編寫minio工具類
package com.vinci.minio.utils;
import com.vinci.minio.config.MinioConfig;
import io.minio.*;
import io.minio.http.Method;
import io.minio.messages.Bucket;
import io.minio.messages.Item;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import org.springframework.util.FastByteArrayOutputStream;
import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource;
import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletResponse;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.UUID;
/**
* @description: minio工具類
* @author: Vinci
* @date: 2023/10/27 13:23
**/
@Component
@Slf4j
public class MinioUtil {
@Resource
private MinioConfig config;
@Resource
private MinioClient minioClient;
/**
* @description: 查看存儲bucket是否存在
* @author: Vinci
* @date: 2023/10/27 13:24
* @param bucketName 要查看的bucket名稱
* @return 存在即返回true
**/
public Boolean bucketExists(String bucketName) {
try {
return minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());
} catch (Exception e) {
log.error("發(fā)現(xiàn)異常",e);
return false;
}
}
/**
* @description: 創(chuàng)建存儲bucket
* @author: Vinci
* @date: 2023/10/27 13:24
* @param bucketName 要創(chuàng)建的bucket名稱
* @return 創(chuàng)建成功即返回true
**/
public Boolean makeBucket(String bucketName) {
try {
minioClient.makeBucket(MakeBucketArgs.builder()
.bucket(bucketName)
.build());
return true;
} catch (Exception e) {
log.error("發(fā)現(xiàn)異常",e);
return false;
}
}
/**
* @description: 刪除存儲bucket
* @author: Vinci
* @date: 2023/10/27 13:24
* @param bucketName 要刪除的bucket名稱
* @return 刪除成功即返回true
**/
public Boolean removeBucket(String bucketName) {
try {
minioClient.removeBucket(
RemoveBucketArgs.builder()
.bucket(bucketName)
.build()
);
return true;
} catch (Exception e) {
log.error("發(fā)現(xiàn)異常",e);
return false;
}
}
/**
* @description: 獲取全部bucket
* @author: Vinci
* @date: 2023/10/27 13:24
* @return 返回bucket結(jié)果集
**/
public List<Bucket> getAllBuckets() {
try {
return minioClient.listBuckets();
} catch (Exception e) {
log.error("發(fā)現(xiàn)異常",e);
return null;
}
}
/**
* @description: 文件上傳
* @author: Vinci
* @date: 2023/10/27 13:24
* @param file 表單上傳的文件
* @return 返回文件上傳的路徑
**/
public String upload(MultipartFile file) {
String originalFilename = file.getOriginalFilename();
if (originalFilename == null || originalFilename.isEmpty()){
throw new RuntimeException();
}
String fileName = UUID.randomUUID() + originalFilename.substring(originalFilename.lastIndexOf("."));
String objectName = new SimpleDateFormat("yyyyMM").format(new Date()) + "/" + fileName;
try {
PutObjectArgs objectArgs = PutObjectArgs.builder().bucket(config.getBucketName()).object(objectName)
.stream(file.getInputStream(), file.getSize(), -1).contentType(file.getContentType()).build();
minioClient.putObject(objectArgs);
return objectName;
} catch (Exception e) {
log.error("發(fā)現(xiàn)異常",e);
return null;
}
}
/**
* @description: 預覽圖片
* @author: Vinci
* @date: 2023/10/27 13:24
* @param fileName 文件在bucket中的全路徑
* @return 返回文件的瀏覽路徑
**/
public String preview(String fileName){
// 查看文件地址
GetPresignedObjectUrlArgs build = GetPresignedObjectUrlArgs
.builder()
.bucket(config.getBucketName())
.object(fileName)
.method(Method.GET)
.build();
try {
return minioClient.getPresignedObjectUrl(build);
} catch (Exception e) {
log.error("發(fā)現(xiàn)異常",e);
return null;
}
}
/**
* @description: 文件下載
* @author: Vinci
* @date: 2023/10/27 13:24
* @param fileName 文件在bucket中的全路徑
**/
public void download(String fileName, HttpServletResponse res) {
GetObjectArgs objectArgs = GetObjectArgs.builder()
.bucket(config.getBucketName())
.object(fileName).build();
try (GetObjectResponse response = minioClient.getObject(objectArgs)){
byte[] buf = new byte[1024];
int len;
try (FastByteArrayOutputStream os = new FastByteArrayOutputStream()){
while ((len=response.read(buf))!=-1){
os.write(buf,0,len);
}
os.flush();
byte[] bytes = os.toByteArray();
res.setCharacterEncoding("utf-8");
res.setContentType("application/force-download");
res.addHeader("Content-Disposition", "inline;fileName=" + fileName);
try (ServletOutputStream stream = res.getOutputStream()){
stream.write(bytes);
stream.flush();
}
}
} catch (Exception e) {
log.error("發(fā)現(xiàn)異常",e);
}
}
/**
* @description: 查看文件對象
* @author: Vinci
* @date: 2023/10/27 13:24
* @return 存儲bucket內(nèi)文件對象信息
**/
public List<Item> listObjects() {
Iterable<Result<Item>> results = minioClient.listObjects(
ListObjectsArgs.builder().bucket(config.getBucketName()).build());
List<Item> items = new ArrayList<>();
try {
for (Result<Item> result : results) {
items.add(result.get());
}
return items;
} catch (Exception e) {
log.error("發(fā)現(xiàn)異常",e);
return null;
}
}
/**
* @description: 刪除文件信息
* @author: Vinci
* @date: 2023/10/27 13:24
* @return 刪除成功則返回true
**/
public boolean remove(String fileName){
try {
minioClient.removeObject(
RemoveObjectArgs.builder()
.bucket(config.getBucketName())
.object(fileName).build()
);
return true;
}catch (Exception e){
log.error("發(fā)現(xiàn)異常",e);
return false;
}
}
}
4.測試 minio 文件上傳、下載及圖片預覽等功能
- 編寫controller通過接口的方式來測試minio功能
package com.vinci.minio.controller;
import com.vinci.minio.utils.MinioUtil;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletResponse;
/**
* @package: com.vinci.minio.controller
* @className: TestMinioController
* @author: Vinci
* @description: 測試minio
* @date: 2023/10/27 13:48
*/
@Controller
@RequestMapping(value = "/minio")
public class TestMinioController {
@Resource
private MinioUtil minioUtil;
/**
* @description: 文件上傳測試
* @author: Vinci
* @date: 2023/10/27 13:48
**/
@ResponseBody
@PostMapping("/upload")
public String fileUpload(MultipartFile file) {
return minioUtil.upload(file);
}
/**
* @description: 文件下載測試
* @author: Vinci
* @date: 2023/10/27 13:51
**/
@ResponseBody
@GetMapping("/download")
public String fileDownload(String fileName, HttpServletResponse response){
minioUtil.download(fileName,response);
return "success";
}
/**
* @description: 圖片預覽
* @author: Vinci
* @date: 2023/10/27 13:53
**/
@GetMapping("/preview")
public String imagePreview(String fileName){
return minioUtil.preview(fileName);
}
}
- 測試文件上傳
使用postMan來調(diào)用文件上傳的接口
我們返回控制臺可以看到文件已經(jīng)上傳上去了 - 測試文件下載
我們借助postman工具點擊發(fā)送并下載可以看到文件下載成功了 - 圖片在線預覽
我們同樣借助postman工具發(fā)送請求,我們可以看到返回了圖片的在線瀏覽地址,點擊即可在線瀏覽圖片
以上便是minio 整合springboot的全部流程了,感謝閱讀!
SpringBoot案例地址:https://gitee.com/vinci99/springboot-minio-test.git
到了這里,關(guān)于minio + linux + docker + spring boot實現(xiàn)文件上傳與下載的文章就介紹完了。如果您還想了解更多內(nèi)容,請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章,希望大家以后多多支持TOY模板網(wǎng)!