【业务功能107】微服务-springcloud-springboot-Sentinel容器安装-熔断降级限流

Sentinel

  • 在微服务架构下，会涉及到 微服务A需要远程调用其他的微服务B,C,D等的接口，比如商品服务接口，需要调用库存服务数据，秒杀服务数据等，这里就会衍生一个长链路的调用过程，那么一旦下游需要被调用的数据接口出现异常，那么就会导致整个上游的接口都会报错无法使用，所以就需要去做相应的方案措施，避免上游服务异常。

image.png

image.png

image.png

一、熔断、降级、限流

1.熔断

  服务熔断的作用类似于我们家用的保险丝，当某服务出现不可用或响应超时的情况时，为了防止整个系统出现雪崩，暂时停止对该服务的调用。

停止是说，当前服务一旦对下游服务进行熔断，当请求到达时，当前服务不再对下游服务进行调用，而是使用设定好的策略(如构建默认值)直接返回。

暂时是说，熔断后，并不会一直不再调用下游服务，而是以一定的策略(如每分钟调用 10 次，若均返回成功，则增大调用量)试探调用下游服务，当下游服务恢复可用时，自动停止熔断。

image.png

2.降级

  降级是指当自身服务压力增大时，采取一些手段，增强自身服务的处理能力，以保障服务的持续可用。比如，下线非核心服务以保证核心服务的稳定、降低实时性、降低数据一致性。

  为了预防某些功能出现负荷过载或者响应慢的情况，在其内部暂时舍弃一些非核心接口和数据的请求（如评论、积分），而直接返回一个提前准备好的 fallback(退路) 错误处理信息。释放CPU和内存资源，以保证整个系统的稳定性和可用性。

3.限流

  限流是指上游服务对本服务请求 QPS 超过阙值时，通过一定的策略(如延迟处理、拒绝处理)对上游服务的请求量进行限制，以保证本服务不被压垮，从而持续提供稳定服务。常见的限流算法有滑动窗口、令牌桶、漏桶等。

二、Sentinel

1.其他组件对比

image.png

2.Sentinel介绍

  随着微服务的流行，服务和服务之间的稳定性变得越来越重要。Sentinel 以流量为切入点，从流量控制、熔断降级、系统负载保护等多个维度保护服务的稳定性。

Sentinel 的历史：

  • 2012 年，Sentinel 诞生，主要功能为入口流量控制。
  • 2013-2017 年，Sentinel 在阿里巴巴集团内部迅速发展，成为基础技术模块，覆盖了所有的核心场景。Sentinel 也因此积累了大量的流量归整场景以及生产实践。
  • 2018 年，Sentinel 开源，并持续演进。
  • 2019 年，Sentinel 朝着多语言扩展的方向不断探索，推出 C++ 原生版本，同时针对 Service Mesh 场景也推出了 Envoy 集群流量控制支持，以解决 Service Mesh 架构下多语言限流的问题。
  • 2020 年，推出 Sentinel Go 版本，继续朝着云原生方向演进。

Sentinel 分为两个部分:

  • 核心库（Java 客户端）不依赖任何框架/库，能够运行于所有 Java 运行时环境，同时对 Dubbo / Spring Cloud 等框架也有较好的支持。
  • 控制台（Dashboard）基于 Spring Boot 开发，打包后可以直接运行，不需要额外的 Tomcat 等应用容器。

Sentinel 可以简单的分为 Sentinel 核心库和 Dashboard。核心库不依赖 Dashboard，但是结合 Dashboard 可以取得最好的效果。

3. 基本概念及作用

基本概念：

资源：是 Sentinel 的关键概念。它可以是 Java 应用程序中的任何内容，例如，由应用程序提供的服务，或由应用程序调用的其它应用提供的服务，甚至可以是一段代码。在接下来的文档中，我们都会用资源来描述代码块。

只要通过 Sentinel API 定义的代码，就是资源，能够被 Sentinel 保护起来。大部分情况下，可以使用方法签名，URL，甚至服务名称作为资源名来标示资源。

规则：围绕资源的实时状态设定的规则，可以包括流量控制规则、熔断降级规则以及系统保护规则。所有规则可以动态实时调整。

主要作用：

  1. 流量控制
  2. 熔断降级
  3. 系统负载保护

我们说的资源，可以是任何东西，服务，服务里的方法，甚至是一段代码。使用 Sentinel 来进行资源保护，主要分为几个步骤:

  1. 定义资源
  2. 定义规则
  3. 检验规则是否生效

先把可能需要保护的资源定义好，之后再配置规则。也可以理解为，只要有了资源，我们就可以在任何时候灵活地定义各种流量控制规则。在编码的时候，只需要考虑这个代码是否需要保护，如果需要保护，就将之定义为一个资源。

4.Sentinel应用

官方文档：https://github.com/alibaba/spring-cloud-alibaba/wiki/Sentinel

4.1 Sentinel控制台搭建

下载对应的jar包：https://github.com/alibaba/Sentinel/releases 下载适合自己的版本

通过命令行启动：

java -Dserver.port=8080 -Dcsp.sentinel.dashboard.server=localhost:8080 -Dproject.name=sentinel-dashboard -jar sentinel-dashboard.jar

启动后需要输入账号密码:sentinel sentinel

image.png

登录成功后看到的页面

image.png

4.2 服务监控

  如果我们需要把自己的服务被Sentinel监控，那么我们需要添加对应的依赖

        <dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-sentinel</artifactId></dependency>

然后需要添加对应的属性信息

image.png

然后我们访问请求后，在控制台就可以看到对应的监控信息了

image.png

然后我们可以指定简单的限流规则

image.png

表示1秒中内只能有一个QPS。超过就限流

image.png

测试我们发送请求快一点就会出现限流的处理

4.3 实时监控

  实时监控这块需要引入Acuator

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

endpoint端点：

image.png

4.4 限流信息自定义

@Component
public class SentinelUrlBlockHandler implements BlockExceptionHandler {@Overridepublic void handle(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, BlockException e) throws Exception {R r = R.error(500,"访问太快，稍后再试!");httpServletResponse.setContentType("application/json;charset=UTF-8");httpServletResponse.getWriter().write(JSON.toJSONString(r));}
}

image.png

5.sentinel容器安装

  直接在windows中安装Sentinel启动管理还是不太方便，所以我们还是把Sentinel安装在Docker容器中

拉取对应的镜像文件

docker pull bladex/sentinel-dashboard:1.7.2

启动容器

docker run --name sentinel  -d -p 8858:8858 -d  bladex/sentinel-dashboard:1.7.2

开机自启动

docker update --restart=always sentinel

访问：

image.png

对应的客户端的使用：需要调整的配置信息

image.png

image.png

6.Sentinel监控所有服务

在公共微服务中引入以上说明的两个依赖，使得每个需要进行限流降级操作的微服务进入sentinel监控中。

        <dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-sentinel</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId></dependency>

  在每一个服务都添加Sentinel的配置 以及 Acuator实时监控的端点配置，这里都是重复的配置信息，也可以配置在nacos配置中心

spring:cloud:sentinel:transport:port: 8719client-ip: 192.168.56.1     dashboard: 192.168.56.100:8858
management:endpoints:web:exposure:include: '*'

image.png

7.熔断降级

https://github.com/alibaba/spring-cloud-alibaba/wiki/Sentinel

场景一 远程服务调用异常 熔断降级实例： 刷新商品页面详情会调用到多个接口包括远程服务接口
商品服务product中–>>会调用本身服务多个接口方法–>>同时也会通过fegin调用到其他的微服务 比如秒杀服务，假如此时秒杀服务接口异常（异常有很多种，比如我们模拟的时候，可以直接把秒杀服务关了…或者接口代码去抛异常…），那么商品服务的请求链路会因为秒杀服务异常而导致整个接口请求异常，页面报错，那么我们通过代码的方式 设置熔断机制，使得即使fegin远程调用的接口异常返回一个回调相应数据，来确保业务逻辑不报错

1.添加对应的配置

feign:sentinel:enabled: true

image.png

2.将涉及fegin远程调用的秒杀服务查询接口添加托底的方法,回调类

@Slf4j
@Component
public class SeckillFeignServiceFallback implements SeckillFeignService {@Overridepublic R getSeckillSessionBySkuId(Long skuId) {log.error("熔断降级....SeckillFeignService:{}",skuId);return R.error(BizCodeEnume.UNKNOW_EXCEPTION.getCode(),BizCodeEnume.UNKNOW_EXCEPTION.getMsg());}
}

image.png

3.在商品服务的调用远程服务接口中增加注解的属性值指定前面定义的回调类:fallback = SeckillFeignServiceFallback.class

@FeignClient(value = "mall-seckill",fallback = SeckillFeignServiceFallback.class)
public interface SeckillFeignService {@GetMapping("/seckill/seckillSessionBySkuId")R getSeckillSessionBySkuId(@RequestParam("skuId") Long skuId);
}

image.png


4.设置好回调类信息，需要进一步的优化业务逻辑的响应，避免出现空指针异常，需要先判断返回值的响应代码，如果是正常的r.getCode() == 0再做进一步的调用

CompletableFuture<Void> seckillFuture = CompletableFuture.runAsync(() -> {// 查询商品的秒杀活动R r = seckillFeignService.getSeckillSessionBySkuId(skuId);if(r.getCode() == 0){SeckillVO seckillVO = JSON.parseObject(r.get("data").toString(),SeckillVO.class);vo.setSeckillVO(seckillVO);}}, threadPoolExecutor);

场景二 远程服务调用慢 延时 熔断降级实例：刷新商品页面详情会调用到多个接口包括远程服务接口
与场景一相同，只不过此时我们模拟远程调用接口时长久一些，调用线程睡眠方法，比如设置500毫秒，然后
可以通过我们安装好的sentinel启动访问客户端，访问商品服务接口中调用到的 远程服务接口，点击编辑降级规则，熔断策略设置：慢调用比例， 最大RT200毫秒，比例阈值0.1 ，熔断时长10s,最小请求数5

熔断策略
Sentinel 提供以下几种熔断策略：

  • 慢调用比例 (SLOW_REQUEST_RATIO)：选择以慢调用比例作为阈值，需要设置允许的慢调用 RT（即最大的响应时间），请求的响应时间大于该值则统计为慢调用。当单位统计时长（statIntervalMs）内请求数目大于设置的最小请求数目，并且慢调用的比例大于阈值，则接下来的熔断时长内请求会自动被熔断。经过熔断时长后熔断器会进入探测恢复状态（HALF-OPEN 状态），若接下来的一个请求响应时间小于设置的慢调用 RT 则结束熔断，若大于设置的慢调用 RT 则会再次被熔断。
  • 异常比例 (ERROR_RATIO)：当单位统计时长（statIntervalMs）内请求数目大于设置的最小请求数目，并且异常的比例大于阈值，则接下来的熔断时长内请求会自动被熔断。经过熔断时长后熔断器会进入探测恢复状态（HALF-OPEN 状态），若接下来的一个请求成功完成（没有错误）则结束熔断，否则会再次被熔断。异常比率的阈值范围是 [0.0, 1.0]，代表 0% - 100%。
  • 异常数 (ERROR_COUNT)：当单位统计时长内的异常数目超过阈值之后会自动进行熔断。经过熔断时长后熔断器会进入探测恢复状态（HALF-OPEN 状态），若接下来的一个请求成功完成（没有错误）则结束熔断，否则会再次被熔断。

手动配置：客户端的Sentinel版本需要和服务器的版本要保持一致。

    @ResponseBody@GetMapping("/seckillSessionBySkuId")public R getSeckillSessionBySkuId(@RequestParam("skuId") Long skuId){System.out.println("seckillSessionBySkuId -----------------------");try {Thread.sleep(500);} catch (InterruptedException e) {e.printStackTrace();}SeckillSkuRedisDto dto = seckillService.getSeckillSessionBySkuId(skuId);return  R.ok().put("data",JSON.toJSONString(dto));}

image.png

8.自定义资源

详情看官网
https://github.com/alibaba/Sentinel/wiki/%E5%A6%82%E4%BD%95%E4%BD%BF%E7%94%A8#%E5%AE%9A%E4%B9%89%E8%B5%84%E6%BA%90

定义资源

  • 方式一：主流框架的默认适配
    为了减少开发的复杂程度，我们对大部分的主流框架，例如 Web Servlet、Dubbo、Spring Cloud、gRPC、Spring WebFlux、Reactor 等都做了适配。您只需要引入对应的依赖即可方便地整合 Sentinel。可以参见: 主流框架的适配。 比如前面结合Feign

  • 方式二：抛出异常的方式定义资源
    SphU 包含了 try-catch 风格的 API。用这种方式，当资源发生了限流之后会抛出 BlockException。这个时候可以捕捉异常，进行限流之后的逻辑处理。示例代码如下:


// 1.5.0 版本开始可以利用 try-with-resources 特性（使用有限制）
// 资源名可使用任意有业务语义的字符串，比如方法名、接口名或其它可唯一标识的字符串。
try (Entry entry = SphU.entry("resourceName")) {// 被保护的业务逻辑// do something here...
} catch (BlockException ex) {// 资源访问阻止，被限流或被降级// 在此处进行相应的处理操作
}
  • 方式四：注解方式定义资源
    Sentinel 支持通过 @SentinelResource 注解定义资源并配置 blockHandler 和 fallback 函数来进行限流之后的处理。示例：
// 原本的业务方法.
@SentinelResource(blockHandler = "blockHandlerForGetUser")
public User getUserById(String id) {throw new RuntimeException("getUserById command failed");
}// blockHandler 函数，原方法调用被限流/降级/系统保护的时候调用
public User blockHandlerForGetUser(String id, BlockException ex) {return new User("admin");
}

带入实际业务接口 秒杀商品信息接口实例：

 public List<SeckillSkuRedisDto> blockHandler(BlockException blockException){log.error("限流执行的 blockHandler 方法 ....{}",blockException.getMessage());return null;}/*** 查询出当前时间内的秒杀活动及对应的商品SKU信息* @return*/@SentinelResource(value = "currentSeckillSkusResources",blockHandler = "blockHandler")@Overridepublic List<SeckillSkuRedisDto> getCurrentSeckillSkus() {// 1.确定当前时间是属于哪个秒杀活动的long time = new Date().getTime();try (Entry entry = SphU.entry("getCurrentSeckillSkusResources")) {// 被保护的业务逻辑// 从Redis中查询所有的秒杀活动Set<String> keys = redisTemplate.keys(SeckillConstant.SESSION_CHACE_PREFIX + "*");for (String key : keys) {//seckill:sessions1656468000000_1656469800000String replace = key.replace(SeckillConstant.SESSION_CHACE_PREFIX, "");// 1656468000000_1656469800000String[] s = replace.split("_");Long start = Long.parseLong(s[0]); // 活动开始的时间Long end = Long.parseLong(s[1]); // 活动结束的时间if(time > start && time < end){// 说明的秒杀活动就是当前时间需要参与的活动// 取出来的是SKU的ID  2_9List<String> range = redisTemplate.opsForList().range(key, -100, 100);BoundHashOperations<String, String, String> ops = redisTemplate.boundHashOps(SeckillConstant.SKU_CHACE_PREFIX);List<String> list = ops.multiGet(range);if(list != null && list.size() > 0){List<SeckillSkuRedisDto> collect = list.stream().map(item -> {SeckillSkuRedisDto seckillSkuRedisDto = JSON.parseObject(item, SeckillSkuRedisDto.class);return seckillSkuRedisDto;}).collect(Collectors.toList());return collect;}}}} catch (BlockException ex) {// 资源访问阻止，被限流或被降级log.error("getCurrentSeckillSkusResources被限制访问了...");// 在此处进行相应的处理操作}return null;}

9.网关流控

  • 前面所做的限流都是基于具体的业务微服务中，在业务代码去限制，而我们微服务架构中也有网关服务Gateway,请求通过网关来转发到具体的微服务中，我们也可以在网关处做限流动作，可以参考官网的指南： 网关流量控制

这里演示一个简单的例子，在网关服务pom文件，导入一个依赖，然后与前面介绍的使用方式一致，直接请求我们的电商首页等接口信息，因为这些都是通过网关转发，然后在sentinel客户端页面刷新，就可以打开看的网关服务的接口信息，请求链路栏目中可以看的API的名称，是网关服务定义的路由id 值如：- id: msbmall_host_route1，点击 流控 按钮 进行相应的 阈值设置即可生效

网关服务依赖引入：

        <dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-alibaba-sentinel-gateway</artifactId><version>2021.1</version></dependency>

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

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

相关文章

【服务器 | 测试】如何在centos 7上面安装jmeter

【服务器 | 测试】如何在centos 7上面安装jmeter

安装之前需要几个环境&#xff0c;以下是列出的几个环境 CentOS 7.7 64位JDK 1.8JMeter 5.2 1. 下载jmeter安装包 JMeter是开源的工具&#xff0c;安装 JMeter 要先安装好 JDK 的环境&#xff0c;安装JDK在前面的文章已经讲到 JMeter最新版下载地址&#xff1a;Apache JMeter…
阅读更多...
成绩定级脚本（Python）

成绩定级脚本（Python）

成绩评定脚本 写一个成绩评定的python脚本&#xff0c;实现用户输入成绩&#xff0c;由脚本来为成绩评级&#xff1a; #成绩评定脚本.pyscoreinput("please input your score:") if int(score)> 90:print("A") elif int(score)> 80:print("B&…
阅读更多...
Java面试笔试acm版输入

Java面试笔试acm版输入

首先区分scanner.nextInt()//输入一个整数&#xff0c;只能读取一个数&#xff0c;空格就停止。 scanner.next()//输入字符串&#xff0c;只能读取一个字符串&#xff0c;空格就停止&#xff0c;但是逗号不停止。 scanner.nextLine() 读取一行&#xff0c;换行停止&#xff0c…
阅读更多...
buuctf crypto 【密码学的心声】解题记录

buuctf crypto 【密码学的心声】解题记录

1.打开可以看到一个曲谱 2.看到曲谱中的提示埃塞克码可以想到ascii码&#xff0c;没有八可以联想到八进制&#xff0c;而八进制又对应着三位的二进制&#xff0c;然后写个脚本就好了 oct [111,114,157,166,145,123,145,143,165,162,151,164,171,126,145,162,171,115,165,143,…
阅读更多...
算法通过村第七关-树(递归/二叉树遍历)青铜笔记|手撕递归

算法通过村第七关-树(递归/二叉树遍历)青铜笔记|手撕递归

文章目录 前言1. 递归的特征2. 如何写出好的递归3. 怎么看懂递归的代码总结 前言 提示&#xff1a;我们生活在24小时不眠不休的社会里但是没有24小时不眠不休的身体有些东西必须舍弃 -- 马特海格 这一关&#xff0c;我看要谈论的是递归问题&#xff0c;说到它就牵扯到很多问题了…
阅读更多...
量化：基于支持向量机的择时策略

量化：基于支持向量机的择时策略

文章目录 参考机器学习简介策略简介SVM简介整体流程收集数据准备数据建立模型训练模型测试模型调节参数 参考 Python机器学习算法与量化交易 利用机器学习模型&#xff0c;构建量化择时策略 机器学习简介 机器学习理论主要是设计和分析一些让计算机可以自动“学习”的算法。…
阅读更多...
Python实现机器学习（下）— 数据预处理、模型训练和模型评估

Python实现机器学习（下）— 数据预处理、模型训练和模型评估

前言&#xff1a;Hello大家好&#xff0c;我是小哥谈。本门课程将介绍人工智能相关概念&#xff0c;重点讲解机器学习原理机器基本算法&#xff08;监督学习及非监督学习&#xff09;。使用python&#xff0c;结合sklearn、Pycharm进行编程&#xff0c;介绍iris&#xff08;鸢尾…
阅读更多...
时间序列论文-聚类和异常检测（二）

时间序列论文-聚类和异常检测（二）

同样摘自知乎的回答&#xff1a;https://www.zhihu.com/question/29507442/answer/1212624591?utm_id0 正巧之前做过时间序列 的异常检测项目&#xff0c;这里介绍几种尝试过的方法&#xff0c;也算是抛砖引玉 吧&#xff0c;欢迎大家讨论交流~ 背景与定义 时间序列异常 检测…
阅读更多...
【C++ • STL • 力扣】详解string相关OJ

【C++ • STL • 力扣】详解string相关OJ

文章目录 1、仅仅翻转字母2、字符串中的第一个唯一字符3、字符串里最后一个单词的长度4、验证一个字符串是否是回文5、字符串相加总结 ヾ(๑╹◡╹)&#xff89;" 人总要为过去的懒惰而付出代价 ヾ(๑╹◡╹)&#xff89;" 1、仅仅翻转字母 力扣链接 代码1展示&…
阅读更多...
Gitlab仓库部署

Gitlab仓库部署

Gitlab仓库部署 一、Gitlab的概述1、gitlab介绍2、gitlab主要功能3、gitlab和github的区别 二、部署环境1、安装依赖环境2、安装Postfix邮箱3、Gitlab优势4、Gitlab工作流程 三、Gitlab部署过程1、Yum安装Gitlab2、配置gitlab站点URL3、启动并访问Gitlab 四、Gitlab具体操作1、…
阅读更多...
X86_64函数调用汇编程序分（2）

X86_64函数调用汇编程序分（2）

X86_64函数调用汇编程序分&#xff08;2&#xff09; 1 X86_64寄存器使用标准2 leaveq和retq指令2.1 leaveq2.2 retq 3 执行leaveq和retq之后栈的结构3.1 执行leaveq之后栈的结构3.1.1 test_fun_b函数执行leaveq之前的栈结构示意图3.1.2 test_fun_b函数执行leaveq之后的栈结构示…
阅读更多...
招投标软件系统技术和服务解决方案

招投标软件系统技术和服务解决方案

附件为全部文章&#xff0c;敬请下载。 ↑&#xff08;完全免费&#xff0c;直接免费下载&#xff09; 软件系统技术和服务解决方案 目录 第一部分 服务方案 6 第一节、 服务方案概述 6 第二节、 服务方式 6 第三节、 服务机构 7 第四节、 服务响应 8 第五节、 服务内容 9 第六…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023