java B2B2C电子商务平台分析之十六----Zuul的容错回退与高可用

ITyi · · 24 次点击 · · 开始浏览    
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,效果如图: ![1效果.png](https://static.kotlintc.com/181205/7a4f1a9d0356435086fba45bfa9b410f.png) 关闭user-provider-eureka服务,再访问http://localhost:10010/user/getuserinfo?name=jack,效果如图: ![2效果.png](https://static.kotlintc.com/181205/c42c168c4c47f5cb6deb324a0b73aa3e.png) 可以看到,当用户微服务不可用时候,默认返回了自定义的json。 zuul的高可用策略 一、如果Zuul也注册到了服务发现组件Eureka上,那么zuul就已经实现了高可用配置,这种情况和普通的服务消费者和提供者的高可用是一致的; 二、若zuul未注册到Eureka上,则可以通过Nginx/HAProxy等负载均衡器来将请求分配到zuul的其中一个节点;这点更多的还是负载均衡器的配置。例如nginx的: ![高可用测略.png](https://static.kotlintc.com/181205/b2c33b6e975c0ca92ca8d1d4d6faa2d0.png) 整体代码结构如下: [资料和源码来源 ](http://minglisoft.cn/honghu/technology.html) ![代码.jpg](https://static.kotlintc.com/181127/f1952de8a02617385356254e45bb9255.jpg)
24 次点击  
加入收藏 微博
1 回复  |  直到
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet