2、RxJava2 Retrofit2 封装实践初始化

本文主要是介绍2、RxJava2 Retrofit2 封装实践初始化，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

RxJava2&Retrofit2的基本实现

RxJava2 & Retrofit2 & Rxlifecycle

依赖

    compile 'com.squareup.okhttp3:okhttp:3.7.0'compile 'com.squareup.retrofit2:retrofit:2.2.0'compile 'com.squareup.retrofit2:converter-gson:2.2.0'compile 'com.squareup.retrofit2:adapter-rxjava2:2.2.0'compile 'io.reactivex.rxjava2:rxandroid:2.0.1'compile 'io.reactivex.rxjava2:rxjava:2.0.8'compile 'com.trello.rxlifecycle2:rxlifecycle:2.0.1'// If you want to bind to Android-specific lifecyclescompile 'com.trello.rxlifecycle2:rxlifecycle-android:2.0.1'// If you want pre-written Activities and Fragments you can subclass as providerscompile 'com.trello.rxlifecycle2:rxlifecycle-components:2.0.1'

`HTTPCENTER`

public static final String SERVICE = "http://xxxa.com/web/";public static final String TOYS_SERVICE = "http://api.xxxb.com/";@StringDef({SERVICE, TOYS_SERVICE})@Retention(RetentionPolicy.SOURCE)public @interface HOST {}/*** 为了拓展性（切换Host），直接传入Retrofit.Builder* 要求传入的Retrofit.Builder是单例** @param builder* @return*/protected static Retrofit getRetrofit(Retrofit.Builder builder) {return builder.addConverterFactory(GsonConverterFactory.create(new Gson())).addCallAdapterFactory(RxJava2CallAdapterFactory.create()).client(initOkHttpClient()).build();}protected static Retrofit.Builder getBuilder(@HOST String host) {do {if (TextUtils.equals(host, SERVICE)) {return BuilderHolder.builder;}if (TextUtils.equals(host, TOYS_SERVICE)) {return BuilderHolder.toyBuilder;}} while (false);return null;}private static class BuilderHolder {private static Retrofit.Builder builder = new Retrofit.Builder().baseUrl(SERVICE);private static Retrofit.Builder toyBuilder = new Retrofit.Builder().baseUrl(TOYS_SERVICE);}/*** 用于请求的Retrofit** @return*/protected static Retrofit getRetrofitDm() {return getRetrofit(getBuilder(SERVICE));}protected static Retrofit getRetrofitToys() {return getRetrofit(getBuilder(TOYS_SERVICE));}public static HTTPService getService(@HOST String host) {do {if (TextUtils.equals(host, SERVICE)) {return ServiceHolder.DMSERVICE;}if (TextUtils.equals(host, TOYS_SERVICE)) {return ServiceHolder.TOYSERVICE;}} while (false);return null;}private static class ServiceHolder {static HTTPService DMSERVICE = getRetrofitDm().create(HTTPService.class);static HTTPService TOYSERVICE = getRetrofitToys().create(HTTPService.class);}/*** client** @return*/private static OkHttpClient initOkHttpClient() {OkHttpClient.Builder client = new OkHttpClient().newBuilder();client.retryOnConnectionFailure(true);client.connectTimeout(1, TimeUnit.MINUTES);client.readTimeout(1, TimeUnit.MINUTES);client.writeTimeout(1, TimeUnit.MINUTES);return client.build();}

根据HOST初始化HTTPService，都实现了单例
- 构建Retrofit的Builder
- 根据Builder创建HTTPService
创建OkhttpClient

`HTTPService`

public interface HTTPService {/*** 发现-推荐-时间轴** @param token* @param offset* @param limit* @return*/@GET("v2/index/list")Observable<TimeLineModel> requestRecommendTimeLine(@Query("offset") int offset, @Query("limit") int limit);@GET("index.php?r=message/heart")Observable<Heart> heart();}

`Activity`请求

private void dm() {HTTPCenter.getService(HTTPCenter.SERVICE).heart().subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()) //切换线程.compose(MainActivity.this.bindToLifecycle()) //绑定生命周期.doOnSubscribe(new Consumer<Disposable>() {@Overridepublic void accept(@NonNull Disposable disposable) throws Exception {Toast.makeText(MainActivity.this,"dm start",Toast.LENGTH_SHORT).show();}}).doOnTerminate(new Action() {@Overridepublic void run() throws Exception {Toast.makeText(MainActivity.this,"dm end",Toast.LENGTH_SHORT).show();}}).subscribe(new Consumer<Heart>() {@Overridepublic void accept(@NonNull Heart heart) throws Exception {if(heart != null) {tvDesc.setText(heart.toString());}}});}private void toys() {HTTPCenter.getService(HTTPCenter.TOYS_SERVICE).requestRecommendTimeLine(1,20).map(new Function<TimeLineModel, TimeLineModel>() {@Overridepublic TimeLineModel apply(@NonNull TimeLineModel timeLineModel) throws Exception {return timeLineModel;}}).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).compose(MainActivity.this.bindToLifecycle()).subscribe(new Observer<TimeLineModel>() {@Overridepublic void onSubscribe(Disposable d) {}@Overridepublic void onNext(TimeLineModel timeLineModel) {tvDesc.setText(timeLineModel.toString());}@Overridepublic void onError(Throwable e) {}@Overridepublic void onComplete() {}});}