RxAndroid + Retrofit callTimeout 不会触发 onError答案

【问题标题】：RxAndroid + Retrofit callTimeout doesn't trigger onErrorRxAndroid + Retrofit callTimeout 不会触发 onError
【发布时间】：2020-08-14 12:59:27
【问题描述】：

我正在使用 RxAndroid + Retrofit 来发出 http 请求。代码如下：

Interceptor headerInterceptor = getHeaderInterceptor();
        HttpLoggingInterceptor httpLoggingInterceptor = new HttpLoggingInterceptor();
        httpLoggingInterceptor.setLevel(HttpLoggingInterceptor.Level.BODY);
        OkHttpClient client = new OkHttpClient.Builder()
                .connectTimeout(60, TimeUnit.SECONDS)
                .writeTimeout(60, TimeUnit.SECONDS)
                .readTimeout(60, TimeUnit.SECONDS)
                .callTimeout(5, TimeUnit.SECONDS)
                .addInterceptor(headerInterceptor)
                .addInterceptor(httpLoggingInterceptor)
                .build();

        Gson gson = new GsonBuilder()
                .setLenient()
                .create();

        sRetrofit = new Retrofit.Builder()
                .baseUrl(BASE_URL)
                .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
                .addConverterFactory(GsonConverterFactory.create(gson))
                .client(client)
                .build();

像这样使用它：

ApiProvider.provideApi(MyApi.class)
                .submit(id, mRequest)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(
                        response -> {
                            Log.w("tag", "success");
                        },
                        throwable -> {
                            Log.w("tag", "error");
                        }
                );

我将connectTimeout / readTimeout / writeTimeout设置为60秒，将callTimeout设置为5秒。

我知道这个配置可能不合理但我只想在5秒后得到一个超时异常，并且可以调用Log.w("tag", "error");。

但是，我发现我的测试永远不会调用这条线。如果我将connectionTimeout 设置为 1 秒，那么将立即调用此行。

那么如果我想让 callTimeout 触发日志错误行该怎么办呢？

【问题讨论】：

尝试添加.retryOnConnectionFailure(false)
5 秒的通话超时非常少...大约 50 秒或 1 分钟。
@AntonisRadz 尝试了retryOnConnectionFailure(false)，不起作用。但还是谢谢你们！
@PrajwalW 嗯，我同意 5 秒太短，但如果我将连接超时设置为 1 秒，代码运行良好，我可以调用 onError。谢谢！
正如你提到的，连接超时似乎小于呼叫超时。请尝试一次。设置调用超时值 > 连接超时值。

标签： android retrofit rx-java okhttp rx-android

【解决方案1】：

就我所见，我认为您的问题可能不在于您为callTimeout(5, TimeUnit.SECONDS) 设置的秒数，我认为您的 Rx 流可能已经引发了一些错误，因此流刚刚中断您可以获得任何响应从这里。但是，您将时间秒数重置为 1 秒，然后重新启动应用程序，此时间流不会中断并且您会收到错误消息。如此简单地再次对其进行重新测试，以确保您的流在输入此订阅之前不会中断。

我已经用一些愚蠢的实现进行了测试：

class MainActivity : AppCompatActivity() {

    val delayInterceptor = object : Interceptor {
        override fun intercept(chain: Interceptor.Chain): okhttp3.Response {
            Thread.sleep(6000L)
            return chain.proceed(chain.request())
        }

    }
    val client: OkHttpClient = OkHttpClient.Builder()
            .connectTimeout(60, TimeUnit.SECONDS)
            .writeTimeout(60, TimeUnit.SECONDS)
            .readTimeout(60, TimeUnit.SECONDS)
            .callTimeout(5, TimeUnit.SECONDS)
            .addInterceptor(delayInterceptor)
            .build()

    val retrofit: Retrofit = Retrofit.Builder()
            .baseUrl("https://en.wikipedia.org/")
            .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
            .addConverterFactory(GsonConverterFactory.create())
            .client(client)
            .build();

    data class Wiki(
            @SerializedName("type")
            val type: String
    )

    interface WikiService {
        @GET("api/rest_v1/page/random/summary")
        fun getRandomSummary(): Single<Wiki>
    }

    @SuppressLint("CheckResult")
    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_main)
        retrofit.create(WikiService::class.java)
                .getRandomSummary()
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe({
                    Log.d("tag", "success")
                }, {
                    Log.e("tag", "error")
                })
    }
}

【讨论】：

感谢您的回答！请您帮忙确认Log.e("tag", "error " + it)，其中it 指的是InterruptedIOException: timeout？好像回调是由 callTimeout 触发的，它应该是这个错误而不是其他错误。如果响应不是json对象而是纯字符串，触发onError的原因可能不止1个，例如SocketTimeoutException（由connectionTimeout引起）或ClassCastException。感谢您的帮助！

【解决方案2】：

我终于找到原因了。

我使用的是com.jakewharton.retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory，根据其自述文件已被弃用：https://github.com/JakeWharton/retrofit2-rxjava2-adapter

This is now DEPRECATED!

Retrofit 2.2 and newer have a first-party call adapter for RxJava 2: https://github.com/square/retrofit/tree/master/retrofit-adapters/rxjava2

切换到retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory 后，一切都开始运行良好。

顺便说一句，对于任何可能对两者之间的区别感兴趣的人？附上我在下面找到的关键信息：

【讨论】：