脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → Android → RxJava2和Retrofit2封装

RxJava2和Retrofit2封装教程（整洁、简单、实用）

 更新时间：2018年11月03日 11:13:42   作者：林祖朋  
这篇文章主要给大家介绍了关于RxJava2和Retrofit2封装的相关资料，文中通过示例代码介绍的非常详细，整洁、简单、实用，非常适合大家学习使用，需要的朋友可以参考下

前言

RxJava2与Retrofit2是老搭档了，之前写了一篇《RxJava和Retrofit2的统一处理单个请求》，是用的Rxjava1.0，本次使用Rxjava2.0与Retrofit2进行封装，一样整洁、简单、实用。Rxjava2相比Rxjava1优化和改动不少了东西，网上有很多大神写的文章，这里就不粘贴复制了。封装的过程有什么问题、疑问，请在下方留言。

下面话不多说了，来一起看看详细的介绍吧

封装教程如下：

核心网络请求：

package com.lin.netrequestdemo.data;


import android.util.Log;

import io.reactivex.Observable;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.Disposable;
import io.reactivex.functions.Consumer;
import io.reactivex.functions.Function;
import io.reactivex.schedulers.Schedulers;

public class RxNet {
 /**
 * 统一处理单个请求
 *
 * @param observable
 * @param callBack
 * @param <T>
 */
 public static <T> Disposable request(Observable<BaseResponse<T>> observable, final RxNetCallBack<T> callBack) {
 return observable.subscribeOn(Schedulers.io())
  .observeOn(AndroidSchedulers.mainThread())
  .onErrorReturn(new Function<Throwable, BaseResponse<T>>() {
   @Override
   public BaseResponse<T> apply(Throwable throwable) {
   Log.e("LinNetError", throwable.getMessage());
   callBack.onFailure(ExceptionHandle.handleException(throwable));
   return null;
   }
  })
  .subscribe(new Consumer<BaseResponse<T>>() {
   @Override
   public void accept(BaseResponse<T> tBaseResponse) {
   if (tBaseResponse.getCode().equals("200")) {
    callBack.onSuccess(tBaseResponse.getData());

   } else {
    callBack.onFailure(tBaseResponse.getMsg());
   }
   }
  }, new Consumer<Throwable>() {
   @Override
   public void accept(Throwable throwable) {
   Log.e("LinNetError", "单个请求的错误" + throwable.getMessage());
   }
  });
 }

 /**
 * 统一处理单个请求
 * 返回数据没有body
 */
 public static Disposable requestWithoutBody(Observable<BaseResponse> observable,
      final RxNetCallBack<String> callBack) {
 return observable.subscribeOn(Schedulers.io())
  .observeOn(AndroidSchedulers.mainThread())
  .onErrorReturn(new Function<Throwable, BaseResponse>() {
   @Override
   public BaseResponse apply(Throwable throwable) {
   Log.v("LinNetError", throwable.getMessage());
   callBack.onFailure(ExceptionHandle.handleException(throwable));
   return null;
   }
  })
  .subscribe(new Consumer<BaseResponse>() {
   @Override
   public void accept(BaseResponse baseResponse) {
   if (baseResponse.getCode().equals("200")) {
    callBack.onSuccess(baseResponse.getMsg());
   } else {
    callBack.onFailure(baseResponse.getMsg());
   }
   }
  }, new Consumer<Throwable>() {
   @Override
   public void accept(Throwable throwable) {
   Log.v("LinNetError", "单个请求的错误:没有body" + throwable.getMessage());
   }
  });

 }
}

回调就是普通的泛型的回调

package com.lin.netrequestdemo.data;


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

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

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

package com.lin.netrequestdemo.data;

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：

package com.lin.netrequestdemo.data.api;

import android.util.Log;

import com.lin.netrequestdemo.data.AppConstants;

import java.util.concurrent.TimeUnit;

import okhttp3.OkHttpClient;
import okhttp3.logging.HttpLoggingInterceptor;
import retrofit2.Retrofit;
import retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory;
import retrofit2.converter.gson.GsonConverterFactory;


public class ApiManager {

 private Retrofit client;

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

 private static volatile MallApi INSTANCE;

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

 private MallApi getMallApi() {
 return client.create(MallApi.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("LinNet", message);
  }
 });
 //设定日志级别
 httpLoggingInterceptor.setLevel(HttpLoggingInterceptor.Level.BODY);
 //延时
 builder.addInterceptor(httpLoggingInterceptor)
  .connectTimeout(10, TimeUnit.SECONDS)
  .readTimeout(10, TimeUnit.SECONDS)
  .writeTimeout(10, TimeUnit.SECONDS);
 return builder.build();
 }

}

怎么用：

showLoading();
 Map<String, String> map = new ArrayMap<>();
 map.put("action", "pricetrend");
 addCompositeDisposable(RxNet.request(ApiManager.getInstance().getCat(map), new RxNetCallBack<List<CatBean>>() {
  @Override
  public void onSuccess(List<CatBean> data) {
  hideLoading();
  showToast("获取列表成功" + data.get(0).toString());
  }

  @Override
  public void onFailure(String msg) {
  hideLoading();
  showToast(msg);
  }
 }));

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

总结

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

您可能感兴趣的文章:

相关文章

  • Android实现广告图片轮播效果

    Android实现广告图片轮播效果

    这篇文章主要为大家详细介绍了Android实现广告图片轮播效果的相关资料，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2016-02-02
  • Android 开发照相功能实例详解

    Android 开发照相功能实例详解

    这篇文章主要介绍了Android 开发照相功能实例详解的相关资料,需要的朋友可以参考下
    2017-04-04
  • android 获取手机内存及 内存可用空间的方法

    android 获取手机内存及 内存可用空间的方法

    下面小编就为大家带来一篇android 获取手机内存及SD卡内存可用空间的方法。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧
    2017-03-03
  • Android SurfaceView画板操作

    Android SurfaceView画板操作

    这篇文章主要为大家详细介绍了Android SurfaceView画板操作，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2020-05-05
  • Android软键盘显示模式及打开和关闭方式(推荐)

    Android软键盘显示模式及打开和关闭方式(推荐)

    这篇文章主要介绍了Android软键盘显示模式及打开和关闭方式(推荐),非常不错，具有参考借鉴价值，需要的朋友可以参考下
    2017-02-02
  • Github简单易用的 Android ViewModel Retrofit框架

    Github简单易用的 Android ViewModel Retrofit框架

    这篇文章主要介绍了Github简单易用的Android ViewModel Retrofit框架，RequestViewMode有自动对LiveData进行缓存管理，每个retrofit api接口复用一个livedata的优势。下文具体详情，感兴趣的小伙伴可以参考一下
    2022-06-06
  • Android编程之数据库Sql编程实例分析

    Android编程之数据库Sql编程实例分析

    这篇文章主要介绍了Android编程之数据库Sql编程,实例分析了Android操作Sqlite数据库的相关技巧,非常具有实用价值,需要的朋友可以参考下
    2015-04-04
  • Android提高之使用NDK把彩图转换灰度图的方法

    Android提高之使用NDK把彩图转换灰度图的方法

    这篇文章主要介绍了Android使用NDK把彩图转换灰度图的方法,在Android项目开发中有一定的实用价值,需要的朋友可以参考下
    2014-08-08
  • Android 判断网络状态对音频静音的实现方法

    Android 判断网络状态对音频静音的实现方法

    最近小编做项目遇到这样的需求，需要根据当前场景让app变的智能，让app根据使用者当前网络状态，自动记性静音等操作，具体怎么实现呢？下面小编给大家分享实例代码，需要的朋友参考下吧
    2018-10-10
  • Android中图片圆角三种实现方法

    Android中图片圆角三种实现方法

    大家好，本篇文章主要讲的是Android中图片圆角三种实现方法，感兴趣的同学赶快来看一看吧，对你有帮助的话记得收藏一下
    2022-02-02

最新评论