springcloud 熔断处理
本文内容纲要：
在springcloud微服务中，有时候一个服务挂了，我们需要友好的提示，此时我们在api网关路由上做一下过滤，进行友好的提示处理.
代码如下:
importcom.fasterxml.jackson.databind.ObjectMapper;
importcom.lujiangchuangzhu.seventeen.api.gateway.vo.BaseVO;
importlombok.extern.slf4j.Slf4j;
importorg.springframework.cloud.netflix.zuul.filters.route.FallbackProvider;
importorg.springframework.http.HttpHeaders;
importorg.springframework.http.HttpStatus;
importorg.springframework.http.client.ClientHttpResponse;
importorg.springframework.http.MediaType;
importorg.springframework.stereotype.Component;
importjava.io.ByteArrayInputStream;
importjava.io.IOException;
importjava.io.InputStream;
/**
*Zull路由发起请求失败时的回滚处理
*Createdbyhmbon2018/3/29.
*/
@Slf4j
@Component
publicclassGenericFallbackProviderimplementsFallbackProvider{
@Override
publicClientHttpResponsefallbackResponse(Throwablethrowable){
log.info("服务调用出现了异常:"+throwable.getMessage());
throwable.printStackTrace();
returncallback();
}
/**
*如果需要所有调用都支持回退，则return"*"或returnnull
*@return
*/
@Override
publicStringgetRoute(){
return"*";
}
@Override
publicClientHttpResponsefallbackResponse(){
returncallback();
}
privateClientHttpResponsecallback(){
returnnewClientHttpResponse(){
@Override
publicInputStreamgetBody()throwsIOException{
ObjectMappermapper=newObjectMapper();
BaseVOvo=newBaseVO();
vo.setCode(10000);
vo.setMessage("服务器开小差了，请稍后再试!");
Stringjson=mapper.writeValueAsString(vo);
returnnewByteArrayInputStream(json.getBytes("UTF-8"));
}
@Override
publicHttpHeadersgetHeaders(){
HttpHeadersheaders=newHttpHeaders();
//和body中的内容编码一致，否则容易乱码
headers.setContentType(MediaType.APPLICATION_JSON_UTF8);
returnheaders;
}
/**
*网关向api服务请求是失败了，但是消费者客户端向网关发起的请求是OK的，
*不应该把api的404,500等问题抛给客户端
*网关和api服务集群对于客户端来说是黑盒子
*/
@Override
publicHttpStatusgetStatusCode()throwsIOException{
returnHttpStatus.OK;
}
@Override
publicintgetRawStatusCode()throwsIOException{
returnHttpStatus.OK.value();
}
@Override
publicStringgetStatusText()throwsIOException{
returnHttpStatus.OK.getReasonPhrase();
}
@Override
publicvoidclose(){
}
};
}
}
FallbackProvider对这个接口实现就可以了.
本文内容总结：
原文链接：https://www.cnblogs.com/huzi007/p/8865825.html