1.什么是Spring Cloud Hystrix？

Spring Cloud Hystrix 是一个用于处理分布式系统中故障的库。它实现了熔断器模式，可以防止由于故障服务的连锁反应而导致整个系统崩溃。Spring Cloud Hystrix 提供了丰富的功能，如熔断、降级、限流、缓存等，可以帮助开发人员更好地处理分布式系统中的故障。

2.原理

在使用 Spring Cloud Hystrix 时，通常会对服务进行监控，当服务出现故障时，熔断器会迅速断开与该服务的连接，从而防止该服务对整个系统造成影响。Hystrix 的原理可以简单分为以下几个步骤：

监控服务：Hystrix 会监控服务的调用情况，例如调用次数、成功率、响应时间等。
判断服务是否故障：Hystrix 会根据监控数据判断服务是否出现故障。例如，如果服务的响应时间超过了阈值，或者服务的成功率低于阈值，熔断器就会认为该服务出现了故障。
断开服务连接：当熔断器认为服务出现了故障时，它会迅速断开与该服务的连接，从而防止该服务对整个系统造成影响。
提供降级方案：当熔断器断开与服务的连接时，它会提供一个降级的方案，例如返回一个缓存的结果或者一个默认值。
定期重试：熔断器会定期重试与服务的连接，以检测服务是否已经恢复正常。

3.代码工程

实验目的

使用hystrix实现断路器功能

pom.xml

<?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>        <artifactId>springcloud-demo</artifactId>        <groupId>com.et</groupId>        <version>1.0-SNAPSHOT</version>    </parent>    <groupId>com.et</groupId>    <artifactId>hystrix</artifactId>    <version>1.0-SNAPSHOT</version>
    <properties>        <maven.compiler.source>8</maven.compiler.source>        <maven.compiler.target>8</maven.compiler.target>        <spring-cloud.version>Hoxton.SR9</spring-cloud.version>    </properties>    <dependencies>
        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-web</artifactId>        </dependency>
        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-autoconfigure</artifactId>        </dependency>        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-test</artifactId>            <scope>test</scope>        </dependency>        <dependency>            <groupId>org.springframework.cloud</groupId>            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>        </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>
</project>

controller

人为模拟超时异常，实现断路器功能，走默认的保护方法

package com.et.hystrix.controller;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty;import org.springframework.cloud.netflix.hystrix.EnableHystrix;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RestController;
import java.util.HashMap;import java.util.Map;
@RestControllerpublic class HelloWorldController {    @RequestMapping("/hello")    @HystrixCommand(fallbackMethod = "fallback_hello", commandProperties = {            @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "1000")    })    public Map<String, Object> showHelloWorld() throws InterruptedException {        Thread.sleep(3000);        Map<String, Object> map = new HashMap<>();        map.put("msg", "HelloWorld");        return map;    }
    private Map<String, Object> fallback_hello() {        Map<String, Object> map = new HashMap<>();        map.put("msg", "Request fails. It takes long time to response");        return map;    }}

DemoApplication.java

package com.et.hystrix;
import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.netflix.hystrix.EnableHystrix;

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

application.yaml

server:  port: 8088

以上只是一些关键代码，所有代码请参见下面代码仓库

代码仓库

https://github.com/Harries/springcloud-demo

4.测试

启动Spring Boot应用程序

验证断路器

访问

http://127.0.0.1:8088/hello

返回

{"msg":"Request fails. It takes long time to response"}

5.引用

https://cloud.spring.io/spring-cloud-netflix/multi/multi__circuit_breaker_hystrix_clients.html
http://www.liuhaihua.cn/archives/710755.html

ITPub博客

Spring Cloud Hystrix快速入门demo