關(guān)于Retrofit+RxJava的基本用法，本文不作詳細(xì)介紹，可以參考
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---
將返回的被觀察者進(jìn)行轉(zhuǎn)換map(new HttpResultFunc<GroupBean>()) 這里牽涉到一個比較重要的地方：服務(wù)器返回碼統(tǒng)一處理

/** 
  * 用來統(tǒng)一處理Http的resultCode,并將HttpResult的Data部分剝離出來返回給subscriber 
  * 假設(shè)code：204是token對應(yīng)的返回碼，那么我們可以進(jìn)行相應(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之后再來細(xì)看code1中的代碼compose，這是rxjava專門為開發(fā)者提供的防止打破鏈?zhǔn)浇Y(jié)構(gòu)的操作符。rxjava最大的亮點(diǎn)就是在線程之間來回切換自如，使用如下代碼

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類型，然后再通過手動解析達(dá)到數(shù)據(jù)->模型的目的。