结合之前学习一个开源项目的时候,重新写一下关于oss的文章(修改api使用及开通流程部分)
使用oss作为文件存储
关于oss作为文件存储的一个叙述
- 文件上传在系统中用的很频繁,所以我们需要将上传的文件进行存储,传统的将文件上传到本机已不适用分布式系统。自己搭建文件服务器有复杂性和维护成本。所以我们可以采用市面上成熟的文件存储服务,如阿里云的OSS对象存储服务
- 每个 OSS 的用户都会用到上传服务。Web 端常见的上传方法是用户在浏览器或 APP 端上传文件到应用服务器,应用服务器再把文件上传到 OSS。具体流程如下图所示。

- 上传慢:用户数据需先上传到应用服务器,之后再上传到OSS。网络传输时间比直传到OSS多一倍。如果用户数据不通过应用服务器中转,而是直传到OSS,速度将大有提升。而且OSS采用BGP带宽,能保证各地各运营商之间的传输速度。 
- 扩展性差:如果后续用户多了,应用服务器会成为瓶颈。 
- 费用高:需要准备多台应用服务器。由于OSS上传流量是免费的,如果数据直传到OSS,不通过应用服务器,可以省下几台应用服务器 
服务端签名后直传
| 12
 
 | 采用JavaScript客户端直接签名时,AccessKeyID和AcessKeySecret会暴露在前端页面,因此存在严重的安全隐患。因此,OSS提供了服务端签名后直传的方案。
 
 | 
原理介绍

服务端签名后直传的原理如下:
- 用户发送上传Policy请求到应用服务器。
- 应用服务器返回上传Policy和签名给用户。
- 用户直接上传数据到OSS。
具体步骤
开通阿里云OSS

 
 
关于bucket有三个点需要注意下
存储类型
标准存储(Standard)
| 1
 | 各种社交、分享类的图片、音视频应用、大型网站、大数据分析等业务场景。例如程序下载、移动应用等。
 | 
低频访问(Infrequent Access)
| 12
 3
 
 | 各种社交、分享类的图片、音视频应用、大型网站、大数据分析等,且对持久性和可用性有更高要求的业务场景。例如企业重要文件、敏感信息等。较低访问频率(平均每月访问频率1到2次)的业务场景。例如热备数据、监控视频数据等。
 较低访问频率(平均每月访问频率1到2次),且对持久性和可用性有更高要求的业务场景。例如企业业务数据、近期的医疗档案等。
 
 | 
归档存储
| 12
 
 | 数据长期保存的业务场景。例如档案数据、医疗影像、科学资料、影视素材等需要超长时间存放的极冷数据。例如因合规要求需要长期留存的数据、大数据及人工智能领域长期积累的原始数据、影视行业长期留存的媒体资源、在线教育行业的归档视频等。
 
 | 
关于存储类型,具体可以查看官网
同城冗余存储
可以提高更高的容灾能力
但是,OSS 同城区域冗余存储属性开启后,将不支持关闭,且该bucket内的文件无法转为归档类型,请谨慎操作。
版本控制
当开启版本控制功能,数据删除或被覆盖后将可以找回
配置RAM
创建用户,分配权限
进入ram访问控制页面
分配 管理对象存储服务(OSS)权限

获取accesskey id和secret

配置跨域
 
 
使用OSS SDK
| 12
 3
 4
 5
 
 | <dependency><groupId>com.aliyun.oss</groupId>
 <artifactId>aliyun-sdk-oss</artifactId>
 <version>3.8.0</version>
 </dependency>
 
 | 
| 12
 3
 4
 5
 6
 7
 8
 9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 
 | String endpoint = "http://oss-cn-beijing.aliyuncs.com";
 
 String accessKeyId = "LTAI4G3KxBJ26EUbWsenmqhP";
 String accessKeySecret = "RHtADVlvlKJvVBQnFNNvnne9p4NwnA";
 String bucketName = "passjava";
 
 
 String localFile = "C:\\Users\\Administrator\\Pictures\\coding_java.png";
 String fileKeyName = "coding_java.png";
 
 OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
 
 InputStream inputStream = new FileInputStream(localFile);
 ossClient.putObject(bucketName, fileKeyName, inputStream);
 
 
 ossClient.shutdown();
 
 | 
整合Spring Cloud Alicloud OSS(这个包19年之后就不再更新了,现不推荐使用)
| 12
 3
 4
 
 | <dependency><groupId>com.alibaba.cloud</groupId>
 <artifactId>spring-cloud-starter-alicloud-oss</artifactId>
 </dependency>
 
 | 
| 12
 3
 4
 5
 6
 7
 8
 9
 10
 11
 12
 13
 14
 15
 16
 17
 
 | spring:cloud:
 nacos:
 discovery:
 server-addr: 127.0.0.1:8848
 alicloud:
 access-key: xxx
 secret-key: xxx
 oss:
 endpoint: oss-cn-beijing.aliyuncs.com
 bucket: xxx
 
 application:
 name: behappy-third-party
 
 server:
 port: 30000
 
 | 

| 12
 3
 4
 5
 6
 
 | spring.application.name=behappy-third-partyspring.cloud.nacos.config.server-addr=127.0.0.1:8848
 spring.cloud.nacos.config.namespace=4380e303-f736-4fe8-99e9-b5e842506888
 spring.cloud.nacos.config.ext-config[0].data-id=oss.yml
 spring.cloud.nacos.config.ext-config[0].group=DEFAULT_GROUP
 spring.cloud.nacos.config.ext-config[0].refresh=true
 
 | 
| 12
 3
 4
 5
 6
 7
 8
 9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 27
 28
 29
 30
 31
 32
 33
 34
 35
 36
 37
 38
 39
 40
 41
 42
 43
 44
 45
 46
 47
 48
 49
 50
 51
 52
 53
 54
 55
 56
 57
 58
 59
 60
 
 | [@RestController](https:public class OssController {
 
 @Autowired
 OSS ossClient;
 
 @Value("${spring.cloud.alicloud.oss.endpoint}")
 private String endpoint;
 @Value("${spring.cloud.alicloud.oss.bucket}")
 private String bucket;
 
 @Value("${spring.cloud.alicloud.access-key}")
 private String accessId;
 
 
 @RequestMapping("/oss/policy")
 public R policy() {
 
 
 
 
 
 String host = "https://" + bucket + "." + endpoint;
 
 
 String format = new SimpleDateFormat("yyyy-MM-dd").format(new Date());
 String dir = format + "/";
 
 Map<String, String> respMap = null;
 try {
 long expireTime = 30;
 long expireEndTime = System.currentTimeMillis() + expireTime * 1000;
 Date expiration = new Date(expireEndTime);
 PolicyConditions policyConds = new PolicyConditions();
 policyConds.addConditionItem(PolicyConditions.COND_CONTENT_LENGTH_RANGE, 0, 1048576000);
 policyConds.addConditionItem(MatchMode.StartWith, PolicyConditions.COND_KEY, dir);
 
 String postPolicy = ossClient.generatePostPolicy(expiration, policyConds);
 byte[] binaryData = postPolicy.getBytes("utf-8");
 String encodedPolicy = BinaryUtil.toBase64String(binaryData);
 String postSignature = ossClient.calculatePostSignature(postPolicy);
 
 respMap = new LinkedHashMap<String, String>();
 respMap.put("accessid", accessId);
 respMap.put("policy", encodedPolicy);
 respMap.put("signature", postSignature);
 respMap.put("dir", dir);
 respMap.put("host", host);
 respMap.put("expire", String.valueOf(expireEndTime / 1000));
 
 
 
 } catch (Exception e) {
 
 System.out.println(e.getMessage());
 }
 
 return R.ok().put("data",respMap);
 }
 }
 
 | 
| 12
 3
 4
 5
 6
 7
 8
 9
 10
 
 | spring:cloud:
 gateway:
 routes:
 - id: third_party_route
 uri: lb://behappy-third-party
 predicates:
 - Path=/api/thirdparty/**
 filters:
 - RewritePath=/api/thirdparty/(?<segment>.*),/$\{segment}
 
 | 
vue组件配合使用
- vue配合oss上传组件(下载放到@components\upload下)-> 组件仓库地址
- 具体使用(单文件上传)
| 12
 3
 4
 5
 6
 7
 8
 9
 10
 11
 
 | <el-form-item label="品牌logo地址" prop="logo">
 
 <single-upload v-model="dataForm.logo"></single-upload>
 </el-form-item>
 <script>
 import SingleUpload from "@/components/upload/singleUpload"
 export default {
 components:{ SingleUpload }
 }
 </script>
 
 |