Java 專案開發中阿里雲 oss上傳本地到伺服器以及下載功能實現例項。

AliyunOSSUtil類：

public class AliyunOSSUtil {

/**
 * 該示例程式碼展示瞭如果在OSS中建立和刪除一個Bucket，以及如何上傳和下載一個檔案。
 * 
 * 該示例程式碼的執行過程是：
 * 1. 建立一個Bucket（如果已經存在，則忽略錯誤碼）；
 * 2. 上傳一個檔案到OSS；
 * 3. 下載這個檔案到本地；
 * 4. 清理測試資源：刪除Bucket及其中的所有Objects。
 * 
 * 嘗試執行這段示例程式碼時需要注意：
 * 1. 為了展示在刪除Bucket時除了需要刪除其中的Objects,
 *    示例程式碼最後為刪除掉指定的Bucket，因為不要使用您的已經有資源的Bucket進行測試！
 * 2. 請使用您的API授權金鑰填充ACCESS_ID和ACCESS_KEY常量；
 * 3. 需要準確上傳用的測試檔案，並修改常量uploadFilePath為測試檔案的路徑；
 *    修改常量downloadFilePath為下載檔案的路徑。
 * 4. 該程式僅為示例程式碼，僅供參考，並不能保證足夠健壯。
 *
 */

    private static final String ACCESS_ID = "cvj2e9aH*****";
    private static final String ACCESS_KEY = "KFdm4MeaT******";
    private static final String endPoint = "http://oss-cn-beijing.aliyuncs.com";
    private static final String bucketName = "x******";
	
    // 設定URL過期時間為1天
    private static final Date expiration = new Date(new Date().getTime() + 3600 * 1000 * 24);
    //在自己內部定義自己的一個 例項，只供內部呼叫
    private static final OSSClient client = new OSSClient(endPoint, ACCESS_ID, ACCESS_KEY);
    
    private AliyunOSSUtil(){
        //do something
    }
 

    //單例模式
    //獲得客戶端
    public static OSSClient getOSSClient(){
        return client;
    }
    
    //建立一個Bucket
    public static void ensureBucket()throws OSSException, ClientException{
        try {
            // 建立bucket, 判斷bucket是否存在
        	boolean exists = client.doesBucketExist(bucketName);
        	if(!exists){
        		client.createBucket(bucketName);
        	}else{
        		
        	}
        } catch (ServiceException e) {
            System.out.println(e.getErrorCode() + "  " + e.getErrorMessage());
                throw e;
        }
    }
		
    // 獲取指定bucket下的所有Object資訊
    public void getObjects(OSSClient client,String bucketName){
        ObjectListing listing = client.listObjects(bucketName);
        // 遍歷所有Object
        for (OSSObjectSummary objectSummary : listing.getObjectSummaries()) {
            System.out.println(objectSummary.getKey());
        }      
    }
    
    // 刪除一個Bucket和其中的Objects 
    public static void deleteBucket(OSSClient client, String bucketName)
            throws OSSException, ClientException {

        ObjectListing ObjectListing = client.listObjects(bucketName);
        List<OSSObjectSummary> listDeletes = ObjectListing.getObjectSummaries();
        for (int i = 0; i < listDeletes.size(); i++) {
            String objectName = listDeletes.get(i).getKey();
            // 如果不為空，先刪除bucket下的檔案
            client.deleteObject(bucketName, objectName);
        }
        client.deleteBucket(bucketName);
    }

    // 把Bucket設定為所有人可讀
    public static void setBucketPublicReadable(OSSClient client, String bucketName)
            throws OSSException, ClientException {
        //建立bucket
        client.createBucket(bucketName);

        //設定bucket的訪問許可權，public-read-write許可權
        client.setBucketAcl(bucketName, CannedAccessControlList.PublicRead);
    }

    // 上傳檔案 file
    public static void uploadFile(String key, File file) throws OSSException, ClientException, FileNotFoundException {
	// 獲取指定檔案的輸入流
	InputStream content = new FileInputStream(file);
	// 建立上傳Object的Metadata
<span style="white-space:pre">	</span> ObjectMetadata meta = new ObjectMetadata();
	 // 必須設定ContentLength
	 meta.setContentLength(file.length());
         meta.setContentType("image/*");
	 client.putObject(bucketName, key, content, meta);
    }	 
    
    // 上傳檔案 MultipartFile multipartFile
    public static void uploadMultipartFile(String key, MultipartFile multipartFile) throws OSSException, ClientException, FileNotFoundException {

		 try {
			// 獲取指定檔案的輸入流
			 InputStream content = multipartFile.getInputStream();
			 // 建立上傳Object的Metadata
			 ObjectMetadata meta = new ObjectMetadata();
			 // 必須設定ContentLength
			 meta.setContentLength(multipartFile.getSize() );
			 meta.setContentType("image/*");
			 client.putObject(bucketName, key, content, meta);
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
    }	 
    
    //生成URL
    public static URL getUrl(String key){
    	URL url = client.generatePresignedUrl(bucketName, key, expiration);
    	return url;
    }
    // 下載檔案
    public static void downloadFile(OSSClient client, String bucketName, String key, String fileDownloadPath)
            throws OSSException, ClientException {
        client.getObject(new GetObjectRequest(bucketName, key), new File(fileDownloadPath));
    }
    
  //建立Bucket 裡的虛擬資料夾
  	public static void createFileDir(String dir)throws OSSException, ClientException{
  		ensureBucket();
  		try {
  			client.getObject(bucketName, dir);
  		} catch (ServiceException e) {
  			// TODO Auto-generated catch block
  			if(e.getErrorCode().equals("NoSuchKey")){
  				//要建立的資料夾名稱,在滿足Object命名規則的情況下以"/"結尾
  				  String objectName = dir + "/";
  				  ObjectMetadata objectMeta = new ObjectMetadata();
  				  
  				  /*這裡的size為0,注意OSS本身沒有資料夾的概念,這裡建立的資料夾本質上是一個size為0的Object,dataStream仍然可以有資料   */
  				  byte[] buffer = new byte[0];
  				  ByteArrayInputStream in = new ByteArrayInputStream(buffer);
  				  objectMeta.setContentLength(0);
  				  try {
  					  //建立檔案上傳目錄
  					  client.putObject(bucketName, objectName, in, objectMeta);
  				  }catch(ServiceException se){
  					  System.out.println(se.getErrorCode() + "  " + se.getErrorMessage());
  					  throw e;
  				  }
  				  finally {
  					  try {
  						  in.close();
  					  } catch (IOException ioe) {
  						  // TODO Auto-generated catch block
  						  ioe.printStackTrace();
  					  }
  				  }
  			}
  			
  		}
  		   
      }
    
}