zuulGateway网关添加路由异常熔断

我不是女神ヾ 2022-05-27 00:00 131阅读 0赞

zuulGateway是spring cloud中很不错的组件，使用频率很高。使用过程中偶尔可能遇到服务路由异常的情况，如果没有异常熔断，可能会造成应用无响应，严重甚至造成系统雪崩。所以一般需要加上熔断机制。直接看代码，很简单：

/*
     * 文件名：ServerFallback.java 版权：Copyright by www.poly.com 描述： 修改人：gogym 修改时间：2018年1月31日 跟踪单号： 修改单号：
     * 修改内容：
     */
    
    package com.poly.zuul.fallback;
    
    
    import java.io.ByteArrayInputStream;
    import java.io.IOException;
    import java.io.InputStream;
    
    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;
    
    
    /**
     * 〈异常熔断〉
     * 
     * @author gogym
     * @version 2018年1月31日
     * @see ServerFallback
     * @since
     */
    @Component
    public class ServerFallback implements ZuulFallbackProvider
    {
    
        @Override
        public String getRoute()
        {
            // api服务id，如果需要所有调用都支持回退，则return "*"或return null
            return "*";
    
        }
    
        @Override
        public ClientHttpResponse fallbackResponse()
        {
    
            // ----------------返回前端-----------------------
            return new ClientHttpResponse()
            {
    
                String responseStr = "{\"code\":10006,\"msg\":\"服务路由异常\"}";
    
                @Override
                public InputStream getBody()
                    throws IOException
                {
    
                    return new ByteArrayInputStream(responseStr.getBytes("UTF-8"));
    
                }
    
                @Override
                public HttpHeaders getHeaders()
                {
    
                    HttpHeaders headers = new HttpHeaders();
                    // 和body中的内容编码一致，否则容易乱码
                    headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
                    return headers;
    
                }
    
                @Override
                public int getRawStatusCode()
                    throws IOException
                {
    
                    return HttpStatus.OK.value();
    
                }
    
                @Override
                public HttpStatus getStatusCode()
                    throws IOException
                {
                    /**
                     * 网关向api服务请求是失败了，但是消费者客户端向网关发起的请求是OK的， 不应该把api的404,500等问题抛给客户端
                     * 网关和api服务集群对于客户端来说是黑盒子
                     */
                    return HttpStatus.OK;
    
                }
    
                @Override
                public String getStatusText()
                    throws IOException
                {
    
                    return HttpStatus.OK.getReasonPhrase();
    
                }
    
                @Override
                public void close()
                {
    
                }
            };
    
        }
    }