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,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,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实现文件上传和下载功能,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对编程小技巧网站的支持! (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |