微服务springcloud—zuul的容错和回退

迈不过友情╰ 2022-04-17 21:15 202阅读 0赞

# zuul的容错与回退 #

1.启动项目microservice-discovery-eureka。  
2.启动项目microservice-provider-user。  
3.启动项目microservice-gateway-zuul。  
4.启动项目microservice-hystrix-dashboard。  
5.访问http://localhost:8040/users/1，可正常获得结果。  
6.访问http://localhost:8040/actuator/hystrix.stream，可获得Hystrix的监控数据。  
7.访问http://localhost:8030/hystrix，并在监控地址一栏填入http://localhost:8040/actuator/hystrix.stream  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzQzOTQ5NA_size_16_color_FFFFFF_t_70]

8.关闭项目microservice-provider-user，再次访问http://localhost:8040/users/1，将会看到异常输出。  
![在这里插入图片描述][20181107144145367.png]  
下面来谈谈如何为zuul添加回退

# 为zuul添加回退 #

想要为Zuul添加回退，需要实现ZuulFallbackProvider接口，在实现类中，指定为哪个微服务提供回退，并提供一个ClientHttpResponse作为回退响应。  
1.复制项目microservice-gateway-zuul，将ArtifactId修改为microservice-gateway-zuul-fallback。  
2.编写zuul的回退类：

@Component
    public class UserFallbackProvider implements FallbackProvider { 
        public String getRoute(){ 
            //表明是为哪个微服务提供回退,"*"表示所有微服务
            return "*";
        }
    
    
        public ClientHttpResponse fallbackResponse(String route, Throwable cause){ 
            return new ClientHttpResponse() { 
                @Override
                public HttpStatus getStatusCode() throws IOException { 
                    //fallback时的状态码
                    return HttpStatus.OK;
                }
    
                @Override
                public int getRawStatusCode() throws IOException { 
                    //数字类型的状态码，本例返回的其实就是200
                    return this.getStatusCode().value();
                }
    
                @Override
                public String getStatusText() throws IOException { 
                    //状态文本，本例返回的其实就是OK
                    return this.getStatusCode().getReasonPhrase();
                }
    
                @Override
                public void close() { 
    
                }
    
                @Override
                public InputStream getBody() throws IOException { 
                    //响应体
                    return new ByteArrayInputStream("用户微服务不可用，请稍后再试".getBytes());
                }
    
                @Override
                public HttpHeaders getHeaders() { 
                    //headers设定
                    HttpHeaders headers = new HttpHeaders();
                    MediaType mt = new MediaType("application",
                              "json", Charset.forName("UTF-8"));
                    headers.setContentType(mt);
                    return headers;
                }
            };
        }
    }

spring2.0以上版本参考：[https://www.2cto.com/kf/201806/754248.html][https_www.2cto.com_kf_201806_754248.html]  
添加回退之后，重复之前的实验，当users微服务无法正常响应时，将会返回以下内容。  
![在这里插入图片描述][20181107145506138.png]

本文大部分内容转载自周立的《Spring Cloud与Docker微服务架构实战》

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzQzOTQ5NA_size_16_color_FFFFFF_t_70]: /images/20220418/1e56c56e74ae4d1d88074e525153e72b.png
[20181107144145367.png]: /images/20220418/7307039e35ec4ca5a3e2ef6cc95e6caa.png
[https_www.2cto.com_kf_201806_754248.html]: https://www.2cto.com/kf/201806/754248.html
[20181107145506138.png]: /images/20220418/f7ab2a7980e346119cae4139333600c7.png