Kotlin結(jié)合Rxjava+Retrofit實(shí)現(xiàn)極簡(jiǎn)網(wǎng)絡(luò)請(qǐng)求的方法
前言
因?yàn)樽罱趯懙捻?xiàng)目集成了兩個(gè)網(wǎng)絡(luò)請(qǐng)求框架（Volley and Retrofit）對(duì)比之下也是選擇了Retrofit。既然選擇那自然要讓自己以后開發(fā)更加省力（就是懶）。于是我在Retrofit中加入了Rxjava，這也是當(dāng)下蠻流行的一個(gè)請(qǐng)求框架。然后又利用了Kotlin的一些新特性，使網(wǎng)絡(luò)請(qǐng)求變得特別簡(jiǎn)單，代碼量特別少。
Kotlin鎮(zhèn)樓
RxJava
RxJava學(xué)習(xí)是一個(gè)曲折漫長(zhǎng)的過(guò)程，但一旦掌握，妙用無(wú)窮。
通過(guò)這里了解更多：http://www.dbjr.com.cn/article/126567.htm
Retrofit
Retrofit與okhttp共同出自于Square公司，retrofit就是對(duì)okhttp做了一層封裝。把網(wǎng)絡(luò)請(qǐng)求都交給給了Okhttp，我們只需要通過(guò)簡(jiǎn)單的配置就能使用retrofit來(lái)進(jìn)行網(wǎng)絡(luò)請(qǐng)求了，其主要作者是Android大神JakeWharton。
導(dǎo)包：
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依賴包
*這里需要值得注意的是：導(dǎo)入的retrofit2包的版本必須要一致，否則就會(huì)報(bào)錯(cuò)。
通過(guò)這里了解更多：http://www.dbjr.com.cn/article/120509.htm
正文
導(dǎo)包
首先需要導(dǎo)入相關(guān)的包，包括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傳入的是一個(gè)OkhttpClient，這里我們需要?jiǎng)?chuàng)建一個(gè)OkhttpClient對(duì)象，這個(gè)可以用來(lái)加入一些攔截器、連接等待時(shí)間等，以下是我的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
我這里只設(shè)置了連接、讀、寫超時(shí)時(shí)間和一個(gè)攔截器，用于在用Retrofit請(qǐng)求網(wǎng)絡(luò)的時(shí)候可以獲取到請(qǐng)求的信息。然后是baseUrl這里是設(shè)置網(wǎng)絡(luò)請(qǐng)求的通用的地址，格式類似于http://ip:端口/后臺(tái)項(xiàng)目名/，需要以/結(jié)尾。而后的addConverterFactory和addCallAdapterFactory是我們剛剛導(dǎo)入的包，用于添加gson和RxJava支持，其中如果解析的時(shí)候有要求時(shí)間格式，可自定義一個(gè)gson傳入：
val gson = GsonBuilder().setDateFormat("yyyy-MM-dd hh:mm:ss").create()
如果不要求時(shí)間格式，GsonConverterFactory.create(此處可以不傳參數(shù))。然后就是RetrofitUrl，這是一個(gè)接口，名字可以根據(jù)個(gè)人喜好進(jìn)行定義，其內(nèi)放置請(qǐng)求的接口：
interface RetrofitUrl {
//方法名自定義
@GET("接口地址")
fun load():Observable<對(duì)應(yīng)實(shí)體類>
@FormUrlEncoded
@Post("接口地址")
fun load():Observable<對(duì)應(yīng)實(shí)體類>
//需要傳遞參數(shù)，多個(gè)參數(shù)逗號(hào)隔開
@GET("接口地址")
fun load(@Query("參數(shù)名字") 參數(shù)名字（可自定義）:參數(shù)類型):Observable<對(duì)應(yīng)實(shí)體類>
@FormUrlEncoded
@Post("接口地址")
fun load(@Field("參數(shù)名字") 參數(shù)名字（可自定義）:參數(shù)類型):Observable<對(duì)應(yīng)實(shí)體類>
//示例
@GET("load")
fun load():Observable<NetOuter<Orgs>>
@GET("load")
fun load(@Query("id") id:Int):Observable<NetOuter<Orgs>>
}
以上就是初始化大概過(guò)程，初始化我是放在了自定義的Application中完成，使用時(shí)通過(guò)Application獲取到Retrofit。
請(qǐng)求網(wǎng)絡(luò)
以上都做完了就可以開始請(qǐng)求網(wǎng)絡(luò)了。
通過(guò)Application獲取到Retrofit后，我們就可以通過(guò)它去調(diào)用我們剛剛在接口中定義的方法，因?yàn)榕渲昧薘xJava，所以調(diào)用方法后會(huì)返回一個(gè)Observable，這也是我們?cè)诮涌谥卸x的返回類型，如果沒(méi)有添加RxJava，返回類型為Call。這樣子我們就可以按照RxJava的習(xí)慣去寫了：
retrofit().load()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(object :Subscriber<NetOuter<Orgs>>(){
override fun onCompleted() {
}
override fun onNext(t: NetOuter<Orgs>?) {
//可以在這里對(duì)獲取到的數(shù)據(jù)進(jìn)行處理
}
override fun onError(e: Throwable?) {
//請(qǐng)求失敗
}
)
這樣子我們就完成了一個(gè)網(wǎng)絡(luò)請(qǐng)求，這里就進(jìn)行了線程調(diào)度的操作，具體看操作者的需求，也可以加入以下RxJava的操作符。
雖然這樣子可以進(jìn)行網(wǎng)絡(luò)請(qǐng)求，可如果每次請(qǐng)求都要去寫線程調(diào)度又覺(jué)得太麻煩了，都是一樣的代碼。這時(shí)候我們就用到了Kotlin的一個(gè)特性，擴(kuò)展函數(shù)。我們新建一個(gè)Kotlin File文件，在其中寫入我們修改了的代碼：
fun <T> runRx(observable: Observable<T>, subscriber: Subscriber<T>): Subscription = observable.subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(subscriber)
讓我們調(diào)調(diào)這個(gè)方法看看效果：
runRx(retrofit().load(),object : Subscriber<NetOuter<Orgs>>() {
override fun onCompleted() {}
override fun onNext(t: NetOuter<Orgs>?) {
//可以在這里對(duì)獲取到的數(shù)據(jù)進(jìn)行處理
}
override fun onError(e: Throwable?) {
//請(qǐng)求失敗
}
)
通過(guò)這一層的封裝，省去了線程調(diào)度的代碼，在大量請(qǐng)求的時(shí)候，可以省去不少代碼。但是，就這個(gè)程度，還是覺(jué)得要一直寫object : Subscriber...，這個(gè)也不想寫，懶嘛。怎么辦？只能繼續(xù)封裝，這時(shí)候就想到了Kotlin的另一個(gè)特性，高階函數(shù)。Kotlin允許把一個(gè)方法當(dāng)做一個(gè)參數(shù)進(jìn)行使用，使用時(shí)通過(guò)Lambda的方式展示，一樣在我們剛剛寫runRx那個(gè)文件：
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) }
})
}
這里通過(guò)next:(T)->Unit將方法當(dāng)做一個(gè)參數(shù)，其中next為這個(gè)參數(shù)的參數(shù)名字，冒號(hào)后面的括號(hào)里面為這個(gè)方法需要的參數(shù)，多個(gè)參數(shù)逗號(hào)隔開，Unit是返回類型，Unit相當(dāng)于Java中的void。其中還看到了completed:() -> Unit = { Log.e("completed","completed") }這里用到了Kotlin的參數(shù)默認(rèn)值，通過(guò)=號(hào)將右邊當(dāng)做左邊方法的默認(rèn)實(shí)現(xiàn)，如果操作者沒(méi)有實(shí)現(xiàn)這個(gè)方法，就用這個(gè)默認(rèn)操作。runRxLambda的方法內(nèi)也就是調(diào)用了我們剛剛寫的runRx方法，然后將對(duì)應(yīng)的方法傳入就可以了。接下來(lái)看看效果：
runRxLambda(retrofit().load(),{
//我們?cè)谶@里的操作就相當(dāng)于在onNext中的操作，參數(shù)可以通過(guò)it獲取
},{
//這里就是onError的實(shí)現(xiàn)，參數(shù)也可以通過(guò)it獲取
})
runRxLambda(retrofit().load(),{
//我們?cè)谶@里的操作就相當(dāng)于在onNext中的操作，參數(shù)可以通過(guò)it獲取
},{
//這里就是onError的實(shí)現(xiàn)，參數(shù)也可以通過(guò)it獲取
},{
//這里是onCompleted,不實(shí)現(xiàn)也可以
})
總結(jié)
以上就是這篇文章的全部?jī)?nèi)容了，這里的一些實(shí)現(xiàn)方式不止用在這里，這篇文章也只是當(dāng)做一個(gè)拋磚引玉，其中可能也有很多操作不到位，講的不到位的，希望噴的小聲點(diǎn),希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，如果有疑問(wèn)大家可以留言交流，謝謝大家對(duì)腳本之家的支持。
相關(guān)文章
Android中Activity之間跳轉(zhuǎn)和參數(shù)傳遞的實(shí)例
本篇文章主要介紹了Android中Activity之間跳轉(zhuǎn)和參數(shù)傳遞的實(shí)例，小編覺(jué)得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-02-02
Android編程中出現(xiàn)The connection to adb is down問(wèn)題的解決方法
這篇文章主要介紹了Android編程中出現(xiàn)The connection to adb is down問(wèn)題的解決方法,涉及Android進(jìn)程與服務(wù)的相關(guān)操作技巧,需要的朋友可以參考下2015-12-12
SimpleCommand框架ImageLoader API詳解(三)
這篇文章主要為大家詳細(xì)介紹了SimpleCommand框架ImageLoader API，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-10-10
今天小編就為大家分享一篇android檢測(cè)SD卡讀寫權(quán)限方法，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2018-08-08
Flutter 全局點(diǎn)擊空白處隱藏鍵盤實(shí)戰(zhàn)
這篇文章主要介紹了Flutter 全局點(diǎn)擊空白處隱藏鍵盤實(shí)戰(zhàn)，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2020-09-09
Android實(shí)現(xiàn)給TableLayou繪制邊框的方法
這篇文章主要介紹了Android實(shí)現(xiàn)給TableLayou繪制邊框的方法,涉及Android TableLayou布局控制相關(guān)技巧,需要的朋友可以參考下2016-03-03
Android中AlertDialog各種對(duì)話框的用法實(shí)例詳解
這篇文章主要介紹了Android中AlertDialog各種對(duì)話框的用法在項(xiàng)目開發(fā)中經(jīng)常用的到，本文給大家介紹的非常詳細(xì)，具有參考借鑒價(jià)值2016-04-04
簡(jiǎn)單實(shí)現(xiàn)Android放大鏡效果
這篇文章主要教大家簡(jiǎn)單實(shí)現(xiàn)Android放大鏡效果，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-12-12
詳解Flutter網(wǎng)絡(luò)圖片本地緩存的實(shí)現(xiàn)
這篇文章主要為大家介紹了詳解Flutter網(wǎng)絡(luò)圖片本地緩存的實(shí)現(xiàn)示例解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2023-04-04
Android模擬實(shí)現(xiàn)華為系統(tǒng)升級(jí)進(jìn)度條
這篇文章主要介紹了如何通過(guò)Android模擬實(shí)現(xiàn)華為在系統(tǒng)升級(jí)時(shí)顯示的進(jìn)度條。文中的實(shí)現(xiàn)過(guò)程講解詳細(xì)，感興趣的小伙伴可以動(dòng)手試一試2022-01-01