首先聲明一下狈孔，這是本人的學(xué)習(xí)Rxjava和Retrofit的第一篇博客，也是我第一次寫博客奴迅，內(nèi)容中可能會(huì)有錯(cuò)誤的地方或者我理解錯(cuò)誤的地方青责，請(qǐng)大家多理解，都是這么過來的嘛，如果有錯(cuò)誤的地方非常歡迎大家指正脖隶，我會(huì)及時(shí)修改以免誤導(dǎo)他人扁耐。
使用場(chǎng)景
連續(xù)請(qǐng)求在很多App中都經(jīng)常會(huì)被使用，例如通過定位獲得當(dāng)前定位城市的天氣預(yù)報(bào)产阱，我們首先要通過Android為我們提供的Api調(diào)用GPS獲得我們當(dāng)前的經(jīng)緯度婉称，然后將經(jīng)緯度轉(zhuǎn)換成具體的城市名稱，再將城市名稱傳入獲取天氣預(yù)報(bào)的請(qǐng)求中构蹬。
如果要實(shí)現(xiàn)這樣一個(gè)需求王暗，在代碼結(jié)構(gòu)上可能會(huì)是很亂的，我們可能會(huì)陷入無盡的回調(diào)地獄中怎燥，例如這樣：
這樣的結(jié)構(gòu)無論對(duì)于開發(fā)人員還是維護(hù)人員都非常容易一臉懵逼瘫筐，為了解決這個(gè)問題，我們可以通過引入Rxjava+Retrofit铐姚，使用鏈?zhǔn)降慕Y(jié)構(gòu)策肝，讓整個(gè)代碼塊更易讀，也為了讓你離職后接手你的項(xiàng)目的人少罵你幾句隐绵。
動(dòng)手試一下
前期準(zhǔn)備
經(jīng)緯度轉(zhuǎn)為城市地址Api：由于Google Maps提供的Api在國內(nèi)無法使用（也可能有更好的方法請(qǐng)指教）之众，我找到了
http://api.map.baidu.com/geocoder?location=緯度,經(jīng)度&output=輸出格式類型&key=用戶密鑰這個(gè)Api來代替，注意這個(gè)Api要提前申請(qǐng)key依许，本文將提供一個(gè)key:6eea93095ae93db2c77be9ac910ff311棺禾。天氣預(yù)報(bào)Api：這里我使用的是心知天氣在百度Api服務(wù)中提供的接口，其中我使用了
天氣實(shí)況這一服務(wù)峭跳，具體的接口Url為http://apis.baidu.com/thinkpage/weather_api_full/currentweather膘婶，注意這里同樣要申請(qǐng)key，此處需要各位自行申請(qǐng)了蛀醉。Rxjava+Retrofit：通過Gradle導(dǎo)入即可
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'
可以開始了
首先我們要準(zhǔn)備好天氣服務(wù)和位置服務(wù)返回的實(shí)體類悬襟，這個(gè)實(shí)體類就需要麻煩大家自行去請(qǐng)求一下了，這里推薦一個(gè)Chrome的小插件Postman（需要翻墻）這個(gè)工具可以幫助你進(jìn)行網(wǎng)頁調(diào)試或發(fā)送http請(qǐng)求拯刁。自動(dòng)生成實(shí)體類應(yīng)該不用多說了GsonFormat即可搞定脊岳。
現(xiàn)在我們有了實(shí)體類，接下來我們就要通過Retrofit為每個(gè)請(qǐng)求創(chuàng)建相應(yīng)的Service了：
- 定位服務(wù)：
public interface LocationService {
@GET("geocoder")
Observable<LocationEntity> getLoation(
@Query("location") String location,
@Query("output") String output,
@Query("key") String key
);
}
- 天氣服務(wù)
請(qǐng)將代碼中的***替換為您申請(qǐng)的apikey
public interface WeatherService {
@Headers({"apikey:*********"})
@GET("currentweather")
Observable<WeatherEntity> getWeather(@Query("location") String city);
}
接下來我們?yōu)槊總€(gè)請(qǐng)求實(shí)例化相應(yīng)的Retrofit對(duì)象垛玻，并加入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);
}
下面就是我們的重點(diǎn)了割捅，我們要使用Rxjava為我們提供的十分豐富的操作符來完成這個(gè)連續(xù)的請(qǐng)求。聲明一下我是在點(diǎn)擊事件中完成的請(qǐng)求
public void getWeather(){
mLocationService.getLoation("31.407452,119.490523", "json", "6eea93095ae93db2c77be9ac910ff311")
.flatMap(new Func1<LocationEntity, Observable<WeatherEntity>>() {
@Override
public Observable<WeatherEntity> call(LocationEntity locationEntity) {
return mWeatherService.getWeather(locationEntity.getResult().getAddressComponent().getCity());
}
}).map(new Func1<WeatherEntity, String>() {
@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<SpannableString>() {
@Override
public void onCompleted() {
Log.d(TAG, "onCompleted: " + "完成數(shù)據(jù)獲取");
}
@Override
public void onError(Throwable e) {
tv.setText(e.toString());
}
@Override
public void onNext(String s) {
tv.setText(s);
Log.d(TAG,"當(dāng)前天氣為："+s)
}
});
}
首先我們通過系統(tǒng)的Api拿到我們目前所在位置的經(jīng)緯度信息帚桩，這里我就直接隨意寫了一個(gè)亿驾，接下來我們就要開始傳入接口所需要的參數(shù)進(jìn)行請(qǐng)求了，第一步我們先要通過經(jīng)緯度獲得我們所在的城市位置账嚎，這里我使用了Map和FlatMap這兩個(gè)操作符颊乘。
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
從文檔中我們可以看出参淹，F(xiàn)latMap可以將Observable對(duì)象發(fā)射到一個(gè)Observables對(duì)象中，然后排列為一個(gè)Observable對(duì)象乏悄，通過該操作符浙值，我們可以將得到的位置信息傳入天氣服務(wù)的Api中，將或得到的天氣實(shí)體發(fā)射到Observables中檩小，之后我們?cè)偻ㄟ^map操作符將天氣的Observable對(duì)象通過處理开呐，得到我們所需要的具體信息，即文中的text规求，之后我們訂閱這個(gè)事件筐付，在onNext方法中取得我們所需的信息。
這樣的鏈?zhǔn)浇Y(jié)構(gòu)相對(duì)于文中開頭的回調(diào)地獄來說阻肿，雖說學(xué)習(xí)成本較高瓦戚，但是一旦學(xué)會(huì)使用Rxjava，好處確實(shí)是非常多的丛塌，最后謝謝大家的閱讀较解。
項(xiàng)目地址
Github: https://github.com/icetea0822/Rxjava-Retrofit
這個(gè)項(xiàng)目本是我學(xué)習(xí)Rxjava和Retrofit練手用的，所以里面也一些不相關(guān)的東西赴邻，而且在學(xué)習(xí)時(shí)谷歌剛剛在北京開完開發(fā)者大會(huì)印衔，試了試Firebase和Google ads請(qǐng)見諒，大家請(qǐng)無視下面的廣告姥敛。
