SpringCloud-05 Hystrix学习笔记

简介: SpringCloud-05 Hystrix学习笔记

@[Toc]

一、Hystrix简介

1、Hystrix是什么?

在这里插入图片描述
 流量高峰时,一个单节点的宕机或延迟,会迅速导致所有服务负载达到饱和。应用中任何一个可能通过网络访问其他服务的节点,都有可能成为造成潜在故障的来源。更严重的是,还可能导致服务之间的延迟增加,占用队列、线程等系统资源,从而导致多系统之间的级联故障
在这里插入图片描述

简单的说,当服务器依次请求A->P->H->I时,如果其中一个发生了故障,都有可能导致整个流程失败,或者降低整个流程的效率。

更严重的是,当网络请求是通过第三方的一个黑盒客户端来发起时,实现细节都被隐藏起来了,而且还可能频繁变动,这样发生问题时就很难监控和改动。如果这个第三方还是通过传递依赖的,主应用程序中根本没有显示地写出调用的代码,那就更难了。

  网络连接失败或者有延迟,服务将会产生故障或者响应变慢,最终反应成为一个 bug。

  所有上述表现出来的故障或延迟,都需要一套管理机制,将节点变得相对独立,这样任何一个单节点故障,都至少不会拖垮整个系统的可用性。
  所以Hystrix就是为了解决请求序列中请求出现问题的情况,核心原则就是丢车保帅,如果一个请求出现问题,常见的有两种方案:
  

  • 一种是按照原来的方案再来一次,这是有成功的可能的。
  • 一种是只是反馈给用户这个请求有问题,出故障的请求不会影响到序列中其他的请求。

2、Hystrix能干什么?

1、服务熔断
2、服务降级
3、数据监控

二、服务熔断

1、服务熔断简介

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

当扇出链路的某个微服务不可用或者响应时间太长时,会进行服务的降级,进而熔断该节点微服务的调用,快速返回错误的响应信息。检测到该节点微服务调用响应正常后恢复调用链路。在SpringCloud框架里熔断机制通过Hystrix实现。Hystrix会监控微服务间调用的状况,当失败的调用到一定阀值缺省是5秒内20次调用失败,就会启动熔断机制。熔断机制的注解是:@HystrixCommand。

服务熔断解决如下问题:

  • 当所依赖的对象不稳定时,能够起到快速失败的目的;
  • 快速失败后,能够根据一定的算法动态试探所依赖对象是否恢复。

2、配置pom.xml

首先新建一个module,和springcloud-provider-dept-8001一模一样(名字除外),修改一下application.yaml,一个是端口(也可以不改,最好修改一下,避免端口冲突),另一个是instance-id,这样在尤里卡中可以分辨出来。
需要引入hystrix的依赖,和feign一样,只是把feign换成hystrix

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

3、配置application.yaml

springcloud-provider-dept-8001一样,只需要修改一下端口号和instance-id

#端口号
server:
  port: 8001

#配置数据库
spring:
  datasource:
    url: jdbc:mysql:///dp80?serverTimezone=UTC
    username: root
    password: 200201203332
    driver-class-name: com.mysql.jdbc.Driver
  application:
    name: springcloud-provider-dept
debug: true

#配置Eureka的配置
eureka:
  client:
    service-url:
      defaultZone: http://localhost:7001/eureka/
  instance:
    instance-id: springcloud-provider-8001

info:  #autuator监控信息
  app.name: rainhey-springcloud
  company.name: www.rainhey.com

4、修改Controller

@HystrixCommand注解

用来处理服务熔断和服务降级,属性和方法可以点进去查看。
@HystrixCommand注解通常放到方法之上,当这个方法抛出异常的时候,系统不会立刻停止处理异常,而是先找Hystrix里面绑定的备用方法,然后去执行备用方法。
那么@HystrixCommand如何绑定备用方法呢?见下图
在这里插入图片描述
@HystrixCommand注释通过内部属性fallbackMethod绑定方法,具体步骤是@HystrixCommand(fallbackMethod = "备用方法名")

package com.you.Controller;


import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import com.you.mapper.DeptMapper;
import com.you.pojo.Dept;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

@RestController
@ResponseBody
@Component
public class DeptController {
    @Autowired
    DeptMapper deptMapper;

    @GetMapping("/dept/aDept/{id}")
    @HystrixCommand(fallbackMethod = "hystrixGetDeptOfId")
    public Dept getDeptOfId(@PathVariable("id") Long id)
    {
        System.out.println("进来了,id是:"+id);
        Dept dept = deptMapper.finaDeptOfId(id);
        if(dept==null)
        {
            throw new RuntimeException("id=>"+id+"不存在该用户,或者信息没有找到!");
        }
        return dept;
    }
    /* 备用方案 */
    public Dept hystrixGetDeptOfId(@PathVariable("id") Long id)
    {

            Dept dept = new Dept();
            dept.setDeptno(id);
            dept.setDeptname("id=>"+id+"不存在该用户,或信息没有找到!@Hystrix");
            dept.setDb_source("no info in datebase");
            System.out.println("dept的值是:"+dept);
            return dept;


    }

}

5、修改启动类

从前面的4篇文章里我们了解到,每次用到新的技术,启动类里都会增加一个新的注解,那么?Hystrix的注解是什么呢?@EnableCircuitBreaker,只要把这个注解加在主启动类上,那么主启动类就可以处理服务熔断了。
在这里插入图片描述

6、效果图

不开熔断机制
在这里插入图片描述
开了熔断机制
在这里插入图片描述

三、服务降级

1、什么是服务降级

服务降级是指 当服务器压力剧增的情况下,根据实际业务情况及流量,对一些服务和页面有策略的不处理,或换种简单的方式处理,从而释放服务器资源以保证核心业务正常运作或高效运作。说白了,就是尽可能的把系统资源让给优先级高的服务。
例如假设有三个服务器ABC,在某一段时间,访问A的用户特别多,导致A服务器快要崩溃了,这时候访问B、C的用户很少,那么我暂时先把B、C停掉,用来处理A。
服务降级主要用于什么场景呢?当整个微服务架构整体的负载超出了预设的上限阈值或即将到来的流量预计将会超过预设的阈值时,为了保证重要或基本的服务能正常运行,可以将一些 不重要 或 不紧急 的服务或任务进行服务的 延迟使用 或 暂停使用。

降级的方式可以根据业务来,可以延迟服务,比如延迟给用户增加积分,只是放到一个缓存中,等服务平稳之后再执行 ;或者在粒度范围内关闭服务,比如关闭相关文章的推荐。
在这里插入图片描述

2、DeptClientFailBackFactory类

springcloud-api模块下的service包中新建降级配置,DeptClientServiceFallBackFactory.java。同时实现其方法,他的返回类型就是我们写服务的接口

package com.you.service;

import com.you.pojo.Dept;
import feign.hystrix.FallbackFactory;
import org.springframework.stereotype.Component;
/*!!!降级!!!*/
@Component  //注册到容器里面去
public class DeptClientFailBackFactory implements FallbackFactory {
    @Override
    public DeptClientService create(Throwable throwable) {
        return new DeptClientService() {
            @Override
            public Dept getDeptOfId(Long id) {
                Dept dept = new Dept();
                dept.setDeptno(id);
                dept.setDeptname("id=>"+id+"没有对应的信息,客户端提供了降级的信息,这个服务现在被关闭了!");
                dept.setDb_source("没有数据");
                return dept;
            }
        };
    }
}

3、添加注解

在DeptClientService中指定降级配置:DeptClientServiceFallBackFactory

package com.you.service;

import com.you.pojo.Dept;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;

@Component
/*@FeignClient:value的值即为 服务的名字,fallbackFactory的值即为 实现FallbackFactory类的名字 */
@FeignClient(value = "SPRINGCLOUD-PROVIDER-DEPT",fallbackFactory = DeptClientFailBackFactory.class)
public interface DeptClientService {
    @GetMapping("/dept/aDept/{id}")
    public Dept getDeptOfId(@PathVariable("id") Long id);
}

4、修改application.yaml

为的是开启服务,但切记此处修改的application是springcloud-consumer-dept-feign下的application.yaml,添加如下代码

#开启降级 feign-hystrix
feign:
  hystrix:
    enabled: true

5、效果图

依次启动springcloud-eureka-7001springcloud-consumer-dept-feignspringcloud-provider-dept-8001,访问服务
正确打开服务
在这里插入图片描述
现在,停掉这个springcloud-provider-dept-8001,模拟服务降级中暂时关闭的一些端口。
8001端口的服务被停掉了,这时候刷新页面。
在这里插入图片描述
端口是可以访问的,只是显示了我们设计的文字
在这里插入图片描述

四、DashBorder

1、新建一个module

新建一个名为springcloud-consumer-hystrix-dashborder的module
在这里插入图片描述

2、pom.xml配置

将springcloud-provider-dept-8001的依赖如复制过来,并且增加上dashborder的依赖

 <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>com.you</groupId>
            <artifactId>springcloud-api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-thymeleaf</artifactId>
        </dependency>
        <!--引入Eureka的依赖-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka</artifactId>
            <version>1.4.6.RELEASE</version>
        </dependency>
        <!--引入ribbon-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-ribbon</artifactId>
            <version>1.4.6.RELEASE</version>
        </dependency>
        <!--引入DashBorder-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-hystrix-dashboard</artifactId>
            <version>1.4.6.RELEASE</version>
        </dependency>
        <!--引入hystrix依赖-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-hystrix</artifactId>
            <version>1.4.6.RELEASE</version>
        </dependency>
    </dependencies>

3、配置application.yml

只需要配置端口号

server:
  port: 9001

4、配置启动类

创建一个名为DeptConsumerDashBorder_9001的JAVA类

package com.you;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;

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

5、添加被监控的类

给springcloud-provider-dept-hystrix-8001模块下的主启动类添加如下代码,添加监控

package com.you;

import com.netflix.hystrix.contrib.metrics.eventstream.HystrixMetricsStreamServlet;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.context.annotation.Bean;


@SpringBootApplication
@EnableEurekaClient
@EnableDiscoveryClient
/*对熔断的支持*/
@EnableCircuitBreaker
public class DeptApplication_Hystrix_8001 {
    public static void main(String[] args) {
        SpringApplication.run(DeptApplication_Hystrix_8001.class,args);
    }
    @Bean
    public ServletRegistrationBean hystrixMetricsStreamServlet(){
        ServletRegistrationBean registrationBean = new ServletRegistrationBean(new HystrixMetricsStreamServlet());
        //访问该页面就是监控页面
        registrationBean.addUrlMappings("/actuator/hystrix.stream");
        return registrationBean;
    }
}

在这里插入图片描述

6、效果图

启动springcloud-eureka-7001springcloud-consumer-hystrix-dashborderspringcloud-provider-dept-hystrix-8001
在7001尤里卡界面,看到springcloud-provider-dept-hystrix-8001被注册进来。
在这里插入图片描述
访问8011,输入http://localhost:8011/dept/aDept/1我设置的端口号是8011),可以看到被成功访问。
在这里插入图片描述
访问http://localhost:8011/actuator/hystrix.stream,看到如下效果

在这里插入图片描述
访问9001,地址输入http://localhost:9001/hystrix,看到如下界面
在这里插入图片描述
将地址填入,http://localhost:8011/actuator/hystrix.stream
在这里插入图片描述
在这里插入图片描述

刷新这个界面,下面的图像会随之变化
在这里插入图片描述

在这里插入图片描述
在这里插入图片描述

相关文章
|
6月前
springCloud之服务降级熔断Hystrix、OpenFeign
springCloud之服务降级熔断Hystrix、OpenFeign
352 0
|
7月前
|
监控 Java API
Spring cloud Hystrix 、Dashboard、API(zuul)相关报错
Spring cloud Hystrix 、Dashboard、API(zuul)相关报错
66 2
|
3月前
|
XML 监控 Java
Spring Cloud全解析:熔断之Hystrix简介
Hystrix 是由 Netflix 开源的延迟和容错库,用于提高分布式系统的弹性。它通过断路器模式、资源隔离、服务降级及限流等机制防止服务雪崩。Hystrix 基于命令模式,通过 `HystrixCommand` 封装对外部依赖的调用逻辑。断路器能在依赖服务故障时快速返回备选响应,避免长时间等待。此外,Hystrix 还提供了监控功能,能够实时监控运行指标和配置变化。依赖管理方面,可通过 `@EnableHystrix` 启用 Hystrix 支持,并配置全局或局部的降级策略。结合 Feign 可实现客户端的服务降级。
182 23
|
3月前
|
Java 对象存储 开发者
故障隔离与容错处理:Hystrix在Spring Cloud和Netflix OSS中的应用
故障隔离与容错处理:Hystrix在Spring Cloud和Netflix OSS中的应用
57 3
|
6月前
|
监控 Java UED
Java一分钟之-Spring Cloud Netflix Hystrix:容错管理
【6月更文挑战第9天】Spring Cloud Hystrix是用于微服务容错管理的库,通过断路器模式防止服务雪崩。本文介绍了Hystrix的基本概念,如断路器、线程隔离和fallback机制,并展示了如何快速上手,包括添加依赖、启用注解和编写Hystrix命令。此外,还讨论了常见问题(如断路器打开、资源泄漏和不当的Fallback策略)及其解决方案。通过自定义Hystrix指标监控,可以进一步优化系统性能。理解Hystrix工作原理并适时调整配置,对于构建健壮的微服务至关重要。
209 3
|
6月前
|
监控 Java 微服务
Spring Cloud 之 Hystrix
Spring Cloud Hystrix 是一个用于处理分布式系统延迟和容错的库,防止雪崩效应。它作为断路器,当服务故障时通过监控短路,返回备用响应,保持系统弹性。主要功能包括服务降级和熔断:
|
6月前
|
监控
springCloud之Hystrix监控
springCloud之Hystrix监控
|
7月前
|
监控 Java 微服务
第八章 Spring Cloud 之 Hystrix
第八章 Spring Cloud 之 Hystrix
65 0
|
7月前
|
SpringCloudAlibaba 负载均衡 Java
【Springcloud Alibaba微服务分布式架构 | Spring Cloud】之学习笔记(目录大纲)
【Springcloud Alibaba微服务分布式架构 | Spring Cloud】之学习笔记(目录大纲)
177 1
|
7月前
Springcloud-ribbon和hystrix配置
Springcloud-ribbon和hystrix配置
46 0