效果：

效果

前言：

这个demo主要是练手和初尝试，后面也在慢慢更新优化网络请求方面的代码。本文的代码也并不完美，推荐一步一步看后续更新的文章。该系列的其他文章：

VOL.1：Android (OkHttp3+Gson)用MVP模式实现天气预报小demo

VOL.2: Android retrofit2+OkHttp3的初尝试

在学习RxJava的过程中给我帮助最大的是一篇文章手把手带你入门神秘的 Rxjava。文章很好的概括了RxJava的特点和原理：

RxJava 是一个基于事件流、实现异步操作的库，它基于事件流的链式调用的特点使得它逻辑更简洁。

RxJava原理可总结为：被观察者（Observable）通过订阅（Subscribe）按顺序发送事件给观察者（Observer），观察者（Observer）按顺序接收事件 & 作出对应的响应动作。

本文简单尝试了RxJava+retrofit2的结合，供新手参考。

一、框架的导入

本项目使用到的api：

https://www.sojson.com/open/api/weather/json.shtml?city=广州

https://api.douban.com/v2/book/search?q=金瓶梅

需要用到的库在build.gradle里输入这几行后sync就好了

compile 'com.squareup.retrofit2:adapter-rxjava:2.1.0'
compile 'io.reactivex:rxandroid:1.2.0'

image.png

二、Observable 被观察者

Retrofit怎么跟RxJava联合起来呢？首先修改我们天气预报小Demo的RetrofitHelper的代码。

image.png

如图，我们在Retrofit的声明中新加了

.addCallAdapterFactory(RxJavaCallAdapterFactory.create())

此时不再返回Call了，我们get方法改为Observable(被观察者)

image.png

在RetrofitService接口中，我们把Call改为Observable

image.png

Retrofit与RxJava的初步联合就完成了。

二、通过订阅连接观察者和被观察者

观察者的任务是按顺序接受事件&作出对应的相应动作。

我们到Model层，将BookModel和WeatherModel的load方法更改为RxJava的链式调用：

BookModel

public class BookModel implements IBookModel {

@Override
public void loadBook(String name, final ILoadBookListener iLoadBookListener) {
   
    RetrofitHelper retrofitHelper=new RetrofitHelper(Api.BOOK_HOST);
    retrofitHelper.getBook(name)
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Subscriber<BookBean>() {
                @Override
                public void onCompleted() {

                }

                @Override
                public void onError(Throwable e) {
                    iLoadBookListener.onFailure(e);
                }

                @Override
                public void onNext(BookBean bookBean) {
                    iLoadBookListener.onSuccess(bookBean);
                }
            });

}

}

WeatherModel

public class WeatherModel implements IWeatherModel {
@Override
public void loadWeather(String city, final ILoadListener loadListener) {
    RetrofitHelper retrofitHelper=new RetrofitHelper(Api.WEATHER_HOST);

   retrofitHelper.getWeather(city)
           .subscribeOn(Schedulers.io())
           .observeOn(AndroidSchedulers.mainThread())
           .subscribe(new Subscriber<WeatherBean>() {
               @Override
               public void onCompleted() {

               }

               @Override
               public void onError(Throwable e) {
                   loadListener.onFailure(e);
               }

               @Override
               public void onNext(WeatherBean weatherBean) {
                   loadListener.onSuccess(weatherBean);
               }
           });


}

}