作者:任聪
原文:http://www.jianshu.com/p/f240ca7bb7c0
前言:此文所述处理方式为本人在实践过程中研究分析得出的一种解决方案。
本文不仅希望能为 SC 学习者提供一种如题问题的一种解决方案,并且希望通过本文引出各位 SC 的朋友对如题问题的共同探讨和最佳实践方案的分享。
场景及痛点
问题分析与解决方案
解决思路
HystrixBadRequestException
不会触发 hystrix 的熔断 --> 但是并没有介绍该异常的实践方案HystrixBadRequestException
了。于是先看源码,一方面对 Hystrix 加深理解,尝试理解作者设计的初衷与想法,另一方面看看是否能找到其他方案达到较高的实践标准interface UserRemoteCall
定义feign的接口其上会有 @FeignClient
,FeignClient 定义了自己的 Configuration --> FeignConfiguration
class FeignConfiguration
这里是定义了指定 Feign 接口使用的自定义配置,如果不想该配置成为全局配置,不要让该类被自动扫描到class UserErrorDecoder implements ErrorDecoder
该类会处理响应状态码 (![200,300) || !404)Feign 的默认配置在 org.springframework.cloud.netflix.feign.FeignClientsConfiguration
类中,如果不自定义Feign.Builder,会优先配置 feign.hystrix.HystrixFeign.Builder extends Feign.Builder
,该类会让 Feign 的内部调用受到 Hystrix 的控制
//省略部分代码@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();
}
}//省略部分代码
ErrorDecoder.decode()
即可。feign.hystrix.enabled=false
,这会在全局生效不推荐。FeignConfiguration
增加:(推荐)
@Bean @Scope("prototype") public Feign.Builder feignBuilder() { return Feign.builder(); }Hystrix 的设计方案是通过命令模式加 RxJava 实现的观察者模式来开发的,想完全熟悉 Hystrix 的运作流程需要熟练掌握 RxJava,本文只对源码进行简单介绍,后面有时间有机会再详细介绍。Hystrix如何处理异常的代码位置:com.netflix.hystrix.AbstractCommand#executeCommandAndObserve
//省略部分代码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 {
if (e instanceof HystrixBadRequestException) {
eventNotifier.markEvent(HystrixEventType.BAD_REQUEST, commandKey); return Observable.error(e);
}
return handleFailureViaFallback(e);
}
}
};//省略部分代码}
该类中该方法为发生异常的回调方法,由此可以看出如果抛出异常如果是 HystrixBadRequestException
是直接处理异常之后进行抛出(这里不会触发熔断机制),而不是进入回调方法。
那么我们对于请求异常的解决方案就需要通过 HystrixBadRequestException
来解决了(不会触发熔断机制),根据返回响应创建对应异常并将异常封装进 HystrixBadRequestException
,业务系统调用中取出 HystrixBadRequestException
中的自定义异常进行处理,封装异常说明:
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);
}else{
logger.error(exception.getMessage(), exception);
} return exception;
}
}
为 Feign 配置 ErrorDecoder
@Configurationpublic class FeignConfiguration {
@Bean
public ErrorDecoder errorDecoder(){
return new UserErrorDecoder();
}
}
业务系统处理异常说明:
@Overridepublic 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;
}
}
WebApplicationException
是 javax.ws.rs
包中异常,通过 Jersey 抛出该异常能够将返回的 HttpCode 封装进该异常中(上述代码中展示了如何封装 HttpCode),抛出该异常,调用端就能得到返回的 HttpCode。
WebApplicationException
即可满足需求,其他架构也是大同小异了。