详解RxJava2 Retrofit2 网络框架简洁轻便封装

更新时间：2017年12月08日 08:34:15 作者：Mh_Listener

本篇文章主要介绍了详解RxJava2 Retrofit2 网络框架简洁轻便封装，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧

前言

RxJava2、Retrofit2火了有一段时间了，前段时间给公司的项目引入了这方面相关的技术，在此记录一下相关封装的思路。

需求

封装之前要先明白需要满足哪些需求。

RxJava2衔接Retrofit2
Retrofit2网络框架异常的统一处理
兼容fastjson（可选）
RxJava2内存泄漏的处理
异步请求加入Loading Dialog

依赖

implementation 'io.reactivex.rxjava2:rxandroid:2.0.1'
 implementation 'io.reactivex.rxjava2:rxjava:2.1.3'
 implementation 'com.squareup.retrofit2:retrofit:2.3.0'
 implementation 'com.squareup.retrofit2:adapter-rxjava2:2.3.0'
 implementation 'com.squareup.okhttp3:okhttp:3.9.0'
 implementation 'com.trello.rxlifecycle2:rxlifecycle-components:2.2.0'
 implementation 'com.alibaba:fastjson:1.1.59.android'//可选其它框架比如Gson

RxJava2衔接Retrofit2

先封装一个网络框架的管理类，方便调用

public class RxHttp {
 private final String BASE_URL = "https://github.com/";
 private Map<String, Retrofit> mRetrofitMap = new HashMap<>();
 private RxHttp() {

 }

 /**
  * 单例模式
  * @return
  */
 public static RxHttp getInstance() {
  return RxHttpHolder.sInstance;
 }

 private static class RxHttpHolder{
  private final static RxHttp sInstance = new RxHttp();
 }

 public Retrofit getRetrofit(String serverUrl) {
  Retrofit retrofit;
  if (mRetrofitMap.containsKey(serverUrl)) {
   retrofit = mRetrofitMap.get(serverUrl);
  } else {
   retrofit = createRetrofit(serverUrl);
   mRetrofitMap.put(serverUrl, retrofit);
  }
  return retrofit;
 }

 public SyncServerService getSyncServer(){
  return getRetrofit(BASE_URL).create(SyncServerService.class);
 }

 /**
  *
  * @param baseUrl baseUrl要以/作为结尾 eg：https://github.com/
  * @return
  */
 private Retrofit createRetrofit(String baseUrl) {
  OkHttpClient client = new OkHttpClient().newBuilder()
    .readTimeout(30, TimeUnit.SECONDS)
    .connectTimeout(30, TimeUnit.SECONDS)
    .retryOnConnectionFailure(true)
    .build();

  return new Retrofit.Builder()
    .baseUrl(baseUrl)
    .addConverterFactory(FastJsonConverterFactory.create())
    .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
    .client(client)
    .build();
 }

}

Restful风格接口

public interface SyncServerService {
 @GET("service/mobile/IsLatestVersion.ashx")
 Observable<Response<String>> getLatestVersion(@Query("SoftwareID") String SoftwareID,
             @Query("ClientVersion") String ClientVersion);
}

服务端返回的基本类型，在导入类的时候特别需要注意区分该Response类型

public class Response<T> {
 public int ret;//约定 -1为server返回数据异常 200为正常范围
 public String msg;
 public T data;

 public int getRet() {
  return ret;
 }

 public void setRet(int ret) {
  this.ret = ret;
 }

 public String getMsg() {
  return msg;
 }

 public void setMsg(String msg) {
  this.msg = msg;
 }

 public T getData() {
  return data;
 }

 public void setData(T data) {
  this.data = data;
 }
}

fastjson的支持

由于项目中采用了fastjson，square尚未实现对fastjson的支持，但是保留了代码的扩展，这边可以自己封装一下fastjson的转换器。

public class FastJsonConverterFactory extends Converter.Factory {
 private final SerializeConfig mSerializeConfig;
 private FastJsonConverterFactory(SerializeConfig serializeConfig) {
  this.mSerializeConfig = serializeConfig;
 }

 public static FastJsonConverterFactory create() {
  return create(SerializeConfig.getGlobalInstance());
 }

 public static FastJsonConverterFactory create(SerializeConfig serializeConfig) {
  return new FastJsonConverterFactory(serializeConfig);
 }

 @Override
 public Converter<?, RequestBody> requestBodyConverter(Type type, Annotation[] parameterAnnotations, Annotation[] methodAnnotations, Retrofit retrofit) {
  return new FastJsonRequestBodyConverter<>(mSerializeConfig);
 }

 @Override
 public Converter<ResponseBody, ?> responseBodyConverter(Type type, Annotation[] annotations, Retrofit retrofit) {
  return new FastJsonResponseBodyConvert<>(type);
 }
}

final class FastJsonRequestBodyConverter<T> implements Converter<T, RequestBody> {
 private final MediaType MEDIA_TYPE = MediaType.parse("application/json; charset=UTF-8");
 private SerializeConfig mSerializeConfig;
 public FastJsonRequestBodyConverter(SerializeConfig serializeConfig) {
  this.mSerializeConfig = serializeConfig;
 }

 @Override
 public RequestBody convert(T value) throws IOException {
  return RequestBody.create(MEDIA_TYPE, JSON.toJSONBytes(value, mSerializeConfig));
 }
}

final class FastJsonResponseBodyConvert<T> implements Converter<ResponseBody, T> {
 private Type mType;
 public FastJsonResponseBodyConvert(Type type) {
  this.mType = type;
 }

 @Override
 public T convert(ResponseBody value) throws IOException {
  return JSON.parseObject(value.string(), mType);
 }
}

数据返回统一处理

public abstract class BaseObserver<T> implements Observer<Response<T>> {
 @Override
 public final void onNext(@NonNull Response<T> result) {
  if (result.getRet() == -1) {
   onFailure(new Exception(result.getMsg()), result.getMsg());//该异常可以汇报服务端
  } else {
   onSuccess(result.getData());
  }
 }

 @Override
 public void onError(@NonNull Throwable e) {
  onFailure(e, RxExceptionUtil.exceptionHandler(e));
 }

 @Override
 public void onComplete() {
 }

 @Override
 public void onSubscribe(@NonNull Disposable d) {
 }

 public abstract void onSuccess(T result);
 public abstract void onFailure(Throwable e, String errorMsg);
}

下面加入了异常处理类

public class RxExceptionUtil {
 public static String exceptionHandler(Throwable e){
  String errorMsg = "未知错误";
  if (e instanceof UnknownHostException) {
   errorMsg = "网络不可用";
  } else if (e instanceof SocketTimeoutException) {
   errorMsg = "请求网络超时";
  } else if (e instanceof HttpException) {
   HttpException httpException = (HttpException) e;
   errorMsg = convertStatusCode(httpException);
  } else if (e instanceof ParseException || e instanceof JSONException
    || e instanceof com.alibaba.fastjson.JSONException) {
   errorMsg = "数据解析错误";
  } 
  return errorMsg;
 }

 private static String convertStatusCode(HttpException httpException) {
  String msg;
  if (httpException.code() >= 500 && httpException.code() < 600) {
   msg = "服务器处理请求出错";
  } else if (httpException.code() >= 400 && httpException.code() < 500) {
   msg = "服务器无法处理请求";
  } else if (httpException.code() >= 300 && httpException.code() < 400) {
   msg = "请求被重定向到其他页面";
  } else {
   msg = httpException.message();
  }
  return msg;
 }
}

异步请求加入Loading Dialog

这个时候我们可以根据自己项目中统一封装的dialog自行扩展BaseObserver

public abstract class ProgressObserver<T> extends BaseObserver<T>{
 private MaterialDialog mMaterialDialog;
 private Context mContext;
 private String mLoadingText;
 public ProgressObserver(Context context){
  this(context, null);
 }

 public ProgressObserver(Context context, String loadingText){
  mContext = context;
  mLoadingText = loadingText;
 }

 @Override
 public void onSubscribe(@NonNull Disposable d) {
  if (!d.isDisposed()) {
   mMaterialDialog = new MaterialDialog.Builder(mContext).content(mLoadingText == null ? "正在加载中..."
     : mLoadingText).isProgress(true).build();
   mMaterialDialog.show();
  }
 }

 @Override
 public void onComplete() {
  if (mMaterialDialog != null) {
   mMaterialDialog.dismiss();
  }
 }

 @Override
 public void onError(@NonNull Throwable e) {
  super.onError(e);
  if (mMaterialDialog != null) {
   mMaterialDialog.dismiss();
  }
 }

}

加入调度类，方便调用线程切换和解决内存泄漏的问题

public class RxSchedulers {
 public static <T> ObservableTransformer<T, T> observableIO2Main(final Context context) {
  return upstream -> {
   Observable<T> observable = upstream.subscribeOn(Schedulers.io())
     .observeOn(AndroidSchedulers.mainThread());
   return composeContext(context, observable);
  };
 }

 public static <T> ObservableTransformer<T, T> observableIO2Main(final RxFragment fragment) {
  return upstream -> upstream.subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread()).compose(fragment.<T>bindToLifecycle());
 }

 private static <T> ObservableSource<T> composeContext(Context context, Observable<T> observable) {
  if(context instanceof RxActivity) {
   return observable.compose(((RxActivity) context).bindUntilEvent(ActivityEvent.DESTROY));
  } else if(context instanceof RxFragmentActivity){
   return observable.compose(((RxFragmentActivity) context).bindUntilEvent(ActivityEvent.DESTROY));
  }else if(context instanceof RxAppCompatActivity){
   return observable.compose(((RxAppCompatActivity) context).bindUntilEvent(ActivityEvent.DESTROY));
  }else {
   return observable;
  }
 }
}

讲了那么多，那么如何使用这个封装呢？下面来看下如何使用。

RxHttp.getInstance().getSyncServer().getLatestVersion("1", "1.0.0")
    .compose(RxSchedulers.observableIO2Main(this))
    .subscribe(new ProgressObserver<String>(this) {
     @Override
     public void onSuccess(String result) {
      Toast.makeText(MainActivity.this, result, Toast.LENGTH_SHORT).show();
     }

     @Override
     public void onFailure(Throwable e, String errorMsg) {
     }
    });

是不是封装后的代码显得更为简洁一点呢？以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

Android开发之DialogFragment用法实例总结
这篇文章主要介绍了Android开发之DialogFragment用法,结合实例形式总结分析了Android使用DialogFragment代替Dialog功能的相关使用技巧与注意事项,需要的朋友可以参考下
2017-11-11
Android布局中gravity与layout_gravity属性说明
这篇文章主要介绍了Android布局中gravity与layout_gravity属性说明，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2023-01-01
Android实现歌词渐变色和进度的效果
这篇文章主要介绍了Android实现歌词渐变色和进度的效果的相关资料,需要的朋友可以参考下
2016-03-03
Android编程中TextView宽度过大导致Drawable无法居中问题解决方法
这篇文章主要介绍了Android编程中TextView宽度过大导致Drawable无法居中问题解决方法,以实例形式较为详细的分析了TextView设置及xml布局与调用技巧,具有一定参考借鉴价值,需要的朋友可以参考下
2015-10-10
Android实现打开本地pdf文件的两种方式
在现代应用中,PDF格式因其跨平台、稳定性好、展示内容一致等特点,在Android平台上,如何高效地打开本地PDF文件,不仅关系到用户体验,也直接影响到应用的功能丰富度,本文将给大家详细介绍了Android打开本地pdf文件的两种方式,需要的朋友可以参考下
2025-04-04
Android中的Looper对象详细介绍
这篇文章主要介绍了Android中的Looper对象,需要的朋友可以参考下
2014-02-02
Android UI控件RatingBar实现自定义星星评分效果
这篇文章主要为大家详细介绍了Android UI控件RatingBar实现自定义星星评分效果，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2017-02-02
Android TextView实现点击显示全文与隐藏功能（附源码）
TextView用法很多，用到的地方更是普遍，所以学好TextView的使用很重要很重要很重要。下面这篇文章主要介绍了Android中TextView实现显示全文与隐藏功能的相关资料，文中给出了详细的示例代码和源码下载，需要的朋友可以参考下。
2017-03-03
Android BadTokenException异常解决案例详解
这篇文章主要介绍了Android BadTokenException异常详解,小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2021-08-08
基于Google ML模型开发Android物体检测应用
ML Kit是Google提供的机器学习SDK,包含了一系列预训练模型,可以在Android和iOS应用中快速添加机器学习功能,本项目基于Google ML模型开发Android物体检测应用,首先对图像中的物体进行分类检测,获取分类物体的位置区域,然后结合图像标记,逐个获取单个物体的标签
2024-07-07

详解RxJava2 Retrofit2 网络框架简洁轻便封装

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具