如果受 hystrix 保护的调用超时,是否可以引发自定义错误?

2022-09-03 08:04:35

我有一个假装的客户与这个外部电话:

@RequestMapping(method = RequestMethod.GET, value = "GetResourceA", consumes = "application/json")
@Cacheable("ResourceA")
List<Stop> getResourceA() throws MyOwnException;

在我的设置中,我有这个设置:application.yml

hystrix:
  command:
    default:
      execution.isolation.thread.timeoutInMilliseconds: 1000
      fallback.enabled: false

现在,如果 getResourceA 超时,即完成时间超过一秒,我要么得到这个:

com.netflix.hystrix.exception.HystrixRuntimeException: getResourceA timed-out and no fallback available

或者,如果我定义了一个回退,从中抛出我自己的异常,我得到这个:

com.netflix.hystrix.exception.HystrixRuntimeException: getResourceA timed-out and fallback failed.

我可以不从回退中抛出自己的异常吗?

如果我希望在服务关闭时引发自己的异常,该怎么办?我不想有回退(因为我没有合理的值从回退返回),而是抛出我自己的错误,我可以抓住并让程序恢复。有人可以帮我解决这个问题吗?

在 Ben 的回答之后更新:

所以我尝试了捕获HysterixRuntimeException并检查导致它的原因的方法,但最终得到了这个丑陋的代码:

try {
    getResourceA();
} catch (HystrixRuntimeException e) {
    if (e.getFailureType().name().equals("TIMEOUT")) {
        throw new MyOwnException("Service timed out");
    }
    throw e;
}

所有这些都是为了能够在超时时抛出MyOwnException。肯定还有别的路吗?


答案 1

您应该能够通过获取HystrixRuntimeException

因此,要处理自定义异常,可以执行以下操作:

try {
    getResourceA();
} catch (HystrixRuntimeException e) {
    if (e.getCause() instanceof MyException) {
        handleException((MyException)e.getCause());
    }
}

答案 2

您可以使用 ErrorDecoder 并从中返回自己的异常,然后使用异常处理程序。我有一个类似的问题,并像这样解决它:

public class ExceptionHandlerControllerAdvice extends ResponseEntityExceptionHandler
...

@ResponseStatus(BAD_REQUEST)
@ExceptionHandler(HystrixRuntimeException.class)
public ExceptionResponse handleHystrixRuntimeException(HystrixRuntimeException exception) {
    if(exception.getCause() instanceof MyException) {
        return handleMyException((MyException) exception.getCause());
...

然后在我的配置类中为我的假装客户:

@Bean
public ErrorDecoder feignErrorDecoder() {
    return new ErrorDecoder() {
        @Override
        public Exception decode(String methodKey, Response response) {
            return new MyException("timeout");
        }
    };
}

这样你就不需要多个嵌套的getCause()


推荐