Minio簡介
介紹高性能分布式存儲文件服務(wù)Minio：Minio是基于Go語言編寫的對象存儲服務(wù)，適合于存儲大容量非結(jié)構(gòu)化的數(shù)據(jù)，例如圖片、音頻、視頻、日志文件、備份數(shù)據(jù)和容器/虛擬機(jī)鏡像等，而一個對象文件可以是任意大小，從幾kb到最大5T不等。區(qū)別于分布式存儲系統(tǒng)，minio的特色在于簡單、輕量級，對開發(fā)者友好?。?！，認(rèn)為存儲應(yīng)該是一個開發(fā)問題而不是一個運(yùn)維問題。
1.安裝minio
可以到官網(wǎng)去下載
鏈接: https://www.minio.org.cn/download.shtml
本文采用的是使用主流的安裝方式：docker安裝(docker的教程大家可以訪問b站的教程進(jìn)行學(xué)習(xí)，本文不作重點(diǎn)講解)
鏈接: https://blog.csdn.net/ouyang_zhen/article/details/118961684
linux系統(tǒng)中敲入如下命令
docker search minio
docker pull minio/minio
docker run -d -p 9000:9000 --name=minio --restart=always -e "MINIO_ROOT_USER=admin" -e "MINIO_ROOT_PASSWORD=admin123456" -v /home/data:/data -v /home/config:/root/.minio minio/minio server /data --console-address ":9000" --address ":9090"
docker logs -f containerid
或者使用docker-compose啟動
通過配置docker-compose.yml文件管理容器，通過docker-compose up -d 啟動容器
docker-compose.yml文件
這里的9100是配置訪問minio自帶的web管理后臺，9090是配置的服務(wù)器
version: "3.1"
services:
minio:
image: minio/minio:latest
container_name: minio
ports:
- "9100:9000"
- "9090:9090"
volumes:
- "./data:/data"
environment:
MINIO_ACCESS_KEY: "root"
MINIO_SECRET_KEY: "12345678"
command: server /data --console-address=":9000" --address=":9090"
logging:
driver: "json-file"
options:
max-size: "1m"
當(dāng)出現(xiàn)如下圖所示即代碼運(yùn)行成功，通過宿主機(jī)ip:9000訪問，輸入命令里的賬號/密碼登錄即可：
啟動成功后訪問 ip+9000(你運(yùn)行的端口號) 如下圖所示例，輸入你在命令行里的用戶名和我密碼
2.minio Ui界面的簡單使用
3.minio結(jié)合springboot
項(xiàng)目目錄結(jié)構(gòu)：
修改配置文件
1，yml文件配置
2，minio配置類并注入容器進(jìn)行管理
3，封裝minio操作服務(wù)器的API的工具類，項(xiàng)目中封裝了單文件上傳、下載、刪除、查看功能，桶的創(chuàng)建等
公司具體的存儲業(yè)務(wù)，在次基礎(chǔ)上根據(jù)公司業(yè)務(wù)來自行擴(kuò)展
4，編寫controller層，用postman進(jìn)行簡單的測試（測試類型：文本、文檔、表格、音頻、視頻、圖片）
yml配置：
spring:
# 配置文件上傳大小限制
servlet:
multipart:
max-file-size: 200MB
max-request-size: 200MB
minio:
server: http://120.76.159.196
port: 9090
accessKey: root
secretKey: 12345678
bucket: test
urlprefix: /minio/
配置類：
/**
* @Author xiaozq
* @Date 2022/11/17 9:54
* <p>@Description: 注意：這里不能用@Data,需手動寫gitter，setter
* reason：與@ConfigurationProperties一起用的時候，配置文件的值不能賦值給對應(yīng)類屬性，屬性值均為null</p>
*/
@Configuration
@ConfigurationProperties(prefix = "minio")
public class MinioConfig {
private String server;
private int port;
private String accessKey;
private String secretKey;
// 桶名
private String bucket;
// 統(tǒng)一前綴
private String urlPrefix;
/**
* 創(chuàng)建minio連接對象
* @return
*/
@Bean
public MinioClient minioClient(){
return MinioClient.builder()
.endpoint(server,port,false)
.credentials(accessKey,secretKey)
.build();
}
public void setServer(String server) {
this.server = server;
}
public void setPort(int port) {
this.port = port;
}
public void setAccessKey(String accessKey) {
this.accessKey = accessKey;
}
public void setSecretKey(String secretKey) {
this.secretKey = secretKey;
}
public void setBucket(String bucket) {
this.bucket = bucket;
}
public void setUrlPrefix(String urlPrefix) { this.urlPrefix = urlPrefix; }
public String getUrlPrefix() {
return urlPrefix;
}
public String getServer() {
return server;
}
public int getPort() {
return port;
}
public String getAccessKey() {
return accessKey;
}
public String getSecretKey() {
return secretKey;
}
public String getBucket() {
return bucket;
}
}
自定義封裝操作minio的api工具類：
**
* @Author xiaozq
* @Date 2022/8/5 10:42
* <p>@Description:</p>
*/
@Component
public class MinioTemplate {
@Autowired
private MinioClient minioClient;
@Value("${minio.bucket}")
public String bucketName;
@Value("${minio.urlprefix}")
public String urlprefix;
/**
* 判斷bucket是否存在，不存在則創(chuàng)建
* @param name
*/
public void existBucket(String name){
try {
boolean exist = minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());
if(!exist){
minioClient.makeBucket(MakeBucketArgs.builder().bucket(name).build());
}
}catch (Exception e){
e.printStackTrace();
}
}
/**
* 創(chuàng)建存儲bucket
* @param bucketName 存儲bucket名稱
* @return Boolean
*/
public Boolean makeBucket(String bucketName) {
try {
minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());
} catch (Exception e) {
e.printStackTrace();
return false;
}
return true;
}
/**
* 刪除存儲bucket
* @param bucketName 存儲bucket名稱
* @return Boolean
*/
public Boolean removeBucket(String bucketName) {
try {
minioClient.removeBucket(RemoveBucketArgs.builder()
.bucket(bucketName)
.build());
} catch (Exception e) {
e.printStackTrace();
return false;
}
return true;
}
/**
* 文件上傳
* @param file
* @return
*/
public Map<String, String> upload(MultipartFile file) {
String filename = FileUtils.extractUploadFilename(file);
try {
InputStream inputStream = file.getInputStream();
// 上傳到minio服務(wù)器
minioClient.putObject(PutObjectArgs.builder()
.bucket(this.bucketName)
.object(filename)
.stream(inputStream, -1L, 10485760L)
.build());
} catch (Exception e) {
e.printStackTrace();
}
// 返回地址
Map<String,String > resultMap = new HashMap<>();
resultMap.put("url",filename);
return resultMap;
}
/**
* 文件下載
* @param fileName 文件名
* @param delete 是否刪除
* @throws IOException
*/
public void fileDownload(@RequestParam(name = "fileName") String fileName,
@RequestParam(defaultValue = "false") Boolean delete,
HttpServletResponse response) {
InputStream inputStream = null;
OutputStream outputStream = null;
try {
if (StringUtils.isBlank(fileName)) {
response.setHeader("Content-type", "text/html;charset=UTF-8");
String data = "文件下載失敗";
OutputStream ps = response.getOutputStream();
ps.write(data.getBytes("UTF-8"));
return;
}
outputStream = response.getOutputStream();
// 獲取文件對象
inputStream =minioClient.getObject(GetObjectArgs.builder().bucket(this.bucketName).object(fileName).build());
byte buf[] = new byte[1024];
int length = 0;
response.reset();
response.setHeader("Content-Disposition", "attachment;filename=" +
URLEncoder.encode(fileName.substring(fileName.lastIndexOf("/") + 1), "UTF-8"));
response.setContentType("application/octet-stream");
response.setCharacterEncoding("UTF-8");
// 輸出文件
while ((length = inputStream.read(buf)) > 0) {
outputStream.write(buf, 0, length);
}
inputStream.close();
// 判斷：下載后是否同時刪除minio上的存儲文件
if (BooleanUtils.isTrue(delete)) {
minioClient.removeObject(RemoveObjectArgs.builder().bucket(this.bucketName).object(fileName).build());
}
} catch (Throwable ex) {
response.setHeader("Content-type", "text/html;charset=UTF-8");
String data = "文件下載失敗";
try {
OutputStream ps = response.getOutputStream();
ps.write(data.getBytes("UTF-8"));
}catch (IOException e){
e.printStackTrace();
}
} finally {
try {
outputStream.close();
if (inputStream != null) {
inputStream.close();
}}catch (IOException e){
e.printStackTrace();
}
}
}
/**
* 查看文件對象
* @param bucketName 存儲bucket名稱
* @return 存儲bucket內(nèi)文件對象信息
*/
public List<ObjectItem> listObjects(String bucketName) {
Iterable<Result<Item>> results = minioClient.listObjects(ListObjectsArgs.builder().bucket(bucketName).build());
List<ObjectItem> objectItems = new ArrayList<>();
try {
for (Result<Item> result : results) {
Item item = result.get();
ObjectItem objectItem = new ObjectItem();
objectItem.setObjectName(item.objectName());
objectItem.setSize(item.size());
objectItems.add(objectItem);
}
} catch (Exception e) {
e.printStackTrace();
return null;
}
return objectItems;
}
/**
* 批量刪除文件對象
* @param bucketName 存儲bucket名稱
* @param objects 對象名稱集合
*/
public Map<String, String> removeObjects(String bucketName, List<String> objects) {
Map<String,String > resultMap = new HashMap<>();
List<DeleteObject> dos = objects.stream().map(e -> new DeleteObject(e)).collect(Collectors.toList());
try {
minioClient.removeObjects(RemoveObjectsArgs.builder().bucket(bucketName).objects(dos).build());
resultMap.put("mes","刪除成功");
}catch (Exception e){
e.printStackTrace();
resultMap.put("mes","網(wǎng)絡(luò)異常，刪除失敗");
}
return resultMap;
}
}
上傳文件名替換工具類：
public class FileUtils {
/**
* 編碼文件名
* 日期路徑 + UUID
* 示例：fileName=2022/11/18/統(tǒng)計報表1668758006562.txt
*/
public static final String extractUploadFilename(MultipartFile file)
{
String fileName = file.getOriginalFilename();
// 注意，這里需要加上 \\ 將 特殊字符 . 轉(zhuǎn)意 \\. ,否則異常
String[] fileArray = fileName.split("\\.");
fileName = datePath() + "/" + fileArray[0]+System.currentTimeMillis()+"."+fileArray[1];
return fileName;
}
/**
* 日期路徑 即年/月/日 如2018/08/08
*/
public static final String datePath() {
Date now = new Date();
return DateFormatUtils.format(now, "yyyy/MM/dd");
}
}
controller層：文章來源：http://www.zghlxwxcb.cn/news/detail-776666.html
@RestController
public class MinioController {
@Autowired
private MinioTemplate minioTemplate;
@Value("${minio.server}")
private String server;
@Value("${minio.port}")
private Integer port;
@Value("${minio.bucket}")
private String bucket;
/**
* 單文件上傳
* @param file 文件
* @return
*/
@PostMapping("/uploadone")
public Object uploadOne(MultipartFile file) {
return minioTemplate.upload(file);
}
/**
* 單文件下載
* @param fileName 文件
* @param delete 下載完后是否刪除, 請謹(jǐn)慎傳參
*/
@GetMapping("/download")
public void download(@RequestParam(value = "fileName") String fileName,
@RequestParam(defaultValue = "false")Boolean delete, HttpServletResponse response) {
minioTemplate.fileDownload(fileName,delete,response);
}
/**
* 查看存儲的文件列表
* @param bucket 桶
* @return
*/
@GetMapping("/list")
public Object fileList(@RequestParam(value = "bucket") String bucket) {
return minioTemplate.listObjects(bucket);
}
/**
* 刪除文件
* @param bucket 桶
* @param list 文件名列表
* @return
*/
@DeleteMapping ("/remove")
public Object fileremove(@RequestParam String bucket,@RequestParam List<String> list) {
return minioTemplate.removeObjects(bucket,list);
}
}
接下來就是用postman測試，非常便利：測試存儲文檔、表格、日志、視頻、音頻、圖片等上傳、下載：
以上就是minio入門的所有內(nèi)容
更多可參考官網(wǎng)文檔：鏈接: https://min.io/docs/minio/kubernetes/upstream/
如果對源碼感興趣可以訪問：鏈接: https://github.com/minio/minio文章來源地址http://www.zghlxwxcb.cn/news/detail-776666.html
到了這里，關(guān)于SpringBoot集成Minio實(shí)戰(zhàn)詳解的文章就介紹完了。如果您還想了解更多內(nèi)容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
