《七》、springcloud微服务——Hystrix断路器

一、概述

1、分布式面临的问题

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

2、服务雪崩

多个微服务之间调用的时候，假设微服务A调用微服务B和微服务C，微服务B和微服务C又调用其它的微服务，这就是所谓的“扇出”。如果扇出的链路上某个微服务的调用响应时间过长或者不可用，对微服务A的调用就会占用越来越多的系统资源，进而引起系统崩溃，所谓的“雪崩效应”。
对于高流量的应用来说，单一的后端依赖可能会导致所有服务器上的所有资源都在几秒钟内饱和。比失败更糟糕的是，这些应用程序还可能导致服务之间的延迟增加，备份队列，线程和其他系统资源紧张，导致整个系统发生更多的级联故障。这些都表示需要对故障和延迟进行隔离和管理，以便单个依赖关系的失败，不能取消整个应用程序或系统。

备注：一般情况对于服务依赖的保护主要有3中解决方案：
（1）熔断模式：这种模式主要是参考电路熔断，如果一条线路电压过高，保险丝会熔断，防止火灾。放到我们的系统中，如果某个目标服务调用慢或者有大量超时，此时，熔断该服务的调用，对于后续调用请求，不在继续调用目标服务，直接返回，快速释放资源。如果目标服务情况好转则恢复调用。
（2）隔离模式：这种模式就像对系统请求按类型划分成一个个小岛的一样，当某个小岛被火少光了，不会影响到其他的小岛。例如可以对不同类型的请求使用线程池来资源隔离，每种类型的请求互不影响，如果一种类型的请求线程资源耗尽，则对后续的该类型请求直接返回，不再调用后续资源。这种模式使用场景非常多，例如将一个服务拆开，对于重要的服务使用单独服务器来部署，再或者公司最近推广的多中心。
（3）限流模式：上述的熔断模式和隔离模式都属于出错后的容错处理机制，而限流模式则可以称为预防模式。限流模式主要是提前对各个类型的请求设置最高的QPS阈值，若高于设置的阈值则对该请求直接返回，不再调用后续资源。这种模式不能解决服务依赖的问题，只能解决系统整体资源分配问题，因为没有被限流的请求依然有可能造成雪崩效应。

3、是什么？

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

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

4、能干吗？

（1）、服务降级：
备注：Hystrix服务降级，其实就是线程池中单个线程障处理，防止单个线程请求时间太长，导致资源长期被占有而得不到释放，从而导致线程池被快速占用完，导致服务崩溃。

Hystrix能解决如下问题：
a、请求超时降级，线程资源不足降级，降级之后可以返回自定义数据；
b、线程池隔离降级，分布式服务可以针对不同的服务使用不同的线程池，从而互不影响；
c、自动触发降级与恢复；
d、实现请求缓存和请求合并；

（2）、服务熔断：
备注：熔断模式：这种模式主要是参考电路熔断，如果一条线路电压过高，保险丝会熔断，防止火灾。放到我们的系统中，如果某个目标服务调用慢或者有大量超时，此时，熔断该服务的调用，对于后续调用请求，不在继续调用目标服务，直接返回，快速释放资源。如果目标服务情况好转则恢复调用。

（3）、服务限流：
备注：限流模式主要是提前对各个类型的请求设置最高的QPS阈值，若高于设置的阈值则对该请求直接返回，不再调用后续资源。这种模式不能解决服务依赖的问题，只能解决系统整体资源分配问题，因为没有被限流的请求依然有可能造成雪崩效应。

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

二、服务熔断

1、是什么？

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

一般是某个服务故障或者异常引起，类似现实世界中的“保险丝”，当某个异常条件被触发，直接熔断整个服务，而不是一直等到此服务超时。

2、参考microservicecloud-provider-dept-8001新建microservicecloud-provider-dept-hystrix-8001

（1）、pom.xml文件

修改内容

  <!-- 引入hystrix -->
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
  </dependency>

全部内容

<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">
  <modelVersion>4.0.0</modelVersion>
  <parent>
    <groupId>cn.smilexl.springcloud</groupId>
    <artifactId>microservicecloud</artifactId>
    <version>0.0.1-SNAPSHOT</version>
  </parent>
  <artifactId>microservicecloud-provider-dept-hystrix-8001</artifactId>

  <dependencies>
        <!-- 引入自己定义的api通用包，可以使用Dept部门Entity -->
        <dependency>
            <groupId>cn.smilexl.springcloud</groupId>
            <artifactId>microservicecloud-api</artifactId>
            <version>${project.version}</version>
        </dependency>
        <!-- 引入hystrix -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
        </dependency>
        <!-- 将微服务provider注册进eureka -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
        </dependency>
        <dependency>
            <groupId>ch.qos.logback</groupId>
            <artifactId>logback-core</artifactId>
        </dependency>
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jetty</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
        </dependency>
        <!-- actuator监控信息完善 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <!-- 修改后立即生效，热部署 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <optional>true</optional>
        </dependency>
    </dependencies>
</project>

（2）、application.yml文件

server:
  port: 8001
  
mybatis:
#  config-location: classpath:mybatis/mybatis.cfg.xml       # mybatis配置文件所在路径
  type-aliases-package: cn.smilexl.springcloud.entities     # 所有Entity别名类所在包
  mapper-locations: classpath:mapper/**/*.xml               # mapper映射文件
    
spring:
   application:
    name: microservicecloud-dept                           # 微服务名
   datasource:
    type: com.alibaba.druid.pool.DruidDataSource            # 当前数据源操作类型
    driver-class-name: org.gjt.mm.mysql.Driver              # mysql驱动包
    url: jdbc:mysql://47.99.218.123:3306/clouddb01          # 数据库名称
    username: root
    password: 123456
    dbcp2:
      min-idle: 5                                           # 数据库连接池的最小维持连接数
      initial-size: 5                                       # 初始化连接数
      max-total: 5                                          # 最大连接数
      max-wait-millis: 200                                  # 等待连接获取的最大超时时间
      
eureka:
  client: #客户端注册进eureka服务列表内
    service-url: 
      defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka,http://eureka7003.com:7003/eureka
  instance:
    instance-id: microservicecloud-provider-dept-hystrix-8001  #自定义服务名称信息
    prefer-ip-address: true  #访问路径可以显示IP地址
 
 #点击超链接后显示信息   
info:
  app.name: microservicecloud
  company.name: www.smilexl.cn
  build.artifactId: $project.artifactId$
  build.version: $project.version$

将服务名修改为： instance-id: microservicecloud-provider-dept-hystrix-8001 #自定义服务名称信息

（3）、将启动类修改为：DeptProvider8001_hystrix_App.java

添加 @EnableCircuitBreaker 注解，具体代码如下：

package cn.smilexl.springcloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;

@SpringBootApplication
@EnableCircuitBreaker //对hystrix熔断机制的支持
public class DeptProvider8001_hystrix_App {

    public static void main(String[] args) {
        
        SpringApplication.run(DeptProvider8001_hystrix_App.class, args);
        
    }
}

（4）、修改 DeptController.java

对于 @HystrixCommand 报异常后如何处理，如下所示：

一旦调用服务方法失败并抛出了错误信息后，会自动调用 @HystrixCommand标准好的fallbackMethod调用类中的指定方法

代码内容如下：

package cn.smilexl.springcloud.controller;

import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
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 com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import cn.smilexl.springcloud.entities.Dept;
import cn.smilexl.springcloud.service.DeptService;

@RestController
public class DeptController {
    
    @Autowired
    private DeptService deptService;
    
    // 添加
    @PostMapping("/dept/add")
    public Boolean addDept(Dept dept) {
        
        return deptService.addDept(dept);
    }
    
    // 查询全部
    @GetMapping("/dept/list")
    public List<Dept> findAll() {
        return deptService.findAll();
    }
    

    // 根据id查询
    @GetMapping("/dept/get/{id}")
   //一旦调用服务方法失败并抛出了错误信息后，会自动调用 @HystrixCommand标准好的fallbackMethod调用类中的指定方法
    @HystrixCommand(fallbackMethod="processHystrix_Get")
    public Dept findById(@PathVariable("id") Long id) {
        Dept dept = deptService.findById(id);
        if(dept == null) {
            throw new RuntimeException("该ID"+id+"没有对应的信息");
        }
        return dept;
    }
    
    //处理@HystrixCommand对应的错误信息
    public Dept processHystrix_Get(@PathVariable("id") Long id) {
        return new Dept().setDeptno(id)
                .setDname("该ID"+id+"没有对应的信息，null---@HystrixCommand")
                .setDb_source("no this datasource in Mysql");
    }
}

（5）、测试

（1）、先启动3个 eureka；
（2）、在启动主启动类 microservicecloud-provider-dept-hystrix-8001
（3）、最后启动consumer类 microservicecloud-consumer-dept-80

当查询的 id 数据库中不存在次 id 信息时：

3、存在的问题

每对应一个方法，都会对应一个兜底的异常处理的方法，容易造成方法膨胀；

处理异常和业务逻辑绑定再一起高耦合，对程序的维护性、健壮性、美观性都不好；
解决办法，采用服务降级，对接口进行处理。

三、服务降级

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

1、是什么？

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

服务降级处理是在客户端实现完成的，与服务端没有关系。

2、修改microservicecloud-api工程

（1）、根据已经有的 DeptClientService.java 接口，新建一个实现了 FallbackFactory接口的类DeptClientServiceFallbackFactory

具体代码如下：

package cn.smilexl.springcloud.service;

import java.util.List;
import org.springframework.stereotype.Component;
import cn.smilexl.springcloud.entities.Dept;
import feign.hystrix.FallbackFactory;

@Component //交给spring;不要忘了 ,不要忘了
public class DeptClientServiceFallbackFactory implements FallbackFactory<DeptClientService>{

    @Override
    public DeptClientService create(Throwable arg0) {
        
        return new DeptClientService() {
            @Override
            public Dept findById(Long id) {
                
                return  new Dept().setDeptno(id)
                            .setDname("该ID："+id+"没有没有对应的信息,Consumer客户端提供的降级信息,此刻服务Provider已经关闭")
                            .setDb_source("no this database in MySQL");
            }
            
            @Override
            public Boolean addDept(Dept dept) {
                return null;
            }

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

（2）、在DeptClientService接口上的注解@FeignClient中添加 fallbackFactory 属性值

具体代码如下：

package cn.smilexl.springcloud.service;

import java.util.List;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import cn.smilexl.springcloud.entities.Dept;

//@FeignClient(value="MICROSERVICECLOUD-DEPT")
@FeignClient(value="MICROSERVICECLOUD-DEPT", fallbackFactory=DeptClientServiceFallbackFactory.class)
public interface DeptClientService {
    
    // 根据id查询
    @GetMapping("/dept/get/{id}")
    public Dept findById(@PathVariable("id") Long id);
    
    // 添加
    @GetMapping("/dept/add")
    public Boolean addDept(Dept dept);

    // 根据id查询
    @GetMapping("/dept/list")
    public List<Dept> findAll();
    
}

修改完成之后进行： mvn clean install

3、修改 microservicecloud-consumer-dept-feign 工程的 yml 配置文件

application.yml文件修改如下：

server:
  port: 80
  
feign: 
  hystrix:
    enabled: true
  
eureka:
  client:
    register-with-eureka: false 
    service-url: 
      defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/

4、测试

（1）、先启动3个eureka
（2）、在启动微服务：microservicecloud-provider-dept-8001
（3）、最后启动微服务：microservicecloud-consumer-dept-feign
（4）、正常访问：http:// localhost/consumer/dept/get/1
（5）、故意关掉微服务：microservicecloud-provider-dept-8001

（6）、再次访问 http:// localhost/consumer/dept/get/1，客户端自己调用提示

此时服务端privoder已经down了，但是我们做了服务降级处理，让客户端不可用时也会获得提示信息而不会挂起耗死服务器。

5、小结

【服务熔断】
一般是某个服务故障或者异常引起，类似现实世界中的“保险丝”，当某个异常条件被触发，直接熔断整个服务，而不是一直等到此服务超时导致系统资源大面积的被占用。
【服务降级】
所谓降级，一般是从整体负荷考虑。就是某个服务熔断之后，服务器将不再被调用，此时客户端可以自己准备一个本地的 fallback 回调，返回一个缺省值。这样做，虽然服务水平下降，但好歹可用，比直接挂掉要强。

四、服务监控 hystrixDashboard

1、概述

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

2、配置步骤

（1）、新建工程 microservicecloud-consumer-hystrix-dashboard

（2）、修改工程pom文件

pom.xml修改内容

    <!-- 引入hystrix和 hystrixDashboard相关 -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
    </dependency>

pom.xml全部内容

<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">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>cn.smilexl.springcloud</groupId>
        <artifactId>microservicecloud</artifactId>
        <version>0.0.1-SNAPSHOT</version>
    </parent>
    <artifactId>microservicecloud-consumer-hystrix-dashboard</artifactId>
    
    <dependencies>
        <dependency><!-- 自己定义的api -->
            <groupId>cn.smilexl.springcloud</groupId>
            <artifactId>microservicecloud-api</artifactId>
            <version>${project.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- Ribbon相关 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
        </dependency>
        <!-- feign相关 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
        <!-- 引入hystrix和 hystrixDashboard相关 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <!-- 修改后立即生效，热部署 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <optional>true</optional>
        </dependency>
    </dependencies>
</project>

（3）、修改工程yml配置文件

application.yml文件

server:
  port: 9001  

eureka:
  client:
    registerWithEureka: false   
    fetchRegistry: false

（4）、新建主启动类 DeptConsumer_HystrixDashboard_App.java 并添加注解@EnableHystrixDashboard

package cn.smilexl.springcloud;

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

@SpringBootApplication
//@EnableCircuitBreaker
@EnableHystrixDashboard //开启仪表盘
public class DeptConsumer_HystrixDashboard_App {

    public static void main(String[] args) {
        
        SpringApplication.run(DeptConsumer_HystrixDashboard_App.class, args);
    }
}

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

  <!-- actuator监控信息完善 -->
  <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-actuator</artifactId>
  </dependency>

（6）、在工程microservicecloud-provider-dept-hystrix-8001主启动类中添加服务监控配置

注意：如果没有此配置下面打开的http:// localhost:9001/hystrix中查看的监控数据将会连接不上，打开的 http:// localhost:8001/hystrix.stream 将会报404。

package cn.smilexl.springcloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.context.annotation.Bean;
import com.netflix.hystrix.contrib.metrics.eventstream.HystrixMetricsStreamServlet;

@SpringBootApplication
//@EnableDiscoveryClient //服务发现
@EnableCircuitBreaker //对hystrix熔断机制的支持
public class DeptProvider8001_hystrix_App {

    public static void main(String[] args) {
        
        SpringApplication.run(DeptProvider8001_hystrix_App.class, args);    
    }
    
     // 此配置是为了服务监控而配置，与服务容错本身无关，
     // ServletRegistrationBean因为springboot的默认路径不是"/hystrix.stream"，
     // 只要在自己的项目里配置上下面的servlet就可以了
     @Bean
      public ServletRegistrationBean<HystrixMetricsStreamServlet> getServlet() {
        HystrixMetricsStreamServlet streamServlet = new HystrixMetricsStreamServlet();
        ServletRegistrationBean<HystrixMetricsStreamServlet> registrationBean = new ServletRegistrationBean<>(streamServlet);
        registrationBean.setLoadOnStartup(1);//系统启动时加载顺序
        registrationBean.addUrlMappings("/hystrix.stream");//路径
        registrationBean.setName("HystrixMetricsStreamServlet");
        return registrationBean;
      }
}

（7）、启动相关工程

先启动3个eureka集群

在启动：microservicecloud-provider-dept-hystrix-8001

接着启动：microservicecloud-consumer-hystrix-dashboard

先测试数据8001是否以通：http://localhost:8001/dept/get/1

打开仪表盘界面：http://localhost:9001/hystrix

检查数据是否以通：http://localhost:8001/hystrix.stream

（8）、监控测试

多次刷新 http://localhost:8001/dept/get/1

观察检测窗口
|--- 填写监控地址

|--- 监控结果

|--- 如何看？
|--- 7色
|--- 1圈：实心圆，共有两种含义。它通过颜色的变化代表了实例的健康程度，它的健康度：绿色<黄色<橙色<红色递减。
该实心圆除了颜色的变化之外，它的大小也会根据实例的请求流量发生变化，流量越大该实心圆就越大。所以通过该实心圆的展示，就可以在大量的实例中快速的发现**故障实例和高压实例。
|--- 1线：曲线用来记录2分钟内流量的相对变化，可以通过它来观察到流量的上升和下降趋势。
|--- 整图说明：

|--- 搞懂一个才能看懂复杂的：

最后编辑于：2019.07.28 10:35:32

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 204,053评论 6赞 478
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 85,527评论 2赞 381
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 150,779评论 0赞 337
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 54,685评论 1赞 276
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 63,699评论 5赞 366
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 48,609评论 1赞 281
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 37,989评论 3赞 396
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 36,654评论 0赞 258
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 40,890评论 1赞 298
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 35,634评论 2赞 321
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 37,716评论 1赞 330
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 33,394评论 4赞 319
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 38,976评论 3赞 307
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 29,950评论 0赞 19
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 31,191评论 1赞 260
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 44,849评论 2赞 349
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 42,458评论 2赞 342

《七》、springcloud微服务——Hystrix断路器

一、概述

1、分布式面临的问题

2、服务雪崩

3、是什么？

4、能干吗？

二、服务熔断

1、是什么？

2、参考microservicecloud-provider-dept-8001新建microservicecloud-provider-dept-hystrix-8001

（1）、pom.xml文件

（2）、application.yml文件

（3）、将启动类修改为：DeptProvider8001_hystrix_App.java

（4）、修改 DeptController.java

（5）、测试

3、存在的问题

三、服务降级

1、是什么？

2、修改microservicecloud-api工程

（1）、根据已经有的 DeptClientService.java 接口，新建一个实现了 FallbackFactory接口的类DeptClientServiceFallbackFactory

（2）、在DeptClientService接口上的注解@FeignClient中添加 fallbackFactory 属性值

3、修改 microservicecloud-consumer-dept-feign 工程的 yml 配置文件

4、测试

5、小结

四、服务监控 hystrixDashboard

1、概述

2、配置步骤

（1）、新建工程 microservicecloud-consumer-hystrix-dashboard

（2）、修改工程pom文件

（3）、修改工程yml配置文件

（4）、新建主启动类 DeptConsumer_HystrixDashboard_App.java 并添加注解@EnableHystrixDashboard

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

（6）、在工程microservicecloud-provider-dept-hystrix-8001主启动类中添加服务监控配置

（7）、启动相关工程

（8）、监控测试

推荐阅读更多精彩内容