我们有可能在 OkHttp 拦截器中停止请求吗？

Question

在我们的应用程序中，我们遇到了一种特殊情况 - 如果我们的 App.specialFlag == true，我们需要停止来自我们代码的任何请求。我们认为，在这种情况下，最好的方法是包含特殊的Interceptor，它将停止我们的任何请求，如下所示：

if (App.specialFlag) {
    // Somehow stop request
} else {
    return chain.proceed(chain.request());
}

此外，我们应该注意，我们使用 RxJavaCallAdapterFactory 将响应包装到 Observables 中。

但是我们在 OkHttp 拦截器中没有看到任何停止请求的方法。

我们想出了两种方法来解决我们的问题：

a) 创建特殊的 ApiService.class 用于在我们的 API 中包装每个请求，如下所示：

public Observable<User> getUserDetails() {
    if (App.specialFlag) {
        return Observable.just(null);
    }
    return api.getUserDetails();
}

但我们认为它是丑陋和麻烦的解决方案。

b) 在 Interceptor 中抛出一个RuntimeException，然后在我们使用 API 的每个地方捕获它。

第二种方案也不好，因为我们的链中需要包含很多onErrorResumeNext操作符。

可能有人知道，如何以更“聪明”的方式处理我们的情况？..

提前致谢！

Answer 1

accepted answer 中缺少的一件事是您需要指定协议和消息。如果你不指定你会得到一个异常。看起来像这样：

if (App.specialFlag) {
    return new Response.Builder()
                       .code(418) // Whatever code
                       .body(ResponseBody.create(null, "")) // Whatever body
                       .protocol(Protocol.HTTP_2)
                       .message("Dummy response")
                       .request(chain.request())
                       .build();
} else {
    return chain.proceed(chain.request());
}

Answer 2

一种防止请求被执行的方法（在它开始之前）它只是按照你的尝试做，但添加了Response.Builder：

if (App.specialFlag) {
    return new Response.Builder()
                       .code(600) //Simply put whatever value you want to designate to aborted request.
                       .protocol(Protocol.HTTP_2)
                       .message("Dummy response")
                       .request(chain.request())
                       .build();
} else {
    return chain.proceed(chain.request());
}

2019 年 9 月 26 日编辑 更新了Bobstring提到的详细答案

Answer 3

1. 我建议将控制逻辑脚本放在 OkHttp 之外，因为它仅用于发出 http 请求。如何触发请求，如何处理响应更新UI，无需关心；

2. 如果你愿意，你可以创建一个继承自okhttp3.Interceptor的Class，然后重写函数intercept并将你的控制逻辑脚本放在里面。

   OkHttpClient client = new OkHttpClient.Builder()
      .connectTimeout(20, TimeUnit.SECONDS)
      .readTimeout(20, TimeUnit.SECONDS)
      .addInterceptor(new Interceptor())
      .build();