1.需要使用到的依赖如下(Retrofit\RxJava\RecyclerView\日志拦截器)

//only Retrofit(只用Retrofit联网)

implementation 'io.reactivex:rxjava:x.y.z'

implementation 'io.reactivex:rxandroid:1.0.1'

implementation 'com.squareup.retrofit2:retrofit:2.0.2'

implementation

'com.squareup.retrofit2:converter-gson:2.0.2'

implementation

'com.squareup.retrofit2:adapter-rxjava:2.0.2'

implementation

'com.android.support:recyclerview-v7:27.1.1'

//1 如果使用OKHttp了，就将以前的依赖使用下面的依赖替换掉，下面的依赖会自带拦截器：

implementation

'com.squareup.okhttp3:logging-interceptor:3.12.0'

2.省略的一些东西

封装类bean、

接口IView

接口回调ICallBack、

适配器adapter、

网络数据地址请求Model、

地址存放API、

与以往的写法都相同，此处就不再写了，不会的，可以翻阅前面的文章。

3.主要的RetrofitIView。

注意点：

以前单单使用Retrofit的时候，在注解@Get或其他下面使用的是Call

ResponseBody> 方法()；

现在结合Rxjava使用，在注解@Get或其他下面使用的是被观察者Observable ResponseBody> 方法()；

如果使用单个参数拼接，可以来方法小括号中添加 (@Query("字段") 类型 字段属性)

举例：

public interface RetrofitView {

//北京天气

@GET("weather_mini")

//注意Observable 右侧还有加括号，里面是ResponseBody 拼接字段可以在方法小括号中使用(@Query(“字段”) 类型 字段)

Observable ResponseBody> getWeather(@Query("city") String

city);

}

4.网络请求工具类

package com.bwie.lx_retrofit_rxjava.utils;

import android.util.Log;

import com.bwie.lx_retrofit_rxjava.bean.WeatherBean;

import com.bwie.lx_retrofit_rxjava.item.ICallBack;

import com.google.gson.Gson;

import java.io.IOException;

import java.lang.reflect.Type;

import java.util.concurrent.TimeUnit;

import okhttp3.OkHttpClient;

import okhttp3.ResponseBody;

import okhttp3.logging.HttpLoggingInterceptor;

import retrofit2.Retrofit;

import

retrofit2.adapter.rxjava.RxJavaCallAdapterFactory;

import retrofit2.converter.gson.GsonConverterFactory;

import rx.Observable;

import rx.Subscriber;

import rx.android.schedulers.AndroidSchedulers;

import rx.schedulers.Schedulers;

public class RxRetrofitUtils {

//使用单例模式

private static volatile RxRetrofitUtils instance;

private final Retrofit.Builder mBuilder;

private RetrofitView mRx {

//日志拦截器

//1 设置日志拦截器级别

HttpLoggingInterceptor.Level level =

HttpLoggingInterceptor.Level.BODY;

//2 创建一个日志拦截器

HttpLoggingInterceptor httpLoggingInterceptor = new

HttpLoggingInterceptor(new HttpLoggingInterceptor.Logger() {

@Override

public void log(String message) {

//打印信息

Log.i("http信息打印:", "log: " + message);

}

});

//3 为日志拦截器设置日志级别

httpLoggingInterceptor.setLevel(level);

//4 创建HttpClient对象 添加拦截器

OkHttpClient okHttpClient = new OkHttpClient.Builder()

.connectTimeout(5000, TimeUnit.SECONDS)

.readTimeout(5000, TimeUnit.SECONDS)

.writeTimeout(5000, TimeUnit.SECONDS)

.addInterceptor(httpLoggingInterceptor)

.build();

//5 将HttpClient对象加入到Retrofit中

//创建Retrifit对象

mBuilder = new Retrofit.Builder();

//设置 Json 转换器

mBuilder.addConverterFactory(GsonConverterFactory.create());

//添加日志拦截器

mBuilder.client(okHttpClient);

}

//双重锁机制

public static RxRetrofitUtils getInstance(){

if(instance==null){

synchronized (RxRetrofitUtils.class){

if(instance==null){

instance = new RxRetrofitUtils();

}

}

}

return instance;

}

//抽取出来的方法

private void getWeatherBeiJing(String url) {

Retrofit retrofit =

mBuilder.baseUrl(url)//添加请求网址,以/结尾

.addCallAdapterFactory(Rx )//括号里 是RxJava 适配器

CallAdapterFactory 点 create()创建一个 。将英文拼接，就是小括号里的参数

.build();

mRxJavaService =

retrofit.create(RetrofitView.class);

}

//北京天气网络请求方法

public void getWeatherU(String url, final ICallBack iCallBack,

final Type type ){

//Retrofit+Rxjava 设置方法 收取出来的

getWeatherBeiJing(url);

//通过接口对象mRxJavaService.点 调用抽象方法如 getWeather("北京")

Observable ResponseBody> weather =

mRxJavaService点RetrofitIView中的抽象方法;

//通过上一步得到的对象，进行设置

weather.subscribeOn(Schedulers.io())//IO线程加载数据

.observeOn(AndroidSchedulers.mainThread())//主线程显示数据

.subscribe(new Subscriber ResponseBody>() {

@Override

public void onCompleted() {

}

@Override

public void onError(Throwable e) {

String str = "网络请求访问失败";

iCallBack.onFailder(str);

}

@Override

public void onNext(ResponseBody responseBody) {

try {

//注意：这儿不用response.body了，它已经是responsebody

String result = responseBody.string();

WeatherBean weatherBean1 = new Gson().fromJson(result,

type);

Log.e("TAG", "response == " +

weatherBean1.getData().getGanmao());

if(weatherBean1!=null){

iCallBack.onSuccess(weatherBean1);

}

} catch (IOException e) {

e.printStackTrace();

}

}

});

}

}