ITPub博客

首页 > 架构设计 > 数据架构 > java B2B2C电子商务平台分析之十六----Zuul的容错回退与高可用

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

原创 数据架构 作者:明理萝 时间:2018-12-05 10:00:04 1 删除 编辑

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的:


整体代码结构如下:

资料和源码来源

来自 “ ITPUB博客 ” ,链接:http://blog.itpub.net/31539957/viewspace-2284165/,如需转载,请注明出处,否则将追究法律责任。

请登录后发表评论 登录
全部评论

注册时间:2018-07-30

  • 博文量
    55
  • 访问量
    18473