先附上初始化Retrofit的工具类：
public class RetrofitProvide {
/**
* 网络连接超时时间
*/
public static final int CONN_TIME_OUT = 60*1000;
/**
* 网络读取超时时间
*/
public static final int READ_TIME_OUT = 60*1000;
private volatile static Retrofit retrofit = null;
private RetrofitProvide(){}
public static Retrofit getInstance(){
if(retrofit == null){
synchronized (RetrofitProvide.class){
retrofit = getRetrofit();
}
}
return retrofit;
}
private static OkHttpClient getOkHttpClient(){
OkHttpClient.Builder builder = new OkHttpClient.Builder();
//超时设置
builder.connectTimeout(CONN_TIME_OUT, TimeUnit.MILLISECONDS);
builder.readTimeout(READ_TIME_OUT, TimeUnit.MILLISECONDS);
//日志
HttpLoggingInterceptor interceptor = new HttpLoggingInterceptor();
interceptor.setLevel(HttpLoggingInterceptor.Level.BODY);
builder.addInterceptor(interceptor);
builder.addNetworkInterceptor(getInterceptor());
return builder.build();
}
private static Interceptor getInterceptor(){
return chain -> {
Request request = chain.request();
HttpUrl url;
//这里是每次app调接口都需要给的参数，统一放在这里
url = request.url().newBuilder()
.addQueryParameter("sessionToken", MyApp.getInstance().getSession())
.addQueryParameter("cityId",MyApp.getInstance().getCurrentCityId())
.addQueryParameter("appVersion",MyApp.getInstance().getAppVersionName())
.addQueryParameter("phoneAttributes",MyApp.getInstance().getPhoneAttributes())
.addQueryParameter("phoneType","android")
.build();
request = request.newBuilder().url(url).build();
LogUtils.LOGI("-- head 修改后",url.toString());
return chain.proceed(request);
};
}
/**
* 设置连接内容
* json转换
* Rxjava适配
* @return
*/
private static Retrofit getRetrofit(){
return new Retrofit
.Builder()
.baseUrl(NetConstant.SERVICE_URL.concat("/"))
.client(getOkHttpClient())
.addConverterFactory(ScalarsConverterFactory.create())
.addConverterFactory(GsonConverterFactory.create())
.addCallAdapterFactory(RxJavaCallAdapterFactory.create())
.build();
}
}
通过这个工具类来初始化Retrofit，可以实现网址拦截，增加联网参数或者打印网址都可以
直接使用:
RetrofitProvide.getInstance()
.create(NannyApi.class)
.getNannyDetail(nannyId)
.compose(RxSchedulers.io_main(mContext))
.subscribe(nannyDetail -> {
//TODO 拿到对象开始做事情
});
比如这个NannyApi，里面有个getNannyDetail的接口，我们通过这个接口可以拿到保姆详情的json数据，然后这个.compose(RxSchedulers.io_main(mContext))是对切换线程和出现错误提示的懒人写法，这里先给出RxSchedulers这个懒人类：
public class RxSchedulers {
public static <T> Observable.Transformer<T, T> io_main(Context context) {
return tObservable -> tObservable.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread())
.doOnError(new MyOnErrorAction1<>(context));
}
}
可以直观的看到，这个.io_main()方法非常简单，就把.subscribeOn(Schedulers.io())被观察者运行在io线程和.observeOn(AndroidSchedulers.mainThread())观察者运行在主线程两个线程切换加入，并增加了一个获取错误的类，这个类继承于Action1，把获取到的错误用dialog来弹出，代码比较简单，如下：
public class MyOnErrorAction1<T> implements Action1<T> {
public Dialog dialog;
private Context mContext;
public MyOnErrorAction1(Context context) {
mContext = context;
}
@Override
public void call(T t) {
if (t instanceof Throwable) {
Throwable throwable = (Throwable) t;
throwable.printStackTrace();
dialog = DialogUtil.showAlert(mContext, "异常消息", throwable.getMessage(), "知道了", false, view -> dialog.dismiss());
}
}
}
当然这里面大家也可以加入把错误提交到服务器等等一系列的操作
这样我们在用Retrofit联网时，不用操心错误处理和线程切换，专注于获取到的数据，只需要加入.compose(RxSchedulers.io_main(mContext))这一行代码，就可以直接订阅一个Action1的onNext来操作数据了，当然需要对onCompleted做操作的话，比如隐藏掉加载动画，在 .doOnError()后面还可以加一个.doOnCompleted()，里面加入一个对操作完成之后的要做的Action0。
有什么不懂的可以留言哦
