阿里雲圖片上傳下載

未註冊雲存儲不知道好很差使

package test;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.InputStream;
import java.util.List;

import com.aliyun.openservices.ClientException;
import com.aliyun.openservices.ServiceException;
import com.aliyun.openservices.oss.OSSClient;
import com.aliyun.openservices.oss.OSSErrorCode;
import com.aliyun.openservices.oss.OSSException;
import com.aliyun.openservices.oss.model.CannedAccessControlList;
import com.aliyun.openservices.oss.model.GetObjectRequest;
import com.aliyun.openservices.oss.model.OSSObjectSummary;
import com.aliyun.openservices.oss.model.ObjectListing;
import com.aliyun.openservices.oss.model.ObjectMetadata;

public class TestOSS {
    /**
     * 阿里雲ACCESS_ID
     */
    private static String ACCESS_ID = "你的ACCESS_ID";
    /**
     * 阿里雲ACCESS_KEY
     */
    private  static String ACCESS_KEY = "你的ACCESS_KEY";
    /**
     * 阿里雲OSS_ENDPOINT  青島Url
     */
    private static String OSS_ENDPOINT = "http://oss-cn-qingdao.aliyuncs.com";
     
    /**
     * 阿里雲BUCKET_NAME  OSS
     */
    private static String BUCKET_NAME = "demo10";

    public static void main(String[] args) {
        //String bucketName = "demo10";
        String Objectkey = "photo1.jpg";
         
        String uploadFilePath = "D:\\photo.jpg";
        String downloadFilePath = "D:\\photo1.jpg";
         
        // 使用默認的OSS服務器地址建立OSSClient對象,不叫OSS_ENDPOINT表明使用杭州節點，青島節點要加上否則包異常
        OSSClient client = new OSSClient(OSS_ENDPOINT, ACCESS_ID, ACCESS_KEY);
         
        //若是你想配置OSSClient的一些細節的參數，能夠在構造OSSClient的時候傳入ClientConfiguration對象。
        //ClientConfiguration是OSS服務的配置類，能夠爲客戶端配置代理，最大鏈接數等參數。
        //具體配置看http://aliyun_portal_storage.oss.aliyuncs.com/oss_api/oss_javahtml/OSSClient.html#id2
        //ClientConfiguration conf = new ClientConfiguration();
        //OSSClient client = new OSSClient(OSS_ENDPOINT, ACCESS_ID, ACCESS_KEY, conf);
 
         
        try {
            ensureBucket(client, BUCKET_NAME);
            setBucketPublicReadable(client, BUCKET_NAME);
 
            System.out.println("正在上傳...");
            uploadFile(client, BUCKET_NAME, Objectkey, uploadFilePath);
 
            System.out.println("正在下載...");
            downloadFile(client, BUCKET_NAME, Objectkey, downloadFilePath);
        }catch(Exception e){
            e.printStackTrace();
        } finally {
            deleteBucket(client, BUCKET_NAME);
        }
    }
    
     /**
     * 建立Bucket
     *
     * @param client  OSSClient對象
     * @param bucketName  BUCKET名
     * @throws OSSException
     * @throws ClientException
     */
    public static void ensureBucket(OSSClient client, String bucketName)throws OSSException, ClientException{
        try{
            client.createBucket(bucketName);
        }catch(ServiceException e){
            if(!OSSErrorCode.BUCKES_ALREADY_EXISTS.equals(e.getErrorCode())){
                throw e;
            }
        }
    }
    
    /**
     * 刪除一個Bucket和其中的Objects
     *
     * @param client  OSSClient對象
     * @param bucketName  Bucket名
     * @throws OSSException
     * @throws ClientException
     */
    private 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();
            System.out.println("objectName = " + objectName);
            //若是不爲空，先刪除bucket下的文件
            client.deleteObject(bucketName, objectName);
        }
        client.deleteBucket(bucketName);
    }
    
    /**
     * 把Bucket設置成全部人可讀
     *
     * @param client  OSSClient對象
     * @param bucketName  Bucket名
     * @throws OSSException
     * @throws ClientException
     */
    private static void setBucketPublicReadable(OSSClient client, String bucketName)throws OSSException, ClientException{
        //建立bucket
        client.createBucket(bucketName);
         
        //設置bucket的訪問權限， public-read-write權限
        client.setBucketAcl(bucketName, CannedAccessControlList.PublicRead);
    }
    
    /**
     * 上傳文件
     *
     * @param client  OSSClient對象
     * @param bucketName  Bucket名
     * @param Objectkey  上傳到OSS起的名
     * @param filename  本地文件名
     * @throws OSSException
     * @throws ClientException
     * @throws FileNotFoundException
     */
    private static void uploadFile(OSSClient client, String bucketName, String Objectkey, String filename)
            throws OSSException, ClientException, FileNotFoundException{
        File file = new File(filename);
        ObjectMetadata objectMeta = new ObjectMetadata();
        objectMeta.setContentLength(file.length());
        //判斷上傳類型，多的可根據本身需求來斷定
        if (filename.endsWith("xml")) {
            objectMeta.setContentType("text/xml");
        }
        else if (filename.endsWith("jpg")) {
            objectMeta.setContentType("image/jpeg");
        }
        else if (filename.endsWith("png")) {
            objectMeta.setContentType("image/png");
        }
         
        InputStream input = new FileInputStream(file);
        client.putObject(bucketName, Objectkey, input, objectMeta);
    }
    
    /**
     *  下載文件
     *
     * @param client  OSSClient對象
     * @param bucketName  Bucket名
     * @param Objectkey  上傳到OSS起的名
     * @param filename 文件下載到本地保存的路徑
     * @throws OSSException
     * @throws ClientException
     */
    private static void downloadFile(OSSClient client, String bucketName, String Objectkey, String filename)
            throws OSSException, ClientException {
        client.getObject(new GetObjectRequest(bucketName, Objectkey),
                new File(filename));
    }

}