Retrofit,Gson解析,自定義解析內(nèi)容(如code=1全部解析,code=0不做解析)

打造終極MVP+Retrofit2+okhttp3+Rxjava2網(wǎng)絡(luò)請求,開發(fā)實用,簡約,由于篇幅字?jǐn)?shù)原因 本章講解服務(wù)器返回類型不統(tǒng)一而引發(fā)的解析失敗問題,繼上篇文章傳送地址,遺留下來的問題,開發(fā)中可能會遇到特殊情況,接口返回正常標(biāo)識(如code=1),我們用GSON自動化解析全部內(nèi)容。接口返回異常標(biāo)識(如code=1001),可能會出現(xiàn)返回的類型不統(tǒng)一,原本是對象內(nèi)容,但是返回了數(shù)組,原本是數(shù)組,返回的是對象,導(dǎo)致GSON自動化解析失敗,在不改后臺代碼的情況下,前端處理,解決辦法請往下看

抓住人生中的一分一秒,勝過虛度中的一月一年!

前言

目前較火的網(wǎng)絡(luò)請求其中有MVP+Retrofit2+okhttp3+Rxjava2,于是我也加入了使用行列,在網(wǎng)上找了許多案例,實際代碼開發(fā)中解決了一些所謂的坑,總結(jié)了些內(nèi)容與大家共享一下,有不足的地方希望大家提出我將進(jìn)行再次完善。

利用了以下技術(shù)點
1.Retrofit2 Retrofit2官網(wǎng)
2.okhttp3 okhttp3官網(wǎng)
3.RxJava2 RxJava2官網(wǎng)
4.MVP

下面看下代碼結(jié)構(gòu)

mmm.png

1.導(dǎo)包

 //網(wǎng)絡(luò)請求
    compile 'com.squareup.okhttp3:okhttp:3.9.1'
    compile 'com.squareup.retrofit2:retrofit:2.3.0'
    //ConverterFactory的Gson依賴包
    compile 'com.squareup.retrofit2:converter-gson:2.3.0'
    //CallAdapterFactory的Rx依賴包
    compile 'com.squareup.retrofit2:adapter-rxjava2:2.3.0'

    compile 'io.reactivex.rxjava2:rxandroid:2.0.2'

2.retrofit代碼實現(xiàn),

/**
 * File descripition:  創(chuàng)建Retrofit
 *
 * @author lp
 * @date 2018/6/19
 */

public class ApiRetrofit {
    public final String BASE_SERVER_URL = BaseContent.baseUrl;
    private String TAG = "ApiRetrofit %s";
    private static ApiRetrofit apiRetrofit;
    private Retrofit retrofit;
    private ApiServer apiServer;
    private static Gson gson;
    private static final int DEFAULT_TIMEOUT = 15;


    public ApiRetrofit() {
        OkHttpClient.Builder httpClientBuilder = new OkHttpClient.Builder();
        httpClientBuilder
                .cookieJar(new CookieManger(App.getContext())) //這塊是添加的管理cookie方法
                .addInterceptor(interceptor)//日志攔截
//                .addInterceptor(new HeadUrlInterceptor())
                .connectTimeout(DEFAULT_TIMEOUT, TimeUnit.SECONDS)
                .writeTimeout(DEFAULT_TIMEOUT, TimeUnit.SECONDS)
                .readTimeout(DEFAULT_TIMEOUT, TimeUnit.SECONDS)
                .retryOnConnectionFailure(true);//錯誤重聯(lián)

        retrofit = new Retrofit.Builder()
                .baseUrl(BASE_SERVER_URL)
                .addConverterFactory(GsonConverterFactory.create())//添加json轉(zhuǎn)換框架
                //支持RxJava2
                .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
                .client(httpClientBuilder.build())
                .build();
        apiServer = retrofit.create(ApiServer.class);
    }

    public static ApiRetrofit getInstance() {
        if (apiRetrofit == null) {
            synchronized (Object.class) {
                if (apiRetrofit == null) {
                    apiRetrofit = new ApiRetrofit();
                }
            }
        }
        return apiRetrofit;
    }

    public ApiServer getApiService() {
        return apiServer;
    }

    /**
     * 請求訪問quest
     * response攔截器
     */
    private Interceptor interceptor = new Interceptor() {
        @Override
        public Response intercept(Chain chain) throws IOException {
            Request request = chain.request();
            long startTime = System.currentTimeMillis();
            Response response = chain.proceed(chain.request());
            long endTime = System.currentTimeMillis();
            long duration = endTime - startTime;
            MediaType mediaType = response.body().contentType();
            String content = response.body().string();
//            analyzeJson("data", "", content);
            Logger.wtf(TAG, "----------Request Start----------------");
            printParams(request.body());
            Logger.e(TAG, "| " + request.toString() + "===========" + request.headers().toString());
            Logger.json(content);
            Logger.e(content);
            Logger.wtf(TAG, "----------Request End:" + duration + "毫秒----------");

            return response.newBuilder()
                    .body(ResponseBody.create(mediaType, content))
                    .build();
        }
    };

    /**
     * 請求參數(shù)日志打印
     *
     * @param body
     */
    private void printParams(RequestBody body) {
        if (body != null) {
            Buffer buffer = new Buffer();
            try {
                body.writeTo(buffer);
                Charset charset = Charset.forName("UTF-8");
                MediaType contentType = body.contentType();
                if (contentType != null) {
                    charset = contentType.charset(UTF_8);
                }
                String params = buffer.readString(charset);
                Logger.e(TAG, "請求參數(shù): | " + params);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

3.新建ApiServer類,注釋的都是請求案例

public interface ApiServer {
    //示例    多種類型請求方式

//    @POST("api/Activity/get_activities?")
//    Observable<BaseModel<List<>>> getApi1(@Query("time") String requestType);

//    @GET("api/Activity/get_activities?")
//    Observable<BaseModel<List<>>> getApi1(@Query("time") String requestType);

//    @FormUrlEncoded
//    @POST("api/Activity/get_activities?")
//    Observable<BaseModel<List<>>> getApi1(@Field("time") String requestType);

//    @FormUrlEncoded
//    @POST("api/Activity/get_activities?")
//    Observable<BaseModel<List<>>> getApi1(@FieldMap HashMap<String, String> params);

//    @Multipart
//    @POST("api/Activity/get_activities?")
//    Observable<BaseModel<List<>>> getApi1(@PartMap Map<String, RequestBody> map);

    @POST("api/Activity/get_activities?")
    Observable<BaseModel<List<MainBean>>> getMain(@Query("time") String requestType);
}

解決辦法如下
1、在上述創(chuàng)建retrofit時,Retrofit需要一個指定轉(zhuǎn)換框架,如fastJson,GSON等,我們采取GSON轉(zhuǎn)化,為了便于我們的需求,需要重寫一下GSON源碼--修改成我們自己重寫的GsonConverterFactory
原始的GsonConverterFactory

.addConverterFactory(GsonConverterFactory.create())
改成如下我們重寫的MyGsonConverterFactory
.addConverterFactory(MyGsonConverterFactory.create())

總共需要重寫三個類
第一個類為:MyGsonConverterFactory源碼如下(以下內(nèi)容復(fù)制粘貼即可,和源碼一樣)

import com.google.gson.Gson;
import com.google.gson.TypeAdapter;
import com.google.gson.reflect.TypeToken;

import java.lang.annotation.Annotation;
import java.lang.reflect.Type;

import okhttp3.RequestBody;
import okhttp3.ResponseBody;
import retrofit2.Converter;
import retrofit2.Retrofit;

/**
 * File descripition: 重寫gson 判斷返回值  狀態(tài)劃分
 *
 * @author lp
 * @date 2018/8/24
 */

/**
 * A {@linkplain Converter.Factory converter} which uses Gson for JSON.
 * <p>
 * Because Gson is so flexible in the types it supports, this converter assumes that it can handle
 * all types. If you are mixing JSON serialization with something else (such as protocol buffers),
 * you must {@linkplain Retrofit.Builder#addConverterFactory(Converter.Factory) add this instance}
 * last to allow the other converters a chance to see their types.
 */
public final class MyGsonConverterFactory extends Converter.Factory {
    /**
     * Create an instance using a default {@link Gson} instance for conversion. Encoding to JSON and
     * decoding from JSON (when no charset is specified by a header) will use UTF-8.
     */
    public static MyGsonConverterFactory create() {
        return create(new Gson());
    }

    /**
     * Create an instance using {@code gson} for conversion. Encoding to JSON and
     * decoding from JSON (when no charset is specified by a header) will use UTF-8.
     */
    @SuppressWarnings("ConstantConditions") // Guarding public API nullability.
    public static MyGsonConverterFactory create(Gson gson) {
        if (gson == null) throw new NullPointerException("gson == null");
        return new MyGsonConverterFactory(gson);
    }

    private final Gson gson;

    private MyGsonConverterFactory(Gson gson) {
        this.gson = gson;
    }

    @Override
    public Converter<ResponseBody, ?> responseBodyConverter(Type type, Annotation[] annotations,
                                                            Retrofit retrofit) {
        TypeAdapter<?> adapter = gson.getAdapter(TypeToken.get(type));
        return new MyGsonResponseBodyConverter<>(gson, adapter);
    }

    @Override
    public Converter<?, RequestBody> requestBodyConverter(Type type,
                                                          Annotation[] parameterAnnotations, Annotation[] methodAnnotations, Retrofit retrofit) {
        TypeAdapter<?> adapter = gson.getAdapter(TypeToken.get(type));
        return new MyGsonRequestBodyConverter<>(gson, adapter);
    }
}

第二個類為:MyGsonRequestBodyConverter源碼如下(以下內(nèi)容復(fù)制粘貼即可,和源碼一樣)

import com.google.gson.Gson;
import com.google.gson.TypeAdapter;
import com.google.gson.stream.JsonWriter;

import java.io.IOException;
import java.io.OutputStreamWriter;
import java.io.Writer;
import java.nio.charset.Charset;

import okhttp3.MediaType;
import okhttp3.RequestBody;
import okio.Buffer;
import retrofit2.Converter;

/**
 * File descripition:   重寫gson 判斷返回值  狀態(tài)劃分
 *
 * @author lp
 * @date 2018/8/24
 */

final class MyGsonRequestBodyConverter<T> implements Converter<T, RequestBody> {
    private static final MediaType MEDIA_TYPE = MediaType.parse("application/json; charset=UTF-8");
    private static final Charset UTF_8 = Charset.forName("UTF-8");

    private final Gson gson;
    private final TypeAdapter<T> adapter;

    MyGsonRequestBodyConverter(Gson gson, TypeAdapter<T> adapter) {
        this.gson = gson;
        this.adapter = adapter;
    }

    @Override
    public RequestBody convert(T value) throws IOException {
        Buffer buffer = new Buffer();
        Writer writer = new OutputStreamWriter(buffer.outputStream(), UTF_8);
        JsonWriter jsonWriter = gson.newJsonWriter(writer);
        adapter.write(jsonWriter, value);
        jsonWriter.close();
        return RequestBody.create(MEDIA_TYPE, buffer.readByteString());
    }
}

第三個類為:MyGsonResponseBodyConverter源碼如下(此類需要自定義內(nèi)容)
說明:convert函數(shù)中包含服務(wù)器請求下全部內(nèi)容,我們單獨拿出下發(fā)的code,message字段,用于狀態(tài)標(biāo)識,解析方式有多種,用gson解析或者強(qiáng)轉(zhuǎn)都可以

BaseResult re = gson.fromJson(response, BaseResult.class);

或者

  BaseResult re  = (BaseResult) response;

拿到code時,如果code和約定正常值不同(如code=1),余下內(nèi)容沒必要進(jìn)行解析,非1情況一律拋出ApiException異常,轉(zhuǎn)交給onError()處理

import com.google.gson.Gson;
import com.google.gson.TypeAdapter;
import com.google.gson.stream.JsonReader;
import com.lp.mvp_network.base.ApiException;
import com.lp.mvp_network.base.BaseContent;
import com.lp.mvp_network.base.BaseResult;

import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.nio.charset.Charset;

import okhttp3.MediaType;
import okhttp3.ResponseBody;
import retrofit2.Converter;

import static okhttp3.internal.Util.UTF_8;


/**
 * File descripition:   重寫gson 判斷返回值  狀態(tài)劃分
 * <p>
 * 此處很重要
 * 為何這樣寫:因為開發(fā)中有這樣的需求   當(dāng)服務(wù)器返回假如0是正常 1是不正常  0我們gson 或 fastJson解析數(shù)據(jù)
 * 1我們不想解析(可能返回值出現(xiàn)以前是對象 數(shù)據(jù)為空變成了數(shù)組等等,于是在不改后臺代碼的情況下  我們前端需要處理)
 * 但是用了插件之后沒有很有效的方法控制解析 所以處理方式為  當(dāng)服務(wù)器返回不等于0時候  其他狀態(tài)都拋出異常 然后提示
 *
 * @author lp
 * @date 2018/8/24
 */

final class MyGsonResponseBodyConverter<T> implements Converter<ResponseBody, T> {
    private final Gson gson;
    private final TypeAdapter<T> adapter;

    MyGsonResponseBodyConverter(Gson gson, TypeAdapter<T> adapter) {
        this.gson = gson;
        this.adapter = adapter;
    }

    @Override
    public T convert(ResponseBody value) throws IOException {
        String response = value.string();
//自定義解析實體類,只解析數(shù)據(jù)最外層,如code message 
        BaseResult re = gson.fromJson(response, BaseResult.class);
        //關(guān)注的重點,自定義響應(yīng)碼中非1的情況,一律拋出ApiException異常。
        //這樣,我們就成功的將該異常交給onError()去處理了。
        if (re.getCode() != BaseContent.basecode) {
            value.close();
            throw new ApiException(re.getCode(), re.getMessage());
        }
//如果是1(數(shù)據(jù)正常返回),我們正常解析
        MediaType mediaType = value.contentType();
        Charset charset = mediaType != null ? mediaType.charset(UTF_8) : UTF_8;
        ByteArrayInputStream bis = new ByteArrayInputStream(response.getBytes());
        InputStreamReader reader = new InputStreamReader(bis, charset);
        JsonReader jsonReader = gson.newJsonReader(reader);
        try {
            return adapter.read(jsonReader);
        } finally {
            value.close();
        }
    }
}

再說明一下上邊實現(xiàn)邏輯,期間我們攔截解析一步,先定義一個BaseResult,實體類只含code,和message,解析這個實體類內(nèi)容,拿到code返回值,與后臺比對約定好的狀態(tài)碼(比如1是正常),當(dāng)返回1,我們不做處理,繼續(xù)向下解析,如果返回其他值,如0或1001等,我們一律拋出自定義異常處理實體類ApiException,將code和message放進(jìn)去,到異常里進(jìn)行邏輯判斷,下邊貼一下BaseResult,ApiException這倆個類的代碼

BaseResult源碼如下(這塊需要改寫為你的項目返回字段名)

/**
 * File descripition:   狀態(tài)劃分 基類
 *
 * @author lp
 * @date 2018/8/27
 */

public class BaseResult {
    public String message;
    public int code;

    public String getMessage() {
        return message;
    }

    public void setMessage(String message) {
        this.message = message;
    }

    public int getCode() {
        return code;
    }

    public void setCode(int code) {
        this.code = code;
    }
}

ApiException源碼如下

/**
 * File descripition:   異常處理基類
 *
 * @author lp
 * @date 2018/8/24
 */

public class ApiException extends RuntimeException {
    private int errorCode;

    public ApiException(int code, String msg) {
        super(msg);
        this.errorCode = code;
    }

    public int getErrorCode() {
        return errorCode;
    }

}

開始分析拋出的異常內(nèi)容

BaseObserver源碼如下(為何憑空出現(xiàn)這個類,可查看鏈接文章)

點擊查看

如果我們項目結(jié)構(gòu)不同,可采取這種思路處理,下邊分析解決辦法

onError代表數(shù)據(jù)解析失敗,如無網(wǎng),http鏈接異常等等,首先需要通過異常類型來判斷哪種異常并做對應(yīng)提示

 @Override
    public void onError(Throwable e) {
        if (view != null) {
            view.hideLoading();
        }
        if (e instanceof HttpException) {
            //   HTTP錯誤
            onException(BAD_NETWORK, "");
        } else if (e instanceof ConnectException
                || e instanceof UnknownHostException) {
            //   連接錯誤
            onException(CONNECT_ERROR, "");
        } else if (e instanceof InterruptedIOException) {
            //  連接超時
            onException(CONNECT_TIMEOUT, "");
        } else if (e instanceof JsonParseException
                || e instanceof JSONException
                || e instanceof ParseException) {
            //  解析錯誤
            onException(PARSE_ERROR, "");
            e.printStackTrace();
        } else {
            if (e != null) {
                onError(e.toString());
            } else {
                onError("未知錯誤");
            }
        }
    }

基本異常分析完畢,再進(jìn)行分析,通過上述內(nèi)容可知,服務(wù)器返回非1(code=1)情況數(shù)據(jù)內(nèi)容都會在onError中(ApiException異常類),所以,我們需要將ApiException提出來得知是哪種異常情況
首先判斷異常信息是否包含ApiException

e instanceof ApiException

然后繼續(xù)向下分析,并分發(fā)異常處理

if (e instanceof ApiException) {
        ApiException exception = (ApiException) e;
        int code = exception.getErrorCode();
        switch (code) {
         //未登錄(這塊只是提供個演示)
        case CONNECT_NOT_LOGIN:
             view.onErrorCode(new BaseModel(exception.getMessage(), code));
             onException(CONNECT_NOT_LOGIN, exception.getMessage());
             break;
        //其他不等于0 的所有狀態(tài)
         default:
             onException(OTHER_MESSAGE, exception.getMessage());
             view.onErrorCode(new BaseModel(exception.getMessage(), code));
             break;
       }
 }

全部代碼如下

import com.google.gson.JsonParseException;
import com.lp.mvp_network.base.ApiException;
import com.lp.mvp_network.base.BaseContent;
import com.lp.mvp_network.utils.NetWorkUtils;

import org.json.JSONException;

import java.io.InterruptedIOException;
import java.net.ConnectException;
import java.net.UnknownHostException;
import java.text.ParseException;

import io.reactivex.observers.DisposableObserver;
import retrofit2.HttpException;

/**
 * File descripition:   數(shù)據(jù)處理基類
 *
 * @author lp
 * @date 2018/6/19
 */

public abstract class BaseObserver<T> extends DisposableObserver<T> {

    public static final int CODE = BaseContent.basecode;

    protected BaseView view;
    /**
     * 網(wǎng)絡(luò)連接失敗  無網(wǎng)
     */
    public static final int NETWORK_ERROR = 100000;
    /**
     * 解析數(shù)據(jù)失敗
     */
    public static final int PARSE_ERROR = 1008;
    /**
     * 網(wǎng)絡(luò)問題
     */
    public static final int BAD_NETWORK = 1007;
    /**
     * 連接錯誤
     */
    public static final int CONNECT_ERROR = 1006;
    /**
     * 連接超時
     */
    public static final int CONNECT_TIMEOUT = 1005;
  /**
     * data為null
     */
    public static final int CONNECT_NULL = 5555;
    /**
     * 未登錄  與服務(wù)器約定返回的值   這里未登錄只是一個案例
     */
    public static final int CONNECT_NOT_LOGIN = 1001;
    /**
     * 其他code  提示
     */
    public static final int OTHER_MESSAGE = 20000;


    public BaseObserver(BaseView view) {
        this.view = view;
    }

    @Override
    protected void onStart() {
        if (view != null) {
            view.showLoading();
        }
    }

   @Override
    public void onNext(T o) {
        try {
            if (view != null) {
                view.hideLoading();
            }

            Gson gson = new Gson();
            BaseModel model = gson.fromJson(o.toString(), BaseModel.class);
            if (model.getData() != null) {
                onSuccess(o);
            } else {
               if (view != null) {
                    model.setErrcode(CONNECT_NULL);
                    model.setErrmsg("怎么會是null呢");
                    view.onErrorCode(model);
                    onException(model.getErrcode(), model.getErrmsg());
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
            onError(e.toString());
        }
    }

    @Override
    public void onError(Throwable e) {
        if (view != null) {
            view.hideLoading();
        }
        if (e instanceof HttpException) {
            //   HTTP錯誤
            onException(BAD_NETWORK, "");
        } else if (e instanceof ConnectException
                || e instanceof UnknownHostException) {
            //   連接錯誤
            onException(CONNECT_ERROR, "");
        } else if (e instanceof InterruptedIOException) {
            //  連接超時
            onException(CONNECT_TIMEOUT, "");
        } else if (e instanceof JsonParseException
                || e instanceof JSONException
                || e instanceof ParseException) {
            //  解析錯誤
            onException(PARSE_ERROR, "");
            e.printStackTrace();


            /**
             * 此處很重要
             * 為何這樣寫:因為開發(fā)中有這樣的需求   當(dāng)服務(wù)器返回假如0是正常 1是不正常  當(dāng)返回0時:我們gson 或 fastJson解析數(shù)據(jù)
             * 返回1時:我們不想解析(可能返回值出現(xiàn)以前是對象 但是現(xiàn)在數(shù)據(jù)為空變成了數(shù)組等等,于是在不改后臺代碼的情況下  我們前端需要處理)
             * 但是用了插件之后沒有很有效的方法控制解析 所以處理方式為  當(dāng)服務(wù)器返回不等于0時候  其他狀態(tài)都拋出異常 然后提示
             * 代碼上一級在 MyGsonResponseBodyConverter 中處理  前往查看邏輯
             */
        } else if (e instanceof ApiException) {
            ApiException exception = (ApiException) e;
            int code = exception.getErrorCode();
            switch (code) {
                //未登錄(此處只是案例 供理解)
                case CONNECT_NOT_LOGIN:
                    view.onErrorCode(new BaseModel(exception.getMessage(), code));
                    onException(CONNECT_NOT_LOGIN, "");
                    break;
                //其他不等于0 的所有狀態(tài)
                default:
                    onException(OTHER_MESSAGE, exception.getMessage());
                    view.onErrorCode(new BaseModel(exception.getMessage(), code));
                    break;
            }
        } else {
            if (e != null) {
                onError(e.toString());
            } else {
                onError("未知錯誤");
            }
        }

    }

    /**
     * 中間攔截一步  判斷是否有網(wǎng)絡(luò)  這步判斷相對準(zhǔn)確  此步去除也可以
     *
     * @param unknownError
     * @param message
     */
    private void onException(int unknownError, String message) {
        BaseModel model = new BaseModel(message, unknownError);
        if (!NetWorkUtils.isAvailableByPing()) {
            model.setErrcode(NETWORK_ERROR);
            model.setErrmsg("網(wǎng)絡(luò)不可用,請檢查網(wǎng)絡(luò)連接!");
        }
        onExceptions(model.getErrcode(), model.getErrmsg());
        if (view != null) {
            view.onErrorCode(model);
        }
    }

    private void onExceptions(int unknownError, String message) {
        switch (unknownError) {
            case CONNECT_ERROR:
                onError("連接錯誤");
                break;
            case CONNECT_TIMEOUT:
                onError("連接超時");
                break;
            case BAD_NETWORK:
                onError("網(wǎng)絡(luò)超時");
                break;
            case PARSE_ERROR:
                onError("數(shù)據(jù)解析失敗");
                break;
            //未登錄
            case CONNECT_NOT_LOGIN:
//                onError("未登錄");
                break;
            //正常執(zhí)行  提示信息
            case OTHER_MESSAGE:
                onError(message);
                break;
            //網(wǎng)絡(luò)不可用
            case NETWORK_ERROR:
                onError("網(wǎng)絡(luò)不可用,請檢查網(wǎng)絡(luò)連接!");
                break;
            //data==null
            case CONNECT_NULL:
                onError(message);
                break;
            default:
                break;
        }
    }

    //消失寫到這 有一定的延遲  對dialog顯示有影響
    @Override
    public void onComplete() {
       /* if (view != null) {
            view.hideLoading();
        }*/
    }

    public abstract void onSuccess(T o);

    public abstract void onError(String msg);
}

此篇文章是傳送連接這篇文章的分支,想加此情況處理,可將相應(yīng)代碼拷貝到對應(yīng)目錄


后記

感謝“逆水寒_53bd”提出的了幾個問題,于是處理之后將文章更新了下
1、onNext特別要注意一下,如果加了拋異常處理不等于1實現(xiàn)模式,onNext這塊就沒必要再次判斷了,和上篇文章代碼不一樣傳送連接,因為加了異常處理,所以這樣寫,注意注意?。。∵@塊內(nèi)容code只有一種情況,就是code=1(1代表成功狀態(tài)),其他值都在onError中,所以內(nèi)容可直接給onSuccess(o);

@Override
    public void onNext(T o) {
        if (view != null) {
            view.hideLoading();
        }
        onSuccess(o);
    }

2、開發(fā)中可能還會有這種情況,message 和code都返回了值,code返回成功狀態(tài),但data返回的是null(按道理data應(yīng)該是返回對象或者數(shù)組,這種惡心的問題純屬后臺制造),再進(jìn)行處理一步
拿到對應(yīng)的data值,判斷是否為null,如果為null,進(jìn)行定制業(yè)務(wù)處理,或者提示

 @Override
    public void onNext(T o) {
        try {
            if (view != null) {
                view.hideLoading();
            }

            Gson gson = new Gson();
            BaseModel model = gson.fromJson(o.toString(), BaseModel.class);
            if (model.getData() != null) {
                onSuccess(o);
            } else {
               if (view != null) {
                    model.setErrcode(CONNECT_NULL);
                    model.setErrmsg("怎么會是null呢");
                    view.onErrorCode(model);
                    onException(model.getErrcode(), model.getErrmsg());
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
            onError(e.toString());
        }
    }

至此 自定義解析體實現(xiàn)完成
本文章最終實現(xiàn)終極MVP+Retrofit2+okhttp3+Rxjava2網(wǎng)絡(luò)請求,開發(fā)實用,簡約

github地址:https://github.com/LPTim/mvp
csdn地址:https://download.csdn.net/download/loocanp/10749238

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容