oss的簡單使用（已實現圖片、視頻的成功上傳）

需要導入的dependency

后兩個依賴主要是用於實現Bucket的創建以及文件的上傳

       <dependency>
            <groupId>com.aliyun.oss</groupId>
            <artifactId>aliyun-sdk-oss</artifactId>
            <version>3.10.2</version>
        </dependency>
        <dependency>
            <groupId>commons-io</groupId>
            <artifactId>commons-io</artifactId>
            <version>1.3.2</version>
        </dependency>
        <dependency>
            <groupId>commons-fileupload</groupId>
            <artifactId>commons-fileupload</artifactId>
            <version>1.2.1</version>
        </dependency>

 

加載完相關依賴后，便可以通過創建OSSClient對象調用相關接口實現相關功能啦.

注意：在沒有綁定私有域名的情況下，文件上傳成功后返回的url只能是下載鏈接...

代碼如下： 1 package com.aliyun.oss;

import com.aliyun.oss.model.CannedAccessControlList;  4 import com.aliyun.oss.model.CreateBucketRequest;  5 import com.aliyun.oss.model.MultipartUpload;  6 import org.springframework.util.StreamUtils;  7 import org.springframework.util.StringUtils;  8 import org.springframework.web.multipart.MultipartFile;  9 
import java.io.ByteArrayInputStream; 11 import java.io.IOException; 12 import java.text.SimpleDateFormat; 13 import java.util.Date; 14 import java.util.UUID; 15 
public class OssUtil { 17     //定義外網訪問的參數 --地域節點
    private static String EndPoint = "oss-cn-zhangjiakou.aliyuncs.com"; 19     private  static String AccessKeyID = "XXXXXXX"; 20     private static String AccessKeySecret = "XXXXXXX"; 21     private static String BucketName = "tiandankanfeng"; //倉庫名稱
    private static String SufferUrl = "http://tiandankanfeng.oss-cn-zhangjiakou.aliyuncs.com/"; //文件上傳成功后返回的路徑，類似二級域名
    private static SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd"); //格式化時間

    public OSSClient getOSSClient(){ 26         //創建一個OSSClient對象
        OSSClient ossClient = new OSSClient(EndPoint,AccessKeyID,AccessKeySecret); 28         if(ossClient.doesBucketExist(BucketName)) { 29             System.out.println("success"); 30             //關閉oss的連接 此處不要關閉，后面會調用，不然會報錯
        }else { //通過api接口來創建bucket
            System.out.println("fail to find ,so to get a new one"); 33             //創建一個oss倉庫
            CreateBucketRequest bucketRequest = new CreateBucketRequest(null); 35  bucketRequest.setBucketName(BucketName); 36             bucketRequest.setCannedACL(CannedAccessControlList.PublicRead); //設置訪問權限 --公共讀
            ossClient.createBucket(bucketRequest); //映射原理，會重新生成一個ossClient並覆蓋當前的ossClient

 } 40         return ossClient; 41  } 42 
    /**
 * 上傳文件 45  * @param multipartFile 需要上傳的文件 46  * @param fileType 文件類型 47  * @return
     */
    public String uploadDocuments(MultipartFile multipartFile, String fileType) throws IOException { 50         //獲取oss連接
        OSSClient ossClient = this.getOSSClient(); 52         //獲取文件的后綴名稱
        String ext = multipartFile.getOriginalFilename().substring(multipartFile.getOriginalFilename().lastIndexOf(".")); 54         String fileName = getFileName(fileType, ext); 55         String url = null; 56         //通過ossclient獲取上傳文件后返回的url
        ossClient.putObject(BucketName,fileName,new ByteArrayInputStream(multipartFile.getBytes())); 58         url = SufferUrl+fileName; 59         System.out.println("------>>上傳文件成功，url："+url); 60 　　　　　ossClient.shutdown();

        return url;

 } 63 
    private String getFileName(String fileType, String ext) { 65         //上傳至oss的那個文件夾 通過filename來指定 生成規則 // www.liangye123.com/img/20200814/jdg.png
        String date = sdf.format(new Date()); 67         if(StringUtils.isEmpty(fileType)){ 68             fileType = "default"; 69  } 70         //為了避免圖片重名，使用UUID來命名圖片
        String uuid = UUID.randomUUID().toString().replace("-",""); 72         //組合filename
        String filename = fileType+"/"+date+"/"+uuid+ext; 74         return filename; 75  } 76 
    public static void main(String[] args) { 78         OssUtil ou = new OssUtil(); 79  ou.getOSSClient(); 80  } 81 }

 

測試類：

package com.aliyun.oss;

import org.junit.jupiter.api.Test;
import org.springframework.mock.web.MockMultipartFile;
import org.springframework.web.multipart.MultipartFile;

import java.io.File;
import java.io.FileInputStream;

import static org.junit.jupiter.api.Assertions.*;

class OssUtilTest {

    @Test
    void getOSSClient() {
    }

    @Test
    void uploadDocuments() throws Exception{
        assert(true);
        File file = new File("H:/desktop/個人image/個人image/寬圖/a2c1f-wemjb.jpg");
        FileInputStream in_file= new FileInputStream(file);
        //File與MutipartFile的轉化
        MultipartFile multipartFile = new MockMultipartFile("a2c1f-wemjb.jpg","a2c1f-wemjb.jpg","jpeg",in_file);
        String url = new OssUtil().uploadDocuments(multipartFile,"jpg");
    }
}

 

測試結果：

啊，圖片應該不違規吧 QAQ