第一步、開啟OSS服務,建立一個Bucket、建立一個使用者并開啟OSS權限

名稱和地區根據自己需求填寫,除了括出來的其他預設即可,建立bucket
建立一個AccessKey使用者
建立好後,再次點選AccessKey管理
擷取下面的兩個字段資訊,後面需要使用它來進行OSS對象管理
開啟OSS跨域
第二步、引入依賴、添加配置
引入依賴
<!-- spring-cloud-starter-alicloud-oss OSS對象存儲服務-->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alicloud-oss</artifactId>
<version>${alicloud-oss.version}</version>
</dependency>
添加配置
spring:
application:
name: cloud-oss
cloud:
alicloud:
access-key: OSS使用者的AccessKey ID
secret-key: OSS使用者的AccessKey SECRET
oss:
endpoint: 通路的節點域名,例如:oss-cn-shenzhen.aliyuncs.com
bucket: yumbo-oss #這個根據自己的bucket名稱填寫,啟動器沒有本身沒有這個配置
OSS的文檔位址
Github文檔位址(https://github.com/alibaba/spring-cloud-alibaba/blob/master/spring-cloud-alibaba-docs/src/main/asciidoc-zh/oss.adoc)
後端簽名後通過javascript直傳
簽名資訊擷取
import com.alibaba.fastjson.JSONObject;
import com.aliyun.oss.OSSClient;
import com.aliyun.oss.common.utils.BinaryUtil;
import com.aliyun.oss.model.MatchMode;
import com.aliyun.oss.model.PolicyConditions;
import org.springframework.web.bind.annotation.CrossOrigin;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import java.io.UnsupportedEncodingException;
import java.sql.Date;
import java.time.LocalDate;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.TimeZone;
@RestController
public class OssController {
@GetMapping("/asign")
@CrossOrigin //開啟跨域通路
public String policyAsign() {
String accessId = "LTAI4GG2L691UsdkKUmE3qP8"; // 請填寫您的 AccessKeyId。
String accessKey = "q12TVvTqJTftUrKVO1xYkFO9D1vHRS"; // 請填寫您的 AccessKeySecret。
String endpoint = "oss-cn-shenzhen.aliyuncs.com"; // 請填寫您的 endpoint。
String bucket = "yumbo-oss.oss-cn-shenzhen.aliyuncs.com"; // 請填寫您的 bucketname 。
String host = "http://" + bucket + "." + endpoint; // host的格式為 bucketname.endpoint
// callbackUrl為 上傳回調伺服器的URL,請将下面的IP和Port配置為您自己的真實資訊。
TimeZone.setDefault(TimeZone.getTimeZone("Asia/Shanghai"));
String dir = LocalDate.now().toString();// 使用者上傳檔案時指定的字首。我這裡設定日期為字首
OSSClient client = new OSSClient(endpoint, accessId, accessKey);
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 = client.generatePostPolicy(expiration, policyConds);
byte[] binaryData = new byte[0];
try {
binaryData = postPolicy.getBytes("utf-8");
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
String encodedPolicy = BinaryUtil.toBase64String(binaryData);
String postSignature = client.calculatePostSignature(postPolicy);
Map<String, Object> respMap = new LinkedHashMap<String, Object>();
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));
// respMap.put("expire", formatISO8601Date(expiration));
JSONObject jasonCallback = new JSONObject();
// jasonCallback.put("callbackUrl", callbackUrl);
jasonCallback.put("callbackBody",
"filename=${object}&size=${size}&mimeType=${mimeType}&height=${imageInfo.height}&width=${imageInfo.width}");
jasonCallback.put("callbackBodyType", "application/x-www-form-urlencoded");
String base64CallbackBody = BinaryUtil.toBase64String(jasonCallback.toString().getBytes());
respMap.put("callback", base64CallbackBody);
return new JSONObject(respMap).toJSONString();//将簽名資料暴露出去
}
}
spring:
cloud:
gateway:
routes:
- id: third_party_route
uri: lb://要負載均衡到的Oss服務名
predicates:
- Path=/api/thirdparty/**
filters:
- RewritePath=/api/thirdparty/(?<segment>.*),/$\{segment}