RxJava和Retrofit2的统一处理单个请求示例详解

更新时间：2018年11月03日 10:57:25 作者：林祖朋

这篇文章主要给大家介绍了关于RxJava和Retrofit2的统一处理单个请求的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧

前言

RxJava和Retrofit2用了一段时间了，写个小例子，分享出来，有什么不对的地方还请大神在评论区指正。

什么是Retrofit2

官网是这么介绍的：

Retrofit adapts a Java interface to HTTP calls by using annotations on the declared methods to
define how requests are made。

我翻译的可能不准确，他的大概意思是说：Retrofit 是一个 java 接口类，以注解的方式用于 HTTP 网络请求。那下面我们一起来看看是怎么使用的？

发现问题

最近在帮兄弟公司做一个资讯类的项目，使用了RxJava和Retrofit2这对黄金组合，在编写代码的过程中发现有很多很多的网络请求都需要做.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).onErrorReturn()的处理，为避免这样,需要沉思。

解决问题

import android.util.Log;

import com.wei.caiqiwang.data.entity.BaseResponse;

import rx.Observable;
import rx.Subscriber;
import rx.Subscription;
import rx.android.schedulers.AndroidSchedulers;
import rx.functions.Func1;
import rx.schedulers.Schedulers;

public class RxNet {
 /**
  * 统一处理单个请求
  */
 public static <T> Subscription request(Observable<BaseResponse<T>> observable, final RxNetCallBack<T> callBack) {
  return observable
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .onErrorReturn(new Func1<Throwable, BaseResponse<T>>() {
     @Override
     public BaseResponse<T> call(Throwable throwable) {
      Log.v("LinNetError",throwable.getMessage());
      callBack.onFailure(ExceptionHandle.handleException(throwable));
      return null;
     }
    })
    .subscribe(new Subscriber<BaseResponse<T>>() {
     @Override
     public void onCompleted() {

     }

     @Override
     public void onError(Throwable e) {

     }

     @Override
     public void onNext(BaseResponse<T> baseResponse) {
      if (baseResponse.getCode().equals("200")) {
       callBack.onSuccess(baseResponse.getData());
      } else {
       callBack.onFailure(baseResponse.getMsg());
      }
     }
    });

 }

 /**
  * 统一处理单个请求没有 msg body
  */
 public static Subscription requestWithoutBody(Observable<BaseResponse> observable, final RxNetCallBack<String> callBack) {
  return observable
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .onErrorReturn(new Func1<Throwable, BaseResponse>() {
     @Override
     public BaseResponse call(Throwable throwable) {
      callBack.onFailure(ExceptionHandle.handleException(throwable));
      return null;
     }
    })
    .subscribe(new Subscriber<BaseResponse>() {
     @Override
     public void onCompleted() {

     }

     @Override
     public void onError(Throwable e) {

     }

     @Override
     public void onNext(BaseResponse baseResponse) {
      if (baseResponse.getCode().equals("200")) {
       callBack.onSuccess(baseResponse.getMsg());
      } else {
       callBack.onFailure(baseResponse.getMsg());
      }
     }
    });

 }
}

回调就是普通的回调

public interface RxNetCallBack<T> {
 /**
  * 数据请求成功
  *
  * @param data 请求到的数据
  */
 void onSuccess(T data);

 /**
  * 数据请求失败
  */
 void onFailure(String msg);
}

错误异常处理（可能不全）：

import android.net.ParseException;

import com.google.gson.JsonParseException;


import org.apache.http.conn.ConnectTimeoutException;
import org.json.JSONException;

import java.net.ConnectException;

import retrofit2.HttpException;

public class ExceptionHandle {

 private static final int UNAUTHORIZED = 401;
 private static final int FORBIDDEN = 403;
 private static final int NOT_FOUND = 404;
 private static final int REQUEST_TIMEOUT = 408;
 private static final int INTERNAL_SERVER_ERROR = 500;
 private static final int BAD_GATEWAY = 502;
 private static final int SERVICE_UNAVAILABLE = 503;
 private static final int GATEWAY_TIMEOUT = 504;

 public static String handleException(Throwable e) {
  String errorMsg;
  if (e instanceof HttpException) {
   HttpException httpException = (HttpException) e;
   switch (httpException.code()) {
    case UNAUTHORIZED:
    case FORBIDDEN:
    case NOT_FOUND:
    case REQUEST_TIMEOUT:
    case GATEWAY_TIMEOUT:
    case INTERNAL_SERVER_ERROR:
    case BAD_GATEWAY:
    case SERVICE_UNAVAILABLE:
    default:
     errorMsg = "网络错误";
     break;
   }
   return errorMsg + ":" + httpException.code();
  } else if (e instanceof JsonParseException || e instanceof JSONException || e instanceof ParseException) {
   return "解析错误";
  } else if (e instanceof ConnectException) {
   return "连接失败";
  } else if (e instanceof javax.net.ssl.SSLHandshakeException) {
   return "证书验证失败";
  } else if (e instanceof ConnectTimeoutException) {
   return "连接超时";
  } else if (e instanceof java.net.SocketTimeoutException) {
   return "连接超时";
  } else {
   return "未知错误";
  }
 }
}

然后就是ApiManager：

import android.util.Log;


import com.wei.demo.data.AppConstants;

import java.util.concurrent.TimeUnit;

import okhttp3.OkHttpClient;
import okhttp3.logging.HttpLoggingInterceptor;
import retrofit2.Retrofit;
import retrofit2.adapter.rxjava.RxJavaCallAdapterFactory;
import retrofit2.converter.gson.GsonConverterFactory;

public class ApiManager {

 private Retrofit client;

 private ApiManager() {
  client = new Retrofit.Builder()
    .baseUrl(AppConstants.Base_Url_Api_Test)
    .client(initClient())
    .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
    .addConverterFactory(GsonConverterFactory.create())
    .build();
 }

 private static volatile DemoApi INSTANCE;

 public static DemoApi getInstance() {
  if (INSTANCE == null) {
   synchronized (ApiManager.class) {
    if (INSTANCE == null) {
     INSTANCE = new ApiManager().getApi();
    }
   }
  }
  return INSTANCE;
 }

 private DemoApi getApi() {
  return client.create(DemoApi.class);
 }

 private static OkHttpClient initClient() {
  OkHttpClient.Builder builder = new OkHttpClient.Builder();
  //声明日志类
  HttpLoggingInterceptor httpLoggingInterceptor = new HttpLoggingInterceptor(new HttpLoggingInterceptor.Logger() {
   @Override
   public void log(String message) {
    Log.v("NetLog", message);
   }
  });
  //设定日志级别
  httpLoggingInterceptor.setLevel(HttpLoggingInterceptor.Level.BODY);
  //延时
  builder.addInterceptor(httpLoggingInterceptor)
    .connectTimeout(10, TimeUnit.SECONDS)
    .readTimeout(10, TimeUnit.SECONDS)
    .writeTimeout(10, TimeUnit.SECONDS);
  return builder.build();
 }
}

怎么用？

 RxNet.request(ApiManager.getInstance().getUserMsg(map), new RxNetCallBack<List<MsgBean>>() {
   @Override
   public void onSuccess(List<MsgBean> data) {
    // 处理数据
   }

   @Override
   public void onFailure(String msg) {
    //出现了错误
    showToast(msg);
    
   }
  });

Demo https://github.com/FriendLin/NetRequestDemo （本地下载）

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对脚本之家的支持。

您可能感兴趣的文章:

36个Android开发常用经典代码大全
本篇文章主要介绍了36个Android开发常用经典代码片段，都是实用的代码段，具有一定的参考价值，感兴趣的小伙伴们可以参考一下。
2016-11-11
Android手册之Toolbar搜索联动及监听小技巧
这篇文章主要为大家介绍了Android手册之Toolbar搜索联动及监听小技巧示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2022-09-09
android @override 报错解决方案
android @override 报错:就是说Java 1.5的编译器默认对父类的方法进行覆盖，采用@Override进行说明；但1.6已经扩展到对接口的方法；所以如果还是以Java 1.5的编译器来编译的话，会出现错误
2012-12-12
Android 自定义返回按钮的实例详解
这篇文章主要介绍了Android 自定义返回按钮的实例详解的相关资料,这里提供实现代码，帮助大家理解使用，需要的朋友可以参考下
2017-07-07
Android中AsyncTask的入门使用学习指南
AsyncTask异步任务,用于执行耗时任务并在UI线程中更新结果。下面这篇文章主要给大家介绍了关于Android中AsyncTask入门使用的相关资料，需要的朋友可以参考下
2019-02-02
Android 设置应用全屏的两种解决方法
本篇文章小编为大家介绍，Android 设置应用全屏的两种解决方法。需要的朋友参考下
2013-04-04
Android组合式自定义控件实现购物车加减商品操作
这篇文章主要介绍了Android组合式自定义控件实现购物车加减商品操作，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2018-11-11
Android中使用HttpURLConnection实现GET POST JSON数据与下载图片
这篇文章主要介绍了Android中使用HttpURLConnection实现GET POST JSON数据与下载图片,需要的朋友可以参考下
2016-01-01
Android执行shell命令详解
本篇文章是对Android执行shell命令进行了详细的分析介绍，需要的朋友参考下
2013-06-06
Android利用广播接收器实现自动填充短信验证码
这篇文章主要为大家详细介绍了Android利用广播接收器实现自动填充短信验证码，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2017-12-12

RxJava和Retrofit2的统一处理单个请求示例详解

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具