Spring Cloud中国社区博客

探讨通过Feign配合Hystrix进行调用时异常的处理

场景及痛点

  • 单个项目是通过Jersey来实现restful风格的架构
  • 发生异常时异常信息总是没有回调方法,不能显示基础服务抛出的异常信息
  • 暂时没有考虑发生异常之后进行回调返回特定内容
  • 业务系统通过feign调用基础服务,基础服务是会根据请求抛出各种请求异常的(采用标准http状态码),现在我的想法是如果调用基础服务时发生请求异常,业务系统返回的能够返回基础服务抛出的状态码
  • 当然基础服务抛出的请求异常不能触发hystrix的熔断机制

问题解决方案分析

解决思路

  • 通过网上一些资料的查询,看到很多文章会说HystrixBadRequestException不会触发hystrix的熔断–>但是并没有介绍该异常的实践方案
  • 感觉要解决项目的痛点,切入点应该就在HystrixBadRequestException了。于是先看源码,一方面对Hystrix加深理解,尝试理解作者设计的初衷与想法,另一方面看看是否能找到其他方案达到较高的实践标准

对应源码解释对应方案

主要类对象简介

  • interface UserRemoteCall 定义feign的接口其上会有@FeignClient,FeignClient定义了自己的Configuration–> FeignConfiguration
  • class FeignConfiguration这里是定义了指定Feign接口使用的自定义配置,如果不想该配置成为全局配置,不要让该类被自动扫描到
  • ‘class UserErrorDecoder implements ErrorDecoder’该类会处理响应状态码 (![200,300) || !404)

不使用Hystrix

源码分析

  • Feign的默认配置在org.springframework.cloud.netflix.feign.FeignClientsConfiguration类中,如果不自定义Feign.Builder,会优先配置feign.hystrix.HystrixFeign.Builder extends Feign.Builder,该类会让Feign的内部调用受到Hystrix的控制
1
2
3
4
5
6
7
8
9
10
11
12
13
//省略部分代码
@Configuration
@ConditionalOnClass({ HystrixCommand.class, HystrixFeign.class })
protected static class HystrixFeignConfiguration {
@Bean
@Scope("prototype")
@ConditionalOnMissingBean
@ConditionalOnProperty(name = "feign.hystrix.enabled", matchIfMissing = true)
public Feign.Builder feignHystrixBuilder() {
return HystrixFeign.builder();
}
}
//省略部分代码

解决方案

  • 当然不使用Hystrix就不会有熔断等问题出现,处理好ErrorDecoder.decode()即可。
  • 不开启Hystrix的方式:
  1. 配置增加feign.hystrix.enabled=false,这会在全局生效不推荐。
  2. FeignConfiguration增加:(推荐)
    1
    2
    3
    4
    5
    @Bean
    @Scope("prototype")
    public Feign.Builder feignBuilder() {
    return Feign.builder();
    }

使用Hystrix解决内部调用抛出异常问题

源码分析

  • Hystrix的设计方案是通过命令模式加RxJava实现的观察者模式来开发的,想完全熟悉Hystrix的运作流程需要熟练掌握RxJava,本文只对源码进行简单介绍,后面有时间有机会再详细介绍
  • Hystrix如何处理异常的:
    代码位置:com.netflix.hystrix.AbstractCommand#executeCommandAndObserve
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    //省略部分代码
    private Observable<R> executeCommandAndObserve(final AbstractCommand<R> _cmd) {
    //省略部分代码
    final Func1<Throwable, Observable<R>> handleFallback = new Func1<Throwable, Observable<R>>() {
    @Override
    public Observable<R> call(Throwable t) {
    Exception e = getExceptionFromThrowable(t);
    executionResult = executionResult.setExecutionException(e);
    if (e instanceof RejectedExecutionException) {
    return handleThreadPoolRejectionViaFallback(e);
    } else if (t instanceof HystrixTimeoutException) {
    return handleTimeoutViaFallback();
    } else if (t instanceof HystrixBadRequestException) {
    return handleBadRequestByEmittingError(e);
    } else {
    /*
    * Treat HystrixBadRequestException from ExecutionHook like a plain HystrixBadRequestException.
    */
    if (e instanceof HystrixBadRequestException) {
    eventNotifier.markEvent(HystrixEventType.BAD_REQUEST, commandKey);
    return Observable.error(e);
    }
    return handleFailureViaFallback(e);
    }
    }
    };
    //省略部分代码
    }

该类中该方法为发生异常的回调方法,由此可以看出如果抛出异常如果是HystrixBadRequestException是直接处理异常之后进行抛出(这里不会触发熔断机制),而不是进入回调方法。

解决方案

  • 那么我们对与异常的解决方案就需要通过HystrixBadRequestException来解决了,根据返回响应创建对应异常并将异常封装进HystrixBadRequestException,业务系统调用中取出HystrixBadRequestException中的自定义异常进行处理

封装异常说明:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
public class UserErrorDecoder implements ErrorDecoder{
private Logger logger = LoggerFactory.getLogger(getClass());
public Exception decode(String methodKey, Response response) {
ObjectMapper om = new JiaJianJacksonObjectMapper();
JiaJianResponse resEntity;
Exception exception = null;
try {
resEntity = om.readValue(Util.toString(response.body().asReader()), JiaJianResponse.class);
//为了说明我使用的WebApplicationException基类,去掉了封装
exception = new WebApplicationException(javax.ws.rs.core.Response.status(response.status()).entity(resEntity).type(MediaType.APPLICATION_JSON).build());
} catch (IOException ex) {
logger.error(ex.getMessage(), ex);
}
// 这里只封装4开头的请求异常
if (400 <= response.status() || response.status() < 500){
exception = new HystrixBadRequestException("request exception wrapper", exception);
}
return exception;
}
}

业务系统处理异常说明:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
@Override
public UserSigninResEntity signIn(UserSigninReqEntity param) throws Exception {
try {
//省略部分代码
UserSigninResEntity entity = userRemoteCall.signin(secretConfiguration.getKeys().get("user-service"), param);
//省略部分代码
} catch (Exception ex) {
logger.error(ex.getMessage(), ex);
//这里进行异常处理
if(ex.getCause() instanceof WebApplicationException){
throw (WebApplicationException) ex.getCause();
}
throw ex;
}
}

  • WebApplicationExceptionjavax.ws.rs包中异常,通过Jersey抛出该异常能够将返回的HttpCode封装进该异常中(上述代码中展示了如何封装HttpCode),抛出该异常,调用端就能得到返回的HttpCode。

总结

  • 本文主要出发点在于如何解决在Feign中使用Hystrix时被调用端抛出请求异常的问题。
  • 本项目使用Jersey,封装WebApplicationException即可满足需求,其他架构也是大同小异了。
  • 该解决方案我不确定是否为最佳实践方案,特别希望和欢迎有不同想法或意见的朋友来与我交流,包括但不限于解决方案、项目痛点是否合理等等。

转载请标明出处:
版权归任聪作者和Spring Cloud中国社区所有
本文出自任聪的博客