脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → retrofit+rxjava 上传和下载文件

Retrofit+Rxjava实现文件上传和下载功能

 更新时间：2017年11月20日 16:55:13   作者：沐风来  
这篇文章主要介绍了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

( "" )//引号内为地址Observable httpName(@PartMultipartBody.Part file);

2).写presenter的方法

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)调用方法发起请求

mPresenter. httpName (f);

其中f我为你要上传的文件对象

以图片为例,经过裁剪后将其转化为文件对象方法如下

@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);
}}}//括号可能多或者少,自己添吧

再说一下多文件上传,以及附带有参数的请求,类似这样

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好像不太恰当

后面只需要像传单文件一样

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

@Streaming//下载大文件时需要加上
@GET
Observable > download(@Url String url);

2)Presenter方法

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)调用方法发起下载请求

mPresenter.httpToDownload(downPath, file);//file为你下载下来的文件要存放的位置

因本人app中用的是rxjava1,所以一些rxjava+retrofit处理逻辑写的不细甚至有些乱,所以大家可以自己作相应修改,不要拿来就用.

总结

以上所述是小编给大家介绍的Retrofit+Rxjava实现文件上传和下载功能，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对脚本之家网站的支持！

您可能感兴趣的文章:

相关文章

  • Java中使用注解校验手机号格式的详细指南

    Java中使用注解校验手机号格式的详细指南

    在现代的Web应用开发中,数据校验是一个非常重要的环节,本文将详细介绍如何在Java中使用注解对手机号格式进行校验,感兴趣的小伙伴可以了解下
    2025-03-03
  • java正则替换img标签中src值的方法

    java正则替换img标签中src值的方法

    今天小编就为大家分享一篇java正则替换img标签中src值的方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
    2018-06-06
  • Java编程—在测试中考虑多态

    Java编程—在测试中考虑多态

    这篇文章主要介绍了Java编程—在测试中考虑多态，具有一定参考价值，需要的朋友可以了解下。
    2017-11-11
  • springboot 缓存@EnableCaching实例

    springboot 缓存@EnableCaching实例

    这篇文章主要介绍了springboot 缓存@EnableCaching实例，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2021-11-11
  • 解决spring boot启动扫描不到自定义注解的问题

    解决spring boot启动扫描不到自定义注解的问题

    这篇文章主要介绍了解决spring boot启动扫描不到自定义注解的问题，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
    2020-09-09
  • 浅谈java指令重排序的问题

    浅谈java指令重排序的问题

    下面小编就为大家带来一篇浅谈java指令重排序的问题。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧
    2017-09-09
  • Java集合框架之WeakHashMap详解

    Java集合框架之WeakHashMap详解

    这篇文章主要介绍了Java集合框架之WeakHashMap详解,在 WeakHashMap 中,当某个键不再正常使用时,会被从WeakHashMap中被自动移除,更精确地说,对于一个给定的键,其映射的存在并不阻止垃圾回收器对该键的丢弃,这就使该键成为可终止的,需要的朋友可以参考下
    2023-09-09
  • Java图形界面超实用使用教程

    Java图形界面超实用使用教程

    在Java编程中图形界面应用程序是非常常见和重要的一部分,下面这篇文章主要给大家介绍了关于Java图形界面的相关资料,文中通过代码介绍的非常详细,需要的朋友可以参考下
    2024-01-01
  • 老生常谈java中cookie的使用

    老生常谈java中cookie的使用

    下面小编就为大家带来一篇老生常谈java中cookie的使用。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧
    2016-12-12
  • 在SpringBoot中实现线程池并行处理任务的方法详解

    在SpringBoot中实现线程池并行处理任务的方法详解

    在使用Spring Boot开发应用程序时，我们经常需要处理一些耗时的任务，例如网络请求、数据库操作或者其他需要花费一定时间的计算任务，本文将介绍如何在Spring Boot中使用线程池来实现任务的并行处理
    2023-06-06

最新评论