RESTAPI请求超时

Question

当没有响应返回时，我需要超时我的RESTAPI。例如，当我发出请求时，如果返回响应需要5秒钟以上，则超时。

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

我当前的实现看起来像，

主类

@SpringBootApplication
@EnableCircuitBreaker
class MyApplication{

}

RestController

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

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

应用程序属性

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（）将异步执行使您检索字符串的任务，因此它应该包含您的函数代码。它应该以返回结束

另一方面，您将在之后获得未来，并且方法. get（Unit， timeoutUnit）将同步等待未来通过超时进行响应。

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

在超时的情况下（意味着未来在5秒之前还没有完成），您将捕获一个TimeoutException，并能够对您的呼叫方做出任何您想要的响应。

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