Hystrix 断路器

1、概述

分布式面临的问题

复杂分布式体系结构复杂的依赖关系，不可避免的存在服务宕机，网络中断的问题

服务雪崩

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

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

Hystrix介绍

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

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

功能

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

官网资料：https://github.com/Netflix/Hystrix/wiki

2、服务熔断

应对雪崩效应的一种微服务链路保护机制，快速返回错误的响应信息。

熔断机制的注解：@HystrixCommand

1、参考springcloud-study-provider-dept-8001新建，springcloud-study-provider-dept-hystrix-8001模块

pom文件新增

<!--Hystrix依赖-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-hystrix</artifactId>
</dependency>

yml文件修改实例id

eureka:
  client:
    service-url:
      #defaultZone: http://localhost:7001/eureka
      defaultZone: http://localhost:7001/eureka,http://localhost:7004/eureka,http://localhost:7003/eureka

  instance:
    instance-id:  cloud-dept8001-hystrix #自定义服务名称信息
    prefer-ip-address: true   #访问路径可以显示ip地址

修改朱启动类名称，并添加注解@EnableCircuitBreaker 开启熔断器

package com.blj.springcloud;

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;

@EnableEurekaClient//本服务启动后会自动注册到Eureka服务中
@SpringBootApplication
@EnableDiscoveryClient //对于注册进eureka里面的服务，可以通过服务发现获得该服务的信息
@EnableCircuitBreaker//开启熔断器
public class DeptProviderHystrix8001_App {
    public static void main(String[] args) {
        SpringApplication.run(DeptProviderHystrix8001_App.class,args);
    }
}

修改DeptController用HystrixCommand报异常后如何处理一旦服务调用失败并抛出错误信息后，会自动调用@HystrixCommand标注好的fallBackMethod调用类中知道的方法

package com.blj.springcloud.controller;

import com.blj.springcloud.entities.Dept;
import com.blj.springcloud.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.*;

import java.util.List;

@RestController
@RequestMapping("dept")
public class DeptController {
    @Autowired
    private DiscoveryClient discoveryClient;


    @Autowired
    private DeptService deptService;

   // @RequestMapping(value = "/add",produces = "application/json",method = RequestMethod.POST)
   @PostMapping("add")
    public Boolean addDept(@RequestBody  Dept dept){
        System.out.println("dept = " + dept);
       return deptService.addDept(dept);
    }

    @GetMapping(value = "/get/{deptno}")
    //-旦调用服务方法失败并抛出了错误信息后，会自动调用@HystrixCommand标注好的fallbackMethod调用类中的指定方法
    @HystrixCommand(fallbackMethod = "processHystrixGet")
    public Dept get(@PathVariable("deptno") Long deptno){
        Dept dept = deptService.findById(deptno);
        if (dept == null) {
            throw new RuntimeException("该ID"+deptno+"没有对应信息！");
        }
        return dept;
    }

    public Dept processHystrixGet(@PathVariable("deptno")Long deptno){
       return new Dept().setDeptno(deptno).setDname("该deptNo没有对应的信息").setDbSource("没有这个数据库");
    }

    @GetMapping(value = "/list")
    public List<Dept> list(){
        return deptService.findAll();
    }


}

测试

3、服务降级

整体资源不够了，忍痛将某些服务先关掉，待度过难关后再开启。

资源的抢占和分配

所谓降级，一般是从整体负荷考虑，当某个服务熔断后，服务器将不再被调用，此时客户端可以自己准备一个本地的fallback回调，返回一个缺省值，这样做，虽然服务水平下降，好歹能用，比直接改掉要强。

服务降级是在客户端（消费者）处理完成的，与服务端没关系

1、修改springcloud-study-api模块

根据已有的com.blj.springcloud.service.DeptClientService接口，新建一个实现FallBackFactory接口的类。

package com.blj.springcloud.service;

import com.blj.springcloud.entities.Dept;
import feign.hystrix.FallbackFactory;
import org.springframework.stereotype.Component;
import java.util.List;
//@Component 不要忘记添加
//主业务与熔断方法解耦
@Component
public class DeptClientServiceFallBackFactory implements FallbackFactory<DeptClientService> {
    @Override
    public DeptClientService create(Throwable throwable) {
        return new DeptClientService() {
            @Override
            public boolean add(Dept dept) {
                return false;
            }

            @Override
            public Dept get(Long deptno) {
                 return new Dept().setDeptno(deptno)
                        .setDname("该deptNo没有对应的信息，Consumer客户端提供的降级信息，此刻服务provider已经关闭")
                        .setDbSource("没有这个数据库");
                  }

            @Override
            public List list() {
                return null;
            }
        };
    }
}

在DeptClientService中的FeignClient注解中添加FallBackfactory属性值

package com.blj.springcloud.service;

import com.blj.springcloud.entities.Dept;
import org.springframework.cloud.netflix.feign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;

import java.util.List;

//@FeignClient(value = "STUDY-SPRINGCLOUD-DEPT")
@FeignClient(value = "STUDY-SPRINGCLOUD-DEPT",fallbackFactory = DeptClientServiceFallBackFactory.class)
public interface DeptClientService {

    @RequestMapping(value = "/dept/add",method = RequestMethod.GET)
    public boolean add(Dept dept);

    @RequestMapping(value = "/dept/get/{deptno}",method = RequestMethod.GET)
    public Dept get(@PathVariable("deptno") Long deptno);

    @RequestMapping(value = "/dept/list",method = RequestMethod.GET)
    public List list();


}

springcloud-study-consumer-dept-feign修改yml

server:
  port: 80

feign:
  hystrix:
    enable: ture


eureka:
  client:
    service-url:
      defaultZone: eureka7001.com:7001/eureka ,http://eureka7004.com:7004/eureka ,http://eureka7003.com:7003/eureka
    register-with-eureka: false

4.HystrixDashboard

1、概述

除了隔离依赖服务的调用以外，Hystrix还提供了准实时的调用监控（HystrixDashboard),Hystrix会持续的记录所有通过Hystrix发起的请求的执行信息，并统计报表和图形的形式展示给用户，包括每秒执行多少次清酒，多少成功，多少失败等。Netflix通过Hystrix-metrics-event-stream项目实现了对以上指标的监控。spring cloud 也提供了对Hystrix Dashboard的整合，对监控内容转化成可视化的界面。

2、构建步骤

构建模块项目springcloud-study-consumer-hystrix-dashboard
pom文件

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>springcloud-study</artifactId>
        <groupId>com.blj</groupId>
        <version>1.0.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>springcloud-study-consumer-hystrix-dashboard</artifactId>

<dependencies>

    <dependency>
        <groupId>com.blj</groupId>
        <artifactId>springcloud-study-api</artifactId>
        <version>${project.version}</version>
    </dependency>
    <!--hystrix和dashboard依赖-->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-hystrix</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-hystrix-dashboard</artifactId>
    </dependency>

    <!--热部署 修改后立即生效-->
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>springloaded</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-devtools</artifactId>
    </dependency>

</dependencies>


</project>

yml文件

server:
  port: 9001

主启动类

package com.blj.springcloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;

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

所有provider微服务提供类（8001、8002、8002）都需要监控依赖配置

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

测试：访问：http://localhost:9001/hystrix，（根据配置端口号），看到豪猪表示已经配置好了

Hystrix 断路器

如何监控：

在dashboard界面中，填入需要监控的服务地址和端口号加上/hystrix.stream和监测间隔即可进入监控。（如http://localhost:8001/hystrix.stream)

Hystrix 断路器

监控分析

七色：进入监控界面后会有其中颜色的数字，其含义可以对应右上角相同颜色的单词表示的状态，其值代表该状态下触发的次数
一圈：圈的大小代表该服务的流量，圈越大流量越大
一线：代表监控间隔中，服务被访问的频率的折线图

通过观察这些就可以在大量的实例中找出故障实例和高压实例进行修复和维护。

Hystrix 断路器

Hystrix 断路器

Hystrix 断路器

1、概述

2、服务熔断

3、服务降级

4.HystrixDashboard

继续阅读

SpringCloud-链路追踪sleuth

SpringCloud（九）Sleuth 分布式请求链路跟踪前言一、安装 zipkin-server二、使用步骤总结感谢B站尚硅谷的老师 ~~~

SpringCloud商业项目工作中遇到的坑(问题)跨模块注入问题

Spring Cloud Zuul（API网关服务）（3）

SpringCloud 的 Ribbon负载均衡、原理分析及负载均衡策略与自定义策略、饥饿加载

分布式系统全局唯一Id(SnowFlake)雪花算法实现简介代码

Sentinel服务熔断功能（sentinel整合ribbon+openFeign+fallback）1、Sentinel服务熔断功能一、Ribbon系列二、OpenFeign系列三、熔断框架比较2、规则持久化

Spring Cloud Learning | 第四篇：声明式服务调用（Fegin）

分布式配置中心+总线——config+bus前言服务端客户端SpringCloud Bus

Spring Cloud 之Config分布式集中配置中心详解

springcloud-config配置中心分布式管理

Config：分布式中心

【SpringCloud】搭建高可用分布式配置中心（Spring Cloud Config）（一）全过程详解（手动刷新）Spring Cloud 2.0.2.RELEASE

Spring Cloud Config 组件、配合GitHub搭建高可用分布式配置中心

在线搭建SpringCloud，一分钟搞定

sleuth链路追踪