本文讲解Android端使用阿里云OSS认证进行实现断点续传的功能。
文末附阿里文档地址及github地址(阿里文档是有点垃圾,很难找...)
思想:
- 进行OSS认证后,认证后的信息要存储起来存储bucket,objectKey(就是对应的服务器上的资源存储地址),signature,accessId,host、dir、filename(能用到的都存储起来,和数据绑定,比如你上传A文件,就把这些信息绑定在A文件上,存储至数据库内)
- 暂停、调用api 暂停上传中的数据
- 读取A文件绑定的ali授权后创建一个oss对象再重新上传即可
用的断点记录在本地持久保存时的方式
String recordDirectory = Environment.getExternalStorageDirectory().getAbsolutePath() + "/oss_record/";
File recordDir = new File(recordDirectory);
// 确保断点记录的保存文件夹已存在,如果不存在则新建断点记录的保存文件夹。
if (!recordDir.exists()) {
recordDir.mkdirs();
}
// 创建断点续传上传请求,并指定断点记录文件的保存路径,保存路径为断点记录文件的绝对路径。
ResumableUploadRequest request = new ResumableUploadRequest("<bucketName>", "<objectKey>", "<uploadFilePath>", recordDirectory);
// 调用OSSAsyncTask cancel()方法时,DeleteUploadOnCancelling设置为false时,则不删除断点记录文件。如果不设置此参数,则默认值为true,表示删除断点记录文件,下次再上传用一个文件时则重新上传。
request.setDeleteUploadOnCancelling(false);
// 设置上传回调。
request.setProgressCallback(new OSSProgressCallback<ResumableUploadRequest>() {
@Override
public void onProgress(ResumableUploadRequest request, long currentSize, long totalSize) {
Log.d("resumableUpload", "currentSize: " + currentSize + " totalSize: " + totalSize);
}
});
OSSAsyncTask resumableTask = oss.asyncResumableUpload(request, new OSSCompletedCallback<ResumableUploadRequest, ResumableUploadResult>() {
@Override
public void onSuccess(ResumableUploadRequest request, ResumableUploadResult result) {
Log.d("resumableUpload", "success!");
}
@Override
public void onFailure(ResumableUploadRequest request, ClientException clientExcepion, ServiceException serviceException) {
// 异常处理。
}
});
暂停的方法:
resumableTask.cancel();
注:
在调用了cancel();后还会继续走几次progress
参考文档:
阿里断点续传文档:https://www.alibabacloud.com/help/zh/doc-detail/32050.htm
Github地址:https://github.com/aliyun/aliyun-oss-android-sdk
目前已经实现了暂停恢复继续的功能,若有问题可留言讨论
网友评论