Rxjava,多线程，断点续传
安卓多线程断点续传
非WIFI暂停，手动暂停。
话不多说，上图，上demo。
喜欢的订阅关注一下，每周会更新3-5个案例。
断点续传
手动暂停
多线程暂停
准备工作
1.添加Gradle依赖Download2.0.3(demo中有)
dependencies{
compile'zlc.season:rxdownload2:2.0.2'
}
2.配置权限
注意: Android 6.0 以上还必须申请运行时权限, 如果遇到不能下载, 请先检查权限
1.创建RxDownload实例
RxDownload rxDownload=RxDownload.getInstance(context);//单例
2.参数配置，可以配置的参数如下:
RxDownload rxDownload=RxDownload.getInstance(context)
.retrofit(myRetrofit)//若需要自己的retrofit客户端,可在这里指定
.defaultSavePath(defaultSavePath)//设置默认的下载路径
.maxThread(3)//设置最大线程
.maxRetryCount(3)//设置下载失败重试次数
.maxDownloadNumber(5)//Service同时下载数量
...
3.下载参数说明
·xxDownload(String url)当只传url时，会自动从服务器获取文件名
·xxDownload(String url, String saveName)也可手动指定保存的文件名称
·xxDownload(String url,String saveName,String savePath)手动指定文件名和保存路径
·xxDownload(DownloadBean bean)当需要保存额外信息到数据库时，可以手动构造Download Bean，具体细节请查看源码
·常规下载，不具备后台下载能力
·适合轻量下载
# 这里有更多资料哈：点我
验证码022
1.调用方式
Disposable disposable=RxDownload.getInstance(this)
.download(url)//只传url即可
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(newConsumer() {
@Override
publicvoidaccept(DownloadStatusstatus)throwsException {
//DownloadStatus为下载进度
}
},newConsumer() {
@Override
publicvoidaccept(Throwablethrowable)throwsException {
//下载失败
}
},newAction() {
@Override
publicvoidrun()throwsException {
//下载成功
}
});
2.暂停下载
//获得订阅返回的Disposable.Disposable disposable=RxDownload.getInstance(context)
.download(url)...
//取消订阅, 即可暂停下载if(disposable!=null&&!disposable.isDisposed()) {
disposable.dispose();
}
3.继续下载
//重新调用download()方法，传入相同的url即可//若该url支持断点续传则继续下载，若不支持则重新下载Disposable disposable=RxDownload.getInstance(context)
.download(url)...
4.transferform形式
提供给RxJava的Compose操作符使用，例如与RxPermission结合使用
RxPermission是为Android 6.0解决运行时权限的一个库, 这里是该库的地址:Rxpermissions（demo中有）
disposable=RxPermissions.getInstance(mContext)
.request(Manifest.permission.WRITE_EXTERNAL_STORAGE)//申请存储卡权限
.doOnNext(newConsumer() {
@Override
publicvoidaccept(Booleangranted)throwsException {
if(!granted) {//权限被拒绝
thrownewRuntimeException("no permission");
}
}
})
.observeOn(Schedulers.io())
.compose(RxDownload.getInstance(context).transform(url))//download
.observeOn(AndroidSchedulers.mainThread())
.subscribe(newConsumer() {...});
·使用Service进行下载, 具备后台下载能力
·具备下载管理功能，能设置同时下载数量
·能够批量添加下载任务
1.添加单个任务
RxDownload.getInstance(this)
.serviceDownload(url)//只需传url即可，添加一个下载任务
.subscribe(newConsumer() {
@Override
publicvoidaccept(Objecto)throwsException {
Toast.makeText(MainActivity.this,"开始下载", Toast.LENGTH_SHORT).show();
}
},newConsumer() {
@Override
publicvoidaccept(Throwablethrowable)throwsException {
Log.w(TAG, throwable);
Toast.makeText(MainActivity.this,"添加任务失败", Toast.LENGTH_SHORT).show();
}
});//只是添加下载任务到队列中，因此不需要取消订阅，取消订阅也不会导致下载暂停
2.添加多个任务
//批量下载RxDownload.getInstance(this)
.serviceMultiDownload(missionId, url1, url2, url3)//添加三个任务
.subscribe(newConsumer() {
@Override
publicvoidaccept(Objecto)throwsException {
Toast.makeText(MainActivity.this,"开始下载", Toast.LENGTH_SHORT).show();
}
},newConsumer() {
@Override
publicvoidaccept(Throwablethrowable)throwsException {
Log.w(TAG, throwable);
Toast.makeText(MainActivity.this,"添加任务失败", Toast.LENGTH_SHORT).show();
}
});//需要missionId，可以是任意字符串//可通过该missionId暂停或删除该批量下载的所有任务//可通过该missionId查询该批量下载的所有任务的下载情况
3.接收下载事件和下载状态.
//接收事件可以在任何地方接收，不管该任务是否开始下载均可接收.Disposable disposable=mRxDownload.receiveDownloadStatus(url)
.subscribe(newConsumer() {
@Override
publicvoidaccept(DownloadEventevent)throwsException {
//当事件为Failed时, 才会有异常信息, 其余时候为null.
if(event.getFlag()==DownloadFlag.FAILED) {
Throwable throwable=event.getError();
Log.w("Error", throwable);
}
mDownloadController.setEvent(event);
updateProgress(event);
}
});// 在Activity销毁时取消订阅，取消订阅即可取消接收事件，但并不会暂停下载.// 不管任务是否开始下载, 都能获取到该url对应的事件和状态.// 只会收到onNext事件，不会收到onError和onComplete事件，因此只需监听onNext即可.
4.暂停下载
//单一暂停，暂停地址为url的下载任务
rxDownload.pauseServiceDownload(url).subscribe();
//批量暂停，暂停该missionId代表的所有任务
rxDownload.pauseServiceDownload(missionId).subscribe();
5.继续下载
//再次调用下载方法并传入相同的url即可继续下载RxDownload.getInstance(this)
.serviceDownload(url)
...
6.删除下载
//暂停地址为url的下载并从数据库中删除记录，deleteFile为true会同时删除该url下载产生的所有文件
rxDownload.deleteServiceDownload(url, deleteFile).subscribe();
//批量删除，暂停该missionId代表的所有任务，同时删除所有任务的记录
rxDownload.deleteServiceDownload(missionId,deleteFile).subscribe();
7.transferform形式
//single url
.compose(rxDownload.transformService(url))
//multi url
.compose(rxDownload.transformMulti(missionId,url1,url2,url3))
获取数据库中所有的下载记录
mRxDownload.getTotalDownloadRecords()
.subscribe(newAction1>() {
@Override
publicvoidcall(Listlist) {
mAdapter.addAll(list);
}
});
获取下载的文件
//利用url获取File[] files=rxDownload.getRealFiles(url);if(files!=null) {
File file=files[0];
}//利用saveName及savePath获取File file=rxDownload.getRealFiles(saveName,savePath)[0];
欢迎关注我的公众号“dongnaoedu”更多资源分享
