前言：
对oss的使用做了一下封装。其中为了可以自动更新token，oss的使用基本跑在工作线程，故如果你有在主线程进行操作的，记得打印一下所在线程，必要的时候转一下线程，要不然可能会崩溃的哦。
配置（二选一）
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包（对Android studio 或者 Eclipse 都适用）
1.在官网下载 sdk 包
2.解压后得到 jar 包，目前包括 aliyun-oss-sdk-android-x.x.x.jar、okhttp-3.x.x.jar 和 okio-1.x.x.jar
3.将以上 3 个 jar 包导入 libs 目录
权限设置
确保AndroidManifest.xml 文件中已经配置了这些权限，否则，SDK 将无法正常工作。
<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>
混淆设置
-keep class com.alibaba.sdk.android.oss.** { *; }
-dontwarn okio.**
-dontwarn org.apache.commons.codec.binary.**
实现方式
首先为了安全起见，采用的是STS鉴权模式，则要用到的数据都是从后台获得然后应用到前台的。
ok准备工作就这么多，下面是封装的一个工具类
说明：
上传oss需要用到的参数都是从后台获取到的，因为每个人的请求方式不同，故获得参数的方式我就不贴出来了，统一使用getParameter()代替
注意！！！：因为init方法是跑在工作线程的，所以从后台获得数据的时候，当报错的时候你有可能会弹出toast提示，由于toast是在主线程弹出来的，所以如果必须要弹出的时候记得切换线程
public class OssServiceUtil {
private static OSS oss;
private static OSSCredentialProvider credentialProvider;
private static ClientConfiguration conf;
private String bucket;
private picResultCallback callback;//回调接口
private String path = 后台回调路径（后台给）;
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;
}
//初始化使用参数
public void init() {
getParameter()；//获得bean,then 以下
bucket=bean.getBucketName();
credentialProvider = new STSGetter();
conf = new ClientConfiguration();
conf.setConnectionTimeout(15 * 1000); // 连接超时，默认15秒
conf.setSocketTimeout(15 * 1000); // socket超时，默认15秒
conf.setMaxConcurrentRequest(5); // 最大并发请求书，默认5个
conf.setMaxErrorRetry(2); // 失败后最大重试次数，默认2次
oss = new OSSClient(MyApp.getContext(), bean.getEndPoint(), credentialProvider, conf);
}
public void setResultCallBack(picResultCallback callback) {
this.callback = callback;
}
/**
* 图片以路径的方式上传
*
* @param 图片的上传地址（更后台要）
* @param 图片本地地址
* @param 进度条
* @param 显示图片的img
* @param type（后台要）
*/
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;
}
// 构造上传请求
PutObjectRequest put = new PutObjectRequest(bucket, object, localFile);
//上传后回调通知
// 客户端在上传Object时可以指定OSS服务端在处理完上传请求后，通知您的业务服务器，在该服务器确认接收了该回调后将回调的结果返回给客户端。
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);
// 异步上传时可以设置进度回调
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 = "";
// 请求异常
if (clientExcepion != null) {
// 本地异常如网络异常等
clientExcepion.printStackTrace();
info = clientExcepion.toString();
}
if (serviceException != null) {
// 服务异常
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;
}
// 构造上传请求
PutObjectRequest put = new PutObjectRequest(bucket, object, getBitmapByte(localFile));
//上传后回调通知
// 客户端在上传Object时可以指定OSS服务端在处理完上传请求后，通知您的业务服务器，在该服务器确认接收了该回调后将回调的结果返回给客户端。
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);
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 = "";
// 请求异常
if (clientExcepion != null) {
// 本地异常如网络异常等
clientExcepion.printStackTrace();
info = clientExcepion.toString();
}
if (serviceException != null) {
// 服务异常
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自动更新token
public class STSGetter extends OSSFederationCredentialProvider {
private OSSFederationToken ossFederationToken;
String ak;
String sk;
String token;
String expiration;
public STSGetter() {
}
public OSSFederationToken getFederationToken() {
getParameter()；//拿到需要用到的参数
return new OSSFederationToken(ak, sk, token, expiration);
}}
3.工具类初始化
由于采用的是单例模式，故每次启动App的时候在MyApp中就初始化util类，拿到工具类的实例，方便以后的直接调用（注意，由于getParameter()方法需要上传用户参数，故需要在登陆成功后也要初始化util类）
OssServiceUtil.getInstance().init();
4.调用上传图片方法
ossService = OssServiceUtil.getInstance();
ossService.setResultCallBack(this);
//上传图片,需要根据自己的逻辑传参数
ossService.asyncPutImage(图片在阿里上的存储路径, 本地路径, ...);
5.回调处理图片逻辑
/**
* 对图片上传回来的数据进行处理
* @param data
*/
@Override
public void getPicData(PutObjectResult data, String oldPath) {
Gson gson = new Gson();
OssUploadImage uploadImage = gson.fromJson(data.getServerCallbackReturnBody(), OssUploadImage.class);
........逻辑自己写吧
}
参考资料：官方文档
~~喵印
