快捷導(dǎo)航

RxJava+Retrofit實(shí)現(xiàn)網(wǎng)絡(luò)請求封裝的方法

更新時(shí)間：2019年04月09日 14:43:45 作者：程序園中猿

Retrofit是當(dāng)前應(yīng)用非常廣泛的網(wǎng)絡(luò)請求框架，通常結(jié)合RxJava來進(jìn)行網(wǎng)絡(luò)請求，本文將展示一個(gè)采用RxJava+Retrofit的網(wǎng)絡(luò)請求demo，感興趣的可以了解一下

簡要介紹

Retrofit是當(dāng)前應(yīng)用非常廣泛的網(wǎng)絡(luò)請求框架,通常結(jié)合RxJava來進(jìn)行網(wǎng)絡(luò)請求,本文將展示一個(gè)采用RxJava+Retrofit的網(wǎng)絡(luò)請求demo.

集成步驟

1、app工程的build.gradle中添加依賴

//retrofit2
implementation 'com.google.code.gson:gson:2.8.5'
implementation 'com.squareup.retrofit2:retrofit:2.5.0'
implementation 'com.squareup.retrofit2:converter-gson:2.5.0'
implementation 'com.squareup.okhttp3:okhttp:3.12.2'
implementation 'com.squareup.okhttp3:logging-interceptor:3.11.0'

//rxjava2
implementation 'io.reactivex.rxjava2:rxjava:2.2.2'
implementation 'io.reactivex.rxjava2:rxandroid:2.1.0'

//配合Rxjava2 使用
implementation 'com.jakewharton.retrofit:retrofit2-rxjava2-adapter:1.0.0'

2、在AndroidManifest.xml中添加權(quán)限

<uses-permission android:name="android.permission.INTERNET"/>

3、添加數(shù)據(jù)類Task

data class Task(var id: Int, var name: String?)

4、添加網(wǎng)絡(luò)請求類NetworkService

import io.reactivex.Observable;
import retrofit2.http.GET;
public interface NetworkService {

  @GET("data.json")
  Observable<Task> query();
}

5、activity中調(diào)用

class MainActivity : AppCompatActivity() {
  private val BASE_URL = "https://raw.githubusercontent.com/cxyzy1/rxjava_retrofit_demo/master/"

  override fun onCreate(savedInstanceState: Bundle?) {
    super.onCreate(savedInstanceState)
    setContentView(R.layout.activity_main)
    queryData()
  }

  private fun queryData() {
    //創(chuàng)建Retrofit對象
    val retrofit = Retrofit.Builder().baseUrl(BASE_URL)
        .addConverterFactory(GsonConverterFactory.create())
        .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
        .build()

    //獲取UserMsgService對象
    val networkService = retrofit.create(NetworkService::class.java)

    networkService.query()
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(object : Observer<Task> {
          override fun onSubscribe(d: Disposable) {
          }

          override fun onNext(task: Task) {
            contentTv.text = task.toString()
          }

          override fun onError(e: Throwable) {
            Log.v("", e.message)
          }

          override fun onComplete() {
          }
        })
  }
}

網(wǎng)絡(luò)請求結(jié)果截圖