Kotlin语言下封装简化Retrofit, rxjava网络调用

封装后的使用示例

接口定义:

interface LdApiService {

    @GET("wapi/ldapp/feedlist")
    fun getHomepageItemFeedlist(@Query("tagId") tagId: String = "0",
                                @Query("locationAnchor") locationAnchor: String = "",
                                @Query("slipDirection") slipDirection: String = "2",
                                @Query("hwratio") hwRatio: Float = 1.0f): Observable<HomeFeedResult>
}

在fragment中调用上面的接口, 加载数据:

api.getHomepageItemFeedlist().action(
                onError = { it -> Log.d(TAG, "exception", it) },
                onNext = { it -> onDataCallBack(it) })

可以看到去掉了基本永远重复的线程切换逻辑:

 .subscribeOn(Schedulers.newThread())
                .observeOn(AndroidSchedulers.mainThread())

整体感觉清爽了很多, 不再是经典的一坨无聊的代码堆积在那了.

实现

下面是Api类全部的实现代码

import okhttp3.OkHttpClient
import retrofit2.Retrofit
import retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory
import retrofit2.converter.gson.GsonConverterFactory
import java.util.concurrent.TimeUnit

object Api {
    var client: OkHttpClient = OkHttpClient.Builder()
//            .sslSocketFactory(HttpsTrustManager.createSSLSocketFactory())
//            .hostnameVerifier(HttpsTrustManager.TrustAllHostnameVerifier())
//            .addInterceptor(HttpLogInterceptor("http", true))
            .connectTimeout(20, TimeUnit.SECONDS)
            .build()
    var service: LdApiService = Retrofit.Builder()
            .baseUrl(BaseURL.SERVER_URL)
            .addConverterFactory(GsonConverterFactory.create())
            .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
            .client(client)
            .build().create(LdApiService::class.java)

}

通过object实现单例模式. 并且这里把OkHttpClient变量单独列出来, 是为了glide等第三方库共用.
简短直接, 而且对于大部分依赖网络的应用来说, 这个初始化过程完全没必要进行懒加载.

这样每次使用时可以直接如此调用:

Api.service.queryXXXX() ..........

为了看着更简洁, 可以通过定义别名来缩短全面的Api.service

 import com.spx.litedo.api.Api.service as api

对于线程切换的封装:

fun <T : Any> Observable<T>.action(
        onError: (Throwable) -> Unit,
        onNext: (T) -> Unit,
        onComplete: () -> Unit = {}
): Disposable {
    return this.subscribeOn(Schedulers.newThread())
            .observeOn(AndroidSchedulers.mainThread()).subscribe(onNext, onError, onComplete)
}

目前还没发现其中有什么问题.

kotlin的表现力太好了. 有时候给人一种天高任鸟飞, 海阔凭鱼跃的柑橘. 赞!!!~

完整代码: https://github.com/shaopx/LiteDig

最后编辑于：2018.08.06 16:00:30