Retrofit+RxJava 简单介绍

Retrofit 是一个当前很流行的网络请求库

　　想使用它首先在gradle文件中引用

　　　compile ‘com.squareup.retrofit2:retrofit:2.1.0‘
  　 compile ‘com.squareup.retrofit2:adapter-rxjava:2.1.0‘
   　compile ‘com.squareup.retrofit2:converter-gson:2.0.2’

RxJava 是针对于Java语音的一个异步响应式编程库

　　compile ‘io.reactivex.rxjava2:rxjava:2.0.1‘
　　compile ‘io.reactivex.rxjava2:rxandroid:2.0.1’

Retrofit的使用

　　创建一个Retrofit对象

private static void initRetrofit() {
        sRetrofit = new Retrofit.Builder()
                .baseUrl("http://www.weather.com.cn/")
                .client(sOkHttpClient)
                .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
                .addConverterFactory(GsonConverterFactory.create())
                .build();
    }

　　client 设置OkHttp用于拦截器设置

　　addCallAdapterFactory()设置支持RxJava返回值为Oservable<M>

　　addConverterFactory() 设置支持Gson 直接返回实体类

接下来在创建一个OKHttpClient.Buildr对象

OkHttpClient.Builder builder = new OkHttpClient.Builder();

　　1设置结果拦截器

Interceptor cacheInterceptor = new Interceptor() {
            @Override
            public Response intercept(Chain chain) throws IOException {
                Request request = chain.request();
                if (!CommonUtil.isNetworkConnected(MyApplication.getInstance())) {
                    request = request.newBuilder()
                            .cacheControl(CacheControl.FORCE_CACHE)
                            .build();
                }
                Response response = chain.proceed(request);
                Response.Builder newBuilder = response.newBuilder();
                if (CommonUtil.isNetworkConnected(MyApplication.getInstance())) {
                    int maxAge = 0;
                    // 有网络时 设置缓存超时时间0个小时
                    newBuilder.header("Cache-Control", "public, max-age=" + maxAge);
                } else {
                    // 无网络时，设置超时为4周
                    int maxStale = 60 * 60 * 24 * 28;
                    newBuilder.header("Cache-Control", "public, only-if-cached, max-stale=" + maxStale);
                }
                return newBuilder.build();
            }
        };

　　在这里有网络取最新，没网取缓存

builder.cache(cache).addInterceptor(cacheInterceptor); 

　　添加到builder；

　　2.设置请求拦截器

Interceptor requestInterceptor = new Interceptor() {
            @Override
            public Response intercept(Chain chain) throws IOException {
                Request request = chain.request()
                        .newBuilder()
                        .addHeader("Accept", "application/vnd.yu.v4+json")
                        .addHeader("Content-Type", "application/json")
                        .addHeader("Range", "page:1,max:10")
                    .addHeader("Authorization", "")
                        .build();request.headers().toString());
                return chain.proceed(request);
            }
        };

　　一般设置统一header 时使用

builder.addNetworkInterceptor(requestInterceptor);

　　设置超时重连

builder.connectTimeout(15, TimeUnit.SECONDS);
builder.readTimeout(20, TimeUnit.SECONDS);
builder.writeTimeout(20, TimeUnit.SECONDS);
builder.retryOnConnectionFailure(true);return builder.build();

　　OkHttp设置完成。

接下来去设置ApiCallBack

　　使用RxJava订阅

　　ApiCallBack<M>是abstract要继承Subscriber<M>

public abstract class ApiCallback<M> extends Subscriber<M> {

    public abstract void onSuccess(M model);

    public abstract void onFailure(String msg);

    public abstract void onFinish();

    @Override
    public void onError(Throwable e) {
        e.printStackTrace();
        if (e instanceof HttpException) {
            HttpException httpException = (HttpException) e;
            int code = httpException.code();
            String msg = httpException.getMessage();
            if (code == 504) {
                msg = "网络不给力";
            }
            if (code == 502 || code == 404) {
                msg = "服务器异常，请稍后再试";
            }
            onFailure(msg);
        } else {
            onFailure(e.getMessage());
        }
        onFinish();
    }

    @Override
    public void onNext(M model) {
        onSuccess(model);
    }

    @Override
    public void onCompleted() {
        onFinish();
    }

}

接下来去写ApiService

　　ApiService 是个接口

　　Retrofit提供的请求方式用注解修改变量生成URL等

　　RxJava方式

@GET("adat/sk/{cityId}.html")
Observable<MainModel> getMainBanner(@Path("cityId") String cityId);

//请求方式@GET，@POST ，@PUT @DELETE 等。
(@Path(“cityId") String cityId)    //修改路径中对应的变量{cityId}
@POST
Observable<MainModel> getTaskToken(@Url String url, @Body String body);

@Headers({"Accept: application/json","Content-Type: application/json"})
@GET
Observable<RecordsTask> getMainTask(@Url String url, @Header("Authorization") String token);

　　以上简单写了几种大多数都包括了

需要的已经配置好了 下面去使用它

 //RXjava注册
    public void addSubscription(Observable observable, Subscriber subscriber) {
        if (mCompositeSubscription == null) {
            mCompositeSubscription = new CompositeSubscription();
        }
        mCompositeSubscription.add(observable
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(subscriber));
    }

　　把上面内容写在Base中

　　subscribeOn() : 指定

p.p1 { margin: 0.0px 0.0px 0.0px 0.0px; line-height: 18.0px; font: 16.0px "PingFang SC"; color: #2f2f2f; background-color: #ffffff }
p.p2 { margin: 0.0px 0.0px 0.0px 0.0px; line-height: 27.0px; font: 16.0px "PingFang SC"; color: #2f2f2f }
p.p3 { margin: 0.0px 0.0px 0.0px 0.0px; line-height: 27.0px; font: 16.0px Helvetica; color: #2f2f2f }
span.s1 { font: 16.0px Helvetica }
span.s2 { }
span.s3 { font: 16.0px "PingFang SC" }
span.Apple-tab-span { white-space: pre }

subscribe（）所发生的线程，即Observable.OnSubscribe被激活时所处的线程。或者叫做事件产生的线程。

observeOn（）：指定用户所运行的线程。或者叫做事件消费的线程。

使用 subscribeOn() 和 observeOn() 两个方法来对线程进行控制了。

在Activity中调用

public void loadWeather(String city) {
        addSubscription(mApiService.getMainBanner(city), new ApiCallback<MainModel>() {
            @Override
            public void onSuccess(MainModel response) {
                mMvpView.onSuccess(response);
            }

            @Override
            public void onFailure(String msg) {
                mMvpView.onFail(msg, 1);
            }

            @Override
            public void onFinish() {

            }
        });
    }

在结束时还需要取消RxJava的注册以免内存泄漏

public void onUnsubscribe() {
        if (mCompositeSubscription != null && mCompositeSubscription.hasSubscriptions()) {
            mCompositeSubscription.unsubscribe();
        }
    }

结束。