如何利用Retrofit+RxJava實(shí)現(xiàn)網(wǎng)絡(luò)請(qǐng)求的異常處理
更新時(shí)間：2019年04月09日 15:13:54 作者：耀東wang
這篇文章主要介紹了如何利用Retrofit+RxJava實(shí)現(xiàn)網(wǎng)絡(luò)請(qǐng)求的異常處理,小編覺(jué)得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧
通常情況下我們?cè)谂c服務(wù)器進(jìn)行通信的時(shí)候，不一定就不會(huì)出錯(cuò)，有時(shí)會(huì)出現(xiàn)其他的錯(cuò)誤，這個(gè)時(shí)候我們只要和服務(wù)器約定好各種異常，在返回結(jié)果處進(jìn)行判斷，到底是執(zhí)行錯(cuò)誤，還是返回正常數(shù)據(jù)。具體的思路大致就是這樣。這里我們定義ExceptionHandle，這里我參考網(wǎng)上的東西，然后稍微做了一些改動(dòng)。
ExceptionHandle
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 ResponseException handleException(Throwable e){
//轉(zhuǎn)換成ResponseException,根據(jù)狀態(tài)碼判定錯(cuò)誤信息
ResponseException ex;
if(e instanceof HttpException){
HttpException httpException=(HttpException)e;
/**
* 傳入狀態(tài)碼，根據(jù)狀態(tài)碼判定錯(cuò)誤信息
*/
ex=new ResponseException(e,ERROR.HTTP_ERROR);
switch (httpException.code()){
case UNAUTHORIZED:
ex.message="未驗(yàn)證";
break;
case FORBIDDEN:
ex.message="服務(wù)禁止訪問(wèn)";
break;
case NOT_FOUND:
ex.message="服務(wù)不存在";
break;
case REQUEST_TIMEOUT:
ex.message="請(qǐng)求超時(shí)";
break;
case GATEWAY_TIMEOUT:
ex.message="網(wǎng)關(guān)超時(shí)";
break;
case INTERNAL_SERVER_ERROR:
ex.message="服務(wù)器內(nèi)部錯(cuò)誤";
break;
case BAD_GATEWAY:
break;
case SERVICE_UNAVAILABLE:
break;
default:
ex.message = "網(wǎng)絡(luò)錯(cuò)誤";
break;
}
return ex;
}else if(e instanceof JsonParseException
|| e instanceof JSONException
|| e instanceof ParseException){
ex=new ResponseException(e,ERROR.PARSE_ERROR);
ex.message="解析錯(cuò)誤";
return ex;
}else if(e instanceof ConnectException){
ex=new ResponseException(e,ERROR.NETWORD_ERROR);
ex.message="連接失敗";
return ex;
}else if(e instanceof javax.net.ssl.SSLHandshakeException){
ex=new ResponseException(e,ERROR.SSL_ERROR);
ex.message="證書(shū)驗(yàn)證失敗";
return ex;
}else {
ex=new ResponseException(e,ERROR.UNKNOWN);
ex.message="未知錯(cuò)誤";
return ex;
}
}
/**
* 約定異常
*/
public static class ERROR{
/**
* 自定義異常
*/
private static final int UNAUTHORIZED = 401;//請(qǐng)求用戶進(jìn)行身份驗(yàn)證
private static final int UNREQUEST=403;//服務(wù)器理解請(qǐng)求客戶端的請(qǐng)求，但是拒絕執(zhí)行此請(qǐng)求
private static final int UNFINDSOURCE=404;//服務(wù)器無(wú)法根據(jù)客戶端的請(qǐng)求找到資源
private static final int SEVERERROR=500;//服務(wù)器內(nèi)部錯(cuò)誤，無(wú)法完成請(qǐng)求。
/**
* 協(xié)議出錯(cuò)
*/
public static final int HTTP_ERROR = 1003;
/**
* 未知錯(cuò)誤
*/
public static final int UNKNOWN = 1000;
/**
* 解析錯(cuò)誤
*/
public static final int PARSE_ERROR = 1001;
/**
* 網(wǎng)絡(luò)錯(cuò)誤
*/
public static final int NETWORD_ERROR = 1002;
/**
* 證書(shū)出錯(cuò)
*/
public static final int SSL_ERROR = 1005;
}
/**
* 自定義Throwable
*/
public static class ResponseThrowable extends Exception{
public int code;
public String message;
public ResponseThrowable(Throwable throwable,int code){
super(throwable);
this.code=code;
}
}
/**
* 服務(wù)器異常
*/
public class ServerException extends RuntimeException{
public int code;
public String message;
}
/**
* 統(tǒng)一異常類，便于處理
*/
public static class ResponseException extends Exception{
public int code;
public String message;
public ResponseException (Throwable throwable,int code){
super(throwable);
this.code=code;
}
}
}
然后自己定義了一個(gè)Observer
public abstract class BaseObserver<T> implements Observer<T> {
private Context context;
public BaseObserver(Context context){
this.context=context;
}
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onNext(T t) {
}
@Override
public void onError(Throwable e) {
if(e instanceof ExceptionHandle.ResponseException){
onError((ExceptionHandle.ResponseException)e);
}else{
onError(new ExceptionHandle.ResponseException(e,ExceptionHandle.ERROR.UNKNOWN));
}
}
@Override
public void onComplete() {
}
public abstract void onError(ExceptionHandle.ResponseException exception);
}
這里發(fā)生錯(cuò)誤時(shí)，Observerble會(huì)先調(diào)用onError(Throwable e),按照我的寫(xiě)法呢，會(huì)繼續(xù)調(diào)用自定義onError。
那么什么時(shí)候我們對(duì)服務(wù)器的返回結(jié)果進(jìn)行判斷，什么時(shí)候該發(fā)出異常了，請(qǐng)繼續(xù)往下看：
這里我們打算用到ObservableTransformer，Transformer其實(shí)就是就是對(duì)Observable進(jìn)行一定的變換。
先看代碼：
public static class HandleFuc<T> implements Function<UserGuideSoftConfigRForm<UserGuideSoftConfigPageInfo<List<UserguideSoftConfig>>>, T> {
@Override
public T apply(UserGuideSoftConfigRForm<UserGuideSoftConfigPageInfo<List<UserguideSoftConfig>>> Response) {
if (!Response.getCode().equals("200")){
Throwable e=new Throwable("約定錯(cuò)誤");
/**
* 可以根據(jù)不同的狀態(tài)嘛返回不同的提示信息
* 與服務(wù)器約定返回異常信息
*/
ExceptionHandle.ResponseException responseException = new ExceptionHandle.ResponseException(e, ExceptionHandle.ERROR.HTTP_ERROR);
return (T) Observable.error(responseException);//發(fā)出錯(cuò)誤異常
}
return (T) Observable.just(Response);//發(fā)出服務(wù)器數(shù)據(jù)，返回Observable<Response>
}
}
//處理錯(cuò)誤的變換
public static class ErrorTransformer<T> implements ObservableTransformer {
@Override
public Observable<T> apply(Observable upstream) {
return (Observable<T>) upstream.flatMap(new HandleFuc<T>());//flatMap會(huì)重新創(chuàng)建一個(gè)Observable,當(dāng)它處理完事件后會(huì)匯入原先的Observable對(duì)象。
}
}
說(shuō)明：我們的HandleFuc其實(shí)就是對(duì)服務(wù)器返回來(lái)的結(jié)果進(jìn)行判斷，邏輯很簡(jiǎn)單了，錯(cuò)誤就拋出異常直接執(zhí)行error方法。如果沒(méi)有錯(cuò)誤，就發(fā)送正常數(shù)據(jù)。這里值的說(shuō)明一點(diǎn)的是，flatMap會(huì)重新創(chuàng)建一個(gè)Observable,當(dāng)它處理完事件后會(huì)重新匯入初始的Observerble并開(kāi)始發(fā)送事件。
使用起來(lái)其實(shí)就很簡(jiǎn)單了：
@Provides
ErrorTransformer provideErrorTransformer(){
return new ErrorTransformer();
}
public Observable<UserGuideSoftConfigRForm<UserGuideSoftConfigPageInfo<List<UserguideSoftConfig>>>> getApplication(PageParmForm pageParmForm){
return retrofit.create(Service.class)
.getApplicationList(pageParmForm)
.compose(errorTransformer)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread());
}
直接用compose方法包裹起來(lái)即可。
最后看看Activity：
new NetRepository().getApplication(new PageParmForm(Constant.orderStr,Constant.pageNum,Constant.pageSize))
.subscribe(new BaseObserver<UserGuideSoftConfigRForm<UserGuideSoftConfigPageInfo<List<UserguideSoftConfig>>>>(NetWorkActivity.this) {
@Override
public void onError(ExceptionHandle.ResponseException exception) {
myToast.showToast(NetWorkActivity.this,exception.getMessage());
Log.d("carhandbook",exception.getMessage());
}
@Override
public void onNext(UserGuideSoftConfigRForm<UserGuideSoftConfigPageInfo<List<UserguideSoftConfig>>> Response) {
data=Response.getData().getList();
code=Response.getCode();
myToast.showToast(NetWorkActivity.this,code);
generateAdapter.setData(data);
generateAdapter.notifyDataSetChanged();
}
});
好了對(duì)網(wǎng)絡(luò)請(qǐng)求的異常處理整個(gè)思路大致就是這樣了。
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
這篇文章主要介紹了java集合框架線程同步代碼詳解，具有一定借鑒價(jià)值，需要的朋友可以參考下。2017-12-12
java8新特性-Stream入門(mén)學(xué)習(xí)心得
這篇文章主要介紹了java8新特性-Stream入門(mén)學(xué)習(xí)心得，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2023-03-03
這篇文章主要為大家詳細(xì)介紹了32位和64位皆適用的MyEclipse安裝教程,具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2016-10-10
這篇文章主要介紹了Java并發(fā)編程中構(gòu)建自定義同步工具,本文講解了可阻塞狀態(tài)依賴操作的結(jié)構(gòu)、有界緩存實(shí)現(xiàn)基類示例、阻塞實(shí)現(xiàn)方式一：拋異常給調(diào)用者、阻塞實(shí)現(xiàn)方式二：通過(guò)輪詢和休眠、阻塞實(shí)現(xiàn)方式三：條件隊(duì)列等內(nèi)容,需要的朋友可以參考下2015-04-04
這篇文章主要介紹了淺談spring注解之@profile，@profile通過(guò)配置來(lái)改變參數(shù)，這里整理的詳細(xì)的用法，有興趣的可以了解一下2017-10-10
SnowFlake 算法（雪花算法）, 是Twitter開(kāi)源的分布式id生成算法。其核心思想就是: 使用一個(gè)64 bit的long型的數(shù)字作為全局唯一id。本文講述Java 基于雪花算法生成分布式id的方法2021-06-06
SpringMVC Mybatis配置多個(gè)數(shù)據(jù)源并切換代碼詳解
這篇文章主要介紹了SpringMVC Mybatis配置多個(gè)數(shù)據(jù)源并切換代碼詳解,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-11-11
Java線程中synchronized和volatile關(guān)鍵字的區(qū)別詳解
這篇文章主要介紹了Java線程中synchronized和volatile關(guān)鍵字的區(qū)別詳解,synchronzied既能夠保障可見(jiàn)性,又能保證原子性,而volatile只能保證可見(jiàn)性,無(wú)法保證原子性,volatile不需要加鎖,比synchronized更輕量級(jí),不會(huì)阻塞線程,需要的朋友可以參考下2024-01-01
這篇文章主要介紹了使用Spring注入Hibernate驗(yàn)證框架方式，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-12-12
這篇文章主要介紹了java語(yǔ)言如何生成plist下載ipa文件問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-08-08