簡介：

構(gòu)建高性能的云原生數(shù)據(jù)、機器學習，大數(shù)據(jù)分析，海量存儲的基礎架構(gòu)、MinIO支持各種應用程序數(shù)據(jù)工作負載。

特點：

• 高性能
• 可擴展性
• 云的原生支持
• 簡單
• 開放全部源代碼 + 企業(yè)級支持
• 與Amazon S3 兼容

一、搭建

支持Docker鏡像部署

1、從hub.docker.com拉取最新鏡像

命令：docker pull minio/minio （此命令就等同于 : docker pull minio/minio:latest）

2、創(chuàng)建目錄

一個用來存放配置，一個用來存儲上傳文件的目錄

啟動前需要先創(chuàng)建Minio外部掛載的配置文件（ /home/minio/config）,和存儲上傳文件的目錄（ /home/minio/data）

mkdir -p /home/minio/configmkdir -p /home/minio/data

3、創(chuàng)建Minio容器并運行

多行命令

docker run -p 9000:9000 -p 9090:9090–net=host–name minio-d –restart=always-e “MINIO_ACCESS_KEY=minioadmin”-e “MINIO_SECRET_KEY=minioadmin”-v /home/minio/data:/data-v /home/minio/config:/root/.miniominio/minio server/data –console-address “:9090” -address “:9000”

單行命令

docker run -p 9000:9000 -p 9090:9090–net=host–name minio-d –restart=always-e “MINIO_ACCESS_KEY=minioadmin”-e “MINIO_SECRET_KEY=minioadmin”-v /home/minio/data:/data-v /home/minio/config:/root/.miniominio/minio server/data –console-address “:9090” -address “:9000”

9090：客戶端端口

9000：api端口（項目中所用）

MINIO_ACCESS_KEY ：賬號

MINIO_SECRET_KEY ：密碼（賬號長度必須大于等于5，密碼長度必須大于等于8位）

4、客戶端訪問

地址：http://ip:9090

二、整合項目（SpringBoot項目）

1、application.yml

2、minio文件上傳工具類

public class MinioUtil {private static String minioUrl;private static String minioName;private static String minioPass;private static String bucketName;public static void setMinioUrl(String minioUrl) {MinioUtil.minioUrl = minioUrl;}public static void setMinioName(String minioName) {MinioUtil.minioName = minioName;}public static void setMinioPass(String minioPass) {MinioUtil.minioPass = minioPass;}public static void setBucketName(String bucketName) {MinioUtil.bucketName = bucketName;}public static String getMinioUrl() {return minioUrl;}public static String getBucketName() {return bucketName;}private static MinioClient minioClient = null;/** * 上傳文件 * @param file * @return */public static String upload(MultipartFile file, String bizPath, String customBucket) {String file_url = “”;//update-begin-author:wangshuai date:20201012 for: 過濾上傳文件夾名特殊字符，防止攻擊bizPath=StrAttackFilter.filter(bizPath);//update-end-author:wangshuai date:20201012 for: 過濾上傳文件夾名特殊字符，防止攻擊String newBucket = bucketName;if(oConvertUtils.isNotEmpty(customBucket)){newBucket = customBucket;}try {initMinio(minioUrl, minioName,minioPass);// 檢查存儲桶是否已經(jīng)存在if(minioClient.bucketExists(BucketExistsArgs.builder().bucket(newBucket).build())) {log.info(“Bucket already exists.”);} else {// 創(chuàng)建一個名為ota的存儲桶minioClient.makeBucket(MakeBucketArgs.builder().bucket(newBucket).build());log.info(“create a new bucket.”);}InputStream stream = file.getInputStream();// 獲取文件名String orgName = file.getOriginalFilename();if(“”.equals(orgName)){orgName=file.getName();}orgName = CommonUtils.getFileName(orgName);String objectName = bizPath+”/”+orgName.substring(0, orgName.lastIndexOf(“.”)) + “_” + System.currentTimeMillis() + orgName.substring(orgName.lastIndexOf(“.”));// 使用putObject上傳一個本地文件到存儲桶中。if(objectName.startsWith(“/”)){objectName = objectName.substring(1);}PutObjectArgs objectArgs = PutObjectArgs.builder().object(objectName).bucket(newBucket).contentType(“application/octet-stream”).stream(stream,stream.available(),-1).build();minioClient.putObject(objectArgs);stream.close();file_url = minioUrl+newBucket+”/”+objectName;}catch (Exception e){log.error(e.getMessage(), e);}return file_url;}/** * 文件上傳 * @param file * @param bizPath * @return */public static String upload(MultipartFile file, String bizPath) {returnupload(file,bizPath,null);}/** * 獲取文件流 * @param bucketName * @param objectName * @return */public static InputStream getMinioFile(String bucketName,String objectName){InputStream inputStream = null;try {initMinio(minioUrl, minioName, minioPass);GetObjectArgs objectArgs = GetObjectArgs.builder().object(objectName).bucket(bucketName).build();inputStream = minioClient.getObject(objectArgs);} catch (Exception e) {log.info(“文件獲取失敗” + e.getMessage());}return inputStream;}/** * 刪除文件 * @param bucketName * @param objectName * @throws Exception */public static void removeObject(String bucketName, String objectName) {try {initMinio(minioUrl, minioName,minioPass);RemoveObjectArgs objectArgs = RemoveObjectArgs.builder().object(objectName).bucket(bucketName).build();minioClient.removeObject(objectArgs);}catch (Exception e){log.info(“文件刪除失敗” + e.getMessage());}}/** * 獲取文件外鏈 * @param bucketName * @param objectName * @param expires * @return */public static String getObjectURL(String bucketName, String objectName, Integer expires) {initMinio(minioUrl, minioName,minioPass);try{GetPresignedObjectUrlArgs objectArgs = GetPresignedObjectUrlArgs.builder().object(objectName).bucket(bucketName).expiry(expires).build();String url = minioClient.getPresignedObjectUrl(objectArgs);return URLDecoder.decode(url,”UTF-8″);}catch (Exception e){log.info(“文件路徑獲取失敗” + e.getMessage());}return null;}/** * 初始化客戶端 * @param minioUrl * @param minioName * @param minioPass * @return */private static MinioClient initMinio(String minioUrl, String minioName,String minioPass) {if (minioClient == null) {try {minioClient = MinioClient.builder().endpoint(minioUrl).credentials(minioName, minioPass).build();} catch (Exception e) {e.printStackTrace();}}return minioClient;}/** * 上傳文件到minio * @param stream * @param relativePath * @return */public static String upload(InputStream stream,String relativePath) throws Exception {initMinio(minioUrl, minioName,minioPass);if(minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build())) {log.info(“Bucket already exists.”);} else {// 創(chuàng)建一個名為ota的存儲桶minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());log.info(“create a new bucket.”);}PutObjectArgs objectArgs = PutObjectArgs.builder().object(relativePath).bucket(bucketName).contentType(“application/octet-stream”).stream(stream,stream.available(),-1).build();minioClient.putObject(objectArgs);stream.close();return minioUrl+bucketName+”/”+relativePath;}}

3、controller

@PostMapping(value = “/uploadMinio”)public Result uploadMinio(HttpServletRequest request) {Result result = new Result();String bizPath = request.getParameter(“biz”);if(oConvertUtils.isEmpty(bizPath)){bizPath = “”;}MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request;MultipartFile file = multipartRequest.getFile(“file”);// 獲取上傳文件對象String orgName = file.getOriginalFilename();// 獲取文件名orgName = CommonUtils.getFileName(orgName);String file_url =MinioUtil.upload(file,bizPath);if(oConvertUtils.isEmpty(file_url)){return Result.error(“上傳失敗,請檢查配置信息是否正確!”);}//保存文件信息OSSFile minioFile = new OSSFile();minioFile.setFileName(orgName);minioFile.setUrl(file_url);ossFileService.save(minioFile);result.setMessage(file_url);result.setSuccess(true);return result;}

4、前端組件

MINIO文件上傳

好啦, 關于{對象存儲-MinIo}分享就到這啦, 如果你是前端工程師同學，歡迎試用體驗【webfunny監(jiān)控系統(tǒng)】。

webfunny前端監(jiān)控

Webfunny前端應用專注于微信小程序、H5前端、PC前端線上應用實時監(jiān)控，實時監(jiān)控前端網(wǎng)頁、前端數(shù)據(jù)分析、錯誤統(tǒng)計分析監(jiān)控和BUG預警，第一時間報警，快速修復BUG！支持私有化部署，容器化部署。