Jodah故障安全库超时时间比预期的要长

Question

我有一种情况，我想实现一个API重试机制。假设我有一个调用第三方API的API，正常响应时间不到2秒，但有时我们会收到一个错误，说“服务不可用”、“网关超时”等等。

所以我上网看看我们是否有一个图书馆来处理这些事情，我发现了https://jodah.net/failsafe/

使用图书馆的目的：-

如果在5秒钟内，我没有得到结果，我将取消当前调用的执行，再试一次。

为此，在库中，我可以看到我们有超时和重试策略。

首先，我尝试超时。

 Timeout<Object> timeout = Timeout.of(Duration.ofMillis(1000)).withCancel(true)
        .onFailure(e -> logger.error("Connection attempt timed out {} {} ",new DateTime(), e.getFailure()))
        .onSuccess(e -> logger.info("Execution completed on time"));


       try {
         logger.info("TIme: {}", new DateTime());
         result = Failsafe.with(timeout).get(() -> restTemplate.postForEntity(messageSendServiceUrl, request, String.class));

      } catch (TimeoutExceededException | HttpClientErrorException e) {
        logger.info("TIme: {}", new DateTime());
        logger.error("Timeout exception", e);

      } catch (Exception e) {
        logger.error("Exception", e);
      }

但是，在计算调用API和接收TimeOutExceedeException之间的延迟时间时，我得到了20秒，这应该是1秒，因为持续时间是持续时间。百万（1000）。下面你可以看到21秒的差异。

TIme: 2020-06-11T10:00:17.964+05:30
Connection attempt timed out 2020-06-11T10:00:39.037+05:30 {}

你能让我知道我做错了什么吗？

其次是重试策略

RetryPolicy<Object> retryPolicy = new RetryPolicy<>()
    .handle(HttpClientErrorException.class, TimeoutExceededException.class, Exception.class)
    .withDelay(Duration.ofSeconds(1))
    .withMaxRetries(3);

我想要一次TimeoutExceedeException异常发生在3秒之后，延迟1秒，再次启动请求，最多重试3次。我把它当作

 result = Failsafe.with(retryPolicy,timeout).get(() -> restTemplate.postForEntity(messageSendServiceUrl, request, String.class));

Answer 1

get是一个阻塞或同步操作，它使用调用线程。故障保护几乎没有办法提前停止。超时最好与异步操作结合使用，通常由*Async方法指示。一定要阅读https://jodah.net/failsafe/schedulers/因为默认值有一些含义，对于IO绑定的操作来说，它通常是一个糟糕的选择。