SpringCloud组件之断路器Hystrix(hoxton版本)

青旅半醒 2023-02-21 09:31 18阅读 0赞

# 1.Hystrix 简介 #

在微服务架构中，根据业务来拆分成一个个的服务，服务与服务之间可以相互调用（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对这一组件进行了整合。 在微服务架构中，一个请求需要调用多个服务是非常常见的，如下图：

![format_png][]

较底层的服务如果出现故障，会导致连锁故障。当对特定的服务的调用的不可用达到一个阀值（Hystrix 是5秒20次） 断路器将会被打开。

![format_png 1][]

断路打开后，可用避免连锁故障，fallback方法可以直接返回一个固定值。

# 2.创建Hystrix调用演示工程 #

## 2.1 准备工作 ##

启动上篇中Eureka演示工程中Eureka Server与Eureka Client Provider服务

![format_png 2][]

## 2.2 创建一个服务消费者 ##

新建一个maven工程，取名为：spring-cloud-hystrix-demo,添加如下依赖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">
        <parent>
            <artifactId>spring-cloud-demo</artifactId>
            <groupId>com.hxmec</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>spring-cloud-hystrix-demo</artifactId>
    
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</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-hystrix</artifactId>
            </dependency>
        </dependencies>
    
    </project>

新建application.yml，增加下面的配置

server:
      port: 9004
    spring:
      application:
        name: hystrix-demo
    logging:
      pattern:
        console: '%d{yyyy-MM-dd HH:mm:ss.SSS} %-5level [%thread] %logger{15} - %msg%n'
    eureka:
      client:
        service-url:
          defaultZone: http://localhost:8888/eureka/
    #开启feign fallback
    feign:
      hystrix:
        enabled: true

创建一个启动类 HystrixDemoApplication，添加hystrix相关注解@EnableCircuitBreaker或者@EnableHystrix

@SpringBootApplication
    @EnableEurekaClient
    @EnableDiscoveryClient
    @EnableFeignClients
    @EnableCircuitBreaker
    public class HystrixDemoApplication {
        public static void main(String[] args) {
            SpringApplication.run(HystrixDemoApplication.class, args );
        }
    }

增加Fallback类，在Feign中使用断路器 有以下两种方式，我们使用第一种方式

*  @FeignClient.fallback = UserFeignFallback.class指定一个实现Feign接口的实现类。
 *  @FeignClient.fallbackFactory = UserFeignFactory.class指定一个实现FallbackFactory工厂接口类

@Component
    public class FeignServiceFallback implements FeignService {
    
        @Override
        public String feignTest(String name) {
            return "服务请求失败，请求参数为name:"+ name;
        }
    }

在Feign接口中配置Fallback类

@FeignClient(value = "eureka-client-provider",fallback = FeignServiceFallback.class)
    public interface FeignService {
    
        @RequestMapping(value = "/demo/feign",method = RequestMethod.GET)
        String feignTest(@RequestParam(value = "name") String name);
    
    }

编写Controller层测试接口

@RestController
    @RequestMapping("/feign")
    @AllArgsConstructor
    public class FeignClientController {
    
        private final FeignService feignService;
    
        @GetMapping(value = "/test1")
        public String feign(@RequestParam String name) {
            return feignService.feignTest(name);
        }
    
    }

启动项目，可以下Eureka中看到对应服务![format_png 3][]通过请求接口http://localhost:9004/feign/test1?name=Trazen ，可以看到正常返回![format_png 4][]停止服务提供者服务后，再次请求接口，会发现已经返回Fallback中定义的失败返回信息![format_png 5][]

# 3.项目git地址 #

[https://github.com/ty1972873004/spring-cloud-demo][https_github.com_ty1972873004_spring-cloud-demo]

[format_png]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly93d3cuc2hvd2RvYy5jYy9zZXJ2ZXIvYXBpL2NvbW1vbi92aXNpdGZpbGUvc2lnbi82ZGE5ZmM1ZDE5ZmU5NzQyOTA3NzRiODU4YTM2YzM3YQ?x-oss-process=image/format,png
[format_png 1]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly93d3cuc2hvd2RvYy5jYy9zZXJ2ZXIvYXBpL2NvbW1vbi92aXNpdGZpbGUvc2lnbi8xODAxOTQ0MjM4NzMxNDVlZGRiN2Y5YWMzZjA4NmY3MA?x-oss-process=image/format,png
[format_png 2]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly93d3cuc2hvd2RvYy5jYy9zZXJ2ZXIvYXBpL2NvbW1vbi92aXNpdGZpbGUvc2lnbi83YzljZDhmNWFiNzM5NWNiNjJjODIyN2NjMWI0NGYyZg?x-oss-process=image/format,png
[format_png 3]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly93d3cuc2hvd2RvYy5jYy9zZXJ2ZXIvYXBpL2NvbW1vbi92aXNpdGZpbGUvc2lnbi9kMzEyZDIxN2RhMDNlYzIyMDBmNTMwNjE2YzU3YzE1Ng?x-oss-process=image/format,png
[format_png 4]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly93d3cuc2hvd2RvYy5jYy9zZXJ2ZXIvYXBpL2NvbW1vbi92aXNpdGZpbGUvc2lnbi9lZWVmZjVmNTA1ODJiY2VjOGU0OWE0NGI1MDNiYzhiZA?x-oss-process=image/format,png
[format_png 5]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly93d3cuc2hvd2RvYy5jYy9zZXJ2ZXIvYXBpL2NvbW1vbi92aXNpdGZpbGUvc2lnbi80YTBkMzdkNDhlOTk0YWYzOTBkNDE0MGMxNjgzNGRlMw?x-oss-process=image/format,png
[https_github.com_ty1972873004_spring-cloud-demo]: https://github.com/ty1972873004/spring-cloud-demo