聊城人事考试网,搜小说网,工商外国语学校
前言
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 （）
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对移动技术网的支持。
如对本文有疑问，请在下面进行留言讨论，广大热心网友会与你互动！！ 点击进行留言回复
Android studio 解决logcat无过滤工具栏的操作
Android Studio 恢复小窗口停靠模式(Docked Mode)
Android studio保存logcat日志到本地的操作
Android Studio快捷键生成TAG、Log.x日志输出介绍
网友评论