我是靠谱客的博主 冷静自行车,最近开发中收集的这篇文章主要介绍Spring Boot 整合 AliCloud OSS(对象存储服务)OSS 入口Java Code(例)AliCloud OSS属性配置类隐藏阿里云的url地址,觉得挺不错的,现在分享给大家,希望可以做个参考。
概述
OSS 入口
进入(开通)OSS
管理控制台界面
创建Bucket
- bucket:存储空间名称,名字只能是字母、数字、中划线
- 区域:即服务器的地址,这里选择了离我们最近的深圳
- Endpoint:选中区域后,会自动生成一个Endpoint地址,这将是我们访问OSS服务的域名的组成部分
- 存储类型:默认
- 读写权限:这里我们选择公共读,否则每次访问都需要额外生成签名并校验,比较麻烦。敏感数据设置为私有即可!
- 日志:不开通
设置跨域访问
创建AccessKey
添加用户对OSS的控制权限
Java Code(例)
Controller
/**
* 获取阿里的OSS签名
* Map<String,Object>: 这里存储了所有签名信息
*/
@GetMapping("/signature")
public ResponseEntity<Map<String,Object>> ossSignature(){
Map<String,Object> resultMap = uploadService.ossSignature();
return ResponseEntity.ok(resultMap);
}
引入SDK依赖
<dependency>
<groupId>com.aliyun.oss</groupId>
<artifactId>aliyun-sdk-oss</artifactId>
<version>3.4.2</version>
<scope>compile</scope>
</dependency>
Nacos中配置OSS
alicloud:
oss:
accessKeyId:
accessKeySecret:
host: # 访问oss的域名,很重要bucket + endpoint
endpoint: # 你的服务的端点,不一定跟我一样
dir: "" # 保存到bucket的某个子目录
expireTime: 20 # 过期时间,单位是S
maxFileSize: 5242880 #文件大小限制,这里是5M
AliCloud OSS属性配置类
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;
/**
* 读取OSS配置类
*/
@Data
@Component
@ConfigurationProperties(prefix = "alicloud.oss") // prefix: 配置前缀
public class OSSProperties {
private String accessKeyId;
private String accessKeySecret;
private String host;
private String endpoint;
private String dir;
private Long expireTime;
private Long maxFileSize;
}
生成签名客户端
import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class OSSConfig {
/**
* @Bean 注解表示把当前方法的返回值对象放入到IOC容器中
* 如果当前方法有参数,spring会在IOC容器中寻找同类型的对象给其传参
* 如果找到了多个,可以通过@Qualifier("name")注解按照名称找对象给其传参
* @param prop
* @return
*/
@Bean
public OSS client(OSSProperties prop){
return new OSSClientBuilder()
.build(prop.getEndpoint(), prop.getAccessKeyId(), prop.getAccessKeySecret());
}
}
ServiceImpl
import com.aliyun.oss.OSS;
import com.aliyun.oss.common.utils.BinaryUtil;
import com.aliyun.oss.model.MatchMode;
import com.aliyun.oss.model.PolicyConditions;
import com.meng.common.constants.MxConstants;
import com.meng.common.exception.pojo.ExceptionEnum;
import com.meng.common.exception.pojo.MxException;
import com.meng.upload.config.OSSProperties;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;
import javax.imageio.ImageIO;
import javax.validation.Valid;
import java.awt.image.BufferedImage;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.util.Date;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.UUID;
/**
* 上传Service
*/
@Service
public class UploadService {
@Autowired
private OSSProperties ossProps;
@Autowired
private OSS ossClient;
public String uploadImage(MultipartFile file) {
try {
//判断文件流是否为空
InputStream inputStream = file.getInputStream();
//判断是否为图片流
BufferedImage image = ImageIO.read(inputStream);
if(image==null){
throw new MxException(ExceptionEnum.INVALID_FILE_TYPE);
}
//1.生成uuid的随机文件名称
//1.1 生成uuid
String uuid = UUID.randomUUID().toString();
//1.2 获取文件原名
String oldName = file.getOriginalFilename();
//1.3 获取文件后缀
String extName = oldName.substring(oldName.lastIndexOf("."));
//1.4 最终的文件名称
String fileName = uuid + extName;
//2.把文件保存到nginx图片服务器
file.transferTo(new File(MxConstants.IMAGE_PATH,fileName));
//3.返回图片的访问路径
return MxConstants.IMAGE_URL+fileName;
} catch (IOException e) {
e.printStackTrace();
throw new MxException(ExceptionEnum.FILE_UPLOAD_ERROR);
}
}
public Map<String,Object> ossSignature() {
try {
long expireTime = ossProps.getExpireTime();
long expireEndTime = System.currentTimeMillis() + expireTime * 1000;
Date expiration = new Date(expireEndTime);
// PostObject请求最大可支持的文件大小为5 GB,即CONTENT_LENGTH_RANGE为5*1024*1024*1024。
PolicyConditions policyConds = new PolicyConditions();
policyConds.addConditionItem(PolicyConditions.COND_CONTENT_LENGTH_RANGE, 0, ossProps.getMaxFileSize());
policyConds.addConditionItem(MatchMode.StartWith, PolicyConditions.COND_KEY, ossProps.getDir());
String postPolicy = ossClient.generatePostPolicy(expiration, policyConds);
byte[] binaryData = postPolicy.getBytes("utf-8");
String encodedPolicy = BinaryUtil.toBase64String(binaryData);
String postSignature = ossClient.calculatePostSignature(postPolicy);
Map<String, Object> respMap = new LinkedHashMap<String, Object>();
respMap.put("accessId", ossProps.getAccessKeyId());//修改名称和前端对应
respMap.put("policy", encodedPolicy);
respMap.put("signature", postSignature);
respMap.put("dir", ossProps.getDir());
respMap.put("host", ossProps.getHost());
respMap.put("expire", String.valueOf(expireEndTime)); //修改超时时间单位和前端对应
return respMap;
} catch (Exception e) {
// Assert.fail(e.getMessage());
System.out.println(e.getMessage());
throw new MxException(ExceptionEnum.INVALID_NOTIFY_SIGN);
} finally {
ossClient.shutdown();
}
}
}
隐藏阿里云的url地址
在刚才的业务中,我们直接把我们在阿里的域名对外暴露了,如果要隐藏域名信息,我们可以使用一个自定义域名。
另外,最好保持与我们自己的域名一致,我们可以使用:http://meng.xin.com
,然后使用nginx反向代理,最终再指向阿里服务器域名。
首先,修改服务器端返回的请求域名,修改微服务中的属性配置文件
alicloud:
oss:
host: http://meng.xin.com
在nginx中设置反向代理
server {
listen 80;
server_name meng.xin.com;
location / {
proxy_pass http://meng-xin-server.oss-cn-aiqinhai.aliyuncs.com; # 微服务名称.endpoint
}
}
最后
以上就是冷静自行车为你收集整理的Spring Boot 整合 AliCloud OSS(对象存储服务)OSS 入口Java Code(例)AliCloud OSS属性配置类隐藏阿里云的url地址的全部内容,希望文章能够帮你解决Spring Boot 整合 AliCloud OSS(对象存储服务)OSS 入口Java Code(例)AliCloud OSS属性配置类隐藏阿里云的url地址所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。
本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
发表评论 取消回复