休息 API 请求超时

Question

当没有返回响应时，我需要让我的 Rest Api 超时。例如，当我发出请求时，如果返回响应的时间超过 5 秒，则超时。

为了实现这一点，我选择了使用 Hystrix 的断路器。但是我不确定这是否是解决这个问题的正确方法，如果一切都好，是否应该对 Hystrix 进行更多配置？

我当前的实现看起来像，

主类

@SpringBootApplication
@EnableCircuitBreaker
class MyApplication{

}

休息控制器

@GetMapping("/data")
@HystrixCommand(commandKey="response")
public String getResponse(){

    Thread.sleep(10000);
    .....
}

application.properties

hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=5000

当超时时，它会抛出一个 HystrixRunTimeException 并使用自定义异常处理程序进行处理。

这是实现请求超时的正确方法吗？

Answer 1

您可以简单地使用本机 CompletableFuture 而无需为此添加外部依赖项：

CompletableFuture<String> task = CompletableFuture.supplyAsync(() -> {
    //your code which will return a String response at some point
});
try {
    return task.get(5, TimeUnit.SECONDS); //this will return if the future returns before 5 seconds, else will throw a timeout exception
} catch (InterruptedException | ExecutionException e) {
    //handle execution issues
} catch (TimeoutException e) {
    //you're called here if you timeout
}

CompletableFuture.supplyAsync() 方法将异步执行使您检索String 的任务，因此它应该包含您的功能代码。它应该以return <your response> 结尾。

另一方面，你马上得到future，.get(unit, timeoutUnit)方法将同步等待future响应超时。

如果发生执行错误（例如，在您的功能代码中抛出异常），您将在 ExecutionException 的原因中捕获它。

如果超时（意味着未来还没有完成 5 秒），您将收到一个 TimeoutException 并能够对您的呼叫者做出任何您想要的响应。

如果异步执行功能操作的线程被中断，InterruptedException 也有可能出现。我没有处理那个异常，你会比我更清楚你想如何处理它。