Hystrix 概述与入门

Posted 2021-04-30 码上筑梦

约定

• 示例项目采用的是Maven父子工程模式，父工程见[]
  

• 示例中采用的Spring Boot版本为1.5.9.RELEASE

• 示例中采用的Spring Cloud版本为Edgware.RELEASE

Hystrix 概述

1

Hystrix是什么

在微服务架构下，单体系统会被拆分成很多个服务节点，各节点通过服务注册中心来进行关联，使用远程调用（RPC）方式进行方法调用。当某些服务出现网络、代码逻辑bug等问题造成某个请求出现延迟，而此时若请求量在不断增加，则会造成某些服务或整个系统瘫痪。这种情况理论上是一定不能发生的，但应用微服务化后，若不加措施，不可避免的会出现这种情况。

为解决这种问题，产生了 “断路器”服务保护机制。当系统某个服务服务出现故障，则快速返回一个错误，避免系统资源被占用。

同样的，Hystrix也是Netflix下断路器组件，Spring Cloud对其进行了封装，变成了Spring Cloud Hystrix。 Hystrix通过控制服务间的远程调用过程，从而提供服务降级、服务熔断、线程与信号隔离、请求缓存、请求合并、服务监控等功能。

使用Hystrix实现断路器

本节继续使用前面所创建的所有项目并部署到服务器启动。同时新增文档服务document-provider子项目，其做法同之前的子项目一样。

1

依赖

在此省略将子项目引入父工程，只贴出本项目依赖，重点关注spring-cloud-starter-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 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <!--继承父工程--> <parent> <groupId>top.learninghub</groupId> <artifactId>learninghub-parent</artifactId> <version>1.0.0.RELEASE</version> </parent>
 <!--GV参数在父模块定义--> <artifactId>document-provider</artifactId>
 <packaging>jar</packaging> <name>document-provider</name> <description>document_consumer_micro_service</description>
 <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <java.version>1.8</java.version> </properties>
  <dependencies>
 <!--eureka客户端--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka</artifactId> </dependency>
 <!--ribbon客户端负载均衡--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-ribbon</artifactId> </dependency>
 <!--配置中心客户端--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-config</artifactId> </dependency>
 <!--消息总线，用于获取配置中心更新配置等--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-bus-amqp</artifactId> </dependency>  <!--hystrix熔断器--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-hystrix</artifactId> </dependency> <!--mysql驱动--> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>5.0.4</version> </dependency> <!--druid链接池--> <dependency> <groupId>com.alibaba</groupId> <artifactId>druid</artifactId> <version>1.1.4</version> </dependency> <!--druid-启动器--> <dependency> <groupId>com.alibaba</groupId> <artifactId>druid-spring-boot-starter</artifactId> <version>1.1.10</version> </dependency>
 <!--集成mybatis--> <dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>1.3.2</version> </dependency>
 <!--lombok插件--> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <version>1.16.18</version> <!--<optional>true</optional>--> </dependency>
 <!--json --> <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.68</version> </dependency>
 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.springframework.security</groupId> <artifactId>spring-security-test</artifactId> <scope>test</scope> </dependency>  </dependencies>
 <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins>  </build></project>

2

配置文件

配置文件与前面项目基本类似，在此不贴出。

3

Java代码

（1）使用@EnableCircuitBreaker开启断路器

@EnableDiscoveryClient//开启Hystrix断路器，用于服务熔断、降级以及监控@EnableCircuitBreaker@SpringBootApplicationpublic class DocumentProviderApplication {
 public static void main(String[] args) { SpringApplication.run(DocumentProviderApplication.class, args); }
}

（2）使用@HystrixCommand注解并添加回调（服务降级）属性

小编将服务调用逻辑直接就放到文档服务的Controller层，下面方法会调用用户服务中的接口并获得数据。

@RestController@Slf4jpublic class DocumentController {     @HystrixCommand(fallbackMethod = "hystrixFallback_GET") @GetMapping("/getUserByHystrix/{id}") public String getUserByHystrix(@PathVariable("id") String id){ String s = restTemplate.getForObject("http://USER-PROVIDER/user/getUser/"+id, String.class);        log.info("返回结果是：{}",s); return s; }    //服务降级逻辑，需要注意方法参数要与上面方法一致，不然会报错    public String hystrixFallback_GET(String id){ return "请您稍后重试，感谢您的配合！"; }}

（3）对用户服务编写相关接口

@RestController@Slf4jpublic class UserController {    @GetMapping("/user/getUser/{id}")    public String getUser(@PathVariable("id") String id){ try { Thread.sleep(50);            //Thread.sleep(5000); } catch (InterruptedException e) { e.printStackTrace(); }finally { return "我是码上筑梦"; } }}

4

验证

（1）停止user-provider服务

（2）使用Thread.sleep()方法模拟服务调用超时

当用睡眠20ms时，响应结果如下：

当睡眠时间为5000ms，大于默认Hystrix超时时间或自定义超时时间，响应结果如下：

至此，我们学会了对接口服务简单的添加服务降级逻辑，达到了更好的保护我们的系统的目的。

—未完待续—