未应用来自使用注释的改型拦截器的OkHttp调用超时

Question

我尝试使用OkHttp 3.12.0中最近添加的一个特性：全操作超时。为此，我还依赖retrofit 2.5.0中新的invocation类，它允许我检索方法注释。

@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface Timeout {

    int value();

    TimeUnit unit();

}

public interface AgentApi {

    @Timeout(value = 100, unit = TimeUnit.MILLISECONDS)
    @GET("something")
    Call<String> getSomething();

}

class TimeoutInterceptor implements Interceptor {

    @NonNull
    @Override
    public Response intercept(@NonNull Chain chain) throws IOException {
        Request request = chain.request();
        final Invocation tag = request.tag(Invocation.class);
        final Method method = tag != null ? tag.method() : null;
        final Timeout timeout = method != null ? method.getAnnotation(Timeout.class) : null;
        if (timeout != null) {
            chain.call().timeout().timeout(timeout.value(), timeout.unit());
        }
        return chain.proceed(request);
    }

}

尽管它在使用拦截器中的链方法时工作得很好：

chain
  .withConnectTimeout(connect, unit)
  .withReadTimeout(read, unit)
  .withWriteTimeout(write, unit)

这是因为在呼叫排队之前必须设置呼叫超时吗？（而拦截器在过程中触发得太晚了？），或者这是其他原因？

Answer 1

不幸的是你是对的。这是因为OKHttpClient在执行拦截器链之前会获得超时。如果您查看OKHTTP3.RealCall类中的response execute()方法，您将发现timeout.enter()行，这是OKHTTP调度超时的地方，它在getResponseWithInterceptorChain()之前调用，这是执行拦截器的地方。

幸运的是，您可以为此编写解决方案：）将TimeoutInterceptor放入OKHTTP3包中（您可以在应用程序中创建该包）。这将允许您访问具有包可见性的RealCall对象。您的TimeoutInterceptor类应该如下所示：

package okhttp3;

public class TimeoutInterceptor implements Interceptor {

   @Override
   public Response intercept(Chain chain) throws IOException {
       Request request = chain.request();
       Invocation tag = request.tag(Invocation.class);
       Method method = tag != null ? tag.method() : null;
       Timeout timeout = method != null ? method.getAnnotation(Timeout.class) : null;
       if (timeout != null) {
           chain.call().timeout().timeout(timeout.value(), timeout.unit());
           RealCall realCall = (RealCall) chain.call();
           realCall.timeout.enter();
       }
       return chain.proceed(request);
   }
}

解决方法包括在更改超时之后再次执行timeout.enter()。所有的魔法都发生在台词中：

RealCall realCall = (RealCall) chain.call();
realCall.timeout.enter();

祝你好运！