Sentinel(三):Sentinel熔断降级

一、Sentinel熔断概念介绍

        官方文档网址:circuit-breaking | Sentinel

1、Sentinel熔断基本介绍

      除了流量控制以外,对调用链路中不稳定的资源进行熔断降级也是保障高可用的重要措

      施之一。一个服务常常会调用别的模块,可能是另外的一个远程服务、数据库,或者第

      三方 API 等。

      例如,支付的时候,可能需要远程调用银联提供的 API;查询某个商品的价格,可能需要

      进行数据库查询。然而,这些被依赖服务的稳定性是不能保证的。如果依赖的服务出现了

      不稳定的情况,请求的响应时间变长,那么调用服务的方法的响应时间也会变长,线程会

      产生堆积,最终可能耗尽业务自身的线程池,服务本身也变得不可用。

      服务间的依赖关系如下图所示:

             

        微服务架构都是分布式的,由非常多的服务组成。不同服务之间相互调用,组成复杂的调用

        链路。以上的问题在链路调用中会产生放大的效果。复杂链路上的某一环不稳定,就可能

        会层层级联,最终导致整个链路都不可用。因此我们需要对不稳定的弱依赖服务调用进行

        熔断降级,暂时切断不稳定调用,避免局部不稳定因素导致整体的雪崩。熔断降级作为保

        护自身的手段,通常在客户端(调用端)进行配置。

2、熔断策略

     Sentinel 支持下面几种熔断策略:

     1)慢调用比例 (SLOW_REQUEST_RATIO)

           选择以慢调用比例作为阈值,需要设置允许的慢调用 RT(即请求最大的响应时间),

           请求的响应时间大于该值则统计为慢调用。当单位统计时长(statIntervalMs)内请求

           数目大于设置的最小请求数目,并且慢调用的比例大于阈值,则接下来的熔断时长内新的

           请求会自动被熔断。经过熔断时长后熔断器会进入探测恢复状态(HALF-OPEN 状态),

           若接下来的第一个请求响应时间小于设置的慢调用 RT 则结束熔断,若大于设置的慢调用

           RT, 则会再次被熔断。

     2)异常比例 (ERROR_RATIO)

           当单位统计时长(statIntervalMs)内请求数目大于设置的最小请求数目,并且异常的

           比例大于阈值,则接下来的熔断时长内请求会自动被熔断。经过熔断时长后熔断器会进入

           探测恢复状态(HALF-OPEN 状态),若接下来的一个请求成功完成(没有错误)则结束

           熔断,否则会再次被熔断。异常比率的阈值范围是 [0.0, 1.0],代表 0% - 100%。

     3)异常数 (ERROR_COUNT)

           当单位统计时长内的异常数目超过阈值之后会自动进行熔断。经过熔断时长后熔断器会

          进入探测恢复状态(HALF-OPEN 状态),若接下来的一个请求成功完成(没有错误),

          则结束熔断,否则会再次被熔断。

3、Sentinel熔断状态

      Sentinel 支持三种熔断状态,分别为:OPEN、HALF_OPEN、CLOSED

      1)OPEN(开启熔断)

             表示熔断开启,拒绝所有请求

      2)HALF_OPEN(探测恢复状态)

             探测恢复状态,如果接下来的一个请求顺利通过则表示结束熔断,否则继续熔断

      3)CLOSED(关闭熔断)

             表示熔断关闭,请求顺利通过

4、Sentinel熔断规则属性解析

      Sentinel在1.8.0版本对熔断降级做了大的调整,可以定义任意时长的熔断时间,引入了半

       开启恢复支持。

      Sentinel 新建熔断规则页面如下:

            

      1)资源名(resource )

            资源名,即规则的作用对象

      2)熔断策略(grade )

            熔断策略,支持慢调用比例/异常比例/异常数策略;默认值是慢调用比例

      3)最大RT(count )

            慢调用比例模式下为慢调用临界 RT(超出该值计为慢调用);

            异常比例/异常数模式下为对应的阈值;如异常比例模式下对应的是“比例阈值”,

            异常数模式下对应的是 “异常数”,如下图所示:

                     

                     

            注意:这一点与”慢调用“模式下 比例阈值 的区别

      4)比例阈值(slowRatioThreshold )

            慢调用比例阈值,仅慢调用比例模式有效(1.8.0 引入)

      5)熔断时长(timeWindow )

            熔断时长,单位秒s,可以定义任意时长的熔断时间

      6)最小请求数(minRequestAmount )

            熔断触发的最小请求数,请求数小于该值时即使异常比率超出阈值也不会熔断

          (1.7.0 引入);默认值是 5

      7)统计时长(statIntervalMs )

            统计时长(单位为 ms),如 60*1000 代表分钟级(1.8.0 引入);默认值是1000ms

二、Sentinel 熔断策略测试

1、慢调用比例 (SLOW_REQUEST_RATIO)

     选择以慢调用比例作为阈值,需要设置允许的慢调用 RT(即请求的最大的响应时间),

    请求的响应时间大于该值则统计为慢调用。当单位统计时长(statIntervalMs,默认是1s)内

    请求数目大于设置的最小请求数目,并且其中慢调用的比例大于阈值,则接下来的熔断时长内

    请求会自动被熔断。经过熔断时长后熔断器会进入探测恢复状态(HALF-OPEN 状态),

    若接下来的一个请求响应时间小于设置的慢调用 RT 则结束熔断,若大于设置的慢调用 RT ,

    则会再次被熔断。

1.1、慢调用规则配置示例

         1)环境准备,首先在 breakerTest() 方法中添加sleep休眠代码,模拟慢执行,如下图所示:

                   

         2)配置慢调用熔断规则

               

               Sentinel 熔断触发流程如下所示:

                    

         3)测试

               测试熔断最好使用JMater 工具,本人这个新电脑上没有安装JMater,所以最小请求数配

               的比较小,然后在浏览器中快速访问 breakerA也能看到效果;

               当请求触发熔断后,在熔断时间段内所有的请求都没拒绝,过了熔断时长,请求可以再

              次被访问,如下图所示:

                      

2、异常比例 (ERROR_RATIO)

      当单位统计时长(statIntervalMs)内请求数目大于设置的最小请求数目,并且异常的比例

     大于阈值,则接下来的熔断时长内请求会自动被熔断。经过熔断时长后熔断器会进入

     探测恢复状态(HALF-OPEN 状态),若接下来的一个请求成功完成(没有错误)则结束

     熔断,否则会再次被熔断。异常比率的阈值范围是 [0.0, 1.0],代表 0% - 100%。

     注意:

           异常降级仅针对业务异常,对 Sentinel 限流降级本身的异常(BlockException)不生效。

2.1、异常比例熔断配置示例

         1)环境准备,创建方法 breakerTestB,并模拟异常,如下所示:

         2)配置“异常比例” 熔断规则

               为请求 /breakerB  配置异常比例熔断规则,如下所示:

                    

              异常比例触发熔断流程:

                    

        3)测试

              当统计时长内,异常请求占比超过阈值后,后续在熔断时长内的请求会被直接拒绝,

              如下图所示:

                   

3、异常数 (ERROR_COUNT)

      当单位统计时长内的异常数目超过阈值之后会自动进行熔断。经过熔断时长后熔断器会进入

      探测恢复状态(HALF-OPEN 状态),若接下来的一个请求成功完成(没有错误)则结束

      熔断,否则会再次被熔断。     

      注意:

             异常降级仅针对业务异常,也是对 Sentinel 限流降级本身的异常(BlockException

             不生效。

3.1、异常数规则配置示例

        还是给请求 /breakerB 异常数的熔断规则,熔断规则配置如下:

                

        异常数熔断触发流程如下所示:

                

        测试:

             在统计时长内,异常请求数超过配置的“异常数”,后续在熔断时长内的请求会被直接拒绝

             测试结果如下图所示:

                    

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若转载,请注明出处:http://www.pswp.cn/diannao/88796.shtml
繁体地址,请注明出处:http://hk.pswp.cn/diannao/88796.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

PostgreSQL 主从集群搭建

下面是 PostgreSQL 主从复制(Streaming Replication)环境的安装与配置指南,适合在两台或多台服务器之间构建一主一从(或一主多从)的高可用读写分离系统。 环境准备 角色主机名/IP说明主库192.168.1.10可读写&#xff…

STM32安全固件升级:使用自定义 bootloader 实现SD卡固件升级,包含固件加密

前言 在 STM32 嵌入式开发中,Bootloader 是一个不可或缺的模块。ST 公司为 STM32 提供了功能完备的官方 Bootloader,支持多种通信接口(如 USART、USB DFU、I2C、SPI 等),适用于标准的固件更新方案。 然而&#xff0c…

一步部署APache编译安装脚本

接下来我来介绍以下编译安装的好处 编译安装的优点与缺点 一、优点 高度可定制 可根据实际需求启用或关闭特性(如 Apache 的模块、MySQL 的引擎等)。 灵活控制编译参数、优化性能(如 --enable-xxx、--with-xxx)。 更高的性能…

[Linux]mmap()函数内存映射原理及用法

一、内存映射 内存映射,简而言之就是将用户空间的一段内存区域映射到内核空间,映射成功后,用户对这段内存区域的修改可以直接反映到内核空间,同样,内核空间对这段区域的修改也直接反映用户空间。那么对于内核空间和用…

通信无BUG,ethernet ip转profinet网关,汽车焊接设备通信有心机

在运用“激光钎焊”对汽车车顶、侧面板、后行李箱盖等位置进行接合时,必须配备能够沿着复杂车身线条,对细窄焊接线实施高精度快速检测及模仿控制的“焊缝跟踪控制”。 那么汽车生产线的系统升级改造迫在眉睫,当西门子PLC和库卡机器人无法通信…

python脚本ETH获取最新发行版本并将是否更新信息发送到钉钉

import requests import json import time import hmac import hashlib import base64 import urllib.parse# 1. 配置钉钉机器人 webhook "https://oapi.dingtalk.com/robot/send?access_tokenXXX" secret "XXX" # 如果没有加签验证,请设…

【Docker基础】Docker容器管理:docker ps及其参数详解

目录 1 docker ps命令概述 1.1 命令定位与作用 1.2 命令基本语法 2 基础参数详解 2.1 默认输出解析 2.2 核心参数解析 2.2.1 -a, --all 2.2.2 -q, --quiet 2.2.3 --no-trunc 3 高级过滤与格式化 3.1 过滤器(--filter)详解 3.1.1 常用过滤条件 3.1.2 实际应用示例 …

应急响应-感染Neshta病毒

病毒确定: 根据感染现象确定为Virus/Win32.Neshta家族病毒 病毒表现: 该病毒为感染式病毒。该病毒会在系统%SystemRoot%目录下释放svchost.com文件,并通过添加注册表的方式确保每个exe文件执行的时候都会先执行这个文件。该病毒还会收集系统信…

Hyperledger Fabric 入门笔记(二十)Fabric V2.5 测试网络进阶之Tape性能测试

文章目录 前言一、介绍二、架构三、安装说明四、使用方法4.1. 修改配置文件4.2. 启动测试网络4.3. 运行测试 前言 本文介绍由Hyperledger中国技术工作组提供的另一款区块链网络性能测试工具Tape的架构、安装和在Fabric测试网络中的使用。 一、介绍 Tape是一款轻量级的、可以快…

怎样在 VS Code 中快速创建 Vue 单文件组件(SFC)的基础模板结构?

问题 在Vue项目的开发中&#xff0c;我们经常遇到一个问题&#xff0c;创建新组件时要自己输入基本的框架&#xff0c;比如&#xff1a; <template><div class"page-box"></div> </template><script> export default {name: ,data()…

高防IP在服务器中的作用都有哪些?

高防IP作为一种通过技术手段让用户网络服务更加安全的一种IP地址&#xff0c;有着更高的防御能力&#xff0c;有着强大的流量清洗中心和防御系统&#xff0c;帮助企业实时监控网络流量&#xff0c;将恶意的用户请求识别并过滤掉&#xff0c;保护目标服务器不会受到网络攻击&…

实战 X-AnyLabeling:构建高效自动标注系统的工程实践

文章目录 一、项目背景与目标二、系统架构与模块划分2.1 模块组成说明2.2 架构图 三、模型封装与平台对接3.1 模型封装接口3.2 接入 X-AnyLabeling 平台 四、可视化与预测验证4.1 UI 预测标签预览 五、性能优化与工程经验5.1 模型加速与推理优化5.2 经验总结5.3 实际效果 本文将…

UC3842/UC3843反激教程教学开关电源 反激设计步骤,每一关键元器件计算

资料下载地址&#xff1a;UC3842/UC3843反激教程教学开关电源 反激设计步骤&#xff0c;每一关键元器件计算 1、原理图 2、PCB图 3、变压器设计资料 4、开关电源设计资料 5、主要元器件说明书 6、系统整体资料 7、说明文档 7.1、电源设计概述 电源规格&#xff1a;设计一款 2…

Docker 入门教程(二):Docker 的基本原理

文章目录 &#x1f433; Docker 入门教程&#xff08;二&#xff09;&#xff1a;Docker 的基本原理1. Docker 架构总览&#xff1a;三大核心角色2. 镜像与容器的关系3. 容器启动流程&#xff1a;docker run 背后发生了什么&#xff1f; &#x1f433; Docker 入门教程&#xf…

21.安卓逆向2-frida hook技术-HookOkHttp的拦截器

免责声明&#xff1a;内容仅供学习参考&#xff0c;请合法利用知识&#xff0c;禁止进行违法犯罪活动&#xff01; 内容参考于&#xff1a;图灵Python学院 工具下载&#xff1a; 链接&#xff1a;https://pan.baidu.com/s/1bb8NhJc9eTuLzQr39lF55Q?pwdzy89 提取码&#xff1…

小程序入门:swpier 和 swpier-item 的基本使用

在前端开发中&#xff0c;创建交互式的用户界面组件是至关重要的。今天&#xff0c;我们将深入探讨 swpier 和 swpier-item 的基本使用方法&#xff0c;这两个组件在构建轮播图等滑动效果的场景中非常实用。 一、swpier 组件概述 swpier 组件是实现滑动效果的核心容器。它负责…

SQL学习笔记4

约束 1、约束 约束&#xff0c;是指作用在表中字段上的规则&#xff0c;用于限制字段输入的数据&#xff0c;使得表格式统一&#xff0c;数据内容正确。同一个字段的约束可以有多个 约束包括&#xff1a; 非空约束&#xff0c;限制表中的值不为null:not null 唯一约束&…

力扣刷题(第七十天)

灵感来源 - 保持更新&#xff0c;努力学习 - python脚本学习 比特位计数 解题思路 对于任意整数 x&#xff0c;其 1 的个数等于 x // 2 的 1 的个数加上 x % 2。状态转移方程&#xff1a;dp[x] dp[x // 2] (x % 2)。 class Solution:def countBits(self, n: int) ->…

鸿蒙网络编程系列56-仓颉版通过数据包结束标志解决TCP粘包问题

1. TCP粘包问题解决思路 在本系列的上一篇文章演示了TCP数据粘包的原因以及可能的解决方法&#xff0c;本文将通过其中的添加数据包结束标志的方法来解决这个问题。我们知道&#xff0c;数据粘包的原因是因为发送的时候没有标明数据包的边界&#xff0c;那么&#xff0c;我们人…

Redis网络通信模块深度解析:单线程Reactor到多线程IO的架构演进

一、核心架构&#xff1a;单线程Reactor模型 Redis网络模块采用经典Reactor模式&#xff0c;核心流程如下&#xff1a; void aeMain(aeEventLoop *eventLoop) {while (!eventLoop->stop) {// 前置钩子&#xff08;集群心跳/数据持久化&#xff09;if (eventLoop->befor…