阿里雲OSS上傳文件模塊-java方法

時間 2019-11-08

原文原文鏈接

上傳內容到阿里雲服務器，獲取保存路徑和點擊路徑。

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.net.URL;
import java.util.Date;

import javax.imageio.stream.FileImageInputStream;

import org.apache.log4j.Logger;
import org.springframework.stereotype.Component;

import com.aliyun.oss.OSSClient;
import com.aliyun.oss.model.Bucket;
import com.aliyun.oss.model.OSSObject;
import com.aliyun.oss.model.ObjectMetadata;
import com.aliyun.oss.model.PutObjectResult;

import sun.misc.BASE64Decoder;

/**
 * 
* @ClassName: AliyunOSSClientUtil 
* @Description: 阿里雲OSS上傳文件模塊 
* @author wy
* @date 2017年5月6日 下午6:01:46 
*
 */
@Component
public class AliyunOSSClientUtil {
    // log日誌
    private static Logger logger = Logger.getLogger(AliyunOSSClientUtil.class);
    // 阿里雲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 BACKET_NAME;
    // 阿里雲API的文件夾名稱
    private static String FOLDER;
    private static String FORMAT;
    private static String FORMATS;
    private static String FOLDER_VIDEO;

    // 初始化屬性
    static {
        ENDPOINT = OSSClientConstants.ENDPOINT;
        ACCESS_KEY_ID = OSSClientConstants.ACCESS_KEY_ID;
        ACCESS_KEY_SECRET = OSSClientConstants.ACCESS_KEY_SECRET;
        BACKET_NAME = OSSClientConstants.BACKET_NAME;
        FOLDER = OSSClientConstants.FOLDER;
        FORMAT = OSSClientConstants.FORMAT;
        FORMATS = OSSClientConstants.FORMATS;
        FOLDER_VIDEO = OSSClientConstants.FOLDER_VIDEO;
    }

    /**
     * 獲取阿里雲OSS客戶端對象
     * 
     * @return ossClient
     */
    public static OSSClient getOSSClient() {
        return new OSSClient(ENDPOINT, ACCESS_KEY_ID, ACCESS_KEY_SECRET);
    }

    /**
     * 建立存儲空間
     * 
     * @param ossClient
     *            OSS鏈接
     * @param bucketName
     *            存儲空間
     * @return
     */
    public static String createBucketName(OSSClient ossClient, String bucketName) {
        // 存儲空間
        final String bucketNames = bucketName;
        if (!ossClient.doesBucketExist(bucketName)) {
            // 建立存儲空間
            Bucket bucket = ossClient.createBucket(bucketName);
            logger.info("建立存儲空間成功");
            return bucket.getName();
        }
        return bucketNames;
    }

    /**
     * 刪除存儲空間buckName
     * 
     * @param ossClient
     *            oss對象
     * @param bucketName
     *            存儲空間
     */
    public static void deleteBucket(OSSClient ossClient, String bucketName) {
        ossClient.deleteBucket(bucketName);
        logger.info("刪除" + bucketName + "Bucket成功");
    }

    /**
     * 建立模擬文件夾
     * 
     * @param ossClient
     *            oss鏈接
     * @param bucketName
     *            存儲空間
     * @param folder
     *            模擬文件夾名如"qj_nanjing/"
     * @return 文件夾名
     */
    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]));
            logger.info("建立文件夾成功");
            // 獲得文件夾名
            OSSObject object = ossClient.getObject(bucketName, keySuffixWithSlash);
            String fileDir = object.getKey();
            return fileDir;
        }
        return keySuffixWithSlash;
    }

    /**
     * 根據key刪除OSS服務器上的文件
     * 
     * @param ossClient
     *            oss鏈接
     * @param bucketName
     *            存儲空間
     * @param folder
     *            模擬文件夾名 如"qj_nanjing/"
     * @param key
     *            Bucket下的文件的路徑名+文件名 如："upload/cake.jpg"
     */
    public static void deleteFile(OSSClient ossClient, String bucketName, String folder, String key) {
        ossClient.deleteObject(bucketName, folder + key);
        logger.info("刪除" + bucketName + "下的文件" + folder + key + "成功");
    }

    /**
     * 上傳圖片至OSS 文件流
     * 
     * @param ossClient
     *            oss鏈接
     * @param file
     *            上傳文件（文件全路徑如：D:\\image\\cake.jpg）
     * @param bucketName
     *            存儲空間
     * @param folder
     *            模擬文件夾名 如"qj_nanjing/"
     * @return String 返回的惟一MD5數字簽名
     */
    public static String[] uploadObject2OSS(OSSClient ossClient, File file, String bucketName, String user_id) {
        String resultStr = null;
        String[] fo = new String[] { "", "" };
        try {
            // 以輸入流的形式上傳文件
            String folder = "";
            folder = FOLDER + user_id + "/" + FORMAT + "/";
            InputStream is = new FileInputStream(file);
            // 文件名
            String timefile = FORMATS;
            String fileName = file.getName();
            fileName = timefile + fileName.substring(fileName.lastIndexOf("."));
            logger.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被下載時的名稱（指示MINME用戶代理如何顯示附加的文件，打開或下載，及文件名稱）
            metadata.setContentDisposition("filename/filesize=" + fileName + "/" + fileSize + "Byte.");
            // 上傳文件 (上傳文件流的形式)
            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();
            logger.error("上傳阿里雲OSS服務器異常." + e.getMessage(), e);
        }
        return fo;
    }
    //上傳路徑返回地址，圖片視頻均可以
    //須要改變上傳那文件位置FOLDER
    public static String[] uploadObjectOSS(OSSClient ossClient, String file, String bucketName, String user_id) {
        String resultStr = null;
        String[] fo = new String[] { "", "" };
        try {
            // 以輸入流的形式上傳文件
            String folder = "";
            folder = FOLDER + user_id + "/" + FORMAT + "/";
//            InputStream is = new FileInputStream(file);
            // 文件名
            String timefile = FORMATS;
//            String fileName = file.getName();
            file = timefile + file.substring(file.lastIndexOf("."));
            logger.info("上傳到路徑" + folder + file);
            // 文件大小
            Integer 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(file));
            // 指定該Object被下載時的名稱（指示MINME用戶代理如何顯示附加的文件，打開或下載，及文件名稱）
            metadata.setContentDisposition("filename/filesize=" + file + "/" + fileSize + "Byte.");
            // 上傳文件 (上傳文件流的形式)
            PutObjectResult putResult = ossClient.putObject(bucketName, folder + file, new ByteArrayInputStream(file.getBytes("UTF-8")), metadata);
            // 解析結果
            resultStr = putResult.getETag();
            fo[1] = folder + file;
            fo[0] = resultStr;

            ossClient.shutdown();
        } catch (Exception e) {
            e.printStackTrace();
            logger.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 timefile = FORMATS;// 文件名
        String fileName = ".MP4";// 後綴擴展名
        fileName = timefile + fileName;
        logger.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.");

        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 user_id) {

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

        // 以輸入流的形式上傳文件
        String folder = "";
        folder = FOLDER + user_id + "/" + FORMAT + "/";
        // 文件名
        String timefile = FORMATS;// 文件名
        String fileName = ".jpg";// 後綴擴展名
        fileName = timefile + fileName;
        logger.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;
    }

    /**
     * 經過文件名判斷並獲取OSS服務文件上傳時文件的contentType
     * 
     * @param fileName
     *            文件名
     * @return 文件的contentType
     */
    public static String getContentType(String fileName) {
        // 文件的後綴名
        String fileExtension = fileName.substring(fileName.lastIndexOf("."));
        if (".bmp".equalsIgnoreCase(fileExtension)) {
            return "image/bmp";
        }
        if (".gif".equalsIgnoreCase(fileExtension)) {
            return "image/gif";
        }
        if (".jpeg".equalsIgnoreCase(fileExtension) || ".jpg".equalsIgnoreCase(fileExtension)
                || ".png".equalsIgnoreCase(fileExtension)) {
            return "image/jpeg";
        }
        if (".html".equalsIgnoreCase(fileExtension)) {
            return "text/html";
        }
        if (".txt".equalsIgnoreCase(fileExtension)) {
            return "text/plain";
        }
        if (".vsd".equalsIgnoreCase(fileExtension)) {
            return "application/vnd.visio";
        }
        if (".ppt".equalsIgnoreCase(fileExtension) || "pptx".equalsIgnoreCase(fileExtension)) {
            return "application/vnd.ms-powerpoint";
        }
        if (".doc".equalsIgnoreCase(fileExtension) || "docx".equalsIgnoreCase(fileExtension)) {
            return "application/msword";
        }
        if (".xml".equalsIgnoreCase(fileExtension)) {
            return "text/xml";
        }
        if (".mp4".equalsIgnoreCase(fileExtension)) {
            return "video/mp4";
        }
        // 默認返回類型
        return "image/jpeg";
    }

    /**
     * 得到url連接
     *
     * @param key
     * @return
     */
    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, BACKET_NAME, user_id);
            logger.info("上傳後的文件MD5數字惟一簽名:" + s[0]);
            logger.info("文件路徑:" + s[1]);
            url = AliyunOSSClientUtil.getUrl(ossClient, BACKET_NAME, s[1]);
            logger.info("訪問網址路徑:" + url);
        }
        // 上傳後的文件MD5數字惟一簽名:40F4131427068E08451D37F02021473A
        return url;
    }
    public String uploadvideo(String url){
        String user_id="localism";
        String[] urllist=AliyunOSSClientUtil.uploadObject2OSS(AliyunOSSClientUtil.getOSSClient(), new File(url), BACKET_NAME, user_id);
        String c=urllist[1];
        return c;
    }
    // 測試
    public static void main(String[] args) throws Exception {
        AliyunOSSClientUtil t = new AliyunOSSClientUtil();
        String url = t.uploadvideo("g:\\餘傑的avi小視頻.mp4");
        System.out.println(url);
        /*// 初始化OSSClient
        OSSClient ossClient = AliyunOSSClientUtil.getOSSClient();
        // 上傳文件
        String files = "D:\\1.jpg";
        String[] file = files.split(",");
        String user_id = "3";
        
         * for (String filename : file) { //
         * System.out.println("filename:"+filename); File filess = new
         * File(filename); String[] s =
         * AliyunOSSClientUtil.uploadObject2OSS(ossClient, filess, BACKET_NAME,
         * user_id); logger.info("上傳後的文件MD5數字惟一簽名:" + s[0]); logger.info("文件路徑:"
         * + s[1]); String url = AliyunOSSClientUtil.getUrl(ossClient,
         * BACKET_NAME, s[1]); logger.info("訪問網址路徑:" + url); //
         * 上傳後的文件MD5數字惟一簽名:40F4131427068E08451D37F02021473A }
         

        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, BACKET_NAME, user_id);
        String path = AliyunOSSClientUtil.uploadByteOSS(ossClient, b1, BACKET_NAME, user_id);
//        String path = AliyunOSSClientUtil.uploadObjectOSS(ossClient, b1, BACKET_NAME, user_id);
        System.out.println(b1.length + "," + b1.toString());
        logger.info("文件路徑:" + path);
        String url = AliyunOSSClientUtil.getUrl(ossClient, BACKET_NAME, path);
        logger.info("訪問網址路徑:" + url);*/
    }

}

下面是阿里雲的一些基本數據常量配置html

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

/**
 * 
* @ClassName: OSSClientConstants 
* @Description: OSS阿里雲經常使用變量
* @author wy
* @date 2017年5月5日 上午11:56:25 
*
 */
public class OSSClientConstants {
    //阿里雲API的外網域名  
    public static final String ENDPOINT = "http://oss-cn-hangzhou.aliyuncs.com";  
    //阿里雲API的密鑰Access Key ID  
    public static final String ACCESS_KEY_ID = "XX";  
    //阿里雲API的密鑰Access Key Secret  
    public static final String ACCESS_KEY_SECRET = "XX";  
    //阿里雲API的bucket名稱  
    public static final String BACKET_NAME = "XX";  
    //阿里雲API的文件夾名稱  
    public static final String FOLDER="user/"; 
    public static final String FOLDER_VIDEO="video/";
    public static final String FORMAT = new SimpleDateFormat("yyyyMMdd").format(new Date());
    public static final String FORMATS = new SimpleDateFormat("yyyyMMddHHmmss").format(new Date());
}