rxjava上传文件

Ⅰ 在android中怎样用rxjava传递数据在不同界面

一个是继承，一个是实现接口，继承这个可以理解为继承父类的方法，父类中的方法可以在子类中用到，super(),实现接口就是在接口中定义了方法，这个方法要你自己去实现，接口可以看作一个标准，比如定义了一个动物的接口，它里面有吃（eat()）这个方法，你就可以实现这个方法implements，这个方法是自己写，可以是吃苹果，吃梨子，香蕉，或者其他的。IMPLEMENTS就是具体实现这个接口。

Ⅱ 重识OkHttp——更深入了解如何使用

OkHttp作为square公司出品的一个网络请求框架，应该算是目前Android端最火爆的网络框架了。我公司目前的项目中采用的都是Rxjava结合Retrofit进行网络请求的处理，对于底层真正实现网络请求的OkHttp关注的不是很多。最近探究了一下OkHttp的源码，对OkHttp的使用有了一些新的认识，在此做一下总结。

OkHttp作为当前Android端最火热的网络请求框架，必然有很多的优点。

对于客户端来讲，我们关注的就是把正确的请求发送到服务端并拿到结果来进行处理。在OkHttp中，我认为可以分为3个部分：

OkHttp中通过建造者模式来构建OkHttpClient、Request和Response。对于客户端来讲，我们不需要过多关注Response是如何构建的，因为这个是OkHttp对响应结果进行了封装处理。我们只关注请求Request和客户端OkHttpClient如何构建即可。

Request采用建造者模式来配置url，请求方法method、header、tag和cacheControl。

OkHttp采用POST方法向服务器发送一个请求体，在OkHttp中这个请求体是RequestBody。这个请求体可以是：

RequestBody有几个静态方法用于创建不同类型的请求体：

最终都是相当于重写了RequestBody的两个抽象方法来写入流，如果传递流类型的参数，只要重写这两个抽象方法即可。

例如，我们提交一个String：

提交File：

提交流：

对于提交表单和分块请求，OkHttp提供了两个RequestBody的子类， FormBody 和 MultipartBody

FormBody也是采用建造者模式， 这个很简单，添加key-value形式的键值对即可。
添加键值对有两个方法：

例如：

MultipartBody也是采用建造者模式，MultipartBody.Builder可以构建兼容Html文件上传表单的复杂请求体。每一部分的多块请求体都是它自身的请求体，并且可以定义它自己的请求头。如果存在的话，这些请求头用来描述这部分的请求体。例如Content-Disposition、Content-Length 和 Content-Type如果可用就会被自动添加到头。

MIME类型有：

有几个主要的方法：

例如提交一个图片文件：

OkHttpClient采用建造者模式，通过Builder可以配置连接超时时间、读写时间，是否缓存、是否重连，还可以设置各种拦截器interceptor等。
建议在一个App中，OkHttpClient保持一个实例。一个OkHttpClient支持一定数量的并发，请求同一个主机最大并发是5，所有的并发最大是64。这个与OkHttp中的调度器Dispatcher有关，可以设置并发数。本文不对Dispatcher进行讨论。

一个例子：

OkHttpClient支持单独配置，例如原来设置不同的请求时间，可以通过OkHttpClient的newBuilder()方法来重新构造一个OkHttpClient。例如：

上面已经讲了如何创建Request和OkHttpClient，剩下的就是发送请求并得到服务器的响应了。OkHttp发送请求可分为同步和异步。OkHttpClient首先通过Request构建一个Call，通过这个Call去执行同步或者异步请求。

同步方式，调用Call的execute()方法，返回Response，会阻塞当前线程：

异步方式，调用Call的enqueue(CallBack callBack)方法，会在另一个线程中返回结果。

为了缓存响应，需要一个可读写并且设置大小Size的缓存目录。缓存目录需要私有，其它不信任的应用不能访问这个文件。
如果同时有多个缓存访问同一个缓存目录会报错。所以最好只在App中初始化一次OkHttpClient，给这个实例配置缓存，在整个App生命周期内都用这一个缓存。否则几个缓存会相互影响，导致缓存出错，引起程序崩溃。
响应缓存采用Http头来配置，你可以添加这样的请求头 Cache-Control: max-stale=3600 。 max-age 指的是客户端可以接收生存期不大于指定时间（以 秒 为单位）的响应。
为了防止响应使用缓存，可以用 CacheControl.FORCE_NETWORK 。为了防止使用网络，采用 CacheControl.FORCE_CACHE 。

调用Call.cancel()方法可以立即取消一个网络请求。如果当前线程正在写request或者读response会报IO异常。如果不再需要网络请求，采用这种方法是比较方便的。例如在App中返回了上一页。无论是同步还是异步的请求都可以被取消。

可以通过Response的code来判断请求是否成功，如果服务器返回的有数据，可以通过Response的body得到一个ResponseBody读取。
如果采用ResponseBody的string()方法会一次性把数据读取到内存中，如果数据超过1MB可能会报内存溢出，所以对于超过1MB的数据，建议采用流的方式去读取，如ResponseBody的byteStream()方法。

需要说明的是：

OkHttp中的很多类都用到了建造者模式，可以根据需要灵活配置。采用建造者模式的有：

如果单独使用OkHttp进行网络请求，通常需要开发者自己再封装一下，如果不想重复造轮子，Github上面的有一些优秀开源库可以拿来使用（本文只列出star较多的几个）：

OkHttp官方Wiki文档

Ⅲ Retrofit的浅析 —— 针对面试

1.近两年Retrofit非常热门，特别是结合Rxjava运用到项目中。Retrofit一个RESTful的Http网络请求框架的封装，内部封装了Okhttp网络请求框架，对网络请求做了大量优化。Retrofit其最大特点就是解耦，要解耦就需要大量的设计模式，内部使用了外观模式、构建模式、观察者模式、动态代理模式、策略模式、适配器模式和装饰模式等等；

实际上分析Retrofit需要熟悉Okhttp才能深入分析Retrofit，Retrofit不止使用okhttp的内核，它还封装了CallAdapter-请求适配器：可以实现多种请求响应形式：同步方式、异步回调方式、RxJava方式；封装了Converter-数据转换器：可以自己定义responseBodyConverter和requestBodyConverter,实现加密功能和各种数据格式的解析；

retrofit 结合 okhttp 的原因就是retrofit使用了代理模式,默认代理走的就是okhttp,okhttp 负责网络请求, retrofit 负责对网络的处理,包括gson解析都是封装在retrofit里面的,如果哪天okttp不流行了是可以切换到别的网络框架的

Retrofit(改良)框架是Square公司出品的目前非常流行的网络框架,效率高,实现简单,运用注解和动态代理设计模式,极大的简化了网络请求的繁琐步骤,非常适合处理REST ful(一种风格)网络请求.目前Retrofit版本是2(可以说是Square公司之前出品okhttp的升级版)

         性能好,处理快,使用简单.(速度比Volley更快)

         使用REST API非常方便

         支持NIO(新的IO API，可以替代标准的Java IO API)

         Retrofit默认使用okhttp处理网络请求；

         默认使用Gson解析 

        1.在项目的build.gradle中添加依赖后一个依赖比前一个多了个Gson解析的功能,看需求,二者依赖一个即可,              一  般依赖带Gson解析的依赖

             compile 'com.squareup.retrofit2:retrofit:2.0.0-beta4'

            compile 'com.squareup.retrofit2:converter-gson:2.0.0-beta4'

             <uses-permission android:name="android.permission.INTERNET" />

@GET        GET网络请求方式

@POST       POST网络请求方式

@Headers    头信息参数

@Path       路径参数.替换url地址中 "{" 和 "}"所包括的部分

@Query      查询参数.将在url地址中追加类似"page = 1"的字符串,形成提交给服务器端的请求参数

@QueryMap        查询参数集合.在url地址中追加类似"type = text & count = 30 & page = 1 " 的字符串

@FormUrlEncoded  对表单域中填写内存进行编码处理,避免乱码

@Field           指定from表单域中每个控件的name及相应数值

@FieldMap        表单域集合

@Multipart       Post提交分块请求.如果上传文件,必须指定Multipart

@Part            Post提交分块请求

@Body            Post提交分块请求

         1.设置请求方式是注解的形式  

        2.接口拼接字符串更灵活 

        3.异步响应回调方法在主线程

/**

* 作用：GET请求最简单的写法,无Path参数和Query参数

* article/list/latest?page=%d实际是Constant下的URL_LATEST地址

* @GET()里的东西是要拼接的网址,注意直接把page=1了

*/

@GET("article/list/latest?page=1")

Call<ResponseBody> getLatestJsonString();

/**

* 其中注解中的变量用{ 变量名自定义 } 在方法参数中

* 格式:@Path("上面定义的变量名") 类型 定义的变量名  作用:替换url地址中"{"和"}"所包括的部分

* 格式:@Query("参数名") 类型 定义的参数名 作用:会拼接在URL的最后部分,类似追加了"page = 1"的字符串,最后提交给服务器

*/

@GET("article/list/{type}?")

Call<QiushiModel> getInfoList(@Path("type") String type, @Query("page") int page);

/**

* @QueryMap参数将在url地址中追加类似"type = text & count = 30 & page = 1 " 的字符串

*/

@GET("web/LoginServlet")

Call<ResponseBody> getRegInfo(@QueryMap Map<String, String> map);

/**

* 静态的URL地址

*/

@GET("http://img.265g.com/userup/1201/201201071126534773.jpg")

Call<ResponseBody> getNetworkData();

///////////////////////////////////////////////////  Post   ////////////////////////////////////////////////

/**

* 作用：post网络请求，向服务器提交表单域数据

* @FormUrlEncoded:解决编码乱码问题,

*/

@FormUrlEncoded

@POST("web/LoginServlet")

Call<ResponseBody> postFormFields(@Field("username") String username,@Field("password") String password);

/**

* 作用：post网络请求，向服务器提交表单域数据

* @FormUrlEncoded:解决编码乱码问题,

*/

@FormUrlEncoded

@POST("web/LoginServlet")

Call<ResponseBody> postFormFieldMap(@FieldMap Map<String , String> map);

/**

* 上传单个文件,必须加上 @Multipart 注解

*/

@Multipart

@POST("web/UploadServlet")

Call<ResponseBody> postUploadFile(@Part("uploadfile\";filename=\"myuploadimg.png") RequestBody requestBody);

Retrofit2中Base Url与@Url不是简单的组合,而是和<a href = "...">的处理方式一样

提示:Base URL: 以"/"结尾        @Url:不要以"/"开头

Ⅳ android开发框架有哪些

1、Rajawali
介绍：
安卓的OpenGL ES 2.0/3.0 引擎。可以用于制作普通应用或者动态壁纸，当然也可以用于制作游戏。
项目地址： https://github.com/Rajawali/Rajawali

2、RxAndroid
介绍：
RxAndroid是RxJava的一个针对Android平台的扩展。它包含了一些能够简化Android开发的工具。
项目地址： https://github.com/ReactiveX/RxAndroid
3、Paginize
介绍：
Paginize 是一个轻量级的UI框架，使用注解来注入布局和view，除了使用注解之外，该框架还有两个特色：1.用Page的概念来取代Fragment，2.切换page时自带ios风格的动画效果。
项目地址： https://github.com/neevek/Paginize

4、otto
介绍：
Otto 是square公司出的一个事件库（pub/sub模式），用来简化应用程序组件之间的通讯。 Otto 修改自Google的Guava库，专门为Android平台进行了优化。
项目地址： https://github.com/square/otto

5 、rebound
介绍：
rebound是facebook的开源动画库。可以认为这个动画库是独立于android Framework之外的一种动画实现。
项目地址： https://github.com/facebook/rebound

6、KJFrameForAndroid
介绍：
KJFrameForAndroid 又叫KJLibrary，是一个帮助快速开发的框架。使用KJFrameForAndroid，你可以只用一行代码就完成http请求、网络图片加载、数据库数据保存或读取。
项目地址： https://github.com/kymjs/KJFrameForAndroid

7、xUtils
介绍：
xUtils
包含了很多实用的android工具。 xUtils
支持大文件上传，更全面的http请求协议支持(10种谓词)，拥有更加灵活的ORM，更多的事件注解支持且不受混淆影响... xUitls
最低兼容android 2.2 (api level 8)
项目地址： https://github.com/wyouflf/xUtils

目前xUtils主要有四大模块：
DbUtils模块：
android中的orm框架，一行代码就可以进行增删改查；
支持事务，默认关闭；
可通过注解自定义表名，列名，外键，唯一性约束，NOT NULL约束，CHECK约束等（需要混淆的时候请注解表名和列名）；
支持绑定外键，保存实体时外键关联实体自动保存或更新；
自动加载外键关联实体，支持延时加载；
支持链式表达查询，更直观的查询语义，参考下面的介绍或sample中的例子。
ViewUtils模块：
android中的ioc框架，完全注解方式就可以进行UI，资源和事件绑定；
新的事件绑定方式，使用混淆工具混淆后仍可正常工作；
目前支持常用的20种事件绑定，参见ViewCommonEventListener类和包com.lidroid.xutils.view.annotation.event。
HttpUtils模块：
支持同步，异步方式的请求；
支持大文件上传，上传大文件不会oom；
支持GET，POST，PUT，MOVE，COPY，DELETE，HEAD，OPTIONS，TRACE，CONNECT请求；
下载支持301/302重定向，支持设置是否根据Content-Disposition重命名下载的文件；
返回文本内容的请求(默认只启用了GET请求)支持缓存，可设置默认过期时间和针对当前请求的过期时间。
BitmapUtils模块：
加载bitmap的时候无需考虑bitmap加载过程中出现的oom和android容器快速滑动时候出现的图片错位等现象；
支持加载网络图片和本地图片；
内存管理使用lru算法，更好的管理bitmap内存；
可配置线程加载线程数量，缓存大小，缓存路径，加载显示动画等...

8、butterknife-view
注入工具
介绍：
为了减少频繁的调用findViewById(R.id...)，可以采用一些注入框架，可以简化自己的代码，让你更专注于实际的功能开发，butterknife就是这样的一个框架，他是jakewharton大神的作品，值得一试。
class ExampleActivity extends Activity {
@InjectView(R.id.title) TextView title;
@InjectView(R.id.subtitle) TextView subtitle;
@InjectView(R.id.footer) TextView footer;
@Override public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.simple_activity);
ButterKnife.inject(this);
// TODO Use "injected" views...
}
}

这是博客地址：
http://jakewharton.github.io/butterknife/
项目地址： https://github.com/JakeWharton/butterknife

9、cube-sdk
一淘推出的开发框架
介绍：
cube一个Android开发包, 可极大提高你的开发效率。主要提供了图片加载以及网络请求方面的api功能。
项目地址： https://github.com/etao-open-source/cube-sdk
他们的网站：http://cube-sdk.liaohuqiu.net/cn/

10、ASimpleCache
一个简单的缓存框架
介绍：
ASimpleCache
是一个为android制定的 轻量级的 开源缓存框架。轻量到只有一个java文件（由十几个类精简而来）。
它可以缓存什么东西？普通的字符串、JsonObject、JsonArray、Bitmap、Drawable、序列化的java对象，和
byte数据。
项目地址： https://github.com/yangfuhai/ASimpleCache

11、androidannotations
介绍：
AndroidAnnotations是一个能够让你快速进行Android开发的开源框架，它能让你专注于真正重要的地方。
使代码更加精简，使项目更加容易维护，它的目标就是“Fast Android Development.Easy maintainance”。
通过一段时间的使用发现，相比原生的Android开发，确实能够让你少些很多代码
项目地址： https://github.com/excilys/androidannotations

12、Event Bus
解耦android模块
介绍：
当一个Android应用功能越来越多的时候，保证应用的各个部分之间高效的通信将变得越来越困难。如何优雅地解决这个问题？这时候，就需要使用到EventBus。
EventBus是GreenRobot出品的Android系统的一个Event
Bus类库，使用起来和之前我们所介绍的Square的Otto差不多，都是用来简化应用组件之间的通信。
项目地址： https://github.com/greenrobot/EventBus

13、BeeFramework_Android
介绍：
BeeFramework
Android版主要为Android初级开发人员提供一个基于MVC开发模式的APP DEMO,并提供一套APP内调试工具,包括
查看网络数据请求历史 Crash Log列表 真机WIFI环境下模拟2G\3G网络 查看APP性能(内存占用，CPU占用等)
项目地址： https://github.com/BeeFramework/BeeFramework_Android

14、afinal
介绍：
Afinal是一个android的ioc，orm框架，内置了四大模块功能：FinalAcitivity,FinalBitmap,FinalDb,FinalHttp。通过finalActivity，我们可以通过注解的方式进行绑定ui和事件。通过finalBitmap，我们可以方便的加载bitmap图片，而无需考虑oom等问题。通过finalDB模块，我们一行代码就可以对android的sqlite数据库进行增删改查。通过FinalHttp模块，我们可以以ajax形式请求http数据。
Afinal里面目前包含了四大组件：
FinalHttp：用于请求http数据，直接ajax方式请求，文件上传， 断点续传下载文件等
FinalBitmap：用于显示bitmap图片，而无需考虑线程并发和oom等问题。
FinalActivity：完全可以通过注解方式绑定控件和事件，无需编写代码。
FinalDb：android中sqlite的orm框架，一行代码搞定增删改查。

Afinal是一个android的ioc，orm框架，内置了四大模块功能：FinalAcitivity,FinalBitmap,FinalDb,FinalHttp。通过finalActivity，我们可以通过注解的方式进行绑定ui和事件。通过finalBitmap，我们可以方便的加载bitmap图片，而无需考虑oom等问题。通过finalDB模块，我们一行代码就可以对android的sqlite数据库进行增删改查。通过FinalHttp模块，我们可以以ajax形式请求http数据。详情请通过以下网址查看。
项目地址： https://github.com/yangfuhai/afinal

15、Volley
介绍：
在这之前，我们在程序中需要和网络通信的时候，大体使用的东西莫过于AsyncTaskLoader，HttpURLConnection，AsyncTask，HTTPClient（Apache）等，今年的Google
I/O 2013上，Volley发布了。Volley是Android平台上的网络通信库，能使网络通信更快，更简单，更健壮。
项目地址： https://github.com/mcxiaoke/android-volley

Ⅳ retrofit可以上传大文件吗

1.单张图片的上传

?

1
2
3
4
5
6
7
8
9
10

/**
* 上传一张图片
* @param description
* @param imgs
* @return
*/
@Multipart
@POST("/upload")
Call<String> uploadImage(@Part("fileName") String description,
@Part("file\"; filename=\"image.png\"")RequestBody imgs);

2.多张图片的上传

?

1
2
3
4
5
6
7
8
9
10
11
12
13
14

/**
* 上传三张图片
* @param description
* @param imgs
* @param imgs1
* @param imgs3
* @return
*/
@Multipart
@POST("/upload")
Call<String> uploadImage(@Part("fileName") String description,
@Part("file\"; filename=\"image.png\"")RequestBody imgs,
@Part("file\"; filename=\"image.png\"")RequestBody imgs1,
@Part("file\"; filename=\"image.png\"")RequestBody imgs3);

注意：目前是提供传3张，要想多上传目前我发现的方法就是想要多传一张，就多增加一个参数
@Part("file\"; filename=\"image.png\"")RequestBody imgs，以此类推。
大家看到上面觉得写法很漏，但是用于能力有限，只能想到这样。用Java中的可变参数解决之后，就只能传一张。不能多张。

?

1
2
3
4

@Multipart
@POST("/upload")
Call<String> uploadImage(@Part("fileName") String description,
@Part("file\"; filename=\"image.png\"")RequestBody ...imgs);

调用：
Call<String> call = apiManager.uploadImage( m[0],requestBody1,requestBody2,null);
这样写看上去很是高端，不幸的是只能传一张
3.最后是实现胡过程
3.1创建FileUploadService接口
?

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

public interface FileUploadService {
/**
* 上传一张图片
* @param description
* @param imgs
* @return
*/
@Multipart
@POST("/upload")
Call<String> uploadImage(@Part("fileName") String description,
@Part("file\"; filename=\"image.png\"")RequestBody imgs);

/**
* 上传三张图片
* @param description
* @param imgs
* @param imgs1
* @param imgs3
* @return
*/
@Multipart
@POST("/upload")
Call<String> uploadImage(@Part("fileName") String description,
@Part("file\"; filename=\"image.png\"")RequestBody imgs,
@Part("file\"; filename=\"image.png\"")RequestBody imgs1,
@Part("file\"; filename=\"image.png\"")RequestBody imgs3);
}

3.2创建Retrofit对象
?

1
2
3
4
5
6
7

private static final Retrofit sRetrofit = new Retrofit .Builder()
.baseUrl(ENDPOINT)
.addConverterFactory(GsonConverterFactory.create())
// .addCallAdapterFactory(RxJavaCallAdapterFactory.create()) // 使用RxJava作为回调适配器
.build();

private static final FileUploadService apiManager = sRetrofit.create(FileUploadService.class);

3.3调用上传的方法
?

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

public static void upload(String path){

String descriptionString = "hello, this is description speaking";

String[] m = new String[2];
m[0]= "share.png";
m[1]= "Screenshot_20160128-140709.png";
File[] ssssss= new File[2];
File file1 = new File("/storage/emulated/0/sc/share.png");
File file = new File("/storage/emulated/0/Pictures/ScreenShots/Screenshot_20160128-140709.png");
ssssss[0]=file;
ssssss[0]=file1;
RequestBody requestBody[] = new RequestBody[3];
RequestBody requestBody1 =
RequestBody.create(MediaType.parse("multipart/form-data"), file);
RequestBody requestBody2 =
RequestBody.create(MediaType.parse("multipart/form-data"), file1);
requestBody[0]=requestBody1;
requestBody[1]=requestBody2;
Call<String> call = apiManager.uploadImage( m[0],requestBody1,requestBody2,null);
call.enqueue(new Callback<String>() {
@Override
public void onResponse(Response<String> response, Retrofit retrofit) {
Log.v("Upload", response.message());
Log.v("Upload", "success");
}

@Override
public void onFailure(Throwable t) {
Log.e("Upload", t.toString());
}
});

}

4.服务器段代码：
服务器用的是struts接收：

@Controller
public class GetToken extends ActionSupport {

/**
*
*/
private static final long serialVersionUID = 1L;
private File[] file;
private String[] fileName;
public File[] getFile() {
return file;
}
public void setFile(File[] file) {
this.file = file;
}
public String[] getFileName() {
return fileName;
}
public void setFileName(String[] fileName) {
this.fileName = fileName;
}

@Action("/upload")
public void login() {
System.out.println("------"+Arrays.toString(file));
System.out.println("------"+Arrays.toString(fileName));
}

}