经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置:技术经验 » Java相关 » Java » 查看文章
【分布式】SpringCloud(6)--Hystrix服务熔断与降级
来源:cnblogs  作者:人无名,则可专心练剑  时间:2021/4/6 10:20:57  对本文有异议

1.Hystrix概述

1.1.什么是Hystrix

Hystrix是一个用于处理分布式系统的延迟和容错的开源库。Hystrix主要用于处理分布式系统中复杂多变的服务依赖调用失败、超时、异常等情况,保证一个服务依赖出问题的情况下,提供一个服务预期的、可处理的备选响应(FallBack),避免微服务整体级联故障,以提高分布式系统的弹性。

 

1.2.Hystrix的作用是什么

Hystrix旨在执行以下操作:

  • 提供保护并控制延迟和失败,以及通过第三方客户端库(通常是通过网络)访问依赖项导致的失败。
  • 切断复杂的分布式系统中的级联故障。
  • 快速响应并快速恢复。
  • 回退并在可能的情况下正常降级。
  • 启用近乎实时的监视,警报和操控。

 

1.3.Hystrix能解决什么问题

Hystrix在分布式项目中主要用于处理:

  • 服务降级
  • 服务熔断
  • 服务限流
  • 接近实时地监控

 

2.Hystrix服务熔断

2.1.服务熔断机制

首先对应服务熔断我们要理解“服务雪崩”的概念,服务雪崩是多个微服务之间调用的时候,假设微服务A调用微服务B和微服务C,微服务B和微服务C又调用其它的微服务,这就是所谓的“扇出”。如果扇出的链路上某个微服务的调用响应时间过长或者不可用,对微服务A的调用就会占用越来越多的系统资源,进而引起系统崩溃,就是所谓的“雪崩”。

熔断机制是应对雪崩效应的一种微服务链路保护机制

当扇出链路的某个微服务不可用或者响应时间太长时,就会通过熔断该节点微服务的调用,快速返回错误的响应信息。当检测到该节点微服务调用响应正常后恢复调用链路。

 

2.2.简单实现一个Hystrix熔断

在SpringCloud框架里熔断机制通过Hystrix实现。Hystrix会监控微服务间调用的状况,当失败的调用到一定阈值,缺省是5秒内20次调用失败就会启动熔断机制。熔断机制的注解是@HystrixCommand。

这里我们还是基于我们之前博客的微服务项目springcloud-provider-dept-8001 服务端 复制一份作为hystrix的微服务项目。

①添加hystrix pom.xml依赖包:

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

 

②修改application.yml配置,修改了实例名称:

server:
  port: 8001
##省略了数据库连接信息与mybatis配置

#eureka的配置,确定客户端服务注册到eureka服务列表内
eureka:
  client:
    service-url:
      #集群配置
      defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/
      #defaultZone: http://localhost:7001/eureka/
  instance:
    instance-id: springcloud-provider-dept-hystrix-8001  #修改eureka上默认的服务描述信息
    prefer-ip-address: true  #访问路径可以显示ip地址

 

③基于Controller层的调用方法通过id获取Dept用户来做异常判定:

@RestController
@RequestMapping("/dept")
public class DeptController {
    @Autowired
    private DeptService service;

    @GetMapping("/queryById/{id}")
    /*@HystrixCommand表示一旦调用服务方法失败并抛出了异常信息之后,
    会自动调用@HystrixCommand标注好的fallbackMethod中指定名称的方法*/
    @HystrixCommand(fallbackMethod = "processHystrixGet")
    public Dept queryById(@PathVariable("id") Long id){
        Dept dept = service.queryById(id);  //模拟当查询不到id或者id信息异常时返回错误异常的提示
        if(null == dept){
            throw new RuntimeException("id=>" + id + "不存在该用户,或者用户信息无法找到!");
        }
        return dept;
    };

    //熔断备选方法:异常回调信息显示
    public Dept processHystrixGet(@PathVariable("id") Long id){
        return new Dept()
                .setDeptno(id)
                .setDname("id=>" + id + "没有对应的信息,null--@Hystrix")
                .setDbSource("no this database in MySQL");
    }
}

 

④在主启动类上添加对hystrix的熔断机制的支持:

@SpringBootApplication
@EnableEurekaClient  //在服务启动后自动注册到eureka中
@EnableDiscoveryClient  //服务发现
@EnableCircuitBreaker  //启用对hystrix的熔断机制的支持
public class DeptProvider8001_Hystrix_App {
    public static void main(String[] args) {
        SpringApplication.run(DeptProvider8001_Hystrix_App.class, args);
    }
}

 

⑤启动Eureka客户端、Hystrix服务端进行访问验证:

访问正常存在的服务id,能返回正常数据:

 

访问异常不存在的id时,返回fallback方法中的信息:

 

 可以看出,当执行调用某个微服务发生异常时,Hystrix能通过自定义的fallbackMethod做异常的错误返回,快速进行异常熔断机制。

服务熔断是在服务运行的情况下,对于服务内部执行错误的异常情况的一种处理方式。

 

3.Hystrix服务降级

3.1.服务降级机制

服务降级是从网站整体的负载考虑,当某个服务在某一时间内承受大量的服务请求,而需要极大的资源消耗,需要关闭当前系统的某些服务,做资源的扩充。牺牲单个服务的运行,当再次访问这单个服务的时候,通过服务降级处理,返回给客户设定的默认缺省值

相当于弃军保帅,维护的是整个系统的可用性。

 

3.2.简单实现服务降级

服务降级这里从客户端进行实现。

(1)首先在springcloud-api中定义一个降级之后的回调函数类,实现FalllbackFactory接口,接口中实现了对应请求信息的异常处理方法:

@Component  //注意不要忘记添加,需要把类加载进Spring容器中才能获取到
public class DeptClientServiceFallbackFactory implements FallbackFactory<DeptClientService> {
    @Override
    public DeptClientService create(Throwable throwable) {
        return new DeptClientService() {
            @Override
            public boolean addDept(Dept dept) {
                return false;
            }

            @Override
            public Dept queryById(Long id) {
                return new Dept().setDeptno(id).setDname("该ID:" + id + "没有对应的信息,Consumer客户端提供的降级信息,此刻服务provider已经关闭").
                        setDbSource("no this database in MySQL");
            }

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

 

(2)对应api接口中使用fallabckFatory去指定调用的是哪个class实现类:

//value中对应服务提供方的名字
//服务降级:表示DeptClientService当前接口中任何一个方法出了问题:都去找DeptClientServiceFallbackFactory回调处理
@FeignClient(value = "SPRINGCLOUD-PROVIDER-DEPT", fallbackFactory = DeptClientServiceFallbackFactory.class)
@Component //注入到容器中
public interface DeptClientService {
    /**
     * 接口中的三个方法对应服务提供者的三个方法
     * 这里面的接口对应服务提供者的controller接口,名称必须一致,然后接口的Mapping映射url必须一致
     * @param dept
     * @return
     */

    @PostMapping("/dept/add")
    public boolean addDept(Dept dept);

    @GetMapping("/dept/queryById/{id}")
    public Dept queryById(@PathVariable("id") Long id);

    @GetMapping("/dept/queryAll")
    public List<Dept> queryAll();
}

 

(3)基于FeignClinet调用,则需要修改服务提供者中application.yml,开启feign中对hystrix的支持:

#开启降级feign.hystrix支持
feign:
  hystrix:
    enabled: true

 

(4)测试验证:

步骤:启动三个Eureka注册中心7001、7002、7003,启动provider-dept-8001作为服务提供者、启动consumer-dept-feign服务消费者:

可以看到服务提供者已经注册进去并正常运行:

 

 

通过客户端consumer-feign的81端口也能访问到对应的id数据:

 

(5)模拟服务熔断异常:

关闭服务提供方provider-dept-8001,同时访问81端口的数据请求:

 

 可以看到此时调用到了我们编写的fallbackFactory中的回调方法显示降级信息。

所以即使服务关闭之后,Hystrix的服务熔断机制也能避免大量重复无效访问带来的服务异常,能较好的提供客户体验。

 

本节涉及实例及相关代码已上传至github:

https://github.com/devyf/SpringCloud_Study/tree/main/springcloud_hello

原文链接:http://www.cnblogs.com/yif0118/p/14616744.html

 友情链接: NPS