springCould中的Hystrix【下】-从小白开始【8】

目录

🧂1.熔断机制??????

🌭2.修改8001服务???????

🥞3.测试???????

🥓4. 服务监控hystrixDashboard??????

?🌭5.仪表盘??????

🧂6.仪表盘的使用???????

---

1.熔断机制??????

• 熔断机制是应对雪崩效应的一种微服务链路保护机制。
• 当扇出链路的某个微服务出错不可用或者响应时间太长时，会进行服务的降级,进而熔断该节点微服务的调用,快速返回错误的响应信息。当检测到该节点微服务调用响应正常后，恢复调用链路。
• 在Spring Cloud框架里,熔断机制通过Hystrix实现。
• Hystrix会监控微服务间调用的状况,当失败的调用到一定阈值,缺省是5秒内20次调用失败,就会启动熔断机制。
• 熔断机制的注解是@HystrixCommand。

服务的降级->进而熔断->恢复调用链路

2.修改8001服务???????

在controller层添加新的方法

涉及到断路器的三个重要参数：快照时间窗、请求总数阀值、错误百分比阀值。

• 1:快照时间窗:断路器确定是否打开需要统计一些请求和错误数据,而统计的时间范围就是快照时间窗,默认为最近的10秒。
• 2:请求总数阀值:在快照时间窗内，必须满足请求总数阀值才有资格熔断。默认为20，意味着在10秒内，如果该hystrix命令的调用次数不足20次,即使所有的请求都超时或其他原因失败,断路器都不会打开。
• 3:错误百分比阀值：当请求总数在快照时间窗内超过了阀值，比如发生了30次调用，如果在这30次调用中，有15次发生了超时异常，也就是超过50%的错误百分比，在默认设定50%阀值情况下，这时候就会将断路器打开。

    //服务熔断
    @HystrixCommand(fallbackMethod = "paymentCircuitBreaker_fallback", commandProperties = {
            @HystrixProperty(name = "circuitBreaker.enabled", value = "true"),//是否开启断路器
            @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold",value = "10"),//请求次数
            @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds",value ="10000"),//时间窗口期
            @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage",value = "60"),//失败率达到多少后跳闸
    })
    @GetMapping("/payment/hystrix/errorId/{id}")
    public CommonResult paymentCircuitBreaker(@PathVariable("id") Integer id) {
        if (id < 0) {
            throw new RuntimeException("id不能为负数");
        }
        Payment result = paymentService.getById_ErrorId(id);
        if (result != null) {
            return new CommonResult(200, "查寻成功,端口:" + serverPort + ",线程池:" + Thread.currentThread().getName(), result);
        } else {
            return new CommonResult(404, "查询失败,端口:" + serverPort + ",线程池:" + Thread.currentThread().getName());
        }
    }

    //降级方法
    public CommonResult paymentCircuitBreaker_fallback(@PathVariable("id") Integer id) {
        return new CommonResult(200, "id不能为负，id=" + id);
    }

开启和关闭的条件：

• 1.当满足一定的阀值的时候(默认10秒内超过20个请求次数)
• 2.当失败率达到一定的时候(默认10秒内超过50%的请求失败)
• 3.到达以上阀值，断路器将会开启
• 4.当开启的时候，所有请求都不会进行转发
• 5.一段时间之后（默认是5秒），这个时候断路器是半开状态，会让其中一个请求进行转发。如果成功，断路器会关闭，若失败，继续开启。重复4和5?

3.测试???????

当输入id为负数时，刷新浏览器10次，在用正确的id访问，发现仍然错误，过一段时间恢复

4. 服务监控hystrixDashboard??????

Hystrix提供了准实时的调用监控(Hystrix Dashboard) , Hystrix会持续地记录所有通过Hystrix发起的请求的执行信息,并以统计报表和图形的形式展示给用户,包括每秒执行多少请求多少成功,多少失败等。Spring Cloud也提供了Hystrix Dashboard的整合，对监控内容转化成可视化界面。

?5.仪表盘??????

1.建工程

在父工程下创建9001.注意jdk和maven版本

2.导pom

1.springboot依赖

2.通用依赖

3.dashboard依赖

 <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.example</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>${project.version}</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
        </dependency>

3.改yml

只添加服务端口即可

server:
  port: 9001

4.主启动

@EnableHystrixDashboard用于启用Hystrix Dashboard功能

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

5.测试

访问：localhost:9001/hystrix，看到豪猪页面也搭建成功

6.仪表盘的使用???????

1.加依赖

要监控的服务，一定要导入依赖

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>

?2.主启动类

此配置是为了服务监控而配置，与服务容错本身无关，springcloud升级后的坑ServletRegistrationBean因为springboot的默认路径不是"/hystrix.stream",只要在自己的项目里配置上下面的servlet就可以了

 @Bean
    public ServletRegistrationBean getServlet() {
        HystrixMetricsStreamServlet streamServlet = new HystrixMetricsStreamServlet();
        ServletRegistrationBean registrationBean = new ServletRegistrationBean(streamServlet);
        registrationBean.setLoadOnStartup(1);
        registrationBean.addUrlMappings("/hystrix.stream");
        registrationBean.setName("HystrixMetricsstreamServlet");
        return registrationBean;
    }

如果不配置，访问时会报错误?

3.测试

解读：?

?