以下部落格簡單介紹連線阿里雲的OSS，新建Bucket，刪除Bucket，向阿里雲的OSS儲存中儲存單個檔案，獲取單個檔案，刪除單個檔案等功能。

以下為pom依賴：

		<!-- aliyun oss -->
		<dependency>
			<groupId>com.aliyun.oss</groupId>
			<artifactId>aliyun-sdk-oss</artifactId>
			<version>2.2.1</version>
		</dependency>

下邊為oss的配置檔案oss.properties，也可以直接寫入程式碼:

endpoint=oss-cn-beijing.aliyuncs.com
accessKeyId=您的key
accessKeySecret=您的secret

OSS的操作程式碼：

package my.demo.java.z.aliyun.oss;

import java.io.File;
import java.io.FileInputStream;
import java.io.InputStream;
import java.util.PropertyResourceBundle;
import java.util.ResourceBundle;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

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;

public class OSSUnit {
	
	//log
	private static final Logger LOG = LoggerFactory.getLogger(OSSUnit.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;
	
	//init static datas
	static{
		ResourceBundle bundle = PropertyResourceBundle.getBundle("properties.oss");
		ENDPOINT = bundle.containsKey("endpoint") == false ? "" : bundle.getString("endpoint");
		ACCESS_KEY_ID = bundle.containsKey("accessKeyId") == false? "" : bundle.getString("accessKeyId");
		ACCESS_KEY_SECRET = bundle.containsKey("accessKeySecret") == false ? "" : bundle.getString("accessKeySecret");
	}
	
	/**
	 * 獲取阿里雲OSS客戶端物件
	 * */
	public static final OSSClient getOSSClient(){
		return new OSSClient(ENDPOINT,ACCESS_KEY_ID, ACCESS_KEY_SECRET);
	}
	
	/**
	 * 新建Bucket  --Bucket許可權:私有
	 * @param bucketName bucket名稱
	 * @return true 新建Bucket成功
	 * */
	public static final boolean createBucket(OSSClient client, String bucketName){
		Bucket bucket = client.createBucket(bucketName); 
		return bucketName.equals(bucket.getName());
	}
	
	/**
	 * 刪除Bucket 
	 * @param bucketName bucket名稱
	 * */
	public static final void deleteBucket(OSSClient client, String bucketName){
		client.deleteBucket(bucketName); 
		LOG.info("刪除" + bucketName + "Bucket成功");
	}
	
	/**
	 * 向阿里雲的OSS儲存中儲存檔案  --file也可以用InputStream替代
	 * @param client OSS客戶端
	 * @param file 上傳檔案
	 * @param bucketName bucket名稱
	 * @param diskName 上傳檔案的目錄  --bucket下檔案的路徑
	 * @return String 唯一MD5數字簽名
	 * */
	public static final String uploadObject2OSS(OSSClient client, File file, String bucketName, String diskName) {
		String resultStr = null;
		try {
			InputStream is = new FileInputStream(file);
			String fileName = file.getName();
			Long fileSize = file.length();
			//建立上傳Object的Metadata
			ObjectMetadata metadata = new ObjectMetadata();
			metadata.setContentLength(is.available());
			metadata.setCacheControl("no-cache");
			metadata.setHeader("Pragma", "no-cache");
			metadata.setContentEncoding("utf-8");
			metadata.setContentType(getContentType(fileName));
			metadata.setContentDisposition("filename/filesize=" + fileName + "/" + fileSize + "Byte.");
			//上傳檔案 
			PutObjectResult putResult = client.putObject(bucketName, diskName + fileName, is, metadata);
			//解析結果
			resultStr = putResult.getETag();
		} catch (Exception e) {
			LOG.error("上傳阿里雲OSS伺服器異常." + e.getMessage(), e);
		}
		return resultStr;
	}
	
    /** 
     * 根據key獲取OSS伺服器上的檔案輸入流
 	 * @param client OSS客戶端
 	 * @param bucketName bucket名稱
 	 * @param diskName 檔案路徑
 	 * @param key Bucket下的檔案的路徑名+檔名
     */  
     public static final InputStream getOSS2InputStream(OSSClient client, String bucketName, String diskName, String key){ 
		OSSObject ossObj = client.getObject(bucketName, diskName + key);
		return ossObj.getObjectContent();	
     }  
	
   /** 
    * 根據key刪除OSS伺服器上的檔案 
  	* @param client OSS客戶端
  	* @param bucketName bucket名稱
  	* @param diskName 檔案路徑
  	* @param key Bucket下的檔案的路徑名+檔名
    */  
	  public static void deleteFile(OSSClient client, String bucketName, String diskName, String key){  
	  	client.deleteObject(bucketName, diskName + key); 
	  	LOG.info("刪除" + bucketName + "下的檔案" + diskName + key + "成功");
	  }  
     
    /** 
     * 通過檔名判斷並獲取OSS服務檔案上傳時檔案的contentType 
     * @param fileName 檔名
     * @return 檔案的contentType   
     */  
     public static final 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";
        return "text/html";  
     }  

}
 

程式碼對應測試程式碼junit如下:

package my.demo.java.z.aliyun.oss;

import static org.junit.Assert.assertEquals;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;

import org.junit.Before;
import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.aliyun.oss.OSSClient;

public class OSSUnitTest {
	
	//log
	private static final Logger LOG = LoggerFactory.getLogger(OSSUnitTest.class);
	
	private OSSUnit ossunit = null;
	private OSSClient client = null;
	private String bucketName = "oss-test-my";
	@Before
	public void initUnit(){
		ossunit = new OSSUnit();
		client = OSSUnit.getOSSClient();
	}

	@Test
	public void testCreateBucket() {
		String bucketName = "oss-test-my";
		//建立bucket
		assertEquals(true, OSSUnit.createBucket(client, bucketName));
	}
	
	@Test
	public void testDeleteBucket(){
		String bucketName = "oss-test-my";
		//刪除bucket
		OSSUnit.deleteBucket(client, bucketName);
		//console log :刪除oss-test-myBucket成功
	}
	
	@Test
	public void testUploadObject2OSS(){
		//上傳檔案
		String flilePathName = "C:/Users/Tony_tian/Desktop/csdnimg/preossimg.jpg";
		File file = new File(flilePathName);
		String diskName = "datas/image/";
		String md5key = OSSUnit.uploadObject2OSS(client, file, bucketName, diskName);
		LOG.info("上傳後的檔案MD5數字唯一簽名:" + md5key);  //上傳後的檔案MD5數字唯一簽名:A30B046A34EB326C4A3BBD784333B017
	}
	
	@Test
	public void testGetOSS2InputStream(){
		//獲取檔案
		try {
			BufferedInputStream bis = new BufferedInputStream(OSSUnit.getOSS2InputStream(client, bucketName, "datas/image/", "preossimg.jpg"));
			String resfile = "C:/Users/Tony_tian/Desktop/csdnimg/preossimg_res.jpg";
			BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(new File(resfile)));
			int itemp = 0;
			while((itemp = bis.read()) != -1){
				bos.write(itemp);
			}
			LOG.info("檔案獲取成功"); //console log :檔案獲取成功
			bis.close();
			bos.close();
		} catch (Exception e) {
			LOG.error("從OSS獲取檔案失敗:" + e.getMessage(), e);
		}
	}
	
	@Test
	public void testDeleteFile(){
		//注：資料夾下只有一個檔案，則資料夾也會一起刪除；如果多個檔案，只會刪除指定檔名的檔案
		//刪除檔案
		OSSUnit.deleteFile(client, bucketName, "datas/image/", "preossimg.jpg");
		//console log : 刪除oss-test-my下的檔案datas/image/preossimg.jpg成功
	}

}
 

新建Bucket(Bucket許可權:私有，公開需手動設定)前後和刪除Bucket：

上傳檔案前後即刪除檔案：

注：資料夾下只有一個檔案，則資料夾也會一起刪除；如果多個檔案，只會刪除指定檔名的檔案

上邊記錄為私有檔案的獲取，如果要獲取“Bucket許可權:公共讀”的就很簡單了：

<!DOCTYPE html>
<html>
	<head>
		<meta charset="utf-8" />
		<title>Aliyun-OSS</title>
		<meta name="keywords" content="Aliyun-OSS"/>
		<meta name="description" content="Aliyun-OSS" />
	<!--	<link rel="stylesheet" href="${serverprc }/static/css/common.css" />
		<script type="text/javascript" src="${serverprc }/static/js/common.js" charset="utf-8"></script> -->
	</head>
	<body>
		<div>
			Bucket許可權:公共讀的圖片:<img src="http://tsxs-datas.oss-cn-beijing.aliyuncs.com/image/public/tsxs_title_logo.ico"/>
		</div>
	</body>
</html>