RxJava 2.0（三）与Retrofit 2 一起完成网络访

1.添加依赖：

compile 'com.squareup.retrofit2:retrofit:2.3.0'
compile 'io.reactivex.rxjava2:rxjava:2.1.0'
compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
compile 'com.jakewharton.retrofit:retrofit2-rxjava2-adapter:1.0.0'
compile 'com.squareup.retrofit2:converter-gson:2.3.0'

RxJava与Retrofit一起使用，除了基础库之外，要注意第四个，Retrofit的adapter，添加完成之后就可以使用了。

2.使用Retrofit

回顾一下Retrofit的使用方法，下面是一个获取并显示网络图片的例子：

首先定义访问接口，这里要获取的是图片，需要Stream数据，所以直接使用ResponseBody作为泛型参数：

<pre>
public interface ConnectService {
@Streaming
@GET("IC.png")
Call<ResponseBody> getImage();
}
</pre>

然后创建Retrofit对象，访问网络，获取ResponseBody并进行处理：
<pre>
Retrofit retrofit = new Retrofit.Builder()
.baseUrl("http://192.168.1.101:8080/")
//必须指定一个converter，否则报错，实际上并没有用到
.addConverterFactory(GsonConverterFactory.create())
.build();
ConnectService cs = retrofit.create(ConnectService.class);
final Call<ResponseBody> imageCall = cs.getImage();
//开始异步访问
imageCall.enqueue(new Callback<ResponseBody>() {
@Override
public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
//从Response获取inputstream
InputStream inputStream = response.body().byteStream();
final Bitmap bitmap = BitmapFactory.decodeStream(inputStream);
//获取到图片，设置到imageView
runOnUiThread(new Runnable() {
@Override
public void run() {
mImageView.setImageBitmap(bitmap);
}
});
}
</pre>

3.与RxJava配合使用

第一步同样是定义访问接口，这里的类型不再是Call，而是被观察者Observable：
<pre>
public interface ImageService {
@Streaming
@GET("IC.png")
Observable<ResponseBody> getImg();
}
</pre>

接下来的步骤也基本一样，需要注意的是，构建Retrofit对象时要指定callAdapter：
<pre>
//构建Retrofit
Retrofit retrofit = new Retrofit.Builder()
.baseUrl("192.168.1.101:8080/")
.addConverterFactory(GsonConverterFactory.create())
.addCallAdapterFactory(RxJava2CallAdapterFactory.create())
.build();
//获取网络访问接口实例
ImageService is = retrofit.create(ImageService.class);
//构建被观察者Observable
Observable<ResponseBody> observable = is.getImg();
//订阅。订阅之后自动执行网络访问。
observable.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Observer<ResponseBody>() {
@Override
public void onSubscribe(@NonNull Disposable d) {
}
@Override
public void onNext(@NonNull ResponseBody responseBody) {
//获取ResponseBody并设置到imageview
mImgView.setImageBitmap(BitmapFactory.decodeStream(responseBody.byteStream()));
}
@Override
public void onError(@NonNull Throwable e) {
}
@Override
public void onComplete() {
}
});
</pre>

或者可以采用更简洁的写法：

<pre>
new Retrofit.Builder()
.baseUrl("http://192.168.1.101:8080/")
.addConverterFactory(GsonConverterFactory.create())
.addCallAdapterFactory(RxJava2CallAdapterFactory.create())
.build()
.create(ImageService.class)
.getImg()
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer<ResponseBody>() {
@Override
public void accept(@NonNull ResponseBody responseBody) throws Exception {
mImgView.setImageBitmap(BitmapFactory.decodeStream(responseBody.byteStream()));
}
});
</pre>