欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  移动技术

RxJava+Retrofit实现网络请求封装的方法

程序员文章站 2022-06-09 14:40:26
简要介绍 retrofit是当前应用非常广泛的网络请求框架,通常结合rxjava来进行网络请求,本文将展示一个采用rxjava+retrofit的网络请求demo. 集...

简要介绍

retrofit是当前应用非常广泛的网络请求框架,通常结合rxjava来进行网络请求,本文将展示一个采用rxjava+retrofit的网络请求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中添加权限

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

3、添加数据类task

data class task(var id: int, var name: string?)

4、 添加网络请求类networkservice

import io.reactivex.observable;
import retrofit2.http.get;
public interface networkservice {

  @get("data.json")
  observable<task> query();
}

5、activity中调用

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() {
    //创建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() {
          }
        })
  }
}

网络请求结果截图

RxJava+Retrofit实现网络请求封装的方法 

demo源代码

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。