關(guān)于Retrofit+RxJava的基本用法，本文不作詳細介紹视卢，可以參考
Retrofit官方文檔
Retrofit官方文檔
給 Android 開發(fā)者的 RxJava 詳解
使用gradle導(dǎo)入對應(yīng)的庫
//retrofit
compile 'com.squareup.retrofit2:retrofit:2.0.2'
//網(wǎng)絡(luò)請求攔截器
compile 'com.squareup.okhttp3:logging-interceptor:3.2.0'
//gson解析
compile 'com.squareup.retrofit2:converter-gson:2.0.2'
//rxjavacompile 'io.reactivex:rxandroid:1.1.0'
compile 'com.squareup.retrofit2:adapter-rxjava:2.0.2'
//dragger2 <不使用Dragger2可以選擇不導(dǎo)入下面的庫>
provided 'org.glassfish:javax.annotation:10.0-b28'
apt 'com.google.dagger:dagger-compiler:2.0.2'
compile 'com.google.dagger:dagger:2.0.2'
先上例子
BaseApplication.get(BaseApplication.getAppContext()).
getComponent()
.getAPIModule()
.getConvstGroup(uid, token)
.subscribe(new BaseSubscribe<GroupBean>(groupView) {
@Override
public void onResponse(GroupBean bean) {
groupView.addGroups(bean.list);
}
});
我們一個一個來看
首先是getConvstGroup()前面的是Dragger2在這里就先不做解釋了
code1
@Provides
@Singleton
public Observable<GroupBean> getConvstGroup(int uid, String token) {
return getService().getConvstGroup(uid, token).map(new HttpResultFunc<GroupBean>()).compose(this.<GroupBean>applySchedulers());
}
code2
/**
* 獲取最近小組相關(guān)的列表 *
* @param uid
* @param token
* @return 包裹數(shù)據(jù)源的Observable
*/
@FormUrlEncoded
@POST("msg/GetGroupConversationList")
Observable<BaseBean<GroupBean>> getConvstGroup(@Field("uid") int uid, @Field("token") String token);
---code2---
關(guān)于Retrofit請求參數(shù)注解字段可以參考
http://blog.csdn.net/yangxi_pekin/article/details/5338205
而此處我們是POST請求所以采取表單提交數(shù)據(jù)以 @field("paramName") type paramName 的形式請求連接地址<msg/GetGroupConversationList>并將結(jié)果通過gsonConverterFactory解析為本地的類并以泛型Obervable<BaseBean<GroupBean>>返回 (PS:basebean將會在下面給出)
---code1---
將返回的被觀察者進行轉(zhuǎn)換map(new HttpResultFunc<GroupBean>()) 這里牽涉到一個比較重要的地方：服務(wù)器返回碼統(tǒng)一處理
/**
* 用來統(tǒng)一處理Http的resultCode,并將HttpResult的Data部分剝離出來返回給subscriber
* 假設(shè)code：204是token對應(yīng)的返回碼踱卵，那么我們可以進行相應(yīng)的操作logout
* 當(dāng)返回碼不為204且不為0（返回成功）時，拋出異常
* 否則返回對應(yīng)的bean
* @param <T> Subscriber真正需要的數(shù)據(jù)類型据过，也就是Data部分的數(shù)據(jù)類型
*/
private class HttpResultFunc<T> implements Func1<BaseBean<T>, T> {
@Override
public T call(BaseBean<T> baseBean) {
if (baseBean.code == 204) {
if (!PollService.isForceLogout)
//logout
} else if (baseBean.code != 0 && baseBean.code != 204) {
throw new APIException(baseBean.desc);
}
return baseBean.ret;
}
}
---BaseBean---
/**
* Created by Mr.Xu on 16/9/7.
*/
public class BaseBean<T>{
/**
* code 狀態(tài)碼
* desc 描述
* ret 數(shù)據(jù)源
*/
public int code;
public String desc;
public T ret;
}
說完類型轉(zhuǎn)換map之后再來細看code1中的代碼compose惋砂，這是rxjava專門為開發(fā)者提供的防止打破鏈?zhǔn)浇Y(jié)構(gòu)的操作符。rxjava最大的亮點就是在線程之間來回切換自如绳锅，使用如下代碼
observable.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
而當(dāng)我們?nèi)绻胍苊庵貜?fù)調(diào)用就可以使用compose操作符西饵，該方法傳入了applySchedulers方法的返回值，applySchedulers方法如下
<T> Observable.Transformer<T, T> applySchedulers() {
return new Observable.Transformer<T, T>() {
@Override
public Observable<T> call(Observable<T> observable) {
return observable.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
}
};
}
至此我們已經(jīng)完成了一個網(wǎng)絡(luò)的請求任務(wù)
關(guān)于Retrofit的配置如下
@Provides
@Singleton
OkHttpClient provideOkHttpClient() {
OkHttpClient.Builder builder = new OkHttpClient().newBuilder().readTimeout(READ_TIME_OUT_VALUE, TimeUnit.SECONDS).connectTimeout(CONNECT_TIME_OUT_VALUE, TimeUnit.SECONDS).addInterceptor(new Interceptor() {
@Override
public Response intercept(Chain chain) throws IOException {
Request request = chain.request().newBuilder()
.addHeader("token", "token")
.build();
return chain.proceed(request.newBuilder().method(request.method(), request.body()).build());
}
});
return client;
}
配置OkHttpClient鳞芙，在配置過程中可以給builder添加一個Interceptor,可以在請求之前攔截并添加需要的header如token驗證眷柔。
@Provides
@Singleton
public static Retrofit provideRetrofit(OkHttpClient okHttpClient) {
Retrofit retrofit;
GsonConverterFactory gsonConverterFactory = GsonConverterFactory.create();
retrofit = new Retrofit.Builder().client(okHttpClient)
.baseUrl(APIService.BASE_RELEASE_URL) //增加返回值為String的支持
.addConverterFactory(ScalarsConverterFactory.create())
.addConverterFactory(gsonConverterFactory)
.addCallAdapterFactory(RxJavaCallAdapterFactory.create())
.build();
return retrofit;
}
當(dāng)我們的服務(wù)器返回的數(shù)據(jù)特別復(fù)雜不能直接使用Gson解析時可以給Retrofit添加上ScalarsConverterFactory，此時返回的類型為String類型原朝，然后再通過手動解析達到數(shù)據(jù)->模型的目的驯嘱。
