华为云obs上传下载粘贴复制即可使用

package com.shie.idiThird.untils;


import com.obs.services.ObsClient;
import com.obs.services.model.ObjectMetadata;
import com.obs.services.model.ObsObject;
import com.obs.services.model.TemporarySignatureRequest;
import com.obs.services.model.TemporarySignatureResponse;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.exception.ExceptionUtils;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.stereotype.Component;
import org.springframework.web.util.UriUtils;

import javax.annotation.PostConstruct;
import javax.servlet.http.HttpServletResponse;
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.URLEncoder;
import java.util.Date;

@Component
@Slf4j
@RefreshScope
public class ObsUtil {

    private static String ENDPOINT = null;

    private static String AK = null;

    private static String SK = null;

    private static String BUCKET = null;
    @Value("${obs.ak}")
    private String ak;
    @Value("${obs.sk}")
    private String sk;
    @Value("${obs.endPoint}")
    private String endPoint;
    @Value("${obs.bucket}")
    private String bucket;
    @PostConstruct
    public void init() {
        ENDPOINT = endPoint;
        AK = ak;
        SK = sk;
        BUCKET = bucket;
    }
    /**
     * 文件上传
     *
     * @return
     */
    public static String upload(InputStream inputStream, String originalFilename, String uuidFileName) {
        log.info("======================>>进入obs上传<<====================");
        uuidFileName = "idi" + "/" + uuidFileName;
        ObsClient obsClient = null;
        //上传图片
        try {
            //获取流对象
            // 创建ObsClient实例
            obsClient = new ObsClient(AK, SK, ENDPOINT);
            //设置下载时，文件名称为原文件名
            ObjectMetadata objectMetadata = new ObjectMetadata();
            //显示文件名过滤特殊字符
            originalFilename = IDIStringUtil.filterSpecialChar(originalFilename, "\\,/,:,*,?,\",<,>,|");
            String type = originalFilename.substring(originalFilename.lastIndexOf(".") + 1);
            originalFilename = originalFilename.substring(0, originalFilename.lastIndexOf("."));
//            objectMetadata.setContentDisposition("attachment;filename=" + UriUtils.encode(originalFilename, "UTF-8") + "." + type);
            objectMetadata.setContentDisposition("attachment;filename=" + UriUtils.encode(originalFilename, "UTF-8") + "." + type);
            // 使用访问OBS
            obsClient.putObject(BUCKET, uuidFileName, inputStream, objectMetadata);
            //将图片信息封装起来，方便前端回显调用
            return uuidFileName;
        } catch (Exception e) {
            e.printStackTrace();
            System.err.println("上传图片失败!");
        } finally {
            try {
                if (obsClient != null) {
                    // 关闭obsClient
                    obsClient.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
                System.err.println("obs客户端流对象关闭失败！");
            }

        }
        return null;
    }

    //文件下载
    public String downloadImg() {
        TemporarySignatureRequest request = new TemporarySignatureRequest();
        request.setBucketName(bucket);
        request.setObjectKey("objectKey");
        request.setRequestDate(new Date());
        // 1分钟后链接失效
        request.setExpires(60);

        ObsClient obsClient = new ObsClient(ak, sk, endPoint);
        // 通过临时授权,直接访问链接下载
        TemporarySignatureResponse signature = obsClient.createTemporarySignature(request);
        log.info("download signedUrl-> {}", signature.getSignedUrl());
        return signature.getSignedUrl();
    }

    public static String getFileUrl(String fileName) {
        log.info("======================>>进入obs下载<<====================");
        TemporarySignatureRequest request = new TemporarySignatureRequest();

        request.setBucketName(BUCKET);
        request.setObjectKey(fileName);
        ObsClient obsClient = new ObsClient(AK, SK, ENDPOINT);

        // 1天后链接失效
        request.setExpires(86400);
        ObjectMetadata objectMetadata = obsClient.getObjectMetadata(BUCKET, fileName);
        log.info("======================>>objectMetadata"+objectMetadata+"<<====================");
        String contentDisposition = objectMetadata.getContentDisposition();
        ObsObject obsObject = obsClient.getObject(BUCKET, fileName);
        ObjectMetadata metadata = obsObject.getMetadata();
        log.info("======================>>metadata"+metadata+"<<====================");
        log.info("======================>>"+contentDisposition+"<<====================");
        //返回上传文件下载路径
        TemporarySignatureResponse signature = obsClient.createTemporarySignature(request);
        log.info("文件下载地址为：{}", signature.getSignedUrl());
        return signature.getSignedUrl();
    }
    /**
     * 下载oos文件流
     * @param fileId     文件id
     * @param showName   文件显示名称
     * @param response
     * @throws IOException
     */
    public static void getFileOutputStream(String fileId, String showName, HttpServletResponse response){
        log.info("======================>>进入obs<<====================");
        ObsClient obsClient = new ObsClient(AK, SK, ENDPOINT);
        ObsObject obsObject = obsClient.getObject(BUCKET, fileId);
        InputStream is = obsObject.getObjectContent();
        getFileOutputStream(showName, response, is);
    }




    public static void getFileOutputStream(String showName, HttpServletResponse response, InputStream is) {

        try {
            response.reset();
            response.setContentType("application/octet-stream;charset=utf-8");
            response.setHeader(
                    "Content-disposition",
                    "attachment; filename=" + URLEncoder.encode(showName, "UTF-8"));
            try (
                    BufferedInputStream bis = new BufferedInputStream(is);
                    // 输出流
                    BufferedOutputStream bos = new BufferedOutputStream(response.getOutputStream());
            ) {
                byte[] buff = new byte[1024];
                int len = 0;
                while ((len = bis.read(buff)) > 0) {
                    bos.write(buff, 0, len);
                }
            }

        } catch (Exception e) {
            log.error(ExceptionUtils.getStackTrace(e));
        }
    }

}