Android Oss上传图片的使用示例

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'}

<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.**

public class OssService {  private OSS oss;  private String bucket;  private picResultCallback callback;//回调接口  private String path=地址(后台告诉);  public OssService(OSS oss, String bucket,picResultCallback callback) {    this.oss = oss;    this.bucket = bucket;    this.callback=callback;  }  /**object字段为图片的上传地址（具体地址的前缀后端给，这个是拼起  *来的一个路径）  *localFile图片的本地地址  *mProgress 进度条  *img 显示图片的控件  *type 类型 *／  public void asyncPutImage(String object, final String localFile, final ProgressBar mProgress, final ImageView img,String type) {    if (object.equals("")) {      Log.w("AsyncPutImage", "ObjectNull");      return;    }    File file = new File(localFile);    if (!file.exists()) {      Log.w("AsyncPutImage", "FileNotExist");      Log.w("LocalFile", localFile);      return;    }    // 构造上传请求    PutObjectRequest put = new PutObjectRequest(bucket, object, localFile);      put.setCallbackParam(new HashMap<String, String>() {        {          put("callbackUrl", path);          put("callbackBody", "filename=${object}&size=${size}&id=${x:id}&action=${x:action}");//https://help.aliyun.com/document_detail/31989.html?spm=5176.doc31984.6.883.brskVg        }      });    HashMap<String, String> hashMap=new HashMap<>();    hashMap.put("x:id",id);    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);        mProgress.setProgress(progress);      }    });    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) {            mProgress.setVisibility(View.GONE);            img.setColorFilter(null);            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();        }      }    });  }//成功的回调接口  public interface picResultCallback {    void getPicData(PutObjectResult data,String oldPath);  }}

public OssService initOSS(String endpoint, String bucket) {  OSSCredentialProvider credentialProvider;  credentialProvider = new STSGetter(tokenBean);  //设置网络参数  ClientConfiguration conf = new ClientConfiguration();  conf.setConnectionTimeout(15 * 1000); // 连接超时，默认15秒  conf.setSocketTimeout(15 * 1000); // socket超时，默认15秒  conf.setMaxConcurrentRequest(5); // 最大并发请求书，默认5个  conf.setMaxErrorRetry(2); // 失败后最大重试次数，默认2次  OSS oss = new OSSClient(getApplicationContext(), endpoint, credentialProvider, conf);  return new OssService(oss, bucket, this);}

public class OSSAuthCredentialsProvider extends OSSFederationCredentialProvider {  private String mAuthServerUrl;  private AuthDecoder mDecoder;  public OSSAuthCredentialsProvider(String authServerUrl) {    this.mAuthServerUrl = authServerUrl;  }  /**   * set auth server url   * @param authServerUrl   */  public void setAuthServerUrl(String authServerUrl) {    this.mAuthServerUrl = authServerUrl;  }  /**   * set response data decoder   * @param decoder   */  public void setDecoder(AuthDecoder decoder) {    this.mDecoder = decoder;  }  @Override  public OSSFederationToken getFederationToken() throws ClientException {    OSSFederationToken authToken;    String authData;    try {      URL stsUrl = new URL(mAuthServerUrl);      HttpURLConnection conn = (HttpURLConnection) stsUrl.openConnection();      conn.setConnectTimeout(10000);      InputStream input = conn.getInputStream();      authData = IOUtils.readStreamAsString(input, OSSConstants.DEFAULT_CHARSET_NAME);      if (mDecoder != null) {        authData = mDecoder.decode(authData);      }      JSONObject jsonObj = new JSONObject(authData);      int statusCode = jsonObj.getInt("StatusCode");      if (statusCode == 200) {        String ak = jsonObj.getString("AccessKeyId");        String sk = jsonObj.getString("AccessKeySecret");        String token = jsonObj.getString("SecurityToken");        String expiration = jsonObj.getString("Expiration");        authToken = new OSSFederationToken(ak, sk, token, expiration);      } else {        String errorCode = jsonObj.getString("ErrorCode");        String errorMessage = jsonObj.getString("ErrorMessage");        throw new ClientException("ErrorCode: " + errorCode + "| ErrorMessage: " + errorMessage);      }      return authToken;    } catch (Exception e) {      throw new ClientException(e);    }  }  public interface AuthDecoder {    String decode(String data);  }}

public class STSGetter extends OSSFederationCredentialProvider {  private OSSFederationToken ossFederationToken;  String ak;  String sk;  String token ;  String expiration ;  public STSGetter(TokenBean bean) {    this.ak = bean.getCredentials().getAccessKeyId();    this.sk = bean.getCredentials().getAccessKeySecret();    this.token = bean.getCredentials().getSecurityToken();    this.expiration = bean.getCredentials().getExpiration();  }  public OSSFederationToken getFederationToken() {  return new OSSFederationToken(ak,sk,token,expiration);  }}

//实例化OSSClient (自己是在onCreate()中实例化的，当然考虑到token的过期问题，也有在onResume()中再次实例化一次)ossService = initOSS(tokenBean.getBucket().getEndPoint(), tokenBean.getBucket().getBucketName());//上传图片,需要根据自己的逻辑传参数ossService.asyncPutImage(图片在阿里上的存储路径, 本地路径, ...);

/** * 对图片上传回来的数据进行处理 * @param data */  @Override  public void getPicData(PutObjectResult data, String oldPath) {    Gson gson = new Gson();    OssUploadImage uploadImage = gson.fromJson(data.getServerCallbackReturnBody(), OssUploadImage.class);          ........逻辑自己写吧}