这篇文章主要介绍如何实现Zuul的容错回退与高可用,文中介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们一定要看完!
zuul的容错与回退
之前说到过,使用Hystrix实现微服务的容错与回退,其实Zuul默认已经整合了Hystrix,使用起来也是比较简单:
在原有 zuul-gateway 项目的基础上新增,实现ZuulFallbackProvider接口,并实现getRoute和fallbackResponse方法。
import com.google.gson.Gson;
import com.simons.cn.util.CommonEnum;
import com.simons.cn.util.CommonResult;
import org.springframework.cloud.netflix.zuul.filters.route.ZuulFallbackProvider;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.http.client.ClientHttpResponse;
import org.springframework.stereotype.Component;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.nio.charset.Charset;
@Component
public class UserProviderZuulFallBack implements ZuulFallbackProvider {
private static final String USER_PROVIDER_SERVICE = "user-provider";
@Override
public String getRoute() {
return USER_PROVIDER_SERVICE; //返回你需要为哪个微服务提供回退
}
@Override
public ClientHttpResponse fallbackResponse() {
return new ClientHttpResponse() {
/**
* 返回Http状态码标识
*/
@Override
public HttpStatus getStatusCode() throws IOException {
return HttpStatus.OK;
}
/**
* 返回Http状态码对应数字:200,详见HttpStatus
*/
@Override
public int getRawStatusCode() throws IOException {
return 200;
}
/**
*返回Http状态码对应中译:OK,详见HttpStatus
*/
@Override
public String getStatusText() throws IOException {
return HttpStatus.OK.getReasonPhrase();
}
@Override
public void close() {
}
/**
*body响应体
*/
@Override
public InputStream getBody() throws IOException {
String message = new Gson().toJson(CommonResult.success(CommonEnum.SERVICE_NOT_AVAILABLE.getCode(), CommonEnum.SERVICE_NOT_AVAILABLE.getMessage()));
return new ByteArrayInputStream(message.getBytes("UTF-8"));
}
/**
* 设置HttpHeaders
*/
@Override
public HttpHeaders getHeaders() {
HttpHeaders headers = new HttpHeaders();
// MediaType mediaType = new MediaType("application/json;charset=utf-8"); //这是错误写法
MediaType mediaType = new MediaType("application", "json", Charset.forName("utf-8"));
headers.setContentType(mediaType);
return headers;
}
};
}
}
CommonEnum中的枚举(部分):
SERVICE_NOT_AVAILABLE("5001","当前服务不可用,请稍后重试!"),
测试:
启动zuul-gateway项目和user-provider-eureka、discovery-eureka三个项目,浏览器访问http://localhost:10010/user/getuserinfo?name=jack,效果如图:
关闭user-provider-eureka服务,再访问http://localhost:10010/user/getuserinfo?name=jack,效果如图:
可以看到,当用户微服务不可用时候,默认返回了自定义的json。
zuul的高可用策略
一、如果Zuul也注册到了服务发现组件Eureka上,那么zuul就已经实现了高可用配置,这种情况和普通的服务消费者和提供者的高可用是一致的;
二、若zuul未注册到Eureka上,则可以通过Nginx/HAProxy等负载均衡器来将请求分配到zuul的其中一个节点;这点更多的还是负载均衡器的配置。例如nginx的:
以上是“如何实现Zuul的容错回退与高可用”这篇文章的所有内容,感谢各位的阅读!希望分享的内容对大家有帮助,更多相关知识,欢迎关注亿速云行业资讯频道!
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。
原文链接:http://blog.itpub.net/31539957/viewspace-2284165/