Kotlin結合Rxjava+Retrofit實現極簡網絡請求的方法

發布時間：2020-09-30 11:36:02 來源：腳本之家閱讀：303 作者：KeepDreaming 欄目：移動開發

前言

因為最近正在寫的項目集成了兩個網絡請求框架（Volley and Retrofit）對比之下也是選擇了Retrofit。既然選擇那自然要讓自己以后開發更加省力（就是懶）。于是我在Retrofit中加入了Rxjava，這也是當下蠻流行的一個請求框架。然后又利用了Kotlin的一些新特性，使網絡請求變得特別簡單，代碼量特別少。

Kotlin鎮樓

RxJava

RxJava學習是一個曲折漫長的過程，但一旦掌握，妙用無窮。

通過這里了解更多：https://www.jb51.net/article/126567.htm

Retrofit

Retrofit與okhttp共同出自于Square公司，retrofit就是對okhttp做了一層封裝。把網絡請求都交給給了Okhttp，我們只需要通過簡單的配置就能使用retrofit來進行網絡請求了，其主要作者是Android大神JakeWharton。

導包：

compile 'com.squareup.retrofit2:retrofit:2.0.0-beta4'//Retrofit2所需要的包
compile 'com.squareup.retrofit2:converter-gson:2.0.0-beta4'//ConverterFactory的Gson依賴包
compile 'com.squareup.retrofit2:converter-scalars:2.0.0-beta4'//ConverterFactory的String依賴包

*這里需要值得注意的是：導入的retrofit2包的版本必須要一致，否則就會報錯。

通過這里了解更多：https://www.jb51.net/article/120509.htm

正文

導包

首先需要導入相關的包，包括Rxjava（我這里使用的是1.x的版本，如果你使用的是2.x的版本影響不大）、Retrofit。

 //Rxjava
 compile 'io.reactivex:rxandroid:1.2.0'
 compile 'io.reactivex:rxjava:1.2.0'
 //Retrofit
 compile 'com.squareup.retrofit2:retrofit:2.3.0'
 compile 'com.squareup.retrofit2:converter-gson:2.3.0'
 compile 'com.squareup.retrofit2:adapter-rxjava:2.3.0'
 compile 'com.squareup.okhttp3:logging-interceptor:3.8.0'

初始化Retrofit

 retrofit = Retrofit.Builder()
  .client(build.build())
  .baseUrl("你的url")
  .addConverterFactory(GsonConverterFactory.create(gson))
  .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
  .build().create(RetrofitUrl::class.java)

client傳入的是一個OkhttpClient，這里我們需要創建一個OkhttpClient對象，這個可以用來加入一些攔截器、連接等待時間等，以下是我的client：

 val build = OkHttpClient.Builder().connectTimeout(15,TimeUnit.SECONDS)
  .writeTimeout(15,TimeUnit.SECONDS)
  .readTimeout(15,TimeUnit.SECONDS)
 val logging = HttpLoggingInterceptor(HttpLoggingInterceptor.Logger {
  Log.e("retrofit url",it)
 })
 logging.level = HttpLoggingInterceptor.Level.BODY

我這里只設置了連接、讀、寫超時時間和一個攔截器，用于在用Retrofit請求網絡的時候可以獲取到請求的信息。然后是baseUrl這里是設置網絡請求的通用的地址，格式類似于http://ip:端口/后臺項目名/，需要以/結尾。而后的addConverterFactory和addCallAdapterFactory是我們剛剛導入的包，用于添加gson和RxJava支持，其中如果解析的時候有要求時間格式，可自定義一個gson傳入：

val gson = GsonBuilder().setDateFormat("yyyy-MM-dd hh:mm:ss").create()

如果不要求時間格式，GsonConverterFactory.create(此處可以不傳參數)。然后就是RetrofitUrl，這是一個接口，名字可以根據個人喜好進行定義，其內放置請求的接口：

interface RetrofitUrl {
 //方法名自定義
 @GET("接口地址")
 fun load():Observable<對應實體類>

 @FormUrlEncoded
 @Post("接口地址")
 fun load():Observable<對應實體類>

 //需要傳遞參數，多個參數逗號隔開
 @GET("接口地址")
 fun load(@Query("參數名字") 參數名字（可自定義）:參數類型):Observable<對應實體類>

 @FormUrlEncoded
 @Post("接口地址")
 fun load(@Field("參數名字") 參數名字（可自定義）:參數類型):Observable<對應實體類>

 //示例
 @GET("load")
 fun load():Observable<NetOuter<Orgs>>

 @GET("load")
 fun load(@Query("id") id:Int):Observable<NetOuter<Orgs>>
}

以上就是初始化大概過程，初始化我是放在了自定義的Application中完成，使用時通過Application獲取到Retrofit。

請求網絡

以上都做完了就可以開始請求網絡了。

通過Application獲取到Retrofit后，我們就可以通過它去調用我們剛剛在接口中定義的方法，因為配置了RxJava，所以調用方法后會返回一個Observable，這也是我們在接口中定義的返回類型，如果沒有添加RxJava，返回類型為Call。這樣子我們就可以按照RxJava的習慣去寫了：

 retrofit().load()
  .subscribeOn(Schedulers.io())
  .observeOn(AndroidSchedulers.mainThread())
  .subscribe(object :Subscriber<NetOuter<Orgs>>(){
  override fun onCompleted() {
    
  }
  override fun onNext(t: NetOuter<Orgs>?) { 
   //可以在這里對獲取到的數據進行處理
  }
  override fun onError(e: Throwable?) { 
   //請求失敗
  }
  )

這樣子我們就完成了一個網絡請求，這里就進行了線程調度的操作，具體看操作者的需求，也可以加入以下RxJava的操作符。
雖然這樣子可以進行網絡請求，可如果每次請求都要去寫線程調度又覺得太麻煩了，都是一樣的代碼。這時候我們就用到了Kotlin的一個特性，擴展函數。我們新建一個Kotlin File文件，在其中寫入我們修改了的代碼：

fun <T> runRx(observable: Observable<T>, subscriber: Subscriber<T>): Subscription = 
 observable.subscribeOn(Schedulers.io())
  .observeOn(AndroidSchedulers.mainThread())
  .subscribe(subscriber)

讓我們調調這個方法看看效果：

runRx(retrofit().load(),object : Subscriber<NetOuter<Orgs>>() {
 override fun onCompleted() {}

 override fun onNext(t: NetOuter<Orgs>?) { 
  //可以在這里對獲取到的數據進行處理
 }

 override fun onError(e: Throwable?) { 
  //請求失敗
 }
)

通過這一層的封裝，省去了線程調度的代碼，在大量請求的時候，可以省去不少代碼。但是，就這個程度，還是覺得要一直寫object : Subscriber...，這個也不想寫，懶嘛。怎么辦？只能繼續封裝，這時候就想到了Kotlin的另一個特性，高階函數。Kotlin允許把一個方法當做一個參數進行使用，使用時通過Lambda的方式展示，一樣在我們剛剛寫runRx那個文件：

fun <T> runRxLambda(observable: Observable<T>,next:(T)->Unit,error:(e: Throwable?)->Unit,completed:() -> Unit = { Log.e("completed","completed") }){
 runRx(observable, object : Subscriber<T>() {
 override fun onCompleted() { completed }
 override fun onNext(t: T) { next(t) }
 override fun onError(e: Throwable?) { error(e) }
 })
}

這里通過next:(T)->Unit將方法當做一個參數，其中next為這個參數的參數名字，冒號后面的括號里面為這個方法需要的參數，多個參數逗號隔開，Unit是返回類型，Unit相當于Java中的void。其中還看到了completed:() -> Unit = { Log.e("completed","completed") }這里用到了Kotlin的參數默認值，通過=號將右邊當做左邊方法的默認實現，如果操作者沒有實現這個方法，就用這個默認操作。runRxLambda的方法內也就是調用了我們剛剛寫的runRx方法，然后將對應的方法傳入就可以了。接下來看看效果：

runRxLambda(retrofit().load(),{
 //我們在這里的操作就相當于在onNext中的操作，參數可以通過it獲取
 },{
 //這里就是onError的實現，參數也可以通過it獲取
 })

runRxLambda(retrofit().load(),{
 //我們在這里的操作就相當于在onNext中的操作，參數可以通過it獲取
 },{
 //這里就是onError的實現，參數也可以通過it獲取
 },{
 //這里是onCompleted,不實現也可以
 })

總結

以上就是這篇文章的全部內容了，這里的一些實現方式不止用在這里，這篇文章也只是當做一個拋磚引玉，其中可能也有很多操作不到位，講的不到位的，希望噴的小聲點,希望本文的內容對大家的學習或者工作具有一定的參考學習價值，如果有疑問大家可以留言交流，謝謝大家對億速云的支持。

向AI問一下細節

中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

Kotlin結合Rxjava+Retrofit實現極簡網絡請求的方法

猜你喜歡

中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

Kotlin結合Rxjava+Retrofit實現極簡網絡請求的方法

猜你喜歡

最新資訊

相關推薦

相關標簽