个人中心
文章发布
退出
作者热门文章
- ubuntu12.04环境下使用kvm ioctl接口实现最简单的虚拟机
- Ubuntu 通过无线网络安装Ubuntu Server启动系统后连接无线网络的方法
- 在Ubuntu上搭建网桥的方法
- ubuntu 虚拟机上网方式及相关配置详解
26
4
CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.
这篇CFSDN的博客文章Retrofit+Rxjava实现文件上传和下载功能由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.
Retrofit简介
在Android API4.4之后，Google官方使用了square公司推出的okHttp替换了HttpClient的请求方式。后来square公司又推出了基于okHttp的网络请求框架：Retrofit.
什么是 RxJava?
RxJava 是一个响应式编程框架，采用观察者设计模式。所以自然少不了 Observable 和 Subscriber 这两个东东了.
RxJava 是一个开源项目，地址：https://github.com/ReactiveX/RxJava 。
还有一个RxAndroid，用于 Android 开发，添加了 Android 用的接口。地址：https://github.com/ReactiveX/RxAndroid 。
每个应用基本都会涉及到文件的上传或下载，最普遍的一般也就是上传头像或者照片，下载安装包了，本篇文章就这两点简单说一下retrofit+rxjava的对文件的上传和下载.
1.上传 。
首先说一下单文件上传,一般上传头像等会用到 . 。
1).写api @Multipart 。
@POST 。
|
1
|
(
""
)
//引号内为地址Observable httpName(@PartMultipartBody.Part file);
|
2).写presenter的方法 。
|
1
2
3
4
5
6
|
public
void
httpName(File file) {
RequestBody requestBody = RequestBody. create (MediaType. parse (
"image/png"
), file);
MultipartBody.Part part = MultipartBody.Part. createFormData (
"file"
, file.getName() , requestBody);
Observable observable = api. httpName (part);
…rajava+retrofit处理逻辑
}
|
3)调用方法发起请求 。
|
1
|
mPresenter. httpName (f);
|
其中f我为你要上传的文件对象 。
以图片为例,经过裁剪后将其转化为文件对象方法如下 。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
@Override
protected
void
onActivityResult(
int
requestCode,
int
resultCode, Intent data) {
if
(data !=
null
) {
Bundle bundle = data.getExtras();
if
(bundle !=
null
) {
bitmap = bundle.getParcelable(
"data"
);
File f =
new
File(
this
.getFilesDir(), (
new
Date()).getTime() +
".png"
);
if
(f.exists()) {f.delete();}
try
{
FileOutputStream out =
new
FileOutputStream(f);
bitmap.compress(Bitmap.CompressFormat.PNG,
90
, out);
out.flush();
out.close();
}
catch
(FileNotFoundException e) {
e.printStackTrace();
f =
null
;
}
catch
(IOException e) {
e.printStackTrace();
f =
null
;
}
if
(f !=
null
) {
mPresenter. httpName(f);
}}}
//括号可能多或者少,自己添吧
|
再说一下多文件上传,以及附带有参数的请求,类似这样 。
|
1
2
3
4
|
mPresenter.httpUpLoadMore(id,phone, File1, File2, File3);
@Multipart
@POST
(
""
)
Observable<ResponseBody> httpUpLoadMore (
@Query
(
"id"
) String id,
@Query
(
"phone"
) String phone,
@Part
MultipartBody.Part file1,
@Part
MultipartBody.Part file2,
@Part
MultipartBody.Part file3);
|
这里附带参数用@FieldMap Map maps也可以,用query好像不太恰当 。
后面只需要像传单文件一样 。
|
1
2
3
4
|
RequestBody requestBody1/
2
/
3
= RequestBody.create(MediaType.parse(
"image/png"
), file1/
2
/
3
);;
MultipartBody.Part part1/
2
/
3
= MultipartBody.Part.createFormData(
"file"
, file1/
2
/
3
.getName() , requestBody1/
2
/
3
);
Observable bservable= api.httpUpLoadMore(id,phone,part1,part2,part3);
……
|
2下载 。
1)写api 。
|
1
2
3
|
@Streaming
//下载大文件时需要加上
@GET
Observable > download(
@Url
String url);
|
2)Presenter方法 。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
|
mApi.download (path)
.subscribeOn(Schedulers.io())
.observeOn(Schedulers.io())
.flatMap(
new
Func1,Observable>() {
@Override
public
Observablecall(Response response) {
boolean
b = writeToFile(response, file);
//将返回的流转写入到file对象中
final
Boolean aBoolean =Boolean.valueOf(b);
return
Observable.create(
new
Observable.OnSubscribe(){
@Override
public
void
call(Subscriber subscriber) {
try
{
subscriber.onNext(aBoolean);
subscriber.onCompleted();
}
catch
(Exceptione) {
subscriber.onError(ExceptionManager.handleException(e));}}});}})
.observeOn(AndroidSchedulers.mainThread())
.subscribe(
new
Action1(){
@Override
public
void
call(Boolean bean) {}
},
new
Action1(){
@Override
public
void
call(Throwablethrowable) {}});
[
if
!supportLineBreakNewLine]
[endif]
private
boolean
writeToFile(Responsebody,File file) {
try
{
InputStream inputStream =
null
;
OutputStream outputStream =
null
;
try
{
byte
[] fileReader =
new
byte
[
2048
];
inputStream =body.body().byteStream();
outputStream =
new
FileOutputStream(file);
while
(
true
) {
int
read =inputStream.read(fileReader);
if
(read == -
1
)
break
;
outputStream.write(fileReader,
0
, read);
}
outputStream.flush();
return
true
;
}
catch
(IOException e) {
return
false
;
}
finally
{
if
(inputStream !=
null
) {
inputStream.close();
}
if
(outputStream !=
null
) {
outputStream.close();
}}
}
catch
(IOException e) {
return
false
;
}}
|
3)调用方法发起下载请求 。
|
1
|
mPresenter.httpToDownload(downPath, file);
//file为你下载下来的文件要存放的位置
|
因本人app中用的是rxjava1,所以一些rxjava+retrofit处理逻辑写的不细甚至有些乱,所以大家可以自己作相应修改,不要拿来就用. 。
总结 。
以上所述是小编给大家介绍的Retrofit+Rxjava实现文件上传和下载功能，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对我网站的支持！ 。
原文链接：http://www.jianshu.com/p/dd3cc78c78b8?utm_source=tuicool&utm_medium=referral 。
最后此篇关于Retrofit+Rxjava实现文件上传和下载功能的文章就讲到这里了,如果你想了解更多关于Retrofit+Rxjava实现文件上传和下载功能的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。
26
4
0
我有以下正则表达式 /[a-zA-Z0-9_-]/ 当字符串只包含从 a 到z 大小写、数字、_ 和 -。 我的代码有什么问题？ 能否请您向我提供一个简短的解释和有关如何修复它的代码示例？ //var
我是一名优秀的程序员,十分优秀！