SpringCloud05-Hystrix（服务熔断等）

Posted 2020-12-19 林森001

Hystrix（服务熔断等）

分布式系统面临的问题

复杂的分布式体系结构中的应用程序有数十个依赖关系，每个依赖关系在某些时候将有不可 避免的失败！

服务雪崩

多个微服务之间调用的时候，假设微服务A调用微服务B和微服务C，微服务B和微服务C又调用其他的微服务，这就是所谓的“扇出”，如果扇出的链路上某个微服务调用响应时间过长或者不可用，对微服务A的调用就会占用越来越多的系统资源，进而引起系统崩溃，所谓的“雪崩效应”

对于高流量的应用来说，单一的后端依赖可能会导致所有服务器上的所有资源都在几秒钟内饱和，比失败更糟的是，这些应用程序还可能导致服务之间的延迟增加，备份队列，线程和其他系统资源紧张，导致整个系统发生更多的级联故障，这些都表示需要对故障和延迟进行隔离和管理，以便单个依赖关系的失败，不能取消整个应用程序或系统。我们需要“弃车保帅”

什么是Hystrix

Hystrix是一个用于处理分布式系统的延迟和容错的开源库，在分布式系统里，许多依赖不可避免的会调用失败，比如超时，异常等，Hystrix能够保证在一个依赖出问题的情况下，不会导致整体服务失败，避免级联故障，以提高分布式系统的弹性

“断路器”本身是一种开关装置，当某个服务单元发送故障之后，提高断路器监控（类似熔断保险丝），向调用方返回一个服务预期的，可处理的备选响应（FallBack），而不是长时间的等待或者抛出调用方法无法处理的异常，这样就保证了服务调用方的线程不会被长时间，不必要的占用。从而避免了故障在分布式系统中的蔓延，乃至雪崩。

能干嘛

• 服务降级
• 服务熔断
• 服务限流
• 接近实时的监控
• 。。。。。

服务熔断（服务端）

熔断机制是对应雪崩效应的一种微服务链路保护机制

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

​ 1）导入依赖（此例子是把以前做的8001端口复制一遍）

<!--Hystrix-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-hystrix</artifactId>
    <version>1.4.6.RELEASE</version>
</dependency>

​ 2）编写配置，在上次例子前提下修改的配置

instance:
  instance-id: springcloud-privider-htystrix-dept8001 

​ 3）开启此功能

​ 1）编写控制层（添加备选方案）

package com.mjh.springcloug.controller;

import com.mjh.springcloud.pojo.Dept;
import com.mjh.springcloug.service.DeptService;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

/**
 * 提供restful风格，让外界调用我们的方法
 */
@RestController
public class DeptController {
    @Autowired
    private DeptService deptService;


    @GetMapping("/dept/queryById/{id}")
    @HystrixCommand(fallbackMethod="HystrixQueryById")  //如果出现异常就调用备选方案
    public Dept queryById(@PathVariable("id") Long id) {
        Dept dept = deptService.queryById(id);//如果id传一个空值就会出现异常
        if (dept == null) {
            throw new RuntimeException("id=>" + id + ",不存在该用户，或者信息无法找到");
        }

        return dept;
    }

    //备选方案
    public Dept HystrixQueryById(@PathVariable("id") Long id) {
        return new Dept()
                .setDeptNo(id)
                .setDName("id=>" + id + "没有对应信息，null---@Hystrix")
                .setDb_source("no this database in mysql");

    }
}

​ 2）在主方法中添加对熔断的支持@Enable~

package com.mjh.springcloug;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

//启动类
@SpringBootApplication
@EnableEurekaClient   //服务启动后自动注册到Eureka中
@EnableDiscoveryClient  //服务发现
@EnableCircuitBreaker //CircuitBreaker断路器的意思
public class DeptPrividerHystrix_8001 {
    public static void main(String[] args) {
        SpringApplication.run( DeptPrividerHystrix_8001.class,args);
    }
}

​ 4）启动（首先要启动集群）

当你访问超时或异常时，本来终端会报错，之后的服务都不会执行；但是有了服务熔断之后，即便有异常，服务端会调用备选方案（让该异常走正常的异常，即编写异常方法），让程序继续运行，防止雪崩。

服务降级（客户端）

在运维期间，当系统处于高峰期，系统资源紧张，我们可以让非核心业务降级运行，某些服务不处理或者简单处理。即当资源不够用，想办法将其关掉，度过难关之后再将其开启

​ 1）在springcloud-api这个微服务里，我们要将下面的DeptClientService实现降级（在feign下实现）

package com.mjh.springcloud.service;

import com.mjh.springcloud.pojo.Dept;
import feign.hystrix.FallbackFactory;
import org.springframework.stereotype.Component;

import java.util.List;

//降级
@Component
public class DeptClientServiceFallbackFactory implements FallbackFactory {
    @Override
    public DeptClientService create(Throwable throwable) {
        return new DeptClientService() {
            @Override
            public boolean addDept(Dept dept) {
                return false;
            }

            @Override
            public Dept queryById(Long id) {
                return new Dept()
                        .setDeptNo(id)
                        .setDName("id=>"+id+"没有对应的信息，客户端提供了降级的信息，这个服务下载已经关闭")
                        .setDb_source("没有用对应的数据库");
            }

            @Override
            public List<Dept> queryAll() {
                return null;
            }
        };
    }
}

​ 2)在接口上实现调用这个处理的类，之后再配置文件里开启降级

@FeignClient(value = "SPRINGCLOUD-PRIVIDER-DEPT",fallbackFactory=DeptClientServiceFallbackFactory.class)

#开启降级
feign:
  hystrix:
    enabled: true

​ 3）启动

当某个服务熔断或者关闭时，服务将不再被调用，我们可以提供一个FallbackFactory，返回一个正常的信息提示用户。整体的服务水平下降了（关闭了服务），好歹能用（比直接挂掉强）

DashBoard流监控

写一个监控页面

​ 1）导入依赖

<!--Hystrix-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-hystrix</artifactId>
    <version>1.4.6.RELEASE</version>
</dependency>
<dependency>
    <!--监控-->
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-hystrix-dashboard</artifactId>
    <version>1.4.6.RELEASE</version>
</dependency>

​ 2)编写配置文件

server:
  port: 9001

​ 3)开启注解 @Enable~(要保证每个服务端都有actuator依赖)

​ 4）启动

​ 5)需要配置一个Hystrix.stream

例如启动一个8001端口，如果想要其被监控就需要注册一个bean

//启动类
@SpringBootApplication
@EnableEurekaClient   //服务启动后自动注册到Eureka中
@EnableDiscoveryClient  //服务发现
@EnableCircuitBreaker //CircuitBreaker断路器的意思
public class DeptPrividerHystrix_8001 {
    public static void main(String[] args) {
        SpringApplication.run( DeptPrividerHystrix_8001.class,args);
    }

    //增加一个Servlet
    @Bean
    public ServletRegistrationBean HystrixMetricsStreamServlet(){
        ServletRegistrationBean registrationBean = new ServletRegistrationBean(new HystrixMetricsStreamServlet());
        registrationBean.addUrlMappings("/actuator/hystrix.stream");
        return registrationBean;
    }
}