Spring结合oss进行云存储

@PostMapping("/postFile/{euid}")
public R postFile(@PathVariable("euid") String euid, @RequestParam("file") MultipartFile multipartFile) {
    return coverErrorService.postFileByEuid(euid, multipartFile);
}

/**
 * oss上传完成的回调
 */
@PostMapping("/putoss/callback")
public R putOssCallBack(@RequestBody Map<String, String> respondBody) {
    return coverErrorService.putOssCallBack(respondBody);
}

@SneakyThrows
@Override
public R postFileByEuid(String euid, MultipartFile multipartFile) {
    CoverErrorEntity errorByEuid = findErrorByEuid(euid);
    if (errorByEuid != null) {
        OSS ossClient = ossClientUtils.getOssClient();
        String data = new SimpleDateFormat("yyyy-MM-dd").format(new Date());
        String[] split = multipartFile.getOriginalFilename().split("\\.");
        String info = String.format("%s/%s/%s.%s", data, errorByEuid.getUid(), UUID.randomUUID(), split[split.length - 1]);
        //设置回调
        PutObjectRequest putObjectRequest = new PutObjectRequest("cover-safety", info,
                multipartFile.getInputStream());
        Callback callback = new Callback();
        callback.setCallbackUrl(callBackUrl);
        log.info("请求链接:" + callBackUrl);
        HashMap<String, String> cb = new HashMap<>();
        cb.put("statue", "success");
        cb.put("url", "https://cover-safety.oss-cn-hangzhou.aliyuncs.com/" + info);
        cb.put("euid", errorByEuid.getUid());
        String s = new ObjectMapper().writeValueAsString(cb);
        callback.setCallbackBody(StringEscapeUtils.escapeJava(s));
        callback.setCalbackBodyType(Callback.CalbackBodyType.JSON);
        putObjectRequest.setCallback(callback);
        //上传
        ossClient.putObject(putObjectRequest);
        ossClient.shutdown();
    } else {
        return R.error().put(Constant.REASON, "没有对应的EUID");
    }
    return R.ok();
}

@Override
public R putOssCallBack(Map<String, String> respondBody) {
    log.info("存储成功{}", respondBody);
    //进行一个数据库的存储
    CoverErrorEntity euid = findErrorByEuid(respondBody.get("euid"));
    if (euid != null) {
        //存储路径地址
        UpdateWrapper<CoverErrorEntity> updateWrapper = new UpdateWrapper<>();
        updateWrapper.eq("uid", euid.getUid());
        euid.setErrorImage(respondBody.get("url"));
        this.baseMapper.update(euid, updateWrapper);
    }
    return R.ok();
}

package com.xyxy.coversafety.coversafetywork.work.tools.utils;

import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.common.utils.BinaryUtil;
import com.aliyun.oss.model.MatchMode;
import com.aliyun.oss.model.PolicyConditions;
import com.xyxy.coversafety.coversafetywork.work.entity.CoverErrorEntity;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.LinkedHashMap;
import java.util.Map;

/**
 * @Author: PengHaiChen
 * @Description:
 * @Date: Create in 12:51 2021/10/15
 * 在业务逻辑中，需要客户端请求服务端的签名后上传到oss，不然本地服务器载荷太大了
 */
@Component
@Slf4j
public class OssClientUtils {

    @Value("${oss.endpoint}")
    private String endpoint;
    @Value("${oss.access-key}")
    private String accessKeyId;
    @Value("${oss.secret-key}")
    private String accessKeySecret;

    private Map<String, String> respMap;

    public OSS getOssClient() {
        log.info(endpoint, accessKeyId, accessKeySecret);
        return new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
    }

    public Map<String, String> generatePostPolicy(CoverErrorEntity coverErrorEntity) {
        String bucket = "cover-safety"; // 请填写您的 bucketname 。
        String host = "https://" + bucket + "." + endpoint; // host的格式为 bucketname.endpoint
        // callbackUrl为上传回调服务器的URL，请将下面的IP和Port配置为您自己的真实信息。
//        String callbackUrl = "http://88.88.88.88:8888";
        String format = new SimpleDateFormat("yyyy-MM-dd").format(new Date());
        String dir = String.format("%s/%s/", format, coverErrorEntity.getUid());// 用户上传文件时指定的前缀。

        // 创建OSSClient实例。
        OSS ossClient = getOssClient();
        try {
            long expireTime = 180;
            long expireEndTime = System.currentTimeMillis() + expireTime * 1000;
            Date expiration = new Date(expireEndTime);
            PolicyConditions policyConds = new PolicyConditions();
            policyConds.addConditionItem(PolicyConditions.COND_CONTENT_LENGTH_RANGE, 0, 10485760);
            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", accessKeyId);
            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));
        } catch (Exception e) {
            // Assert.fail(e.getMessage());
            log.info(e.getMessage());
        } finally {
            ossClient.shutdown();
        }
        return respMap;
    }
}