快捷導航

如何利用Retrofit+RxJava實現(xiàn)網(wǎng)絡(luò)請求的異常處理

更新時間：2019年04月09日 15:13:54 作者：耀東wang

這篇文章主要介紹了如何利用Retrofit+RxJava實現(xiàn)網(wǎng)絡(luò)請求的異常處理,小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧

通常情況下我們在與服務(wù)器進行通信的時候，不一定就不會出錯，有時會出現(xiàn)其他的錯誤，這個時候我們只要和服務(wù)器約定好各種異常，在返回結(jié)果處進行判斷，到底是執(zhí)行錯誤，還是返回正常數(shù)據(jù)。具體的思路大致就是這樣。這里我們定義ExceptionHandle，這里我參考網(wǎ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)碼判定錯誤信息
    ResponseException ex;
    if(e instanceof HttpException){
      HttpException httpException=(HttpException)e;
      /**
       * 傳入狀態(tài)碼，根據(jù)狀態(tài)碼判定錯誤信息
       */
      ex=new ResponseException(e,ERROR.HTTP_ERROR);
      switch (httpException.code()){
        case UNAUTHORIZED:
          ex.message="未驗證";
          break;
        case FORBIDDEN:
          ex.message="服務(wù)禁止訪問";
          break;
        case NOT_FOUND:
          ex.message="服務(wù)不存在";
          break;
        case REQUEST_TIMEOUT:
          ex.message="請求超時";
          break;
        case GATEWAY_TIMEOUT:
          ex.message="網(wǎng)關(guān)超時";
          break;
        case INTERNAL_SERVER_ERROR:
          ex.message="服務(wù)器內(nèi)部錯誤";
          break;
        case BAD_GATEWAY:

          break;
        case SERVICE_UNAVAILABLE:
          break;
        default:
          ex.message = "網(wǎng)絡(luò)錯誤";
          break;
      }
      return ex;
    }else if(e instanceof JsonParseException
        || e instanceof JSONException
        || e instanceof ParseException){
      ex=new ResponseException(e,ERROR.PARSE_ERROR);
      ex.message="解析錯誤";
      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="證書驗證失敗";
      return ex;
    }else {
      ex=new ResponseException(e,ERROR.UNKNOWN);
      ex.message="未知錯誤";
      return ex;
    }
  }
  /**
   * 約定異常
   */
 public static  class ERROR{
    /**
     * 自定義異常
     */
    private static final int UNAUTHORIZED = 401;//請求用戶進行身份驗證
    private static final int UNREQUEST=403;//服務(wù)器理解請求客戶端的請求，但是拒絕執(zhí)行此請求
    private static final int UNFINDSOURCE=404;//服務(wù)器無法根據(jù)客戶端的請求找到資源
    private static final int SEVERERROR=500;//服務(wù)器內(nèi)部錯誤，無法完成請求。
    /**
     * 協(xié)議出錯
     */
    public static final int HTTP_ERROR = 1003;
    /**
     * 未知錯誤
     */
    public static final int UNKNOWN = 1000;
    /**
     * 解析錯誤
     */
    public static final int PARSE_ERROR = 1001;
    /**
     * 網(wǎng)絡(luò)錯誤
     */
    public static final int NETWORD_ERROR = 1002;
    /**
     * 證書出錯
     */
    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;
    }
  }
}

然后自己定義了一個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ā)生錯誤時，Observerble會先調(diào)用onError(Throwable e),按照我的寫法呢，會繼續(xù)調(diào)用自定義onError。

那么什么時候我們對服務(wù)器的返回結(jié)果進行判斷，什么時候該發(fā)出異常了，請繼續(xù)往下看：

這里我們打算用到ObservableTransformer，Transformer其實就是就是對Observable進行一定的變換。

先看代碼：

  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("約定錯誤");
        /**
         * 可以根據(jù)不同的狀態(tài)嘛返回不同的提示信息
         * 與服務(wù)器約定返回異常信息
         */
        ExceptionHandle.ResponseException responseException = new ExceptionHandle.ResponseException(e, ExceptionHandle.ERROR.HTTP_ERROR);
        return (T) Observable.error(responseException);//發(fā)出錯誤異常
      }
      return (T) Observable.just(Response);//發(fā)出服務(wù)器數(shù)據(jù)，返回Observable<Response>
    }
  }

  //處理錯誤的變換
  public static class ErrorTransformer<T> implements ObservableTransformer {
    @Override
    public Observable<T> apply(Observable upstream) {
      return (Observable<T>) upstream.flatMap(new HandleFuc<T>());//flatMap會重新創(chuàng)建一個Observable,當它處理完事件后會匯入原先的Observable對象。
    }
  }

說明：我們的HandleFuc其實就是對服務(wù)器返回來的結(jié)果進行判斷，邏輯很簡單了，錯誤就拋出異常直接執(zhí)行error方法。如果沒有錯誤，就發(fā)送正常數(shù)據(jù)。這里值的說明一點的是，flatMap會重新創(chuàng)建一個Observable,當它處理完事件后會重新匯入初始的Observerble并開始發(fā)送事件。

使用起來其實就很簡單了：

@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方法包裹起來即可。

最后看看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();
      }
    });

好了對網(wǎng)絡(luò)請求的異常處理整個思路大致就是這樣了。

以上就是本文的全部內(nèi)容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: