前言
之前做網(wǎng)絡請求，用的是android-async-http惰蜜，基于HttpClient 的，雖然早已淘汰受神，但一直懶得換抛猖，前一段時間看了stormzhang的《2016 Android Top 10 Library》文章，提到RxJava+Retrofit 是完美搭配路克，所以下定決定重構一下現(xiàn)在的項目
網(wǎng)上查了一些資料樟结，遇到了一些小坎坷养交，終于搞定了精算，因為網(wǎng)上查到的一些文章大多都是半年以前的，而我使用的都是最新的庫碎连，遇到了一些新的問題灰羽，所以感覺有必要寫篇文章幫助后人少走一些彎路
本文默認讀者對RxJava和Retrofit 已經(jīng)有了一定的了解，若對RxJava和Retrofit 還不了解鱼辙，請先查閱相關資料
使用
1廉嚼、添加依賴庫
compile "io.reactivex.rxjava2:rxjava:2.1.1"
compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
compile 'com.squareup.retrofit2:retrofit:2.3.0'
compile 'com.squareup.retrofit2:converter-gson:2.3.0'
compile 'com.squareup.retrofit2:adapter-rxjava2:2.3.0'
converter-gson是Retrofit到Gson進行轉換的庫，adapter-rxjava2是Retrofit到RxJava進行轉換的庫
這里我是采用Google Gson進行數(shù)據(jù)解析的倒戏，如果你使用的是Jackson怠噪，替換為如下依賴即可
compile 'com.squareup.retrofit2:converter-jackson:2.3.0'
如果需要添加HttpLoggingInterceptor進行調試，添加如下依賴
compile 'com.squareup.okhttp3:logging-interceptor:3.8.1'
2杜跷、寫一個Service
public interface RetrofitService {
@FormUrlEncoded
@POST("account/login")
Observable<BaseEntity<UserInfo>> login(
@Field("userId") String userId,
@Field("password") String password
);
@GET("video/getUrl")
Observable<BaseEntity<VideoUrl>> getVideoUrl(
@Query("id") long id
);
@FormUrlEncoded
@POST("user/addVideo")
Observable<BaseEntity<Boolean>> addVideo(
@FieldMap Map<String, Object> map
);
}
相對于單獨使用Retrofit傍念，該處返回的是Observable對象
3矫夷、通常服務器端會返回統(tǒng)一的數(shù)據(jù)格式，這里我們寫一個BaseEntity
public class BaseEntity<E> {
@SerializedName("code")
private int code;
@SerializedName("msg")
private String msg;
@SerializedName("data")
private E data;
public boolean isSuccess() {
return code == 0;
}
public int getCode() {
return code;
}
public void setCode(int code) {
this.code = code;
}
public String getMsg() {
return msg;
}
public void setMsg(String msg) {
this.msg = msg;
}
public E getData() {
return data;
}
public void setData(E data) {
this.data = data;
}
}
4憋槐、然后我們可以封裝一個RetrofitFactory
public class RetrofitFactory {
private static final String BASE_URL = "http://api.baidu.com/";
private static final long TIMEOUT = 30;
// Retrofit是基于OkHttpClient的双藕，可以創(chuàng)建一個OkHttpClient進行一些配置
private static OkHttpClient httpClient = new OkHttpClient.Builder()
// 添加通用的Header
.addInterceptor(new Interceptor() {
@Override
public Response intercept(Chain chain) throws IOException {
Request.Builder builder = chain.request().newBuilder();
builder.addHeader("token", "123");
return chain.proceed(builder.build());
}
})
/*
這里可以添加一個HttpLoggingInterceptor，因為Retrofit封裝好了從Http請求到解析阳仔，
出了bug很難找出來問題忧陪，添加HttpLoggingInterceptor攔截器方便調試接口
*/
.addInterceptor(new HttpLoggingInterceptor(new HttpLoggingInterceptor.Logger() {
@Override
public void log(String message) {
}
}).setLevel(HttpLoggingInterceptor.Level.BASIC))
.connectTimeout(TIMEOUT, TimeUnit.SECONDS)
.readTimeout(TIMEOUT, TimeUnit.SECONDS)
.build();
private static RetrofitService retrofitService = new Retrofit.Builder()
.baseUrl(BASE_URL)
// 添加Gson轉換器
.addConverterFactory(GsonConverterFactory.create(buildGson()))
// 添加Retrofit到RxJava的轉換器
.addCallAdapterFactory(RxJava2CallAdapterFactory.create())
.client(httpClient)
.build()
.create(RetrofitService.class);
public static RetrofitService getInstance() {
return retrofitService;
}
private static Gson buildGson() {
return new GsonBuilder()
.serializeNulls()
.setFieldNamingPolicy(FieldNamingPolicy.IDENTITY)
// 此處可以添加Gson 自定義TypeAdapter
.registerTypeAdapter(UserInfo.class, new UserInfoTypeAdapter())
.create();
}
}
5、通常我們會在IO線程進行請求近范，在主線程進行回調
public class RxSchedulers {
public static <T> ObservableTransformer<T, T> compose() {
return new ObservableTransformer<T, T>() {
@Override
public ObservableSource<T> apply(Observable<T> observable) {
return observable
.subscribeOn(Schedulers.io())
.doOnSubscribe(new Consumer<Disposable>() {
@Override
public void accept(Disposable disposable) throws Exception {
if (!Utils.isNetworkConnected()) {
Toast.makeText(context, R.string.toast_network_error, Toast.LENGTH_SHORT).show();
}
}
})
.observeOn(AndroidSchedulers.mainThread());
}
};
}
}
這里我們可以添加一個通用的網(wǎng)絡連接判斷
6嘶摊、RxJava Observable 訂閱需要傳入一個Observer對象，此處封裝一個BaseObserver
public abstract class BaseObserver<T> implements Observer<BaseEntity<T>> {
private static final String TAG = "BaseObserver";
private Context mContext;
protected BaseObserver(Context context) {
this.mContext = context.getApplicationContext();
}
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onNext(BaseEntity<T> value) {
if (value.isSuccess()) {
T t = value.getData();
onHandleSuccess(t);
} else {
onHandleError(value.getMsg());
}
}
@Override
public void onError(Throwable e) {
Log.e(TAG, "error:" + e.toString());
}
@Override
public void onComplete() {
Log.d(TAG, "onComplete");
}
protected abstract void onHandleSuccess(T t);
protected void onHandleError(String msg) {
Toast.makeText(mContext, msg, Toast.LENGTH_SHORT).show();
}
}
7评矩、調用
private void login(String userId, String password) {
Observable<BaseEntity<UserInfo>> observable = RetrofitFactory.getInstance().login(userId, password);
observable.compose(RxSchedulers.compose()).subscribe(new BaseObserver<UserInfo>(context) {
@Override
protected void onHandleSuccess(UserInfo userInfo) {
// 保存用戶信息等操作
}
});
}
RxJava生命周期管理
可以用RxLifecycle來管理RxJava的生命周期
RxLifecycle：https://github.com/trello/RxLifecycle/tree/2.x
小結
重構之后發(fā)現(xiàn)Retrofit搭配RxJava之后更卒，絕對是最好用的網(wǎng)絡請求庫，沒有之一
如有問題稚照，歡迎留言指正
Demo地址：https://github.com/jaycee88/RxJavaRetrofitDemo
參考文章：http://www.reibang.com/p/1fb294ec7e3b
http://blog.csdn.net/gesanri/article/details/52701651
最后
向大家推薦《進階全棧工程師之路》
https://xiaozhuanlan.com/fullstack?rel=4605162920
