前言：
對(duì)oss的使用做了一下封裝撩独。其中為了可以自動(dòng)更新token，oss的使用基本跑在工作線程胜卤，故如果你有在主線程進(jìn)行操作的疆导，記得打印一下所在線程，必要的時(shí)候轉(zhuǎn)一下線程葛躏，要不然可能會(huì)崩潰的哦澈段。
配置（二選一）
Android studio添加依賴
dependencies {
compile 'com.aliyun.dpa:oss-android-sdk:2.4.5'
compile 'com.squareup.okhttp3:okhttp:3.4.1'
compile 'com.squareup.okio:okio:1.9.0'
}
直接引入jar包（對(duì)Android studio 或者 Eclipse 都適用）
1.在官網(wǎng)下載 sdk 包
2.解壓后得到 jar 包，目前包括 aliyun-oss-sdk-android-x.x.x.jar舰攒、okhttp-3.x.x.jar 和 okio-1.x.x.jar
3.將以上 3 個(gè) jar 包導(dǎo)入 libs 目錄
權(quán)限設(shè)置
確保AndroidManifest.xml 文件中已經(jīng)配置了這些權(quán)限败富，否則，SDK 將無(wú)法正常工作摩窃。
<uses-permission android:name="android.permission.INTERNET"></uses-permission>
<uses-permission android:name="android.permission.ACCESS_NETWORK_STATE"></uses-permission>
<uses-permission android:name="android.permission.ACCESS_WIFI_STATE"></uses-permission>
<uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE"></uses-permission>
混淆設(shè)置
-keep class com.alibaba.sdk.android.oss.** { *; }
-dontwarn okio.**
-dontwarn org.apache.commons.codec.binary.**
實(shí)現(xiàn)方式
首先為了安全起見(jiàn)兽叮，采用的是STS鑒權(quán)模式，則要用到的數(shù)據(jù)都是從后臺(tái)獲得然后應(yīng)用到前臺(tái)的。
ok準(zhǔn)備工作就這么多充择，下面是封裝的一個(gè)工具類
說(shuō)明：
上傳oss需要用到的參數(shù)都是從后臺(tái)獲取到的德玫，因?yàn)槊總€(gè)人的請(qǐng)求方式不同，故獲得參數(shù)的方式我就不貼出來(lái)了椎麦，統(tǒng)一使用getParameter()代替
注意Ｔ咨！观挎！：因?yàn)閕nit方法是跑在工作線程的琴儿，所以從后臺(tái)獲得數(shù)據(jù)的時(shí)候，當(dāng)報(bào)錯(cuò)的時(shí)候你有可能會(huì)彈出toast提示嘁捷，由于toast是在主線程彈出來(lái)的造成，所以如果必須要彈出的時(shí)候記得切換線程
public class OssServiceUtil {
private static OSS oss;
private static OSSCredentialProvider credentialProvider;
private static ClientConfiguration conf;
private String bucket;
private picResultCallback callback;//回調(diào)接口
private String path = 后臺(tái)回調(diào)路徑（后臺(tái)給）;
private OssServiceUtil() {
}
private static volatile OssServiceUtil ossUtils;
public static OssServiceUtil getInstance() {
if (ossUtils == null) {
synchronized (OssServiceUtil.class) {
if (ossUtils == null) {
ossUtils = new OssServiceUtil();
}
}
}
return ossUtils;
}
//初始化使用參數(shù)
public void init() {
getParameter()；//獲得bean,then 以下
bucket=bean.getBucketName();
credentialProvider = new STSGetter();
conf = new ClientConfiguration();
conf.setConnectionTimeout(15 * 1000); // 連接超時(shí)雄嚣，默認(rèn)15秒
conf.setSocketTimeout(15 * 1000); // socket超時(shí)晒屎，默認(rèn)15秒
conf.setMaxConcurrentRequest(5); // 最大并發(fā)請(qǐng)求書(shū)，默認(rèn)5個(gè)
conf.setMaxErrorRetry(2); // 失敗后最大重試次數(shù)缓升，默認(rèn)2次
oss = new OSSClient(MyApp.getContext(), bean.getEndPoint(), credentialProvider, conf);
}
public void setResultCallBack(picResultCallback callback) {
this.callback = callback;
}
/**
* 圖片以路徑的方式上傳
*
* @param 圖片的上傳地址（更后臺(tái)要）
* @param 圖片本地地址
* @param 進(jìn)度條
* @param 顯示圖片的img
* @param type（后臺(tái)要）
*/
public void asyncPutImage(String object, final String localFile, final ProgressBar mProgress, final ImageView img, String type) {
if (object.equals("")) {
return;
}
File file = new File(localFile);
if (!file.exists()) {
return;
}
// 構(gòu)造上傳請(qǐng)求
PutObjectRequest put = new PutObjectRequest(bucket, object, localFile);
//上傳后回調(diào)通知
// 客戶端在上傳Object時(shí)可以指定OSS服務(wù)端在處理完上傳請(qǐng)求后鼓鲁，通知您的業(yè)務(wù)服務(wù)器，在該服務(wù)器確認(rèn)接收了該回調(diào)后將回調(diào)的結(jié)果返回給客戶端港谊。
put.setCallbackParam(new HashMap<String, String>() {
{
put("callbackUrl", path);
put("callbackBody", "filename=${object}&size=${size}&action=${x:action}");}
});
HashMap<String, String> hashMap = new HashMap<>();
hashMap.put("x:action", type)；
put.setCallbackVars(hashMap);
// 異步上傳時(shí)可以設(shè)置進(jìn)度回調(diào)
put.setProgressCallback(new OSSProgressCallback<PutObjectRequest>() {
@Override
public void onProgress(PutObjectRequest request, long currentSize, long totalSize) {
int progress = (int) (100 * currentSize / totalSize);
if (mProgress != null) {
mProgress.setProgress(progress);
}}
});
OSSAsyncTask task = oss.asyncPutObject(put, new OSSCompletedCallback<PutObjectRequest, PutObjectResult>() {
@Override
public void onSuccess(PutObjectRequest request, final PutObjectResult result) {
callback.getPicData(result, localFile);
}
@Override
public void onFailure(PutObjectRequest request, ClientException clientExcepion, ServiceException serviceException) {
String info = "";
// 請(qǐng)求異常
if (clientExcepion != null) {
// 本地異常如網(wǎng)絡(luò)異常等
clientExcepion.printStackTrace();
info = clientExcepion.toString();
}
if (serviceException != null) {
// 服務(wù)異常
Log.e("ErrorCode", serviceException.getErrorCode());
Log.e("RequestId", serviceException.getRequestId());
Log.e("HostId", serviceException.getHostId());
Log.e("RawMessage", serviceException.getRawMessage());
info = serviceException.toString();
}
}
}); }
/**
* 圖片以bitmap的形式上傳
*
* @param object
* @param localFile
* @param mProgress
* @param img
* @param type
*/
public void asyncPutImage(String object, final Bitmap localFile, final ProgressBar mProgress, final ImageView img, String type) {
if (object.equals("")) {
Log.w("AsyncPutImage", "ObjectNull");
return;
}
if (localFile == null) {
Log.w("AsyncPutImage", "bitmapNull");
return;
}
// 構(gòu)造上傳請(qǐng)求
PutObjectRequest put = new PutObjectRequest(bucket, object, getBitmapByte(localFile));
//上傳后回調(diào)通知
// 客戶端在上傳Object時(shí)可以指定OSS服務(wù)端在處理完上傳請(qǐng)求后燥狰，通知您的業(yè)務(wù)服務(wù)器，在該服務(wù)器確認(rèn)接收了該回調(diào)后將回調(diào)的結(jié)果返回給客戶端龙致。
put.setCallbackParam(new HashMap<String, String>() {
{
put("callbackUrl", path);
put("callbackBody",
//參數(shù)跟后臺(tái)商議
"filename=${object}&size=${size}&action=${x:action}}"); }
});
HashMap<String, String> hashMap = new HashMap<>();
hashMap.put("x:action", type);
put.setCallbackVars(hashMap);
OSSAsyncTask task = oss.asyncPutObject(put, new OSSCompletedCallback<PutObjectRequest, PutObjectResult>() {
@Override
public void onSuccess(PutObjectRequest request, final PutObjectResult result) {
Observable.just(result).observeOn(AndroidSchedulers.mainThread()).subscribe(new Action1<PutObjectResult>() {
@Override
public void call(PutObjectResult putObjectResult) {
callback.getPicData(result, "");
}
});
}
@Override
public void onFailure(PutObjectRequest request, ClientException clientExcepion, ServiceException serviceException) {
String info = "";
// 請(qǐng)求異常
if (clientExcepion != null) {
// 本地異常如網(wǎng)絡(luò)異常等
clientExcepion.printStackTrace();
info = clientExcepion.toString();
}
if (serviceException != null) {
// 服務(wù)異常
Log.e("ErrorCode", serviceException.getErrorCode());
Log.e("RequestId", serviceException.getRequestId());
Log.e("HostId", serviceException.getHostId());
Log.e("RawMessage", serviceException.getRawMessage());
info = serviceException.toString();
}
}
});
}
public byte[] getBitmapByte(Bitmap bitmap) {
ByteArrayOutputStream out = new ByteArrayOutputStream();
bitmap.compress(Bitmap.CompressFormat.JPEG, 100, out);
try {
out.flush();
out.close();
} catch (IOException e) {
e.printStackTrace();
}
return out.toByteArray();
}
public interface picResultCallback {
void getPicData(PutObjectResult data, String oldPath);
}
}
2.重載OSSFederationCredentialProvider自動(dòng)更新token
public class STSGetter extends OSSFederationCredentialProvider {
private OSSFederationToken ossFederationToken;
String ak;
String sk;
String token;
String expiration;
public STSGetter() {
}
public OSSFederationToken getFederationToken() {
getParameter()净当；//拿到需要用到的參數(shù)
return new OSSFederationToken(ak, sk, token, expiration);
}}
3.工具類初始化
由于采用的是單例模式，故每次啟動(dòng)App的時(shí)候在MyApp中就初始化util類，拿到工具類的實(shí)例俘闯，方便以后的直接調(diào)用（注意潭苞，由于getParameter()方法需要上傳用戶參數(shù)真朗，故需要在登陸成功后也要初始化util類）
OssServiceUtil.getInstance().init();
4.調(diào)用上傳圖片方法
ossService = OssServiceUtil.getInstance();
ossService.setResultCallBack(this);
//上傳圖片,需要根據(jù)自己的邏輯傳參數(shù)
ossService.asyncPutImage(圖片在阿里上的存儲(chǔ)路徑, 本地路徑, ...);
5.回調(diào)處理圖片邏輯
/**
* 對(duì)圖片上傳回來(lái)的數(shù)據(jù)進(jìn)行處理
* @param data
*/
@Override
public void getPicData(PutObjectResult data, String oldPath) {
Gson gson = new Gson();
OssUploadImage uploadImage = gson.fromJson(data.getServerCallbackReturnBody(), OssUploadImage.class);
........邏輯自己寫吧
}
參考資料：官方文檔
~~喵印
