使用RxJava+Retrofit完成同步连续请求使用RxJava+Retrofit完成同步连续

首先声明一下，这是本人的学习Rxjava和Retrofit的第一篇博客，也是我第一次写博客，内容中可能会有错误的地方或者我理解错误的地方，请大家多理解，都是这么过来的嘛，如果有错误的地方非常欢迎大家指正，我会及时修改以免误导他人。

使用场景连续请求在很多App中都经常会被使用，例如通过定位获得当前定位城市的天气预报，我们首先要通过Android为我们提供的Api调用GPS获得我们当前的经纬度，然后将经纬度转换成具体的城市名称，再将城市名称传入获取天气预报的请求中。
如果要实现这样一个需求，在代码结构上可能会是很乱的，我们可能会陷入无尽的回调地狱中，例如这样：

文章图片
快的打车这样的结构无论对于开发人员还是维护人员都非常容易一脸懵逼，为了解决这个问题，我们可以通过引入Rxjava+Retrofit，使用链式的结构，让整个代码块更易读，也为了让你离职后接手你的项目的人少骂你几句。
动手试一下前期准备

经纬度转为城市地址Api：由于Google Maps提供的Api在国内无法使用（也可能有更好的方法请指教），我找到了
http://api.map.baidu.com/geocoder?location=纬度,经度&output=输出格式类型&key=用户密钥这个Api来代替，注意这个Api要提前申请key，本文将提供一个key:6eea93095ae93db2c77be9ac910ff311。
天气预报Api：这里我使用的是心知天气在百度Api服务中提供的接口，其中我使用了天气实况这一服务，具体的接口Url为http://apis.baidu.com/thinkpage/weather_api_full/currentweather，注意这里同样要申请key，此处需要各位自行申请了。
Rxjava+Retrofit：通过Gradle导入即可

compile 'io.reactivex:rxjava:1.1.0' compile 'io.reactivex:rxandroid:1.1.0' compile 'com.squareup.retrofit2:retrofit:2.0.0-beta4' compile 'com.squareup.retrofit2:converter-gson:2.0.0-beta4' compile 'com.squareup.retrofit2:adapter-rxjava:2.0.0-beta4' compile 'com.google.code.gson:gson:2.6.2' compile 'com.jakewharton:butterknife:7.0.1'

可以开始了
首先我们要准备好天气服务和位置服务返回的实体类，这个实体类就需要麻烦大家自行去请求一下了，这里推荐一个Chrome的小插件Postman（需要翻墙）这个工具可以帮助你进行网页调试或发送http请求。自动生成实体类应该不用多说了GsonFormat即可搞定。
现在我们有了实体类，接下来我们就要通过Retrofit为每个请求创建相应的Service了：

定位服务：

public interface LocationService { @GET("geocoder") Observable getLoation( @Query("location") String location, @Query("output") String output, @Query("key") String key ); }

天气服务 请将代码中的***替换为您申请的apikey

public interface WeatherService { @Headers({"apikey:*********"}) @GET("currentweather") Observable getWeather(@Query("location") String city); }

接下来我们为每个请求实例化相应的Retrofit对象，并加入Rxjava的支持：

public static final String WEATHER_URL = "http://apis.baidu.com/thinkpage/weather_api/"; public static final String LOCATION_URL ="http://api.map.baidu.com/"; Retrofit mRetrofitWeather; Retrofit mRetrofitLocation; WeatherService mWeatherService; LocationService mLocationService; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); mRetrofitWeather = new Retrofit.Builder() .addConverterFactory(GsonConverterFactory.create()) .addCallAdapterFactory(RxJavaCallAdapterFactory.create()) .baseUrl(WEATHER_URL) .build(); mWeatherService = mRetrofitWeather.create(WeatherService.class); mRetrofitLocation = new Retrofit.Builder() .addConverterFactory(GsonConverterFactory.create()) .addCallAdapterFactory(RxJavaCallAdapterFactory.create()) .baseUrl(LOCATION_URL) .build(); mLocationService = mRetrofitLocation.create(LocationService.class); }

下面就是我们的重点了，我们要使用Rxjava为我们提供的十分丰富的操作符来完成这个连续的请求。声明一下我是在点击事件中完成的请求

public void getWeather(){ mLocationService.getLoation("31.407452,119.490523", "json", "6eea93095ae93db2c77be9ac910ff311") .flatMap(new Func1>() { @Override public Observable call(LocationEntity locationEntity) { return mWeatherService.getWeather(locationEntity.getResult().getAddressComponent().getCity()); } }).map(new Func1() { @Override public String call(WeatherEntity weatherEntity) { String text = weatherEntity.getResults().get(0).getLocation().getName() + ":" + weatherEntity.getResults().get(0).getNow().getText()+ " 温度:" + weatherEntity.getResults().get(0).getNow().getTemperature() + ""; return text; } }).subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Subscriber() { @Override public void onCompleted() { Log.d(TAG, "onCompleted: " + "完成数据获取"); }@Override public void onError(Throwable e) { tv.setText(e.toString()); }@Override public void onNext(String s) { tv.setText(s); Log.d(TAG,"当前天气为："+s) } }); }

首先我们通过系统的Api拿到我们目前所在位置的经纬度信息，这里我就直接随意写了一个，接下来我们就要开始传入接口所需要的参数进行请求了，第一步我们先要通过经纬度获得我们所在的城市位置，这里我使用了Map和FlatMap这两个操作符。

Map
transform the items emitted by an Observable by applying a function to each item

FlatMap
transform the items emitted by an Observable into Observables, then flatten the emissions from those into a single Observable

从文档中我们可以看出，FlatMap可以将Observable对象发射到一个Observables对象中，然后排列为一个Observable对象，通过该操作符，我们可以将得到的位置信息传入天气服务的Api中，将或得到的天气实体发射到Observables中，之后我们再通过map操作符将天气的Observable对象通过处理，得到我们所需要的具体信息，即文中的text，之后我们订阅这个事件，在onNext方法中取得我们所需的信息。
这样的链式结构相对于文中开头的回调地狱来说，虽说学习成本较高，但是一旦学会使用Rxjava，好处确实是非常多的，最后谢谢大家的阅读。
项目地址
【使用RxJava+Retrofit完成同步连续请求】Github: https://github.com/icetea0822/Rxjava-Retrofit