MinIO Linux 安装使用 & SpringBoot整合MinIO
目录[*]MinIO Linux 安装
[*]单节点部署
[*]创建 systemd 系统启动服务文件
[*]创建环境变量文件
[*]启动MinIO服务
[*]连接到MinIO服务
[*]SpringBoot项目整合MinIO
[*]配置项
[*]工具类
[*]测试
[*]链接永不过期
MinIO 是一个基于Apache License v2.0开源协议的对象存储服务。它可以运行在多种操作系统上，包括 Linux 和 Windows 等。
它兼容亚马逊S3云存储服务接口，非常适合于存储大容量非结构化的数据，例如图片、视频、日志文件、备份数据和容器/虚拟机镜像等，而一个对象文件可以是任意大小，从几kb到最大5TB不等。
Minio官网：https://min.io/
中文地址：https://www.minio.org.cn
中文文档：https://www.minio.org.cn/docs/minio/linux/index.html
演示：https://play.minio.org.cn用户名：minioadmin、密码minioadmin
MinIO Linux 安装
单节点部署
Download： https://www.minio.org.cn/download.shtml#/linux
使用以下命令下载安装最新版本的稳定 MinIO二进制包， 并设置 $PATH :
# wget https://dl.minio.org.cn/server/minio/release/linux-amd64/minio# chmod +x minio# sudo mv minio /usr/local/bin/
创建 systemd 系统启动服务文件
创建 minio.service 启动文件，确保文件在 /usr/lib/systemd/system/minio.service
# vi /usr/lib/systemd/system/minio.serviceminio.service
Description=MinIODocumentation=https://min.io/docs/minio/linux/index.htmlWants=network-online.targetAfter=network-online.targetAssertFileIsExecutable=/usr/local/bin/minioWorkingDirectory=/usr/localUser=minio-userGroup=minio-userProtectProc=invisibleEnvironmentFile=-/etc/default/minioExecStartPre=/bin/bash -c "if [ -z \"${MINIO_VOLUMES}\" ]; then echo \"Variable MINIO_VOLUMES not set in /etc/default/minio\"; exit 1; fi"ExecStart=/usr/local/bin/minio server $MINIO_OPTS $MINIO_VOLUMES# MinIO RELEASE.2023-05-04T21-44-30Z adds support for Type=notify (https://www.freedesktop.org/software/systemd/man/systemd.service.html#Type=)# This may improve systemctl setups where other services use `After=minio.server`# Uncomment the line to enable the functionality# Type=notify# Let systemd restart this service alwaysRestart=always# Specifies the maximum file descriptor number that can be opened by this processLimitNOFILE=65536# Specifies the maximum number of threads this process can createTasksMax=infinity# Disable timeout logic and wait until process is stoppedTimeoutStopSec=infinitySendSIGKILL=noWantedBy=multi-user.target# Built for ${project.name}-${project.version} (${project.name})默认情况下， minio.service 文件以 minio-user 用户和组的身份运行。 您可以使用 groupadd 和 useradd 创建用户和组。 命令。下面的示例创建了用户和组，并设置了权限 来访问供 MinIO 使用的文件夹路径。这些命令通常 需要 root ( sudo ) 权限。
# groupadd -r minio-user# useradd -M -r -g minio-user minio-user# 存储路径# chown minio-user:minio-user /mnt/datachown: 无法访问"/mnt/data": 没有那个文件或目录# mkdir /mnt/data# chown minio-user:minio-user /mnt/data本例中的驱动器路径由 MINIO_VOLUMES 环境变量指定。更改此处和环境变量文件中的值，使其与 MinIO 打算使用的驱动器路径相匹配。
创建环境变量文件
在 /etc/default/minio 创建环境变量文件。 MinIO 服务器容器可以将此文件作为所有 environment variables
下面的示例提供了一个起始环境文件:
密码不能小于8个字符, 否则无法启动
# vi /etc/default/minio# MINIO_ROOT_USER and MINIO_ROOT_PASSWORD sets the root account for the MinIO server.# This user has unrestricted permissions to perform S3 and administrative API operations on any resource in the deployment.# Omit to use the default values 'minioadmin:minioadmin'.# MinIO recommends setting non-default values as a best practice, regardless of environment# 用户名长度不能小于3个字符MINIO_ROOT_USER=admin# 密码不能小于8个字符, 否则无法启动MINIO_ROOT_PASSWORD=minioadmin# MINIO_VOLUMES sets the storage volume or path to use for the MinIO server.MINIO_VOLUMES="/mnt/data"# MINIO_OPTS sets any additional commandline options to pass to the MinIO server.# For example, `--console-address :9001` sets the MinIO Console listen portMINIO_OPTS="--console-address :9001"启动MinIO服务
启动 MinIO SNSD 部署即服务：
# sudo systemctl start minio.service使用以下命令确认服务是否在线和功能正常：
# sudo systemctl status minio.service# journalctl -f -u minio.service自启动，将进程作为主机引导的一部分，在服务器重启的过程中该进程会自动重启，而不用再进行手动管理。
# sudo systemctl enable minio.service
连接到MinIO服务
浏览器中输入：http://localhost:9001
登录MinIO的用户名和密码配置参数为 MINIO_ROOT_USER 和 MINIO_ROOT_PASSWORD 这些配置可以在在容器指定的环境文件中进行修改。
您可以使用MinIO控制台进行一般管理任务，如身份和访问管理、指标和日志监控或服务器配置。每个MinIO服务器都包含其自己的嵌入式MinIO控制台。 如果您的本地主机防火墙允许外部访问控制台端口，则同一网络上的其他主机可以使用您的本地主机的IP地址或主机名访问控制台。
SpringBoot项目整合MinIO
https://mvnrepository.com/artifact/io.minio/minio
配置项
添加依赖
<dependency> <groupId>io.minio</groupId> <artifactId>minio</artifactId> <version>8.5.10</version></dependency>application.yml 配置 minio
spring: mvc: hiddenmethod: filter: enabled: true#设置文件上传大小限制servlet: multipart: max-file-size: -1 #设置单个文件的大小 -1表示不限制 max-request-size: -1 #单次请求的文件的总大小 -1表示不限制minio:endpoint: http://172.16.3.195:9000accessKey: adminsecretKey: minioadminbucketName: vipsoft-devminioadminMinioConfig.java
package com.vipsoft.oss.config;import io.minio.MinioClient;import org.springframework.boot.context.properties.ConfigurationProperties;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;@Configuration@ConfigurationProperties(prefix = "minio")public class MinioConfig { /** * 服务地址：http://172.16.3.195:9000 */ private String endpoint; /** * 用户名 */ private String accessKey; /** * 密码 */ private String secretKey; /** * 存储桶名称 */ private String bucketName; @Bean public MinioClient getMinioClient() { MinioClient minioClient = MinioClient.builder().endpoint(endpoint) .credentials(accessKey, secretKey) .build(); return minioClient; } //todo 省去 getter & setter}工具类
MinioUtil.java
package com.vipsoft.oss.util;import cn.hutool.core.io.IoUtil;import com.cuwor.oss.config.MinioConfig;import io.minio.*;import io.minio.MinioClient;import io.minio.http.Method;import io.minio.messages.Bucket;import io.minio.messages.DeleteError;import io.minio.messages.DeleteObject;import io.minio.messages.Item;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Component;import org.springframework.web.multipart.MultipartFile;import javax.servlet.ServletOutputStream;import javax.servlet.http.HttpServletResponse;import java.io.InputStream;import java.net.URLEncoder;import java.util.ArrayList;import java.util.List;import java.util.concurrent.TimeUnit;@Componentpublic class MinioUtil { @Autowired private MinioClient minioClient; @Autowired private MinioConfig minioConfig; private static final int DEFAULT_EXPIRY_TIME = 7 * 24 * 3600; /** * 判断bucket是否存在 */ public boolean bucketExists(String bucketName) { boolean exists; try { exists = minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build()); } catch (Exception e) { e.printStackTrace(); exists = false; } return exists; } /** * 创建存储桶，存在则不创建 */ public boolean makeBucket(String bucketName) { boolean exists; try { exists = bucketExists(bucketName); if (!exists) { minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build()); exists = true; } } catch (Exception e) { e.printStackTrace(); exists = false; } return exists; } /** * 删除存储桶 -- 有文件，不让删除 * * @param bucketName 存储桶名称 * @return boolean */ public boolean removeBucket(String bucketName) { try { boolean flag = bucketExists(bucketName); if (flag) { Iterable<Result<Item>> myObjects = listObjects(bucketName); for (Result<Item> result : myObjects) { Item item = result.get(); // 有对象文件，则删除失败 if (item.size() > 0) { return false; } } // 删除存储桶，注意，只有存储桶为空时才能删除成功。 minioClient.removeBucket(RemoveBucketArgs.builder().bucket(bucketName).build()); flag = bucketExists(bucketName); if (!flag) { return true; } } return false; } catch (Exception e) { e.printStackTrace(); return false; } } /** * 列出存储桶中的所有对象 * * @param bucketName 存储桶名称 * @return Iterable<Result < Item>> */ public Iterable<Result<Item>> listObjects(String bucketName) { boolean flag = bucketExists(bucketName); if (flag) { return minioClient.listObjects(ListObjectsArgs.builder().bucket(bucketName).build()); } return null; } /** * 列出所有存储桶名称 * * @return List<String> */ public List<String> listBucketNames() { List<String> bucketListName = new ArrayList<>(); try { List<Bucket> bucketList = minioClient.listBuckets(); for (Bucket bucket : bucketList) { bucketListName.add(bucket.name()); } } catch (Exception e) { e.printStackTrace(); } return bucketListName; } /** * 列出存储桶中的所有对象名称 * * @param bucketName 存储桶名称 * @return List<String> */ public List<String> listObjectNames(String bucketName) { List<String> listObjectNames = new ArrayList<>(); try { boolean flag = bucketExists(bucketName); if (flag) { Iterable<Result<Item>> myObjects = listObjects(bucketName); for (Result<Item> result : myObjects) { Item item = result.get(); listObjectNames.add(item.objectName()); } } } catch (Exception e) { e.printStackTrace(); } return listObjectNames; } /** * 获取对象的元数据 * * @param objectName 存储桶里的对象名称 * @return */ public StatObjectResponse statObject(String objectName) { StatObjectResponse statObject = null; try { statObject = minioClient.statObject(StatObjectArgs.builder().bucket(minioConfig.getBucketName()).object(objectName).build()); } catch (Exception e) { e.printStackTrace(); } return statObject; } //region 上传文件 /** * 上传文件 * * @param file 文件 * @param objectName 文件名称 */ public boolean uploadObject(MultipartFile file, String objectName) { // 使用putObject上传一个文件到存储桶中。 try { InputStream inputStream = file.getInputStream(); minioClient.putObject(PutObjectArgs.builder() .bucket(minioConfig.getBucketName()) .object(objectName) .stream(inputStream, file.getSize(), -1) .contentType(file.getContentType()) .build()); IoUtil.close(inputStream);// return StrUtil.format("{}/{}/{}", minioConfig.getEndpoint(), minioConfig.getBucketName(), objectName); return true; } catch (Exception e) { e.printStackTrace(); } return false; } /** * 通过InputStream上传对象 * * @param objectName存储桶里的对象名称 * @param inputStream 要上传的流 * @param contentType 上传的文件类型 例如 video/mp4image/jpg * @return boolean */ public boolean uploadObject(InputStream inputStream, String objectName, String contentType) { try { minioClient.putObject(PutObjectArgs.builder().bucket(minioConfig.getBucketName()).object(objectName).stream( //不清楚文件的大小时，可以传-1，10485760。如果知道大小也可以传入size，partsize。 inputStream, -1, 10485760) .contentType(contentType) .build()); IoUtil.close(inputStream); StatObjectResponse statObject = statObject(objectName); if (statObject != null && statObject.size() > 0) { return true; } } catch (Exception e) { e.printStackTrace(); } return false; } /** * 通过文件上传到对象 * * @param objectName 存储桶里的对象名称 * @param fileName File name * @return boolean */ public boolean uploadObject(String objectName, String fileName) { try { minioClient.uploadObject(UploadObjectArgs.builder() .bucket(minioConfig.getBucketName()) .object(objectName) .filename(fileName) .build()); StatObjectResponse statObject = statObject(objectName); if (statObject != null && statObject.size() > 0) { return true; } } catch (Exception e) { e.printStackTrace(); } return false; } //endregion /** * 获取文件访问地址 * * @param fileName 文件名称 */ public String getPresignedObjectUrl(String fileName) { try { return minioClient.getPresignedObjectUrl(GetPresignedObjectUrlArgs.builder() .method(Method.GET) .bucket(minioConfig.getBucketName()) .object(fileName) .build() ); } catch (Exception e) { e.printStackTrace(); } return null; } public String getObjectUrl(String objectName) { String url = ""; try { url = minioClient.getPresignedObjectUrl(GetPresignedObjectUrlArgs.builder() .method(Method.GET) .bucket(minioConfig.getBucketName()) .object(objectName) .build()); } catch (Exception e) { e.printStackTrace(); } return url; } /** * 生成一个给HTTP GET请求用的presigned URL。 * 浏览器/移动端的客户端可以用这个URL进行下载，即使其所在的存储桶是私有的。这个presigned URL可以设置一个失效时间，默认值是7天。 * * @param objectName 存储桶里的对象名称 * @param expires 失效时间（以小时单位），默认是7天，不得大于七天 * @return */ public String getObjectUrl(String objectName, Integer expires) { String url = ""; try { if (expires < 1 || expires > DEFAULT_EXPIRY_TIME) { throw new Exception("Expires must be in range of 1 to " + DEFAULT_EXPIRY_TIME); } url = minioClient.getPresignedObjectUrl(GetPresignedObjectUrlArgs.builder() .method(Method.GET) .bucket(minioConfig.getBucketName()) .object(objectName) .expiry(expires, TimeUnit.HOURS)//动态参数 // .expiry(24 * 60 * 60)//用秒来计算一天时间有效期 // .expiry(1, TimeUnit.DAYS)//按天传参 // .expiry(1, TimeUnit.HOURS)//按小时传参数 .build()); } catch (Exception e) { e.printStackTrace(); } return url; } /** * 下载文件，通过 HttpServletResponse 返回 * * @param objectName 存储桶里的对象名称 */ public void downloadObject(HttpServletResponse response, String objectName) { try { InputStream file = minioClient.getObject(GetObjectArgs.builder() .bucket(minioConfig.getBucketName()) .object(objectName) .build()); response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(objectName, "UTF-8")); ServletOutputStream servletOutputStream = response.getOutputStream(); int len; byte[] buffer = new byte; while ((len = file.read(buffer)) > 0) { servletOutputStream.write(buffer, 0, len); } servletOutputStream.flush(); file.close(); servletOutputStream.close(); } catch (Exception e) { e.printStackTrace(); } } /** * 下载并将文件保存到本地 * * @param objectName 存储桶里的对象名称 * @param fileName 下载保存的文件名 * @return boolean */ public boolean downloadObject(String objectName, String fileName) { try { StatObjectResponse statObject = statObject(objectName); if (statObject != null && statObject.size() > 0) { minioClient.downloadObject(DownloadObjectArgs.builder() .bucket(minioConfig.getBucketName()) .object(objectName) .filename(fileName) .build()); return true; } } catch (Exception e) { e.printStackTrace(); } return false; } /** * 以流的形式获取一个文件对象 * * @param bucketName 存储桶名称 * @param objectName 存储桶里的对象名称 * @return InputStream */ public InputStream getObject(String bucketName, String objectName) { try { StatObjectResponse statObject = statObject(objectName); if (statObject != null && statObject.size() > 0) { InputStream stream = minioClient.getObject(GetObjectArgs.builder() .bucket(bucketName) .object(objectName) .build()); return stream; } } catch (Exception e) { e.printStackTrace(); } return null; } /** * 以流的形式获取一个文件对象（断点下载） * * @param bucketName 存储桶名称 * @param objectName 存储桶里的对象名称 * @param offset 起始字节的位置 * @param length 要读取的长度 (可选，如果无值则代表读到文件结尾) * @return InputStream */ public InputStream getObject(String bucketName, String objectName, long offset, Long length) { try { StatObjectResponse statObject = statObject(objectName); if (statObject != null && statObject.size() > 0) { InputStream stream = minioClient.getObject(GetObjectArgs.builder() .bucket(bucketName) .object(objectName) .offset(1024L) .length(4096L) .build()); return stream; } } catch (Exception e) { e.printStackTrace(); } return null; } /** * 删除一个对象 * * @param objectName 存储桶里的对象名称 */ public boolean removeObject(String objectName) { try { minioClient.removeObject(RemoveObjectArgs.builder().bucket(minioConfig.getBucketName()).object(objectName).build()); return true; } catch (Exception e) { e.printStackTrace(); } return false; } /** * 删除指定桶的多个文件对象,返回删除错误的对象列表，全部删除成功，返回空列表 * * @param bucketName存储桶名称 * @param objectNames 含有要删除的多个object名称的迭代器对象 eg: * List<DeleteObject> objects = new LinkedList<>(); * objects.add(new DeleteObject("my-objectname1")); * objects.add(new DeleteObject("my-objectname2")); * objects.add(new DeleteObject("my-objectname3")); * @return 如果有值，说明当前文件删除失败 */ public List<String> removeObjects(String bucketName, List<DeleteObject> objectNames) { List<String> deleteErrorNames = new ArrayList<>(); try { Iterable<Result<DeleteError>> results = minioClient.removeObjects(RemoveObjectsArgs.builder().bucket(bucketName).objects(objectNames).build()); for (Result<DeleteError> result : results) { DeleteError error = result.get(); deleteErrorNames.add(error.objectName()); } } catch (Exception e) { e.printStackTrace(); } return deleteErrorNames; }}测试
package com.vipsoft.admin;import cn.hutool.core.util.StrUtil;import com.cuwor.oss.util.MinioUtil;import org.junit.jupiter.api.Test;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.test.context.SpringBootTest;import org.springframework.util.Assert;@SpringBootTestpublic class MinioTest { Logger logger = LoggerFactory.getLogger(this.getClass()); @Autowired private MinioUtil minioUtil; @Test void makeBucketTest() { boolean flag = minioUtil.makeBucket("public"); Assert.isTrue(flag, "查询异常"); } @Test void uploadObjectTest() { boolean flag = minioUtil.uploadObject("/avatar/123.png", "D:\\Users\\Pictures\\R-C.png"); Assert.isTrue(flag, "上传异常"); } @Test void getObjectUrlTest() { String objectName="/avatar/123.png"; String url = minioUtil.getObjectUrl(objectName); logger.info("url:{}", url); url = minioUtil.getObjectUrl(objectName, 3); logger.info("expires url:{}", url); Assert.isTrue(StrUtil.isNotEmpty(url), "上传异常"); }}
链接永不过期
在MinIO网页控制台上创建的桶(Buckets)权限默认都是私有桶，无论是通过网页控制台获取到的分享路径，还是通过API获取到的文件访问地址，地址后都是带参数和签名的，访问地址最长的有效时间为7天，有时候，我们期望文件的这个访问地址是永久有效的。
http://172.16.3.195:9000/public/avatar.png
将Buckets访问权限修改为public公有桶，上传文件，然后直接通过：ip地址+端口+桶名+文件名访问
再次访问
http://172.16.3.195:9000/public/avatar.png
页:
[1]