文档章节

Spring Cloud 入门教程8、服务网关Zuul+Hystrix:断路处理与监控

吴伟祥
 吴伟祥
发布于 2019/02/19 10:50
字数 1066
阅读 146
收藏 3

一、前言

1、本篇主要内容

  • 通过实现FallbackProvider进行Zuul网关路由断路处理
  • Zuul+Hystrix路由断路监控配置与说明

2、本篇环境信息

框架 版本
Spring Boot 2.0.0.RELEASE
Spring Cloud Finchley.RELEASE
Zuul 1.3.1
JDK 1.8.x

3、准备工作

参考上一篇:https://ken.io/note/spring-cloud-zuul-quickstart
基于源码:https://github.com/ken-io/springcloud-course/tree/master/chapter-07

  • 准备Eureka Server、服务提供者

启动Eureka Server: http://localhost:8800
启动Test Service:http://localhost:8602,http://localhost:8603

二、服务网关Zuul:服务断路处理

Zuul作为服务网关为了保证自己不被服务拖垮,本身已经集成了Hystrix对路由转发进行隔离。
为了方便开发人员对服务短路进行自定义处理,
Zuul 提供了 ZuulFallbackProvider 接口,开发人员可以通过实现该接口来完成自定义Hystrix Fallback

Spring Cloud Zuul 提供了 FallbackProvider替代了ZuulFallbackProvider接口。因此我们实现FallbackProvider即可

基于上一篇中zuul项目的源码进行修改即可:https://github.com/ken-io/springcloud-course/tree/master/chapter-07/zuul

1、实现FallbackProvider

在src\main\java\io\ken\springcloud\zuul创建package:provider
然后创建Filter类:ApiFallbackProvider.java

实现FallbackProvider并标记为@Component

package io.ken.springcloud.zuul.provider;

import com.netflix.hystrix.exception.HystrixTimeoutException;
import org.springframework.cloud.netflix.zuul.filters.route.FallbackProvider;
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.util.logging.Logger;

@Component
public class ApiFallbackProvider implements FallbackProvider {

    private Logger logger = Logger.getLogger(ApiFallbackProvider.class.toString());

    @Override
    public String getRoute() {
        return "*";
    }

    @Override
    public ClientHttpResponse fallbackResponse(String route, Throwable cause) {
        logger.warning(String.format("route:%s,exceptionType:%s,stackTrace:%s", route, cause.getClass().getName(), cause.getStackTrace()));
        String message = "";
        if (cause instanceof HystrixTimeoutException) {
            message = "Timeout";
        } else {
            message = "Service exception";
        }
        return fallbackResponse(message);
    }

    public ClientHttpResponse fallbackResponse(String message) {

        return new ClientHttpResponse() {
            @Override
            public HttpStatus getStatusCode() throws IOException {
                return HttpStatus.OK;
            }

            @Override
            public int getRawStatusCode() throws IOException {
                return 200;
            }

            @Override
            public String getStatusText() throws IOException {
                return "OK";
            }

            @Override
            public void close() {

            }

            @Override
            public InputStream getBody() throws IOException {
                String bodyText = String.format("{\"code\": 999,\"message\": \"Service unavailable:%s\"}", message);
                return new ByteArrayInputStream(bodyText.getBytes());
            }

            @Override
            public HttpHeaders getHeaders() {
                HttpHeaders headers = new HttpHeaders();
                headers.setContentType(MediaType.APPLICATION_JSON);
                return headers;
            }
        };

    }

}
  • FallbackProvider 成员说明
说明
getRoute() 该Provider应用的Route ID,例如:testservice,如果设置为 * ,那就对所有路由生效
fallbackResponse(String route, Throwable cause) 快速回退失败/响应,即处理异常并返回对应输出/响应内容。route:发生异常的RouteID,cause:触发快速回退/失败的异常/错误
ClientHttpResponse Spring提供的HttpResponse接口。可以通过实现该接口自定义Http status、body、header

2、回退/失败响应测试

启动zuul项目,访问 http://localhost:8888/testservice?token=123
会得到正常响应内容:

{
  "code": 0,
  "message": "hello",
  "content": null,
  "serviceName": "testservice",
  "host": "localhost:8602"
}

关掉testservice启动的实例。然后再访问 http://localhost:8888/testservice?token=123 ,就会看到

{
  "code": 999,
  "message": "Service unavailable:Timeout"
}

三、服务网关Zuul:服务断路监控/仪表盘

上一节咱们提到了,Zuul本身就集成了Hystrix,实际上Zuul的路由转发也是用到了Ribbon+Hystrix,也就意味着我们可以通过Hystrix Dashboard监控Zuul的工作情况

1、开启访问Hystri.stream入口

新建package:configuration,然后在此package下创建HystrixConfiguration.java

package io.ken.springcloud.zuul.configuration;

import com.netflix.hystrix.contrib.metrics.eventstream.HystrixMetricsStreamServlet;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class HystrixConfiguration {

    @Bean(name = "hystrixRegistrationBean")
    public ServletRegistrationBean servletRegistrationBean() {
        ServletRegistrationBean registration = new ServletRegistrationBean(
                new HystrixMetricsStreamServlet(), "/hystrix.stream");
        registration.setName("hystrixServlet");
        registration.setLoadOnStartup(1);
        return registration;
    }

    @Bean(name = "hystrixForTurbineRegistrationBean")
    public ServletRegistrationBean servletTurbineRegistrationBean() {
        ServletRegistrationBean registration = new ServletRegistrationBean(
                new HystrixMetricsStreamServlet(), "/actuator/hystrix.stream");
        registration.setName("hystrixForTurbineServlet");
        registration.setLoadOnStartup(1);
        return registration;
    }
}

配置完成后重启启动zuul,访问 http://localhost:8888/hystrix.stream 或者
http://localhost:8888/actuator/hystrix.stream
就可以看到Hystrix流信息.(之所以配置两个入口,是为了满足turbine需要)

//截取片段
{"type":"HystrixCommand","name":"testservice","group":"RibbonCommand","currentTime":1532412948030,"isCircuitBreakerOpen":false,"errorPercentage":100,"errorCount":1,"requestCount":1}

这时候我们通过已有看板以链接方式查看Hystrix Dashboard,或者可以用Turbine来聚合Hystrix数据了。
当然,也可以在zuul项目中引入Hystrix Dashboard 进行监控。

2、引入Hystrix Dashboard

  • 修改pom.xml引入Hystrix Dashboard相关依赖
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
</dependency>
package io.ken.springcloud.zuul;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
import org.springframework.cloud.netflix.zuul.EnableZuulProxy;

@EnableHystrixDashboard
@EnableZuulProxy
@EnableEurekaClient
@SpringBootApplication
public class App {
    public static void main(String[] args) {
        SpringApplication.run(App.class, args);
    }
}

配置完成后重启启动zuul,访问 http://localhost:8888/hystrix ,就可以看到门户页

image

具体操作,不再赘述,参考本系列前面几篇Hystrix随笔即可

本文转载自:https://ken.io/note/spring-cloud-zuul-hystrix-fallback-quickstart

吴伟祥

吴伟祥

粉丝 34
博文 500
码字总数 285677
作品 0
泉州
后端工程师
私信 提问
加载中

评论(0)

Spring Cloud 入门教程4、服务容错保护:断路器(Hystrix)

一、前言 1、为什么需要断路器 在分布式架构中,一个应用依赖多个服务是非常常见的,如果其中一个依赖由于延迟过高发生阻塞,调用该依赖服务的线程就会阻塞,如果相关业务的QPS较高,就可能产...

吴伟祥
2019/02/18
88
0
Spring Cloud入门教程(十):消息总线(Bus)

Spring Cloud入门教程系列: Spring Cloud入门教程(一):服务治理(Eureka) Spring Cloud入门教程(二):客户端负载均衡(Ribbon) Spring Cloud入门教程(三):声明式服务调用(Feign) Spring Cl...

CD826
2018/05/22
0
0
spring cloud 入门系列:总结

从我第一次接触Spring Cloud到现在已经有3个多月了,当时是在博客园里面注册了账号,并且看到很多文章都在谈论微服务,因此我就去了解了下,最终决定开始学习Spring Cloud。我在一款阅读App...

JAVA开发老菜鸟
2018/07/20
0
0
跟我学Spring Cloud(Finchley版)-16-Zuul

至此,已实现基于Eureka的服务发现,基于Ribbon的负载均衡,Feign也为我们提供了很不错的远程调用能力,使用Hystrix后,高并发场景下应用也不会被别人拖死——咱们的微服务架构已经日趋完善!...

周立_ITMuch
2019/01/24
98
0
热门技术从零开始学Spring Cloud视频教程发布

使用技术 (1)spring boot,使用版本:1.5.8 (2)spring cloud ,使用版本:Dalston.SR4 (3)Netflix Eureka (4)Netflix Ribbon (5)Feign (6)Netflix Hystrix (7)Spring Clou Con...

小红牛
2018/08/04
0
0

没有更多内容

加载失败,请刷新页面

加载更多

如何在PHP中定义一个空对象

用一个新的数组,我这样做: $aVal = array();$aVal[key1][var1] = "something";$aVal[key1][var2] = "something else"; 对象有类似的语法吗 (object)$oVal = "";$oVal->key1->var1 =......

javail
9分钟前
13
0
从centos服务器上导出项目,记录一次做憨批的工作记录

遇到一个客户,说要从他的centos上导出网站和数据库,以前操作centos都是直接putty上shell,装宝塔,然后面板操作就完事儿了.然后遇到这种dos操作linux,还是第一次. 首先xshell,登录上去后,安装一...

老bia同学
12分钟前
27
0
Linuxprobe第五天

shell命令脚本 一个完整的shell脚本 脚本声明 #!/bin/bash 脚本注释 #xusikkwusxshuusnxu 脚本命令 ls pwd 1、接收参数 2、判断参数 3、流程控制 && 若前面成功,则执行后面 || 若前面失败,...

nt狮子男人
17分钟前
13
0
array_map,array_walk和array_filter之间的区别

array_map , array_walk和array_filter之间究竟有什么区别。 我从文档中看到的是,您可以传递一个回调函数来对提供的数组执行操作。 但我似乎没有发现它们之间有任何特别的区别。 他们做同样...

技术盛宴
24分钟前
41
0
MySQL字符串截取的4个函数

1、从左开始截取字符串 left(str, length) 说明: left(被截取字段,截取长度) 例如: select left(content,200) as abstract from my_content_t 从左边(字符串开始位置)截取指定长...

fairy1674
今天
92
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部