SpringCloud学到刚好够用之五-断路器（Hystrix）

爱被打了一巴掌 2022-02-15 21:25 311阅读 0赞

# SpringCloud学到刚好够用之四-断路器（Hystrix） #

### 文章目录 ###

*  SpringCloud学到刚好够用之四-断路器（Hystrix）
 *   *  总览
     *  看的不过瘾
     *   *  进阶使用
         *  源码分析
     *  简介
     *  准备活动
     *  断路器（Hystrix）
     *   *  主要步骤
         *   *  pom文件引入包spring-cloud-starter-netflix-hystrix
             *  配置文件，端口8766，添加feign:hystrix:enabled: true
             *  启动类注解EnableFeignClients
             *  \*\*FeignClient添加注解fallback =PointHiServiceHystric.class\*\*
             *  \*\*写一个一个PointHiServiceHystric类，用来处理服务断路的逻辑\*\*
         *  上述步骤关键代码及图片
     *  测试：分别请求hystrix（开启hi服务，关闭hi服务）
     *   *  主要步骤
         *   *  运行eureka，hi服务1，Hystrix服务
             *  打开eureka面板查看服务数
             *  访问http://localhost:8766/hi?name=lizhao
             *  关闭hi服务访问http://localhost:8766/hi?name=lizhao
         *  上述步骤关键代码及图片
     *  总结
     *  广告时间

## 总览 ##

spring cloud相关技术栈在现在各个互联网公司的普及率已经很高了，这次去面试，基本面试官都有提到这一块，但是有没有实际接触过，只能遗憾的摇摇头。这里记录下学习过程，将一些踩坑的经验写出来，供大家参考。这个系列只会写到很浅的一部分，如有兴趣深入，可以看"这个系列"，将会给大家一个方向哈

基于SpringCloud的Greenwich.SR1，Jdk11，Maven，Idea开发

## 看的不过瘾 ##

### 进阶使用 ###

### 源码分析 ###

## 简介 ##

在一个分布式系统里，许多依赖不可避免的会调用失败，比如超时、异常等，如何能够保证在一个依赖出问题的情况下，不会导致整体服务失败，这个就是Hystrix需要做的事情。Hystrix提供了熔断、隔离、Fallback、cache、监控等功能，能够在一个、或多个依赖同时出现问题时保证系统依然可用。

在微服务架构中，根据业务来拆分成一个个的服务，服务与服务之间可以相互调用（RPC），在Spring Cloud可以用RestTemplate+Ribbon和Feign来调用。为了保证其高可用，单个服务通常会集群部署。由于网络原因或者自身的原因，服务并不能保证100%可用，如果单个服务出现问题，调用这个服务就会出现线程阻塞，此时若有大量的请求涌入，Servlet容器的线程资源会被消耗完毕，导致服务瘫痪。服务与服务之间的依赖性，故障会传播，会对整个微服务系统造成灾难性的严重后果，这就是服务故障的“雪崩”效应。
    
    为了解决这个问题，业界提出了断路器模型。
    
    一、断路器简介
    Netflix has created a library called Hystrix that implements the circuit breaker pattern. In a microservice architecture it is common to have multiple layers of service calls.
    
    . ----摘自官网
    
    Netflix开源了Hystrix组件，实现了断路器模式，SpringCloud对这一组件进行了整合。 在微服务架构中，一个请求需要调用多个服务是非常常见的，如下图：
    
    
    
    较底层的服务如果出现故障，会导致连锁故障。当对特定的服务的调用的不可用达到一个阀值（Hystric 是5秒20次） 断路器将会被打开。
    
    
    
    断路打开后，可用避免连锁故障，fallback方法可以直接返回一个固定值。
    --------------------- 
    作者：方志朋 
    来源：CSDN 
    原文：https://blog.csdn.net/forezp/article/details/69934399 
    版权声明：本文为博主原创文章，转载请附上博文链接！

## 准备活动 ##

1.  eureka
2.  一个hi服务
3.  一个hystrix，对标feign，在pro004-feign的基础上添加新内容

## 断路器（Hystrix） ##

### 主要步骤 ###

#### pom文件引入包spring-cloud-starter-netflix-hystrix ####

#### 配置文件，端口8766，添加feign:hystrix:enabled: true ####

#### 启动类注解EnableFeignClients ####

#### **FeignClient添加注解fallback =PointHiServiceHystric.class** ####

#### **写一个一个PointHiServiceHystric类，用来处理服务断路的逻辑** ####

### 上述步骤关键代码及图片 ###

1.  pom文件引入包spring-cloud-starter-netflix-hystrix

<?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">
      <modelVersion>4.0.0</modelVersion>
      <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.4.RELEASE</version>
        <relativePath/> 
      </parent>
      <groupId>com.lizhaoblog.scl</groupId>
      <artifactId>pro005-hystrix</artifactId>
      <version>0.0.1-SNAPSHOT</version>
      <name>pro005-hystrix</name>
      <description>Hystrix project for Spring Boot</description>
    
      <properties>
        <java.version>11</java.version>
        <spring-cloud.version>Greenwich.SR1</spring-cloud.version>
      </properties>
    
      <dependencies>
        <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-hystrix</artifactId>
        </dependency>
        <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-openfeign</artifactId>
        </dependency>
    
        <dependency>
          <groupId>org.springframework.cloud</groupId>
          <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
        </dependency>
        <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-test</artifactId>
          <scope>test</scope>
        </dependency>
      </dependencies>
    
      <dependencyManagement>
        <dependencies>
          <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>${spring-cloud.version}</version>
            <type>pom</type>
            <scope>import</scope>
          </dependency>
        </dependencies>
      </dependencyManagement>
    
      <build>
        <plugins>
          <plugin>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
          </plugin>
        </plugins>
      </build>
    
    </project>

1.  配置文件，端口8766，添加feign:hystrix:enabled: true

eureka:
      client:
        serviceUrl:
          defaultZone: http://localhost:8761/eureka/
    server:
      port: 8766
    spring:
      application:
        name: service-hystrix
    feign:
      hystrix:
        enabled: true

1.  启动类注解EnableFeignClients

package com.lizhaoblog.scl.pro005hystrix;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    import org.springframework.cloud.openfeign.EnableFeignClients;
    
    @SpringBootApplication
    @EnableDiscoveryClient
    @EnableFeignClients
    public class Pro005HystrixApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(Pro005HystrixApplication.class, args);
        }
    
    }

1.  **FeignClient添加注解fallback =PointHiServiceHystric.class**

/*
     * Copyright (C), 2015-2019
     * FileName: PointHiService
     * Author:   zhao
     * Date:     2019/4/20 22:01
     * Description: feign请求hi接口
     * History:
     * <author>          <time>          <version>          <desc>
     * 作者姓名           修改时间           版本号              描述
     */
    package com.lizhaoblog.scl.pro005hystrix.service;
    
    import com.lizhaoblog.scl.pro005hystrix.hystric.PointHiServiceHystric;
    
    import org.springframework.cloud.openfeign.FeignClient;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestMethod;
    import org.springframework.web.bind.annotation.RequestParam;
    
    /**
     * 〈一句话功能简述〉<br>
     * 〈feign请求hi接口〉
     *
     * @author zhao
     * @date 2019/4/20 22:01
     * @since 1.0.0
     */
    @FeignClient(value = "service-hi",fallback = PointHiServiceHystric.class)
    public interface PointHiService {
        @RequestMapping(value = "/hi", method = RequestMethod.GET)
        String sayHiFromClientOne(@RequestParam(value = "name") String name);
    }

1.  **写一个一个PointHiServiceHystric类，用来处理服务断路的逻辑**

/*
     * Copyright (C), 2015-2019
     * FileName: PointHiServiceHystric
     * Author:   zhao
     * Date:     2019/4/20 23:36
     * Description: 断路器Hystric处理类
     * History:
     * <author>          <time>          <version>          <desc>
     * 作者姓名           修改时间           版本号              描述
     */
    package com.lizhaoblog.scl.pro005hystrix.hystric;
    
    import com.lizhaoblog.scl.pro005hystrix.service.PointHiService;
    
    import org.springframework.stereotype.Component;
    
    /**
     * 〈一句话功能简述〉<br>
     * 〈断路器Hystric处理类〉
     *
     * @author zhao
     * @date 2019/4/20 23:36
     * @since 1.0.0
     */
    @Component
    public class PointHiServiceHystric implements PointHiService {
        @Override
        public String sayHiFromClientOne(String name) {
            return "PointHiServiceHystric:sorry " + name;
        }
    }

## 测试：分别请求hystrix（开启hi服务，关闭hi服务） ##

### 主要步骤 ###

#### 运行eureka，hi服务1，Hystrix服务 ####

#### 打开eureka面板查看服务数 ####

#### 访问http://localhost:8766/hi?name=lizhao ####

#### 关闭hi服务访问http://localhost:8766/hi?name=lizhao ####

### 上述步骤关键代码及图片 ###

1.  访问http://localhost:8766/hi?name=lizhao

hi lizhao,i am from port:8762

1.  关闭hi服务访问http://localhost:8766/hi?name=lizhao

PointHiServiceHystric:sorry lizhao

## 总结 ##

## 广告时间 ##

我是小王，一个喜欢抛转的码人。

*  所有代码都在这里：[https://gitee.com/lizhaoandroid/spring-cloud-learning][https_gitee.com_lizhaoandroid_spring-cloud-learning]
 *  本片对应的章节：pro005-hystrix
 *  我的csdn：[https://lizhao.blog.csdn.net][https_lizhao.blog.csdn.net]
 *  我的联系方式：QQ3060507060
 *  我的公众号：lizhaoblog、小王老店
 *  我的银行卡及密码：\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\***/**

[https_gitee.com_lizhaoandroid_spring-cloud-learning]: https://gitee.com/lizhaoandroid/spring-cloud-learning
[https_lizhao.blog.csdn.net]: https://lizhao.blog.csdn.net