Java oss 上传图片视频

Util类里的公共参数暂时还做不到动态更新，有大佬有空可以弄一下

package com.test.file.util;

import com.aliyun.oss.OSSClient;
import com.aliyun.oss.model.*;
import com.test.file.config.OssClientConstants;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.stereotype.Component;
import org.springframework.web.multipart.MultipartFile;

import javax.annotation.Resource;
import javax.imageio.stream.FileImageInputStream;
import java.io.*;
import java.net.URL;
import java.util.Date;
import java.util.List;
import java.util.UUID;

@Slf4j
@Component
public class AliyunOSSClientUtil implements InitializingBean {

    @Resource
    OssClientConstants oSSClientConstants;

    // 阿里云API的内或外网域名
    private static String ENDPOINT;
    // 阿里云API的密钥Access Key ID
    private static String ACCESS_KEY_ID;
    // 阿里云API的密钥Access Key Secret
    private static String ACCESS_KEY_SECRET;
    // 阿里云API的bucket名称
    public static String BUCKET_NAME;
    private static String FORMAT;
    private static String FORMATS;
    private static String FOLDER_VIDEO;

    @Override
    public void afterPropertiesSet() {
        ENDPOINT = oSSClientConstants.getENDPOINT();
        ACCESS_KEY_ID = oSSClientConstants.getACCESS_KEY_ID();
        ACCESS_KEY_SECRET = oSSClientConstants.getACCESS_KEY_SECRET();
        BUCKET_NAME = oSSClientConstants.getBUCKET_NAME();
        FORMAT = oSSClientConstants.getFORMAT();
        FORMATS = oSSClientConstants.getFORMATS();
        FOLDER_VIDEO = oSSClientConstants.getFOLDER_VIDEO();
    }

    
    public static OSSClient getOSSClient() {
        return new OSSClient(ENDPOINT, ACCESS_KEY_ID, ACCESS_KEY_SECRET);
        //return new OSSClient("oss-cn-beijing.aliyuncs.com", "LTAI5tLuEo5USuY2Ta9gyX5S","SiO5A1DQmq4GuCrZLmctHIsgaYnpnJ");
    }

    
    public static String createBucketName(OSSClient ossClient, String bucketName) {
        // 存储空间
        final String bucketNames = bucketName;
        if (!ossClient.doesBucketExist(bucketName)) {
            // 创建存储空间
            Bucket bucket = ossClient.createBucket(bucketName);
            log.info("创建存储空间成功");
            return bucket.getName();
        }
        return bucketNames;
    }

    
    public static void deleteBucket(OSSClient ossClient, String bucketName) {
        ossClient.deleteBucket(bucketName);
        log.info("删除" + bucketName + "Bucket成功");
    }

    
    public static String createFolder(OSSClient ossClient, String bucketName, String folder) {
        // 文件夹名
        final String keySuffixWithSlash = folder;
        // 判断文件夹是否存在，不存在则创建
        if (!ossClient.doesObjectExist(bucketName, keySuffixWithSlash)) {
            // 创建文件夹
            ossClient.putObject(bucketName, keySuffixWithSlash, new ByteArrayInputStream(new byte[0]));
            log.info("创建文件夹成功");
            // 得到文件夹名
            OSSObject object = ossClient.getObject(bucketName, keySuffixWithSlash);
            String fileDir = object.getKey();
            return fileDir;
        }
        return keySuffixWithSlash;
    }

    
    public static void deleteFile(OSSClient ossClient, String bucketName, String key) {
        ossClient.deleteObject(bucketName, key);
        log.info("删除" + bucketName + "下的文件" + key + "成功");
    }

    
    public static List getFiles(OSSClient ossClient, String bucketName) {
        // ossClient.listObjects返回ObjectListing实例，包含此次listObject请求的返回结果。
        ObjectListing objectListing = ossClient.listObjects(bucketName);
        List sums = objectListing.getObjectSummaries();
        // objectListing.getObjectSummaries获取所有文件的描述信息。
        log.info("根据存储空间获取OSS服务器上的文件" + bucketName + "下的文件成功");
        return sums;
    }

    
    public static List getFilesByPrefix(OSSClient ossClient, String bucketName, String keyPrefix) {
        // ossClient.listObjects返回ObjectListing实例，包含此次listObject请求的返回结果。
        // 指定前缀，例如exampledir/object。
        // 列举包含指定前缀的文件。默认列举100个文件。
        ObjectListing objectListing = ossClient.listObjects(new ListObjectsRequest(bucketName).withPrefix(keyPrefix));
        List sums = objectListing.getObjectSummaries();
        log.info("获取" + bucketName + "下的" + keyPrefix + "文件成功");
        return sums;
    }

    
    public static Objectmetadata getFileByKey(OSSClient ossClient, String bucketName, String key) {
        // 获取Object，返回结果为OSSObject对象
        OSSObject object = ossClient.getObject(bucketName, key);

        // 获取Objectmeta
        Objectmetadata meta = object.getObjectmetadata();
        log.info("获取" + bucketName + "下的" + key + "+文件成功");
        return meta;
    }

    
    public static String[] uploadObject2OSS(OSSClient ossClient, File file, String bucketName, String path) {
        String resultStr = null;
        String[] fo = new String[]{"", ""};
        try {
            // 以输入流的形式上传文件
            String folder = "";
            folder = path + "/" + FORMAT + "/";
            InputStream is = new FileInputStream(file);
            // 文件名
            String timefile = FORMATS;
            String fileName = file.getName();
            String uuid = UUID.randomUUID().toString().replace("-", "");
            fileName = uuid + fileName.substring(fileName.lastIndexOf("."));
            log.info("上传到路径" + folder + fileName);
            // 文件大小
            Long fileSize = file.length();
            // 创建上传Object的metadata
            Objectmetadata metadata = new Objectmetadata();
            // 上传的文件的长度
            metadata.setContentLength(is.available());
            // 指定该Object被下载时的网页的缓存行为
            metadata.setCacheControl("no-cache");
            // 指定该Object下设置Header
            metadata.setHeader("Pragma", "no-cache");
            // 指定该Object被下载时的内容编码格式
            metadata.setContentEncoding("utf-8");
            // 文件的MIME，定义文件的类型及网页编码，决定浏览器将以什么形式、什么编码读取文件。如果用户没有指定则根据Key或文件名的扩展名生成，
            // 如果没有扩展名则填默认值application/octet-stream
            metadata.setContentType(getContentType(fileName));
            // 指定该Object被下载时的名称
            // inline ：将文件内容直接显示在页面
            // attachment：弹出对话框让用户下载
            // filename=cccc 就是下载下来的文件名filename/filesize=" + fileName + "/" + fileSize + "Byte.
            metadata.setContentDisposition("inline;filename=" + fileName);
            // 指定上传文件操作时是否覆盖同名Object。
            // 不指定x-oss-forbid-overwrite时，默认覆盖同名Object。
            // 指定x-oss-forbid-overwrite为false时，表示允许覆盖同名Object。
            // 指定x-oss-forbid-overwrite为true时，表示禁止覆盖同名Object，如果同名Object已存在，程序将报错。
            metadata.setHeader("x-oss-forbid-overwrite", "true");
            // 上传文件 (上传文件流的形式)
            PutObjectResult putResult = ossClient.putObject(bucketName, folder + fileName, is, metadata);
            // 解析结果
            resultStr = putResult.getETag();
            fo[1] = folder + fileName;
            fo[0] = resultStr;

            ossClient.shutdown();
        } catch (Exception e) {
            e.printStackTrace();
            log.error("上传阿里云OSS服务器异常." + e.getMessage(), e);
        }
        return fo;
    }

    
    public static String[] uploadObjectOSS(OSSClient ossClient, MultipartFile file, String bucketName, String path) {
        String resultStr = null;
        String[] fo = new String[]{"", ""};
        try {
            // 以输入流的形式上传文件
            String folder = "";
            folder = path + "/" + FORMAT + "/";
            // InputStream is = new FileInputStream(file);
            // 文件名
            //String timefile = FORMATS;
            String fileName = file.getOriginalFilename();
            String uuid = UUID.randomUUID().toString().replace("-", "");
            fileName = uuid + fileName.substring(fileName.lastIndexOf("."));
            log.info("上传到路径" + folder + fileName);
            // 文件大小
            long fileSize = file.getSize();
            // 创建上传Object的metadata
            Objectmetadata metadata = new Objectmetadata();
//            // 上传的文件的长度
//            metadata.setContentLength(is.available());
            // 指定该Object被下载时的网页的缓存行为
            metadata.setCacheControl("no-cache");
            // 指定该Object下设置Header
            metadata.setHeader("Pragma", "no-cache");
            // 指定该Object被下载时的内容编码格式
            metadata.setContentEncoding("utf-8");
            // 文件的MIME，定义文件的类型及网页编码，决定浏览器将以什么形式、什么编码读取文件。如果用户没有指定则根据Key或文件名的扩展名生成，
            // 如果没有扩展名则填默认值application/octet-stream
            metadata.setContentType(getContentType(fileName));
            // 指定该Object被下载时的名称
            // inline ：将文件内容直接显示在页面
            // attachment：弹出对话框让用户下载
            // filename=cccc 就是下载下来的文件名filename/filesize=" + fileName + "/" + fileSize + "Byte.
            metadata.setContentDisposition("inline;filename=" + fileName);
            // 指定上传文件操作时是否覆盖同名Object。
            // 不指定x-oss-forbid-overwrite时，默认覆盖同名Object。
            // 指定x-oss-forbid-overwrite为false时，表示允许覆盖同名Object。
            // 指定x-oss-forbid-overwrite为true时，表示禁止覆盖同名Object，如果同名Object已存在，程序将报错。
            metadata.setHeader("x-oss-forbid-overwrite", "true");
            // 上传文件 (上传文件流的形式)
            PutObjectResult putResult = ossClient.putObject(bucketName, folder + fileName, new ByteArrayInputStream(file.getBytes()), metadata);
            // 解析结果
            //String url = "http://" + bucketName + "." + endpoint + "/" + objectName;
            resultStr = putResult.getETag();
            fo[0] = resultStr;
            fo[1] = folder + fileName;

            ossClient.shutdown();
        } catch (Exception e) {
            e.printStackTrace();
            log.error("上传阿里云OSS服务器异常." + e.getMessage(), e);
        }
        return fo;
    }

    //上传视频
    public static String uploadByteVideoOSS(OSSClient ossClient, byte[] b, String bucketName, String user_id) {

        // byte[] content = "Hello OSS".getBytes();

        // 以输入流的形式上传文件
        String folder = "";
        folder = FOLDER_VIDEO + user_id + "/" + FORMAT + "/";
        // 文件名
        String uuid = UUID.randomUUID().toString().replace("-", "");
        String timefile = uuid;// 文件名
        String fileName = ".MP4";// 后缀扩展名
        fileName = timefile + fileName;
        log.info("上传到路径" + folder + fileName);

        Long fileSize = (long) b.length;

        // 创建上传Object的metadata
        Objectmetadata metadata = new Objectmetadata();
        metadata.setContentLength(fileSize);
        // 指定该Object被下载时的网页的缓存行为
        metadata.setCacheControl("no-cache");
        // 指定该Object下设置Header
        metadata.setHeader("Pragma", "no-cache");
        // 指定该Object被下载时的内容编码格式
        metadata.setContentEncoding("utf-8");
        // 文件的MIME，定义文件的类型及网页编码，决定浏览器将以什么形式、什么编码读取文件。如果用户没有指定则根据Key或文件名的扩展名生成，
        // 如果没有扩展名则填默认值application/octet-stream
        metadata.setContentType(getContentType(fileName));
        // 指定该Object被下载时的名称（指示MINME用户代理如何显示附加的文件，打开或下载，及文件名称）
        metadata.setContentDisposition("filename/filesize=" + fileName + "/" + fileSize + "Byte.");
        // 指定上传文件操作时是否覆盖同名Object。
        // 不指定x-oss-forbid-overwrite时，默认覆盖同名Object。
        // 指定x-oss-forbid-overwrite为false时，表示允许覆盖同名Object。
        // 指定x-oss-forbid-overwrite为true时，表示禁止覆盖同名Object，如果同名Object已存在，程序将报错。
        metadata.setHeader("x-oss-forbid-overwrite", "true");

        PutObjectResult putResult = ossClient.putObject(bucketName, folder + fileName, new ByteArrayInputStream(b),
                metadata);
        ossClient.shutdown();
        String filepath = folder + fileName;
        return filepath;
    }

    //上传图片
    public static String uploadByteOSS(OSSClient ossClient, byte[] b, String bucketName, String path) {

        // byte[] content = "Hello OSS".getBytes();

        // 以输入流的形式上传文件
        String folder = "";
        folder = path + "/" + FORMAT + "/";
        // 文件名
        String uuid = UUID.randomUUID().toString().replace("-", "");
        String timefile = uuid;// 文件名
        String fileName = ".jpg";// 后缀扩展名
        fileName = timefile + fileName;
        log.info("上传到路径" + folder + fileName);

        Long fileSize = (long) b.length;
//        String timefile = FORMATS;
        String fileName = file.getName();
//        file = timefile + file.substring(file.lastIndexOf("."));
        // 创建上传Object的metadata
        Objectmetadata metadata = new Objectmetadata();
        metadata.setContentLength(fileSize);
        // 指定该Object被下载时的网页的缓存行为
        metadata.setCacheControl("no-cache");
        // 指定该Object下设置Header
        metadata.setHeader("Pragma", "no-cache");
        // 指定该Object被下载时的内容编码格式
        metadata.setContentEncoding("utf-8");
        // 文件的MIME，定义文件的类型及网页编码，决定浏览器将以什么形式、什么编码读取文件。如果用户没有指定则根据Key或文件名的扩展名生成，
        // 如果没有扩展名则填默认值application/octet-stream
        metadata.setContentType(getContentType(fileName));
        // 指定该Object被下载时的名称（指示MINME用户代理如何显示附加的文件，打开或下载，及文件名称）
        metadata.setContentDisposition("filename/filesize=" + fileName + "/" + fileSize + "Byte.");

        PutObjectResult putResult = ossClient.putObject(bucketName, folder + fileName, new ByteArrayInputStream(b),
                metadata);
        ossClient.shutdown();
        String filepath = folder + fileName;
        return filepath;
    }

    public static byte[] image2Bytes(String imgSrc) throws Exception {
        FileInputStream fin = new FileInputStream(new File(imgSrc));
        // 可能溢出,简单起见就不考虑太多,如果太大就要另外想办法，比如一次传入固定长度byte[]
        byte[] bytes = new byte[fin.available()];
        // 将文件内容写入字节数组，提供测试的case
        fin.read(bytes);

        fin.close();
        return bytes;
    }

    //图片转化为byte数组
    public static byte[] image2byte(String path) {
        byte[] data = null;
        FileImageInputStream input = null;
        try {
            input = new FileImageInputStream(new File(path));
            ByteArrayOutputStream output = new ByteArrayOutputStream();
            byte[] buf = new byte[1024];
            int numBytesRead = 0;
            while ((numBytesRead = input.read(buf)) != -1) {
                output.write(buf, 0, numBytesRead);
            }
            data = output.toByteArray();
            output.close();
            input.close();
        } catch (FileNotFoundException ex1) {
            ex1.printStackTrace();
        } catch (IOException ex1) {
            ex1.printStackTrace();
        }
        return data;
    }

    
    public static final String getContentType(String fileName) {
        // 文件的后缀名
        String FilenameExtension = fileName.substring(fileName.lastIndexOf("."));
        if (FilenameExtension.equalsIgnoreCase(".bmp")) {
            return "application/x-bmp";
        }
        if (FilenameExtension.equalsIgnoreCase(".gif")) {
            return "image/gif";
        }
        if (FilenameExtension.equalsIgnoreCase(".jpeg") ||
                FilenameExtension.equalsIgnoreCase(".jpg") ||
                FilenameExtension.equalsIgnoreCase(".png")) {
            return "image/jpeg";
        }
        if (FilenameExtension.equalsIgnoreCase(".html")) {
            return "text/html";
        }
        if (FilenameExtension.equalsIgnoreCase(".txt")) {
            return "text/plain";
        }
        if (FilenameExtension.equalsIgnoreCase(".vsd")) {
            return "application/vnd.visio";
        }
        if (FilenameExtension.equalsIgnoreCase(".pptx") ||
                FilenameExtension.equalsIgnoreCase(".ppt")) {
            return "application/vnd.ms-powerpoint";
        }
        if (FilenameExtension.equalsIgnoreCase(".docx") ||
                FilenameExtension.equalsIgnoreCase(".doc")) {
            return "application/msword";
        }
        if (FilenameExtension.equalsIgnoreCase(".xla") ||
                FilenameExtension.equalsIgnoreCase(".xlc") ||
                FilenameExtension.equalsIgnoreCase(".xlm") ||
                FilenameExtension.equalsIgnoreCase(".xls") ||
                FilenameExtension.equalsIgnoreCase(".xlt") ||
                FilenameExtension.equalsIgnoreCase(".xlw")) {
            return "application/vnd.ms-excel";
        }
        if (FilenameExtension.equalsIgnoreCase(".xml")) {
            return "text/xml";
        }
        if (FilenameExtension.equalsIgnoreCase(".pdf")) {
            return "application/pdf";
        }
        if (FilenameExtension.equalsIgnoreCase(".zip")) {
            return "application/zip";
        }
        if (FilenameExtension.equalsIgnoreCase(".tar")) {
            return "application/x-tar";
        }
        if (FilenameExtension.equalsIgnoreCase(".avi")) {
            return "video/avi";
        }
        if (FilenameExtension.equalsIgnoreCase(".mp4")) {
            return "video/mpeg4";
        }
        if (FilenameExtension.equalsIgnoreCase(".mp3")) {
            return "audio/mp3";
        }
        if (FilenameExtension.equalsIgnoreCase(".mp2")) {
            return "audio/mp2";
        }
        // 默认返回类型
        return "application/octet-stream";
    }

    
    public static String getUrl(OSSClient ossClient, String bucketName, String fileName) {
        // 设置URL过期时间为10年 3600l* 1000*24*365*10
        Date expiration = new Date(new Date().getTime() + 3600l * 1000 * 24 * 365 * 10);
        // 生成URL
        URL url = ossClient.generatePresignedUrl(bucketName, fileName, expiration);
        if (url != null) {
            return url.toString();
        }
        return "获网址路径出错";
    }

    public String urlpath(String user_id, String files) {
        OSSClient ossClient = AliyunOSSClientUtil.getOSSClient();
        String[] file = files.split(",");
        String url = "";
        for (String filename : file) {
            // System.out.println("filename:"+filename);
            File filess = new File(filename);
            String[] s = AliyunOSSClientUtil.uploadObject2OSS(ossClient, filess, BUCKET_NAME, user_id);
            log.info("上传后的文件MD5数字唯一签名:" + s[0]);
            log.info("文件路径:" + s[1]);
            url = AliyunOSSClientUtil.getUrl(ossClient, BUCKET_NAME, s[1]);
            log.info("访问网址路径:" + url);
        }
        // 上传后的文件MD5数字唯一签名:40F4131427068E08451D37F02021473A
        return url;
    }

    public String uploadvideo(String url) {
        String user_id = "localism";
        String[] urllist = AliyunOSSClientUtil.uploadObject2OSS(AliyunOSSClientUtil.getOSSClient(), new File(url), BUCKET_NAME, user_id);
        String c = urllist[1];
        return c;
    }

    // 测试
    public static void main(String[] args) throws Exception {
        
        // 初始化OSSClient
        //OSSClient ossClient = AliyunOSSClientUtil.getOSSClient();

        // ossClient.listObjects返回ObjectListing实例，包含此次listObject请求的返回结果。
        

        //deleteFile(ossClient,"ly2021test","user/test/20211223/a355ed49dc3d4515b39c81be869f9d3d.jpg");
        // 填写需要删除的多个文件完整路径。文件完整路径中不能包含Bucket名称。
        

        /*byte[] b1 = AliyunOSSClientUtil.image2byte("g:\余杰AVI.png");

            String str ="";
            base64Decoder decoder = new base64Decoder();
            byte[] b = decoder.decodeBuffer(str);
            System.out.println(b.length);


//        String path = AliyunOSSClientUtil.uploadByteVideoOSS(ossClient, b1, BUCKET_NAME, user_id);
            String path = AliyunOSSClientUtil.uploadByteOSS(ossClient, b1, BUCKET_NAME, user_id);
//        String path = AliyunOSSClientUtil.uploadObjectOSS(ossClient, b1, BUCKET_NAME, user_id);
            System.out.println(b1.length + "," + b1.toString());
            log.info("文件路径:" + path);
            String url = AliyunOSSClientUtil.getUrl(ossClient, BUCKET_NAME, path);
            log.info("访问网址路径:" + url);*/
@RefreshScope
@ConfigurationProperties(prefix = "aliyun.oss")
@Component
@Data
public class OssClientConstants {
    //阿里云API的外网域名
    private String ENDPOINT;

    //阿里云API的密钥Access Key ID
    private String ACCESS_KEY_ID;

    //阿里云API的密钥Access Key Secret
    private String ACCESS_KEY_SECRET;

    //阿里云API的bucket名称
    private String BUCKET_NAME;

    private String FOLDER_VIDEO="video/";

    private String FORMAT = 
    DateFormatUtils.format(LocalDateTime.now(),"yyyyMMdd");

    private String FORMATS = 
    DateFormatUtils.format(LocalDateTime.now(),"yyyyMMddHHmmss");
}