Rückkehr Fehler von OKHttp interceptor (mit Nachrüstung)

Ich bin mit OkHttp mit Retrofit, um meine app-Anfragen im Netzwerk. Ich bin auch mit Abfangjägern, die für die Authentifizierung und Wiederholung bitten, wenn nötig.

Dem server hat manchmal vorübergehende Probleme, und gibt einen leeren Körper, obwohl die response status 200 OK. Dies bewirkt, dass meine app abstürzt, weil der Erfolg blockieren des Retrofit-Callback wird aufgerufen, das eigene Objekt zurückgegeben (und analysiert, mit GSON) null ist, und der code in der Erfolgs-callback wird ein Objekt zurückgegeben.

Habe ich bereits berichtet das an das server-team, aber ich möchte es zu beheben, ohne zu müssen, wickeln Sie alle success-callback-code über die app mit null überprüft.

Currenty bin ich geneigt, zu zwei Optionen, obwohl alle anderen Ideen sind herzlich willkommen:
1) Keine Rückkehr aus dem interceptor (ist das überhaupt möglich?) und einfach Anzeige ein Fehler-dialog
2) eine Rücknahme von etwas, das Retrofit nennen, das scheitern Teil des Rückrufs.

Mein code ist unten. Wie Sie sehen können, ich wiederholen Sie die Anfrage für einen maximal 3 mal, wenn ein leerer Körper empfangen wird.

@Override
public Response intercept(Chain chain) throws IOException
{
    //First
    Request request = chain.request();
    Response response = chain.proceed(request);

    ....
    ....
    ....

    //Retry empty body response requests for a maximum of 3 times
    Integer retryMaxCount = 3;
    MediaType contentType = response.body().contentType();
    String bodyString = response.body().string();

    while (bodyString.length() == 0 && retryMaxCount > 0)
    {
        //Empty body received!, Retrying...

        retryMaxCount--;
        response = chain.proceed(request);
        bodyString = response.body().string();
    }

    if (bodyString.length() != 0)
    {
        //Create and return new response because it was consumed
        ResponseBody newResponseBody = ResponseBody.create(contentType, bodyString);
        return response.newBuilder().body(newResponseBody).build();
    }
    else
    {
        //WHAT TO WRITE HERE???
    }
}

Vielen Dank.

Warum nicht werfen Sie eine exception vom interceptor?
Vielen Dank. Das war ja einfach. Wenn Sie es post als Antwort werde ich es akzeptieren. 🙂
Wenn Sie werfen einen Fehler gibt, wird Ihre app Abstürzen? Wie behandeln Sie Fehler/propagieren Sie um Rückruf?
Nein, die app stürzt nicht ab. Das OnFailure-block des Retrofit-callback aufgerufen wird.
Darüber hinaus, wenn Sie nur verwenden, OkHttp, ohne Retrofit2, Ihre app zum Absturz.

InformationsquelleAutor Murat Ögat | 2015-09-19

Hatte gerade das gleiche Szenario und dieser Beitrag hat mir geholfen, die Implementierung der Lösung. Dank @mastov zu zeigen in die richtige Richtung.

Arbeiten mit einem back-end-api, die immer wieder HTTP 200, auch wenn es ein Fehler war. Das war meine Antwort-Beispiel für einen Fehler

{"status":403,"message":"Bad User credentials","time":1495597740061,"version":"1.0"}

Hier ist eine einfache Implementierung als Ergänzung zu dieser Antwort.

public Response intercept(Chain chain) throws IOException {
        Request request   = chain.request();
        Response response = chain.proceed(request);
        ResponseBody body = response.body();
        //Only intercept JSON type responses and ignore the rest.
        if (body != null && body.contentType() != null && body.contentType().subtype() != null && body.contentType().subtype().toLowerCase().equals("json")) {
            String errorMessage = "";
            int errorCode       = 200; //Assume default OK
            try {
                BufferedSource source = body.source();
                source.request(Long.MAX_VALUE); //Buffer the entire body.
                Buffer buffer   = source.buffer();
                Charset charset = body.contentType().charset(Charset.forName("UTF-8"));
                //Clone the existing buffer is they can only read once so we still want to pass the original one to the chain.
                String json     = buffer.clone().readString(charset);
                JsonElement obj = new JsonParser().parse(json);
                //Capture error code an message.
                if (obj instanceof JsonObject && ((JsonObject) obj).has("status")) {
                    errorCode   = ((JsonObject) obj).get("status").getAsInt();
                }
                if (obj instanceof JsonObject && ((JsonObject) obj).has("message")) {
                    errorMessage= ((JsonObject) obj).get("message").getAsString();
                }
            } catch (Exception e) {
                Log.e(TAG, "Error: " + e.getMessage());
            }
            //Check if status has an error code then throw and exception so retrofit can trigger the onFailure callback method.
            //Anything above 400 is treated as a server error.
            if(errorCode > 399){
                throw new Exception("Server error code: " + errorCode + " with error message: " + errorMessage);
            }
        }

        return response;
    }

InformationsquelleAutor velval

Meine Lösung entnommen okhttp3.die Protokollierung.HttpLoggingInterceptor

class ErrorResponseInterceptor : Interceptor {

    override fun intercept(chain: Interceptor.Chain): Response {
        val response = chain.proceed(chain.request())
        val code = response.code()
        if (code in 400..500) {
            responseBody(response)?.also { errorString ->
                //error string here is a body of server error
            }
        }
        return response
    }

    private fun responseBody(response: Response): String? {
        val responseBody = response.body() ?: return null
        val contentLength = responseBody.contentLength()

        if (contentLength == 0L) {
            return null
        }

        val source = responseBody.source()
        source.request(Long.MAX_VALUE) //Buffer the entire body.
        var buffer = source.buffer()
        val headers = response.headers()

        if ("gzip".equals(headers.get("Content-Encoding"), ignoreCase = true)) {
            var gzippedResponseBody: GzipSource? = null
            try {
                gzippedResponseBody = GzipSource(buffer.clone())
                buffer = okio.Buffer()
                buffer.writeAll(gzippedResponseBody)
            } finally {
                gzippedResponseBody?.close()
            }
        }

        val charset: Charset = responseBody.contentType()?.charset(UTF8) ?: UTF8
        return buffer.clone().readString(charset)
    }

    private companion object {
        val UTF8: Charset = Charset.forName("UTF-8")
    }
}

InformationsquelleAutor kengura

Schreibe einen Kommentar

Du musst angemeldet sein, um einen Kommentar abzugeben.