SpringCloud断路器

news2024/11/24 8:36:31

SpringCloud断路器

Hystrix

简介

img

hystrix对应的中文名字是“豪猪”，豪猪周身长满了刺，能保护自己不受天敌的伤害，代表了一种防御机制。

这与hystrix本身的功能不谋而合，因此Netflix团队将该框架命名为Hystrix，并使用了对应的卡通形象做作为logo。

在一个分布式系统里，许多依赖不可避免的会调用失败，比如超时、异常等，如何能够保证在一个依赖出问题的情况下，不会导致整体服务失败，这个就是Hystrix需要做的事情。

Hystrix提供了熔断、隔离、Fallback、cache、监控等功能，能够在一个、或多个依赖同时出现问题时保证系统依然可用

什么是断路器

在这里插入图片描述

Hystrix重要概念

服务降级

简单来说,就是对方系统不可用了,你需要给我一个兜底的解决方法

服务降级是指在系统负载过高或者出现异常情况时，通过减少或关闭某些服务功能，来保证系统的稳定性和可用性。服务降级可以有效地避免系统崩溃或者无法响应的情况，同时也可以保证系统的核心功能能够正常运行。在实际应用中，服务降级通常是通过设置优先级、限流、熔断等方式来实现的。

哪些情况会触发降级:

  • 程序运行异常
  • 超时
  • 服务熔断
  • 线程池/信号量打满

服务熔断

服务熔断是一种微服务架构中的容错机制，用于保护系统免受服务故障的影响。当一个服务出现故障或响应时间过长时，熔断器会自动断开该服务的调用，并返回一个预设的错误响应，从而避免请求在该服务上长时间阻塞。这样可以减少系统的响应时间和资源消耗，同时也可以防止故障服务的连锁反应，提高系统的可用性和稳定性。服务熔断通常与服务注册与发现、负载均衡等技术一起使用，是构建高可用、弹性和可靠的分布式系统的重要手段之一。

类比保险丝达到最大服务访问后,直接拒绝访问,拉闸限电,让后调用服务降级的方法并返回友好提示

服务限流

秒杀高并发等操作,严禁一窝蜂的过来拥挤,大家排队,一秒钟N个,有序进行

服务限流是一种控制系统或应用程序流量的技术，它可以限制系统或应用程序接受的请求数量，以避免系统或应用程序过载或崩溃。服务限流通常用于保护系统或应用程序免受恶意攻击或过度使用的影响。它可以通过限制每个用户的请求速率、限制每个IP地址的请求速率或限制整个系统的请求速率来实现。服务限流可以帮助系统或应用程序更好地处理高负载情况，提高系统的可用性和稳定性。

分布式系统面临的问题

服务雪崩
在这里插入图片描述

Hystrix案例实战!

新建项目cloud-provider-hystrix-payment8003

引入依赖

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>

修改yml文件

server:
  port: 8003

spring:
  application:
    name: cloud-provider-hystrix-payment
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://127.0.0.1:3306/db2019?characterEncoding=utf8&useSSL=false&serverTimezone=UTC
    username: root
    password: 123456

mybatis:
  mapper-locations: classpath:mapper/*.xml
  type-aliases-package: com.atguigu.springcloud.entities



eureka:
  client:
    register-with-eureka: true
    fetch-registry: true
    service-url:
      defaultZone: http://localhost:7001/eureka

eureka客户端,启动!

Hystrix,启动!

在这里插入图片描述

==

在这里插入图片描述

==

在这里插入图片描述

没有问题,启动成功

新建moudle

cloud-consumer-feign-hystrix-order80

pom:

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

<dependency>
    <groupId>org.mybatis.spring.boot</groupId>
    <artifactId>mybatis-spring-boot-starter</artifactId>
</dependency>

yml:

server:
  port: 8005

eureka:
  client:
    register-with-eureka: false
    service-url:
      defaultZone: http://localhost:7001/eureka


spring:
  main:
    #允许存在多个Feign调用相同Service的接口
    allow-bean-definition-overriding: true

服务降级

@HystrixCommand

设置自身调用超时时间的峰值,峰值内可以正常运行,超过了需要有兜底的方法处理,作服务降级fallback

不要忘了主启动类加上注解: @EnableHystrix

在这里插入图片描述

超过了3s,直接返回我们定义的页面

在这里插入图片描述

当我们在程序中间加入: int age = 10/0

系统就不会等待3s,而是直接输出错误页面

客户端开启服务降级

yml:

feign:
  hystrix:
    enabled: true

客户端代码:

在这里插入图片描述

全局服务降级DefaultProperties

目前的问题:每个业务方法都有对应的一个兜底的方法–代码膨胀

第一步:在类上添加注解

在这里插入图片描述

第二步:在方法上写注解

在这里插入图片描述

这样解决了代码膨胀的问题

服务熔断

熔断机制概述:

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

当扇出链路的某个微服务出错或响应时间过长时,会进行服务降级,进而熔断该节点微服务的调用,快速返回错误的响应信息

而当检测该节点微服务调用响应正常的时候,就应当恢复调用链路

Spring Cloud框架里,熔断机制通过Hystrix实现 其会监控微服务之间的调用情况

比如出现5s内20次失败调用,就会触发熔断机制

熔断机制的注解是@HystrixCommand

 //这里是服务熔断的相关代码
    @HystrixCommand(fallbackMethod = "paymentCircuitBreaker_fallback",commandProperties = {
            @HystrixProperty(name = "circuitBreaker.enabled",value = "true"),//是否开启断路器?开启
            @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold",value = "10"),//置Hystrix熔断器的请求阈值为10，即当在一个统计窗口内处理的请求总数达到10个时，才会触发熔断器的开启操作。
            @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliSeconds",value = "10000"),//表示在熔断器打开后，等待多长时间后尝试再次请求服务。这里设置的是10秒。
            @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage",value = "60")//失败率达到多少跳闸
    })

在这里插入图片描述

//这里是服务熔断的相关代码
    @HystrixCommand(fallbackMethod = "paymentCircuitBreaker_fallback",commandProperties = {
            @HystrixProperty(name = "circuitBreaker.enabled",value = "true"),//是否开启断路器?开启
            @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold",value = "10"),//置Hystrix熔断器的请求阈值为10，即当在一个统计窗口内处理的请求总数达到10个时，才会触发熔断器的开启操作。
            @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds",value = "10000"),//表示在熔断器打开后，等待多长时间后尝试再次请求服务。这里设置的是10秒。
            @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage",value = "60")//失败率达到多少跳闸
    })
    @GetMapping("/consumer/circuit/{id}")
    public String paymentCircuitBreaker(@PathVariable("id") Integer id){
        if (id < 0){
            throw new RuntimeException("id不能为负数!");
        }
        String serialNumber = String.valueOf(UUID.randomUUID());
        return "gg";
    }

    public String paymentCircuitBreaker_fallback(@PathVariable("id") Integer id){
        return "id不能为负数,请重试";
    }

对于上述代码,如果我们在浏览器输入的id为负数,多次刷新浏览器,就会触发服务熔断,因为失败次数过多,这个时候,在熔断器时间窗口期内,即使我们输入的id为正数,也会输出fallback页面,直到时间窗口期外,熔断器进入半熔断状态,正确访问才会显示页面gg

在这里插入图片描述

服务监控hystrixDashboard

新建模块cloud-consumer-hystrix-dashboard9001

依赖:

<dependencies>

    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
    </dependency>

    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
    </dependency>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>

    <dependency>
        <groupId>org.mybatis.spring.boot</groupId>
        <artifactId>mybatis-spring-boot-starter</artifactId>
    </dependency>


    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <optional>true</optional>
    </dependency>

    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
    </dependency>



</dependencies>

yml:

server:
  port: 9001

spring:
  application:
    name: cloud-monitor-hystrix
  datasource:
    url: jdbc:mysql://127.0.0.1:3306/db2019?characterEncoding=utf8&useSSL=false&serverTimezone=UTC
    username: root
    password: 123456
    driver-class-name: com.mysql.cj.jdbc.Driver

启动类:

package com.atguigu.springcloud;

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

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

浏览器输入:

在这里插入图片描述

接着,我们在熔断器类(端口号8005)启动类下写代码:

@Bean
public ServletRegistrationBean getServlet(){
    HystrixMetricsStreamServlet streamServlet = new HystrixMetricsStreamServlet();
    ServletRegistrationBean registrationBean = new ServletRegistrationBean(streamServlet);
    registrationBean.setLoadOnStartup(1);
    registrationBean.addUrlMappings("/hystrix.stream");
    registrationBean.setName("HystrixMetricsStreamServlet");
    return registrationBean;
}

在这里插入图片描述

==

很好玩

在这里插入图片描述

==

在这里插入图片描述

技术这条路,道阻且长~~~

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/616962.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

2023最详细的接口测试用例设计教程，详细文档等你来拿

2023最详细的接口测试用例设计教程，详细文档等你来拿

目录 一、接口测试流程 二、分析接口文档元素 三、如何设计接口测试用例 四、常用的接口测试用例覆盖方法 五、接口测试接口优先级 六、接口测试的设计思路分析 七、接口测试返回结果的比较 一、接口测试流程 1、需求讨论 2、需求评审 3、场景设计 4、数据准备 5、测试执…
阅读更多...
sdf与timingCheck和后仿真

sdf与timingCheck和后仿真

目录 1.Distributed delays 2.specify--endspecify 1.1 specify内部语法 2.sdf 2.1 sdf的格式 3.timingCheck和网表后仿真 4.关于负值delay sdf和 module 里面的specify--endspecify都可以对路径延时进行赋值和检查&#xff1b;HDL语言中的‘#()’也可以描述延时【叫做D…
阅读更多...
没事千万别动生产服数据库 - 来自小菜鸟的忠告

没事千万别动生产服数据库 - 来自小菜鸟的忠告

阿里云官方参考文档 目录 背景一、环境部署二、目录规划三、操作步骤FAQ 背景 今天把一张 5500 多万条记录的表进行按年度拆分&#xff0c;本来打算将表数据拆分为 2020 年、2021 年、2022 年三张新表&#xff0c;提升原表查询效率&#xff0c;仅保留 2023 年数据。表拆分完毕…
阅读更多...
【SpinalHDL快速入门】4.1、基本类型之Bool

【SpinalHDL快速入门】4.1、基本类型之Bool

Tips1&#xff1a; 由于SpinalHDL是基于Scala构建的&#xff0c;Scala本身自带类似变量Boolean&#xff0c;故在此要认准SpinalHDL中采用的是Bool而非Boolean&#xff1a; Bool&#xff08;大写的True和False&#xff09;&#xff1a;True表示1&#xff0c;False表示0Boolean&…
阅读更多...
Vue3搭建

Vue3搭建

Vue3项目搭建全过程 vue create 项目名 选择手动吗&#xff0c;自定义安装 选择vue3 是否选择class风格组件 选择ts处理工具和css预处理器 Y 是否使用router的history模式 Y 选择css预处理语言 ;less 9.选择lint的检查规范 只使用EsLint官网推荐规范 使用EsLint官网推荐规…
阅读更多...
MyBatis-plus(1)

MyBatis-plus(1)

基本概念: 一)开发效率也就是我们使用这款框架开发的速度快不快&#xff0c;是否简单好用易上手。从这个角度思考&#xff0c;每当我们需要编写一个SQL需求的时候&#xff0c;我们需要做几步 1)Mapper接口提供一个抽象方法 2)Mapper接口对应的映射配置文件提供对应的标签和SQL语…
阅读更多...
论文笔记--LLaMA: Open and Efficient Foundation Language Models

论文笔记--LLaMA: Open and Efficient Foundation Language Models

论文笔记--LLaMA: Open and Efficient Foundation Language Models 1. 文章简介2. 文章概括3 文章重点技术3.1 数据集3.2 模型训练 4. 数值实验5. 文章亮点6. 原文传送门7. References 1. 文章简介 标题&#xff1a;LLaMA: Open and Efficient Foundation Language Models作者…
阅读更多...
【自动化测试】--JUnit5

【自动化测试】--JUnit5

前言 小亭子正在努力的学习编程&#xff0c;接下来将开启软件测试的学习~~ 分享的文章都是学习的笔记和感悟&#xff0c;如有不妥之处希望大佬们批评指正~~ 同时如果本文对你有帮助的话&#xff0c;烦请点赞关注支持一波, 感激不尽~~ 目录 前言 Junit5简介 什么是Junit5 JU…
阅读更多...
tomcat和undertow、jetty、netty的区别

tomcat和undertow、jetty、netty的区别

记录一下&#xff0c;最近发现的几个容器的区别 tomcat简介 Tomcat&#xff1a;免费开源&#xff0c;轻量级应用服务器&#xff0c;在中小型系统和并发访问用户不是很多的场合下被普遍使用&#xff0c;是开发和调试JSP 程序的首选。实际上Tomcat 部分是Apache 服务器的扩展&am…
阅读更多...
十年历程：下定决心转向自动化测试/开发

十年历程：下定决心转向自动化测试/开发

目录 前言&#xff1a; 十年测试心路历程&#xff1a; 放弃了年薪二十万的offer&#xff0c;挑战自动化测试&#xff1a; 自动化测试心得&#xff1a; 自动化测试没用的误解&#xff1f; 关于测试开发 测试行业的现状 那么如何来全面的学习自动化测试呢&#xff1f; 前言&…
阅读更多...
4.2 synchronized 解决方案

4.2 synchronized 解决方案

4.2 synchronized 解决方案 1、应用之互斥2、synchronized3、思考4、面向对象改进 1、应用之互斥 为了避免临界区的竞态条件发生&#xff0c;有多种手段可以达到目的。 阻塞式的解决方案&#xff1a;synchronized&#xff0c;Lock非阻塞式的解决方案&#xff1a;原子变量 本…
阅读更多...
Linux网络基础 — 应用层

Linux网络基础 — 应用层

目录 应用层 再谈 "协议" 网络版计算器 HTTP协议 认识URL urlencode和urldecode HTTP协议格式 HTTP请求 HTTP响应 HTTP的方法 HTTP的状态码 HTTP常见Header 拓展知识&#xff08;了解&#xff09; 长链接 http周边会话保持 基本工具(http) 应用层 程序…
阅读更多...
MOS管电源开关电路的缓启动功能是怎么实现的

MOS管电源开关电路的缓启动功能是怎么实现的

先看一个电路&#xff1a; 其主要设计思路是使用MOS管来做一个开关&#xff0c;控制电源输出&#xff1b; 为什么选用MOS管&#xff1f; 这就涉及到MOS管的两个重要特性&#xff1a; 1.MOS管的导通电流大&#xff1b; 2.MOS管导通时内阻小&#xff0c;内部功耗低&#xff1b…
阅读更多...
Probit模型、Logit模型、IV-Probit模型、IV-Probit模型

Probit模型、Logit模型、IV-Probit模型、IV-Probit模型

概述 Y β 1 X 1 β 2 X 2 ϵ i Y\beta_1X_1\beta_2X_2\epsilon_i Yβ1​X1​β2​X2​ϵi​ 边际效应&#xff1a;就是系数&#xff0c;即 β 1 \beta_1 β1​ 、 β 2 \beta_2 β2​ 解释&#xff1a;如&#xff0c;在控制其他变量&#xff08;条件&#xff09;不变的情况…
阅读更多...
常用设计模式之单例模式

常用设计模式之单例模式

文章目录 饿汉式和懒汉式多线程中的懒汉式单例模式内存释放问题单例模式优缺点单例应用场景测试代码 饿汉式和懒汉式 单例模式是指在任何时候都保证只有一个类实例&#xff0c;并提供一个访问它的全局访问节点。 单例模式结构图&#xff1a; 解释&#xff1a;单例模式就是一…
阅读更多...
罗湖区田心村旧改确认实施主体的公示，华润集团开发

罗湖区田心村旧改确认实施主体的公示，华润集团开发

深圳市罗湖区城市更新和土地整备局发布关于罗湖区笋岗街道田心村改造项目一期子项目2&#xff08;1-14、1-16、1-17地块&#xff09;确认实施主体的公示。 田心村改造项目位于罗湖区笋岗街道田心村&#xff0c;2012年4月&#xff0c;深圳市城市规划委员会建筑与环境艺术委员会2…
阅读更多...
关于ElementPlus中的表单验证

关于ElementPlus中的表单验证

关于ElementPlus中表单的校验规则&#xff0c;官网文档已经给出了&#xff0c;但是没有说明性文字&#xff0c;所以我想来记录一下&#xff0c;给出一些文字说明 ElementPlus中的简单校验 ElementPlus的表单的一般结构是&#xff1a; <el-form><el-form-item>&l…
阅读更多...
（一）CSharp-Net框架

（一）CSharp-Net框架

.NET框架由三部分组成&#xff1a; 1.编程工具。 2.基类库(BCL). 3.公共语言运行库(CLR) CLR 在运行时管理程序的执行&#xff0c;包括以下内容&#xff1a; 内存管理和垃圾收集。代码安全验证。代码执行、线程管理及异常处理。 NET 框架的特点以及其带来的好处&#xff1a…
阅读更多...
web测试工程师的工作职责（合集）

web测试工程师的工作职责（合集）

web测试工程师的工作职责1 职责: 1、 负责数据平台产品的测试工作&#xff0c;参与产品需求分析&#xff0c;负责方案制定,并能预先评估项目风险&#xff0c;确保测试活动的顺利开展; 2、 深入理解系统内部的设计原理&#xff0c;并能从测试的角度提供优化意见; 3、 根据产品需…
阅读更多...
【Linux】多线程概念初讲

【Linux】多线程概念初讲

线程大章节第一篇文章 文章目录 前言一、linux线程基本概念二、线程与进程的对比 1.线程控制的接口总结 前言 什么是线程呢&#xff1f; 在一个程序里的一个执行路线就叫做线程&#xff08; thread &#xff09;。更准确的定义是&#xff1a;线程是 “ 一个进程内部的控制…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023