/** * BladeX Commercial License Agreement * Copyright (c) 2018-2099, https://bladex.cn. All rights reserved. *

* Use of this software is governed by the Commercial License Agreement * obtained after purchasing a license from BladeX. *

* 1. This software is for development use only under a valid license * from BladeX. *

* 2. Redistribution of this software's source code to any third party * without a commercial license is strictly prohibited. *

* 3. Licensees may copyright their own code but cannot use segments * from this software for such purposes. Copyright of this software * remains with BladeX. *

* Using this software signifies agreement to this License, and the software * must not be used for illegal purposes. *

* THIS SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY. The author is * not liable for any claims arising from secondary or illegal development. *

* Author: Chill Zhuang (bladejava@qq.com) */ package org.springblade.resource.rule.oss; import io.minio.MinioClient; import org.springblade.core.literule.annotation.LiteRuleComponent; import org.springblade.core.literule.core.RuleComponent; import org.springblade.core.oss.MinioTemplate; import org.springblade.core.oss.OssTemplate; import org.springblade.core.oss.props.OssProperties; import org.springblade.core.oss.rule.OssRule; import org.springblade.resource.pojo.entity.Oss; import org.springblade.resource.rule.context.OssContext; import static org.springblade.resource.rule.constant.OssRuleConstant.MINIO_RULE; /** * Minio云存储构建类 * * @author Chill */ @LiteRuleComponent(id = MINIO_RULE, name = "minioOSS构建") public class MinioRule extends RuleComponent { @Override public void process() { // 获取上下文 OssContext contextBean = this.getContextBean(OssContext.class); Oss oss = contextBean.getOss(); OssRule ossRule = contextBean.getOssRule(); // 创建配置类 OssProperties ossProperties = new OssProperties(); ossProperties.setEndpoint(oss.getEndpoint()); ossProperties.setTransformEndpoint(oss.getTransformEndpoint()); ossProperties.setAccessKey(oss.getAccessKey()); ossProperties.setSecretKey(oss.getSecretKey()); ossProperties.setBucketName(oss.getBucketName()); // 创建客户端 MinioClient minioClient = MinioClient.builder() .endpoint(oss.getEndpoint()) .credentials(oss.getAccessKey(), oss.getSecretKey()) .build(); OssTemplate ossTemplate = new MinioTemplate(minioClient, ossRule, ossProperties); // 设置上下文 contextBean.setOssTemplate(ossTemplate); } }