天天看點

阿裡----OSS對象存儲服務

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

阿裡----OSS對象存儲服務

名稱和地區根據自己需求填寫,除了括出來的其他預設即可,建立bucket

阿裡----OSS對象存儲服務

建立一個AccessKey使用者

阿裡----OSS對象存儲服務
阿裡----OSS對象存儲服務
阿裡----OSS對象存儲服務
阿裡----OSS對象存儲服務
阿裡----OSS對象存儲服務

建立好後,再次點選AccessKey管理

阿裡----OSS對象存儲服務

擷取下面的兩個字段資訊,後面需要使用它來進行OSS對象管理

阿裡----OSS對象存儲服務

開啟OSS跨域

阿裡----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對象存儲服務

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}