1.简介
阿里云对象存储 OSS（Object Storage Service）是一款海量、安全、低成本、高可靠的云存储服务，提供数据高可用性, 多种存储类型供选择，全面优化存储成本。
1.1 普通上传方式
- 上传慢：用户数据需先上传到应用服务器，之后再上传到OSS。网络传输时间比直传到OSS多一倍。如果用户数据不通过应用服务器中转，而是直传到OSS，速度将大大提升。
- 扩展性差：如果后续用户多了，应用服务器会成为瓶颈。
- 费用高：需要准备多台应用服务器。由于OSS上传流量是免费的，如果数据直传到OSS，不通过应用服务器，那么将能省下几台应用服务器。
1.2 服务端签名后直传
- Web端向服务端请求签名，然后直接上传，不会对服务端产生压力，而且安全可靠。
- 但服务端无法实时了解用户上传了多少文件，上传了什么文件。如果想实时了解用户上传了什么文件，可以采用服务端签名直传并设置上传回调。
- 但存在着恶意上传的风险，造成存储空间的浪费
3.服务端签名后直传文档
🏠 https://help.aliyun.com/document_detail/31926.html
基于Post Policy的使用规则在服务端通过各种语言代码完成签名，然后通过表单直传数据到OSS。由于服务端签名直传无需将AccessKey暴露在前端页面，相比JavaScript客户端签名直传具有更高的安全性。
3.1 用户向应用服务器请求上传Policy和回调。
请将客户端源码中的upload.js文件的如下代码片段的变量serverUrl的值设置为应用服务器的URL。
// serverUrl是用户获取签名和Policy等信息的应用服务器的URL，请将下面的IP和Port配置为您自己的真实信息。 serverUrl = 'http://88.88.88.88:8888'
设置完成后，客户端会向该serverUrl发送Get请求来获取需要的信息。客户端源码下载地址，请参见aliyun-oss-appserver-js-master.zip。
本场景为服务端签名后直传，不涉及上传回调。因此，您需要注释客户端源码的upload.js文件内的'callback' : callbackbody字段，以关闭上传回调功能。
{ 'key' : key + '${filename}', 'policy': policyBase64, 'OSSAccessKeyId': accessid, // 设置服务端返回200状态码，默认返回204。 'success_action_status' : '200', 'callback' : callbackbody, 'signature': signature, }
3.2 应用服务器返回上传Policy和签名给用户。
应用服务器侧的签名直传服务会处理客户端发送的Get请求消息，您可以设置对应的代码让应用服务器能够给客户端返回正确的消息。
以下是签名直传服务返回给客户端消息Body内容的示例：
{ "accessid":"LTAI5tBDFVar1hoq****", "host":"http://post-test.oss-cn-hangzhou.aliyuncs.com", "policy":"eyJleHBpcmF0aW9uIjoiMjAxNS0xMS0wNVQyMDoyMzoyM1oiLCJjxb25kaXRpb25zIjpbWyJjcb250ZW50LWxlbmd0aC1yYW5nZSIsMCwxMDQ4NTc2MDAwXSxbInN0YXJ0cy13aXRoIiwiJGtleSIsInVzZXItZGlyXC8i****", "signature":"VsxOcOudx******z93CLaXPz+4s=", "expire":1446727949, "dir":"user-dirs/" }
Body中的各字段说明如下：
| 字段 | 描述 |
| accessid | 用户请求的AccessKey ID。 |
| host | 用户发送上传请求的域名。 |
| policy | 用户表单上传的策略（Policy），Policy为经过Base64编码过的字符串。详情请参见Post Policy。 |
| signature | 对Policy签名后的字符串。详情请参见Post Signature。 |
| expire | 由服务器端指定的Policy过期时间，格式为Unix时间戳（自UTC时间1970年01月01号开始的秒数）。 |
| dir | 限制上传的文件前缀。 |
3.3 用户使用Post方法向OSS发送文件上传请求。
new_multipart_params = { // key表示上传到Bucket内的Object的完整路径，例如exampledir/exampleobject.txtObject，完整路径中不能包含Bucket名称。 // filename表示待上传的本地文件名称。 'key' : key + '${filename}', 'policy': policyBase64, 'OSSAccessKeyId': accessid, // 设置服务端返回状态码为200，不设置则默认返回状态码204。 'success_action_status' : '200', 'signature': signature, };
4.实战开发-后端
4.1 pom.xml核心配置
<dependencyManagement> <dependencies> <dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-alibaba-dependencies</artifactId> <version>2.1.0.RELEASE</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement> <dependencies> <dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alicloud-oss</artifactId> <!--<version>2.1.0.RELEASE</version>--> </dependency>
4.2 application.yml核心配置
server: port: 9101 max-http-header-size: 2MB servlet: context-path: /service spring: cloud: alicloud: access-key: LTAI5tKcWoeuxTK8******** secret-key: TQXiDtEnaR8Y7tXetvYZ0t******** oss: endpoint: oss-cn-hangzhou.aliyuncs.com bucket: waveedu
4.3 OssClientUtils工具类
package com.zhulang.waveedu.sms.util; 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.zhulang.waveedu.common.entity.Result; import java.text.SimpleDateFormat; import java.util.Date; import java.util.LinkedHashMap; import java.util.Map; /** * @author 狐狸半面添 * @create 2023-01-29 1:36 */ public class OssClientUtils { private OSS ossClient; private String accessId; private String endpoint; private String bucket; public OssClientUtils(OSS ossClient, String accessId, String endpoint, String bucket) { this.ossClient = ossClient; this.accessId = accessId; this.endpoint = endpoint; this.bucket = bucket; } public Result policy(String dirType) { // 1.指定填写Host地址，格式为https://bucketname.endpoint String host = "https://" + bucket + "." + endpoint; // 2.设置上传到OSS文件的前缀，可置空此项。置空后，文件将上传至Bucket的根目录下。 String format = new SimpleDateFormat("/yyyy/MM/").format(new Date()); String dir = dirType + format; Map<String, String> respMap = null; try { // 3.指定默认超时时间是30s long expireTime = 30; // 4.得到最终的截止时间 long expireEndTime = System.currentTimeMillis() + expireTime * 1000; Date expiration = new Date(expireEndTime); // 5.封装签名 PolicyConditions policyConds = new PolicyConditions(); // 5.1 设置可上传文件的大小，这里设置为 0 - 10MB policyConds.addConditionItem(PolicyConditions.COND_CONTENT_LENGTH_RANGE, 0, 10485760); // 5.2 设置上传文件的前缀、可忽略 policyConds.addConditionItem(MatchMode.StartWith, PolicyConditions.COND_KEY, dir); // 5.3 对Policy签名后的字符串。 String postPolicy = ossClient.generatePostPolicy(expiration, policyConds); String postSignature = ossClient.calculatePostSignature(postPolicy); // 6.用户表单上传的策略（Policy），Policy为经过Base64编码过的字符串。 byte[] binaryData = postPolicy.getBytes("utf-8"); String encodedPolicy = BinaryUtil.toBase64String(binaryData); // 7.封装签名直传服务返回给客户端消息Body内容 respMap = new LinkedHashMap<>(); // 7.1 用户请求的AccessKey ID。 respMap.put("accessid", accessId); // 7.2 用户表单上传的策略（Policy），Policy为经过Base64编码过的字符串。 respMap.put("policy", encodedPolicy); // 7.3 对Policy签名后的字符串。 respMap.put("signature", postSignature); // 7.4 限制上传的文件前缀。 respMap.put("dir", dir); // 7.5 用户发送上传请求的域名。 respMap.put("host", host); // 7.6 由服务器端指定的Policy过期时间，格式为Unix时间戳（自UTC时间1970年01月01号开始的秒数）。 respMap.put("expire", String.valueOf(expireEndTime / 1000)); } catch (Exception e) { return Result.error(); } return Result.ok(respMap); } }
4.4 OssConfig配置类
package com.zhulang.waveedu.sms.config; import com.aliyun.oss.OSS; import com.zhulang.waveedu.sms.util.OssClientUtils; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import javax.annotation.Resource; /** * @author 狐狸半面添 * @create 2023-01-29 1:41 */ @Configuration public class OssConfig { @Resource private OSS ossClient; @Value("${spring.cloud.alicloud.access-key}") private String accessId; @Value("${spring.cloud.alicloud.oss.endpoint}") private String endpoint; @Value("${spring.cloud.alicloud.oss.bucket}") private String bucket; @Bean public OssClientUtils ossClientUtils() { return new OssClientUtils(ossClient, accessId, endpoint, bucket); }
4.5 OssConstants常量类
package com.zhulang.waveedu.sms.constant; /** * 与Oss相关的常量 * * @author 狐狸半面添 * @create 2023-01-29 1:55 */ public class OssConstants { public static final String HEAD_IMAGE_DIR = "head-image"; }
4.6 OssServiceController控制器
package com.zhulang.waveedu.sms.controller; import com.zhulang.waveedu.common.entity.Result; import com.zhulang.waveedu.sms.constant.OssConstants; import com.zhulang.waveedu.sms.util.OssClientUtils; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import javax.annotation.Resource; /** * @author 狐狸半面添 * @create 2023-01-29 1:30 */ @RestController @RequestMapping("/oss") public class OssServiceController { @Resource private OssClientUtils ossClientUtils; /** * 获取头像的签名 * * @return 签名信息 */ @RequestMapping("/headImage") public Result headImage(){ return ossClientUtils.policy(OssConstants.HEAD_IMAGE_DIR); } }
4.7 Apifox测试
5.注意事项和细节说明
5.1 解决后端跨域问题
package com.zhulang.waveedu.basic.config; import org.springframework.context.annotation.Configuration; import org.springframework.web.servlet.config.annotation.CorsRegistry; import org.springframework.web.servlet.config.annotation.WebMvcConfigurer; /** * 解决跨域问题 * * @author 狐狸半面添 * @create 2023-01-15 23:08 */ @Configuration public class CorsConfig implements WebMvcConfigurer { @Override public void addCorsMappings(CorsRegistry registry) { registry.addMapping("/**") .allowedOrigins("*") .allowCredentials(true) .allowedMethods("GET", "POST", "PUT", "DELETE", "OPTIONS") .maxAge(3600); } }
5.2 解决阿里云跨域问题
