RxDownload
项目地址： ssseasonnn/RxDownload 
简介：基于 RxJava 打造的多线程下载工具, 支持断点续传, 下载管理等
更多： 作者 提 Bug
标签：
RxJava- Download-
基于 RxJava 打造的下载工具, 支持多线程下载和断点续传, 智能判断是否支持断点续传等功能
Read this in other languages: 中文, English
更新日志：更新日志搬到这里了
效果图
1.添加 Gradle 依赖 
dependencies{
compile 'zlc.season:rxdownload2:2.0.4'
}
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，具体细节请查看源码
- 常规下载，不具备后台下载能力
- 适合轻量下载
1.调用方式
Disposable disposable = RxDownload.getInstance(this)
.download(url) //只传 url 即可
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer() {
@Override
public void accept(DownloadStatus status) throws Exception {
//DownloadStatus 为下载进度
}
}, new Consumer() {
@Override
public void accept(Throwable throwable) throws Exception {
//下载失败
}
}, new Action() {
@Override
public void run() throws Exception {
//下载成功
}
});
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 解决运行时权限的一个库, 这里是该库的地址: RxPermission
disposable = RxPermissions.getInstance(mContext)
.request(Manifest.permission.WRITE_EXTERNAL_STORAGE) //申请存储卡权限
.doOnNext(new Consumer() {
@Override
public void accept(Boolean granted) throws Exception {
if (!granted) { //权限被拒绝
throw new RuntimeException("no permission");
}
}
})
.observeOn(Schedulers.io())
.compose(RxDownload.getInstance(context).transform(url)) //download
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer() { ... });
Service Download
- 使用 Service 进行下载, 具备后台下载能力
- 具备下载管理功能，能设置同时下载数量
- 能够批量添加下载任务
1.添加单个任务
RxDownload.getInstance(this)
.serviceDownload(url) //只需传 url 即可，添加一个下载任务
.subscribe(new Consumer() {
@Override
public void accept(Object o) throws Exception {
Toast.makeText(MainActivity.this, "开始下载", Toast.LENGTH_SHORT).show();
}
}, new Consumer() {
@Override
public void accept(Throwable throwable) throws Exception {
Log.w(TAG, throwable);
Toast.makeText(MainActivity.this, "添加任务失败", Toast.LENGTH_SHORT).show();
}
});
//只是添加下载任务到队列中，因此不需要取消订阅，取消订阅也不会导致下载暂停
2.添加多个任务
//批量下载
RxDownload.getInstance(this)
.serviceMultiDownload(missionId, url1, url2, url3) //添加三个任务
.subscribe(new Consumer() {
@Override
public void accept(Object o) throws Exception {
Toast.makeText(MainActivity.this, "开始下载", Toast.LENGTH_SHORT).show();
}
}, new Consumer() {
@Override
public void accept(Throwable throwable) throws Exception {
Log.w(TAG, throwable);
Toast.makeText(MainActivity.this, "添加任务失败", Toast.LENGTH_SHORT).show();
}
});
//需要 missionId，可以是任意字符串
//可通过该 missionId 暂停或删除该批量下载的所有任务
//可通过该 missionId 查询该批量下载的所有任务的下载情况
3.接收下载事件和下载状态.
//接收事件可以在任何地方接收，不管该任务是否开始下载均可接收.
Disposable disposable = mRxDownload.receiveDownloadStatus(url)
.subscribe(new Consumer() {
@Override
public void accept(DownloadEvent event) throws Exception {
//当事件为 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(new Action1() {
@Override
public void call(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];
关于我
若您想对该项目来进行交流,可以通过以下方式:
QQ : 270362455
QQ 群：603610731
Gmail: ssseasonnn@gmail.com
