Minio——docker

• MinIO 是在 Apache License v2.0 下发布的对象存储服务器。 它与 Amazon S3 云存储服务兼容。 它最适合存储非结构化数据&＃xff0c;如照片&＃xff0c;视频&＃xff0c;日志文件&＃xff0c;备份和容器/ VM 映像。 对象的大小可以从几 KB 到最大 5TB。
• MinIO 服务器足够轻&＃xff0c;可以与应用程序堆栈捆绑在一起&＃xff0c;类似于 NodeJS&＃xff0c;Redis 和 MySQL
• 一种高性能的分布式对象存储服务器&＃xff0c;用于大型数据基础设施。它是机器学习和其他大数据工作负载下Hadoop HDFS 的理想 s3 兼容替代品

docker pull minio/minio:RELEASE.2021-04-18T19-26-29Z

运行MinIO 自定义 Access&＃xff08;至少三位&＃xff09; 和 Secret &＃xff08;至少8位&＃xff09;密钥要覆盖 MinIO 的自动生成的密钥&＃xff0c;将 Access 和 Secret 密钥设为环境变量。MinIO 允许常规字符串作为 Access 和 Secret 密钥

docker run -p 9000:9000 --name&＃61;cg_minio -d --restart&＃61;always -e "MINIO_ACCESS_KEY&＃61;cgadmin" -e "MINIO_SECRET_KEY&＃61;cgadmin2022" -v /root/minio/data:/data -v /root/minio/config:/root/.minio minio/minio:RELEASE.2021-04-18T19-26-29Z server /data

登录&＃xff1a;

http://192.168.220.130:9000

导入依赖

io.miniominio8.0.3

修改配置文件

spring:# 配置文件上传大小限制servlet:multipart:max-file-size: 200MBmax-request-size: 200MB
minio:endpoint: http://192.168.220.110:9000accessKey: cgadminsecretKey: cgadmin2022secure: falseimgSize: 1024 # 图片大小限制&＃xff0c;单位&＃xff1a;mfileSize: 1024 # 文件大小限制&＃xff0c;单位&＃xff1a;mshareBucketName: pet-photo-bucketvideoShareBucketName: pet-video-bucket# 雪花算法配置
code:worker_id: 2datacenter_id: 22
配置实体类

&＃64;Component
&＃64;ConfigurationProperties(prefix &＃61; "minio")
&＃64;Data
public class MinioProperties{/*** 是否开启*/private Boolean enabled;/*** 存储对象服务器类型*/private OssType type;/*** OSS 访问端点&＃xff0c;集群时需提供统一入口*/private String endpoint;/*** 用户名*/private String accessKey;/*** 密码*/private String secretKey;}

存储对象服务器枚举

&＃64;Getter
&＃64;AllArgsConstructor
public enum OssType {/*** Minio 对象存储*/MINIO("minio", 1),/*** 华为 OBS*/OBS("obs", 2),/*** 腾讯 COS*/COS("tencent", 3),/*** 阿里巴巴 SSO*/ALIBABA("alibaba", 4),;/*** 名称*/final String name;/*** 类型*/final int type;
}

配置类

&＃64;Configuration(proxyBeanMethods &＃61; false)
&＃64;ConditionalOnClass({MinioClient.class})
&＃64;EnableConfigurationProperties({MinioProperties.class, CodeProperties.class})
&＃64;ConditionalOnExpression("${minio.enabled}")
&＃64;ConditionalOnProperty(value &＃61; "minio.type", havingValue &＃61; "minio")
public class MinioConfiguration {&＃64;Bean&＃64;SneakyThrows&＃64;ConditionalOnMissingBean(MinioClient.class)public MinioClient minioClient(MinioProperties minioProperties) {return MinioClient.builder().endpoint(minioProperties.getEndpoint()).credentials(minioProperties.getAccessKey(), minioProperties.getSecretKey()).build();}&＃64;Bean&＃64;ConditionalOnBean({MinioClient.class})&＃64;ConditionalOnMissingBean(MinioUtil.class)public MinioUtil minioUtil(MinioClient minioClient, MinioProperties minioProperties, CodeProperties codeProperties) {return new MinioUtil(minioClient, minioProperties,codeProperties);}}
工具类

&＃64;Slf4j
&＃64;AllArgsConstructor
public class MinioUtil {/*** MinIO 客户端*/private MinioClient minioClient;/*** MinIO 配置类*/private MinioProperties minioProperties;/*** 订单号*/private CodeProperties codeProperties;/*** 查询所有存储桶** &＃64;return Bucket 集合*/&＃64;SneakyThrowspublic List listBuckets() {return minioClient.listBuckets();}/*** 桶是否存在** &＃64;param bucketName 桶名* &＃64;return 是否存在*/&＃64;SneakyThrowspublic boolean bucketExists(String bucketName) {return minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());}/*** 创建存储桶** &＃64;param bucketName 桶名*/&＃64;SneakyThrowspublic void makeBucket(String bucketName) {if (!bucketExists(bucketName)) {minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());}}/*** 删除一个空桶 如果存储桶存在对象不为空时&＃xff0c;删除会报错。** &＃64;param bucketName 桶名*/&＃64;SneakyThrowspublic void removeBucket(String bucketName) {minioClient.removeBucket(RemoveBucketArgs.builder().bucket(bucketName).build());}/*** description: 上传文件** &＃64;author: CG* &＃64;date: 2022/4/20* &＃64;params:* &＃64;Param multipartFile:* &＃64;Param bucketName:* &＃64;return:* &＃64;return: java.lang.String*/&＃64;SneakyThrowspublic String pullObject(MultipartFile multipartFile, String bucketName) {String fileExt &＃61; FileUtil.extName(multipartFile.getOriginalFilename());String uuidFileName &＃61; generateOssUuidFileName(fileExt);InputStream inputStream &＃61; multipartFile.getInputStream();String fileType &＃61; multipartFile.getContentType();System.out.println(fileExt &＃43; "--" &＃43; fileType);try {Assert.isTrue(bucketExists(bucketName), "桶不存在");minioClient.putObject(PutObjectArgs.builder().bucket(bucketName).object(uuidFileName).stream(inputStream, inputStream.available(), -1).contentType(fileType).build());return StrUtil.SLASH &＃43; bucketName &＃43; StrUtil.SLASH &＃43; uuidFileName;} finally {inputStream.close();}}/*** 返回临时带签名、过期时间一天、Get请求方式的访问URL** &＃64;param bucketName 桶名* &＃64;param ossFilePath Oss文件路径* &＃64;return*/&＃64;SneakyThrowspublic String getPresignedObjectUrl(String bucketName, String ossFilePath) {return minioClient.getPresignedObjectUrl(GetPresignedObjectUrlArgs.builder().method(Method.GET).bucket(bucketName).object(ossFilePath).expiry(60 * 60 * 24).build());}/*** GetObject接口用于获取某个文件&＃xff08;Object&＃xff09;。此操作需要对此Object具有读权限。** &＃64;param bucketName 桶名* &＃64;param ossFilePath Oss文件路径*/&＃64;SneakyThrowspublic InputStream getObject(String bucketName, String ossFilePath) {return minioClient.getObject(GetObjectArgs.builder().bucket(bucketName).object(ossFilePath).build());}/*** 查询桶的对象信息** &＃64;param bucketName 桶名* &＃64;param recursive 是否递归查询* &＃64;return*/&＃64;SneakyThrowspublic Iterable> listObjects(String bucketName, boolean recursive) {return minioClient.listObjects(ListObjectsArgs.builder().bucket(bucketName).recursive(recursive).build());}/*** 生成随机文件名&＃xff0c;防止重复** &＃64;return*/public String generateOssUuidFileName(String fileExt) {Snowflake snowflake &＃61; IdUtil.getSnowflake(codeProperties.getWorkerId(), codeProperties.getDatacenterId());String resourceCodeNum &＃61; snowflake.nextIdStr();returnDateUtil.format(new Date(), "yyyy/MM/dd") &＃43;StrUtil.SLASH &＃43;resourceCodeNum &＃43;StrUtil.C_DOT &＃43;fileExt;}/*** 获取带签名的临时上传元数据对象&＃xff0c;前端可获取后&＃xff0c;直接上传到Minio** &＃64;param bucketName* &＃64;param fileName* &＃64;return*/&＃64;SneakyThrowspublic Map getPresignedPostFormData(String bucketName, String fileName) {// 为存储桶创建一个上传策略&＃xff0c;过期时间为7天PostPolicy policy &＃61; new PostPolicy(bucketName, ZonedDateTime.now().plusDays(7));// 设置一个参数key&＃xff0c;值为上传对象的名称policy.addEqualsCondition("key", fileName);// 添加Content-Type以"image/"开头&＃xff0c;表示只能上传照片policy.addStartsWithCondition("Content-Type", "image/");// 设置上传文件的大小 64kiB to 10MiB.policy.addContentLengthRangeCondition(64 * 1024, 10 * 1024 * 1024);return minioClient.getPresignedPostFormData(policy);}}
service

public void upResource(String resourceDescribe, MultipartFile multipartFile, String bucketName) {String resourcePath &＃61; minioUtil.pullObject(multipartFile, bucketName);Assert.notEmpty(resourcePath, "资源上传失败");}
controller

&＃64;PostMapping(value &＃61; "{bucket-name}", headers &＃61; "content-type&＃61;multipart/form-data")&＃64;ApiOperation(value &＃61; "资源上传", response &＃61; ResultDTO.class)&＃64;ApiImplicitParams({&＃64;ApiImplicitParam(value &＃61; "资源描述", name &＃61; "resourceDescribe", required &＃61; true, paramType &＃61; "query", dataType &＃61; "String"),&＃64;ApiImplicitParam(value &＃61; "minio桶名称", name &＃61; "bucket-name", required &＃61; true, paramType &＃61; "path", dataType &＃61; "String"),})public ResultDTO resourceUp(&＃64;NotNull String resourceDescribe, &＃64;NotNull &＃64;ApiParam(name &＃61; "multipartFile", value &＃61; "资源文件", required &＃61; true) MultipartFile multipartFile, &＃64;PathVariable("bucket-name") &＃64;NotNull String bucketName) {service.upResource(resourceDescribe, multipartFile, bucketName);return ResultDTO.success();}