甜橘子，专注成都网站制作网站设计与营销型网站建设与优化
QQ :532337155
电话：028-86922220
前言
创新互联公司成立与2013年，公司以成都做网站、网站制作、系统开发、网络推广、文化传媒、企业宣传、平面广告设计等为主要业务，适用行业近百种。服务企业客户成百上千，涉及国内多个省份客户。拥有多年网站建设开发经验。为企业提供专业的网站建设、创意设计、宣传推广等服务。 通过专业的设计、独特的风格，为不同客户提供各种风格的特色服务。
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 Subscription request(Observable> observable, final RxNetCallBack callBack) {
return observable
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.onErrorReturn(new Func1>() {
@Override
public BaseResponse call(Throwable throwable) {
Log.v("LinNetError",throwable.getMessage());
callBack.onFailure(ExceptionHandle.handleException(throwable));
return null;
}
})
.subscribe(new Subscriber>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(BaseResponse baseResponse) {
if (baseResponse.getCode().equals("200")) {
callBack.onSuccess(baseResponse.getData());
} else {
callBack.onFailure(baseResponse.getMsg());
}
}
});
}
/**
* 统一处理单个请求没有 msg body
*/
public static Subscription requestWithoutBody(Observable observable, final RxNetCallBack callBack) {
return observable
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.onErrorReturn(new Func1() {
@Override
public BaseResponse call(Throwable throwable) {
callBack.onFailure(ExceptionHandle.handleException(throwable));
return null;
}
})
.subscribe(new Subscriber() {
@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{ /** * 数据请求成功 * * @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();
}
}怎么用？