MinIO 是一個基于 Apache License v2.0 開源協(xié)議的對象存儲服務(wù)。它兼容亞馬遜 S3 云存儲服務(wù)接口，非常適合于存儲大容量非結(jié)構(gòu)化的數(shù)據(jù)，例如圖片、視頻、日志文件、備份數(shù)據(jù)和容器/虛擬機鏡像等，而一個對象文件可以是任意大小，從幾 kb 到最大 5T 不等
1. 下載
我們可以直接去官網(wǎng)下載: https://docs.min.io/cn，這里介紹 Windows 版本
圖片
2. 使用
將之前下載的exe程序放到一個地方
圖片
啟動一個 CMD 窗口，進入 minio.exe 所在文件夾，輸入如下命令
.\minio.exe server D:\Tools\minio
圖片
這樣就啟動了，可以訪問后臺界面: http://127.0.0.1:9000，Access Key 和 Secret Key 在命令行那有顯示，都是 minioadmin
圖片
圖片
先創(chuàng)建你的 Bucket，Bucket 創(chuàng)建成功之后就可以上傳文件了，Bucket 不能含大寫字母，我創(chuàng)建了一個名為 file 的 Bucket，點擊上傳文件
圖片
上傳成功了，可以點擊文件分享，設(shè)置多久鏈接過期
圖片
打開鏈接可以看到讀取我們的圖片文件了
圖片
3. Docker
轉(zhuǎn)移到 Docker 專欄: Docker下MinIO的使用
4. Linux
這里我使用的是 CentOs，先去官網(wǎng)下載文件，然后傳到服務(wù)器里
圖片
命令如下
# 設(shè)置權(quán)限
chmod +x minio
# 設(shè)置密鑰
export MINIO_ACCESS_KEY=minioadmin
export MINIO_SECRET_KEY=miniostorage
# 啟動
./minio server /app/minio/data
# 后臺啟動
nohup /app/minio/minio server /app/minio/data > /app/minio/log/minio.log 2>&1 &
圖片
圖片
5. 代碼
- pom.xml
<minio.version>6.0.12</minio.version>
<guava.version>20.0</guava.version>
<!-- MinIO文件系統(tǒng) -->
<dependency>
<groupId>io.minio</groupId>
<artifactId>minio</artifactId>
<version>${minio.version}</version>
</dependency>
<dependency>
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
<version>${guava.version}</version>
</dependency>
- MinioConfig
# MinIO文件系統(tǒng)
minio:
url: http://xx.xx.xx.xxx:9000
access: minioadmin
secret: miniostorage
bucket: pdms
package com.example.config;
import io.minio.MinioClient;
import io.minio.errors.MinioException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.task.TaskExecutor;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import java.io.ByteArrayInputStream;
import java.util.HashMap;
import java.util.concurrent.ThreadPoolExecutor;
/**
* Minio文件系統(tǒng)初始化
*
* @author wliduo[i@dolyw.com]
* @date 2020/2/5 14:36
*/
@Configuration
public class MinioConfig {
/**
* logger
*/
private final static Logger logger = LoggerFactory.getLogger(MinioConfig.class);
@Value("${minio.url}")
private String url;
@Value("${minio.access}")
private String access;
@Value("${minio.secret}")
private String secret;
@Value("${minio.bucket}")
private String bucket;
/**
* Minio文件系統(tǒng)配置
*
* @param
* @return io.minio.MinioClient
* @throws
* @author wliduo[i@dolyw.com]
* @date 2020/2/5 16:10
*/
@Bean(name = "minioClient")
public MinioClient minioClient() throws Exception {
logger.info("---------- Minio文件系統(tǒng)初始化加載 ----------");
MinioClient minioClient = new MinioClient(url, access, secret);
// 判斷Bucket是否存在
boolean isExist = minioClient.bucketExists(bucket);
if(isExist) {
logger.info("---------- Minio文件系統(tǒng)Bucket已存在 ----------");
} else {
// 不存在創(chuàng)建一個新的Bucket
minioClient.makeBucket(bucket);
logger.info("---------- Minio文件系統(tǒng)Bucket已創(chuàng)建 ----------");
}
logger.info("---------- Minio文件系統(tǒng)初始化完成 ----------");
return minioClient;
}
}
- MinioUtil
package com.example.util;
import io.minio.MinioClient;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.springframework.web.multipart.MultipartFile;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.HashMap;
/**
* MinioUtil工具類
*
* @author wliduo[i@dolyw.com]
* @date 2020/2/5 17:53
*/
@Component
public class MinioUtil {
/**
* logger
*/
private final static Logger logger = LoggerFactory.getLogger(MinioUtil.class);
@Value("${minio.bucket}")
private String bucket;
/**
* minioClient
*/
private final MinioClient minioClient;
@Autowired
public MinioUtil(MinioClient minioClient) {
this.minioClient = minioClient;
}
/**
* 上傳文件
*
* @param file
* @return java.lang.String
* @throws
* @author wliduo[i@dolyw.com]
* @date 2020/2/6 16:03
*/
public String uploadFile(MultipartFile file) {
try(ByteArrayInputStream bais = new ByteArrayInputStream(file.getBytes())) {
return uploadFile(bais, file.getOriginalFilename());
} catch (IOException e) {
logger.error("{}文件上傳失敗", file.getOriginalFilename());
return "";
}
}
/**
* 上傳文件
*
* @param stream
* @param fileName
* @return java.lang.String
* @throws
* @author wliduo[i@dolyw.com]
* @date 2020/2/6 16:04
*/
public String uploadFile(InputStream stream, String fileName) {
// 獲取當前日期，設(shè)置文件夾
LocalDateTime localDateTime = LocalDateTime.now();
DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("yyyy/MM/dd/");
// 上傳文件路徑
StringBuilder objectName = new StringBuilder(localDateTime.format(dateTimeFormatter));
objectName.append('[').append(System.currentTimeMillis()).append(']').append(fileName);
try {
// 上傳文件
minioClient.putObject(bucket, objectName.toString(), stream, new HashMap(16));
return objectName.toString();
} catch (Exception e) {
logger.error("{}文件上傳失敗", objectName);
return "";
}
}
/**
* 獲取文件
*
* @param objectName
* @return java.io.InputStream
* @throws
* @author wliduo[i@dolyw.com]
* @date 2020/2/6 16:05
*/
public InputStream getFile(String objectName) {
try {
// 文件是否存在
minioClient.statObject(bucket, objectName);
// 獲取文件
return minioClient.getObject(bucket, objectName);
} catch (Exception e) {
logger.error("{}文件獲取失敗", objectName);
return null;
}
}
/**
* 直接下載文件
*
* @param req
* @param res
* @param fid
* @param fileName
* @return void
* @throws
* @author wliduo[i@dolyw.com]
* @date 2020/3/5 9:45
*/
public void lookUploadFile(HttpServletRequest req, HttpServletResponse res, String fid, String fileName) {
try (InputStream in = minioUtil.getFile(fid);
OutputStream output = res.getOutputStream()) {
// 得到輸入流
if (in == null) {
try (PrintWriter printWriter = res.getWriter()) {
printWriter.append("404 - File Not Exist");
} catch (IOException e) {
logger.error("數(shù)據(jù)異常: {}", e);
}
return;
}
res.reset();
// res.setContentType(getMimeType(fileName));
// https://gitee.com/dolyw/codes/2h1r6avwxumegjs89ztyn86
res.addHeader("content-Disposition", "inline;filename=" + java.net.URLEncoder.encode(fileName, "UTF-8"));
byte[] b = new byte[4096];
int i = 0;
while ((i = in.read(b)) > 0) {
output.write(b, 0, i);
}
} catch (MalformedURLException me) {
logger.error("數(shù)據(jù)異常: {}", me);
} catch (IOException e) {
logger.error("數(shù)據(jù)異常: {}", e);
}
}
/**
* 獲取外鏈
*
* @param objectName
* @return java.lang.String
* @throws
* @author wliduo[i@dolyw.com]
* @date 2020/2/6 16:04
*/
public String getFileUrl(String objectName) {
try {
return minioClient.presignedGetObject(bucket, objectName, 60 * 60 * 24);
} catch (Exception e) {
logger.error("{}文件獲取失敗", objectName);
return "";
}
}
}
參考
