HTTPが失敗しました：java.net.SocketException：Socket closed;例外処理メソッドを起動しません

Question

いくつかのロックonError（）、またはonComplete（）を解放する必要があるRxJavaチェーン要求がありますので、基本的に私の問題は何ですか：私が読み込みを設定し、 OkHttpClient、私は希望の動作を取得しません。 、

public <T extends Response> Observable<T> doSomething(Observable<T> base) { 
    isLocked = true; 
    return someApiCall() 
       .flatMap(apiResponse -> handleResponse(apiResponse, base) 
        .doOnError(throwable -> { 
         isLocked = false; 
        }) 
        .doOnCompleted(() -> { 
         isLocked = false; 
        })); 
} 

handleResponse()別のAPI呼び出しを行い、Observable<Response<Something>>を返しますが：ここで私が持っているチェーン要求の簡易版だ

OkHttpClient.Builder builder = new OkHttpClient.Builder() 
      .readTimeout(30, TimeUnit.SECONDS) 
      .connectTimeout(30, TimeUnit.SECONDS) 
      .writeTimeout(30, TimeUnit.SECONDS) 
OkHttpClient okHttpClient = builder.build(); 

：私はここに私の単純化クライアントだRetrofit2とOkHttp3.6.0を使用しています私が言ったように、それは時々HTTP FAILED: java.net.SocketException: Socket closedで失敗し、Observableを終了しないので、onError（）またはonComplete（）は決して呼び出されません。私はonTerminate（）も試みましたが、運がありません。 OkHttlClientからタイムアウト設定を削除すると、SocketExceptionが実際にスローされて捕捉され、isLocked変数を解放します。私はhandleResponse()の返信文をtry {} catch (Exception e) {}ブロックでラップしようとしましたが、カスタムタイムアウトが設定されている場合でもSocketExceptionをキャッチしません。何か案は？

Answer 1

それは要求がHTTP FAILED: java.net.SocketException: Socket closedエラーの出現を引き起こした、解除になったので、解決策は、単にチェーンにこのコードを追加したことが判明しますカスタムタイムアウト値はSocketExceptionをトリガーしていましたが、タイムアウトがタイムアウトして終了するか、要求を完了して閉じるまでソケットが待機していたとしますが、unsubscribeコールによって割り込みが発生し、予期せず終了しました。

Answer 2

Retrofit 2では、HTTPレイヤーの下/上の例外はResponse<?>として報告されていませんが、実際の例外としてはonErrorと報告されています。あなたのケースでは

、あなたはflatMapのうちdoOnError/doOnCompletedを移動する必要があります。今のところhandleResponseで生成されたエラーに応答しますが、someApiCallがObservableエラーを返した場合、そのメソッドは呼び出されません。私はまだ理由を理解していない

.doOnUnsubscribe(() -> { 
    isLocked = false; 
}) 

：

Answer 3

私は、この状況をビルダーで設定されたretryOnConnectionFailure（true）オプションを使ってAndroidで解決しました。

Retrofit 2がOkHttpClientオブジェクトを受け取ったばかりであることを考えると、