使用 Kotlin 配合 RxJava 進行網路請求

1.首先需要配置Kotlin在專案中

• Android Studio 3.0是自帶的,可以在建立專案的時候勾選include kotlin support
• Android Studio 2.0+是需要自己配置的,首先需要安裝Kotlin外掛,然後在下圖這裡配置一下,Configure Kotlin in Project

2.引入第3方庫

我這裡使用的是 OkHttp3,RxJava2,RxAndroid

引入如下(在我使用時,這是最新的版本):

• implementation ‘com.squareup.okhttp3:okhttp:3.8.1’
• implementation ‘io.reactivex.rxjava2:rxjava:2.1.2’
• implementation ‘io.reactivex.rxjava2:rxandroid:2.0.1’
• implementation ‘com.google.code.gson:gson:2.8.1’
• implementation ‘com.github.bumptech.glide:glide:4.0.0’

3.正式開始寫程式碼

在MainActivity中寫入如下程式碼

    //使用RxJava處理
    Observable.create(ObservableOnSubscribe<String> {
        e ->

        //使用okhttp3訪問網路
        val builder = Request.Builder()
        val request = builder.url(NEWS_URL).get().build()
        val response = client.newCall(request).execute()
        val responseBody = response.body()
        val result = responseBody?.string()
        //這裡的.string()只能用一次  如果下面那一句不註釋的話就會報錯
        //val result2 = responseBody?.string()

        Log.e(TAG, result)

        //這裡其實形參是String型別,然而實參是String?型別,如果直接傳result會報錯,在後面加!!即可解決
        //發射(這裡是被觀察者,被觀察者發射事件)
        e.onNext(result!!)

        //上面那句程式碼可以這樣寫
        //e.onNext(result as String)
    }).subscribeOn(Schedulers.io())  //io執行緒  被觀察者
            .observeOn(AndroidSchedulers.mainThread())  //主執行緒 觀察者
            .subscribe({

                //這裡接收剛剛被觀察者發射的事件
                //這個response就是io執行緒發射過來的result
                response ->
                Log.e(TAG, response)
            })
 

簡簡單單的總結

看似程式碼極少的demo,可是我卻遇到了很多的挫折,,搞了好久好久才寫好,主要是遇到錯誤的話,這種東西網上不好找解決方案….