kotlin之RxJava2+Retrofit2

之前分享出来的RxJava2+Retrofit2实现网络请求封装在新的项目中使用良好没有出现什么水土不服的情况。好久没有更新简书了,最近到了新公司忙的昏天暗地的.乘着产品迭代的中间期,学习kotlin的使用,也把之前的网络请求框架转换成了kotlin语言.现在将代码分享出来 https://github.com/timordu/Rely-kotlin ，对比以前的java的框架，kotlin语言的框架使用起来更简单。现就新的特性介绍如下

构建请求

在kotlin版本中使用了建造者模式，通过HttpBuilder类来获取Retrofit对象，具体使用如下

interface ApiService {
    companion object Factory {
        fun auth(): ApiService {
            val httpBuilder = HttpBuilder()
                    .baseUrl("http://192.168.2.111:8080/JNCApp/")
//                    .addHeader("","")
//                    .addHeaders(ArrayMap())
//                    .addParam("","")
//                    .addParams(ArrayMap())
//                    .addInterceptor()
//                    .addNetworkInterceptor()
                    .build()
            return httpBuilder.create(ApiService::class.java)
        }

        fun default(): ApiService {
            val dir = Environment.getExternalStorageDirectory()
            val file = File(dir.absoluteFile, "Rely")
            if (!file.exists()) file.mkdirs()
            val httpBuilder = HttpBuilder()
                    .baseUrl("http://192.168.2.111:8080/JNCApp/")
                    .addHeaders(ShareData.getHeaders())
                    .setCacheFile(file)
                    .build()
            return httpBuilder.create(ApiService::class.java)
        }
    }

    //@Headers("Cache-Control: public, max-age=600")//只缓存get请求

    /**
     * 刷新token
     */
    @FormUrlEncoded
    @POST("login/refreshToken.action")
    fun refreshToken(@Field("refreshToken") refreshToken: String): Call<String>


    @FormUrlEncoded
    @POST("login/login.action")
    @Headers("Cache-Control: public, max-age=600")
    fun login(@Field("user_id") account: String,
              @Field("passwd") passport: String): Observable<Result<Account>>

    @FormUrlEncoded
    @POST("login/login.action")
    fun login2(@Field("user_id") account: String,
               @Field("passwd") passport: String): Call<Result<Account>>
}

该接口类主要是用来声明接口的，和之前的使用方式一样，唯一不同的是增加了伴生对象，在此可以建立多个方法以满足不同请求地址和请求参数的配置。在使用的时候也有所简化，比如上面我们调用登录的接口可以直接使用ApiService.auth().login()。

生命周期

在java版本中，我们创建了RxUtil对象来简化请求和绑定生命周期，在kotlin版本中，代码有所简化,这此使用了扩展函数，暂时只支持跟随Activity和Fragment的生命周期，无法绑定到具体的生命周期，后期补充。

/*
 * 绑定生命周期和弹窗
 */
fun <T> applySchedulers(provider: LifecycleProvider<*>, dialog: Dialog): ObservableTransformer<T, T> {
    return ObservableTransformer<T, T> {
        upstream ->
        upstream
                .delay(1, TimeUnit.SECONDS)
                .subscribeOn(Schedulers.io())
                .doOnSubscribe({ disposable ->
                    dialog.setOnCancelListener { disposable.dispose() }
                    dialog.show()
                })
                .observeOn(AndroidSchedulers.mainThread())
                .doOnTerminate { dialog.dismiss() }
                .bindToLifecycle(provider)
    }
}

/*
 * 绑定生命周期和无弹窗
 */
fun <T> applySchedulers(provider: LifecycleProvider<*>): ObservableTransformer<T, T> {
    return ObservableTransformer<T, T> {
        upstream ->
        upstream
                .delay(1, TimeUnit.SECONDS)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .bindToLifecycle(provider)
    }
}

/*
 * 不绑定生命周期和无弹窗，针对Service中的请求使用
 */
fun <T> applySchedulers(): ObservableTransformer<T, T> {
    return ObservableTransformer<T, T> {
        upstream ->
        upstream
                .delay(1, TimeUnit.SECONDS)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
    }
}

利用kotlin的扩展函数的属性可以优化成

fun <T> Observable<T>.applySchedulers(provider: LifecycleProvider<*>, dialog: Dialog?, delay: Long = 1): Observable<T> {
    return delay(delay, TimeUnit.SECONDS)
            .subscribeOn(Schedulers.io())
            .doOnSubscribe { disposable ->
                dialog?.setOnCancelListener { disposable.dispose() }
                dialog?.show()
            }
            .observeOn(AndroidSchedulers.mainThread())
            .doOnTerminate { dialog?.dismiss() }
            .bindToLifecycle(provider)
}

fun <T> Observable<T>.applySchedulers(provider: LifecycleProvider<*>): Observable<T> {
    return subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .bindToLifecycle(provider)
}

fun <T> Observable<T>.applySchedulers(): Observable<T> {
    return subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
}

优化后的网络请求相比之前的写法又简化了不少.

ApiService.getUser().login("","") .applySchedulers() .subscribe(...)

请求重试

在java版本中，请求失败重试时配置在RxUtil类中的，为了让请求重试的参数可配置，所以新建了RetryInterceptor，在配置okhttpBuilder添加了拦截器，以达到同样的效果。具体代码如下

class RetryInterceptor(private var retryCount: Int, private var retryDelay: Int) : Interceptor {
    private var currentRetry = 0

    override fun intercept(chain: Interceptor.Chain): Response {
        var response = chain.proceed(chain.request())
        while (!response.isSuccessful && currentRetry < retryCount) {
            currentRetry++
            Thread.sleep(retryDelay * 1000L)
            response = chain.proceed(chain.request())
        }
        return response
    }
}

总结

以上就是kotlin版本RxJava2+Retrofit2的网络请求框架，后续有新的想法将继续补充