我正在构建一个调用另一个微服务的 SpringBoot 微服务，自然希望使用 Hystrix 和 Feign 客户端，它们都包含在 Spring Cloud 中。我使用的是 Camden.SR5 版本。

对于来自 Feign 的任何超时、连接失败和 50x 响应代码，我希望 Hystrix 启动并正常工作:触发断路器并调用回退(如果已配置)等。它默认执行此操作，所以我很好。

但是对于 40x 响应代码，其中包括无效条目、错误格式的字段等，我希望 Hystrix 将这些异常传播给调用者，这样我也可以根据自己的选择来处理它们。这不是我观察到的默认设置。 如何在 Spring Cloud 中配置 Hystrix/Feign 来执行此操作？

开箱即用，使用以下代码:

import org.springframework.cloud.netflix.feign.FeignClient;
import org.springframework.hateoas.Resource;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;

@FeignClient(name = "dog-service", url = "http://...")
public interface DogsFeignClient {
  @RequestMapping(method = RequestMethod.POST, path = "/dogs")
  Resource<Dog> createDog(Dog dog);
}

生成此异常，它不适合将 40x 响应很好地传递回调用者:

com.netflix.hystrix.exception.HystrixRuntimeException: DogsFeignClient#createDog(Dog) failed and no fallback available.
    at com.netflix.hystrix.AbstractCommand$22.call(AbstractCommand.java:805) ~[hystrix-core-1.5.6.jar:1.5.6]
    ....lines ommited for brevity....
Caused by: feign.FeignException: status 400 reading DogsFeignClient#createDog(Dog); content:
{
  "errors" : [ {
    "entity" : "Dog",
    "property" : "numberOfLegs",
    "invalidValue" : "3",
    "message" : "All dogs must have 4 legs"
  } ]
}
    at feign.FeignException.errorStatus(FeignException.java:62) ~[feign-core-9.3.1.jar:na]
    at feign.codec.ErrorDecoder$Default.decode(ErrorDecoder.java:91) ~[feign-core-9.3.1.jar:na]
    at feign.SynchronousMethodHandler.executeAndDecode(SynchronousMethodHandler.java:138) ~[feign-core-9.3.1.jar:na]
    at feign.SynchronousMethodHandler.invoke(SynchronousMethodHandler.java:76) ~[feign-core-9.3.1.jar:na]
    at feign.hystrix.HystrixInvocationHandler$1.run(HystrixInvocationHandler.java:108) ~[feign-hystrix-9.3.1.jar:na]
    at com.netflix.hystrix.HystrixCommand$2.call(HystrixCommand.java:301) ~[hystrix-core-1.5.6.jar:1.5.6]
    at com.netflix.hystrix.HystrixCommand$2.call(HystrixCommand.java:297) ~[hystrix-core-1.5.6.jar:1.5.6]
    at rx.internal.operators.OnSubscribeDefer.call(OnSubscribeDefer.java:46) ~[rxjava-1.1.10.jar:1.1.10]
    ... 26 common frames omitted

我当然可以查看 com.netflix.hystrix.exception.HystrixRuntimeException，cause 字段包含一个 feign.FeignException 和隐藏在描述中的是 JSON 响应本身，带有换行符等。但是 feign.FeignException 的 cause 字段是对自身的引用。有没有办法传播更深层次的异常而不是 HystrixRuntimeException？

还有没有办法让下游服务的响应中包含原始主体，这样我就不必解构嵌套异常的消息字段？

最佳答案

这可以使用单独的配置来实现，它将 400 包装在 HystrixBadRequestException 的子类中并将它们抛给客户端代码。 这些异常不会影响断路器状态 - 如果电路关闭，它将保持关闭状态，如果打开，它将保持打开状态。

@FeignClient(name = "dog-service", 
             url = "http://...", 
             configuration=FeignPropagateBadRequestsConfiguration.class)
public interface DogsFeignClient {
  @RequestMapping(method = RequestMethod.POST, path = "/dogs")
  Resource<Dog> createDog(Dog dog);
}

FeignPropagateBadRequestsConfiguration 在哪里

@Configuration
public class FeignSkipBadRequestsConfiguration {
    @Bean
    public ErrorDecoder errorDecoder() {
        return (methodKey, response) -> {
            int status = response.status();
            if (status == 400) {
                String body = "Bad request";
                try {
                    body = IOUtils.toString(response.body().asReader());
                } catch (Exception ignored) {}
                HttpHeaders httpHeaders = new HttpHeaders();
                response.headers().forEach((k, v) -> httpHeaders.add("feign-" + k, StringUtils.join(v,",")));
                return new FeignBadResponseWrapper(status, httpHeaders, body);
            }
            else {
                return new RuntimeException("Response Code " + status);
            }
        };
    }
}

和FeignBadResponseWrapper是

@Getter
@Setter
public class FeignBadResponseWrapper extends HystrixBadRequestException {
    private final int status;
    private final HttpHeaders headers;
    private final String body;

    public FeignBadResponseWrapper(int status, HttpHeaders headers, String body) {
        super("Bad request");
        this.status = status;
        this.headers = headers;
        this.body = body;
    }
}

这有点 hack，您只能在 ErrorDecoder 中获取响应主体，因为之后流将关闭。但是使用这个，你可以在不影响电路的情况下将响应数据丢给客户端代码:

    try {
        return dogsFeignClient.createDog(dog);
    } catch (HystrixBadRequestException he) {
        if (he instanceof FeignBadResponseWrapper) {
            // obtain data from wrapper and return it to client
        } else {
            // return basic error data for other exceptions
        }
    }

关于java - 将 Feign 与 Hystrix 结合使用时如何允许 400 错误传播？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/42730881/