1. 首页
  2. 文章中心
  3. # SpringCloud 2020

SpringCloud Alibaba Sentinel 服务熔断与限流1-SpringCloud Alibaba Sentinel 概述2-SpringCloud Alibaba Sentinel 安装3-SpringCloud Alibaba Sentinel 配置

74 阅读 0 评论
我是靠谱客的博主 谦让火车，最近开发中收集的这篇文章主要介绍SpringCloud Alibaba Sentinel 服务熔断与限流1-SpringCloud Alibaba Sentinel 概述2-SpringCloud Alibaba Sentinel 安装3-SpringCloud Alibaba Sentinel 配置，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

为了下一章节演示nacos的负载均衡，参照9001新建9002
新建cloudalibaba-provider-payment9002
9002其他步骤你懂的
或者取巧不想新建重复体力劳动，直接拷贝虚拟端口映射

SpringCloud Alibaba Sentinel 服务熔断与限流

  • 1-SpringCloud Alibaba Sentinel 概述
    • 1.1-是什么
    • 1.2-去哪下
    • 1.3-能干嘛
    • 1.4-怎么玩
  • 2-SpringCloud Alibaba Sentinel 安装
    • 2.1-Sentinel 下载
    • 2.2-Sentinel 安装
    • 2.3-Sentinel 示例
  • 3-SpringCloud Alibaba Sentinel 配置
    • 3.1-SpringCloud Alibaba Sentinel 流控规则
    • 3.2-SpringCloud Alibaba Sentinel 降级规则
    • 3.3-SpringCloud Alibaba Sentinel 热点 Key 限流
    • 3.4-SpringCloud Alibaba Sentinel 系统规则
    • 3.5-SpringCloud Alibaba Sentinel @SentinelResource
    • 3.6-SpringCloud Alibaba Sentinel 服务熔断
    • 3.7SpringCloud Alibaba Sentinel 规则持久化

1-SpringCloud Alibaba Sentinel 概述

1.1-是什么

GitHub：

  • https://github.com/alibaba/Sentinel

中文：

  • https://github.com/alibaba/Sentinel/wiki/%E4%BB%8B%E7%BB%8D

在这里插入图片描述

一句话解释，之前我们讲解过的Hystrix

1.2-去哪下

https://github.com/alibaba/Sentinel/releases

在这里插入图片描述

1.3-能干嘛

在这里插入图片描述

1.4-怎么玩

https://spring-cloud-alibaba-group.github.io/github-pages/greenwich/spring-cloud-alibaba.html#_spring_cloud_alibaba_sentinel

服务使用中的各种问题
服务雪崩
服务降级
服务熔断
服务限流

2-SpringCloud Alibaba Sentinel 安装

在这里插入图片描述
安装Sentinel控制台
sentinel组件由2部分组成
后台
前台8080

2.1-Sentinel 下载

https://github.com/alibaba/Sentinel/releases

下载到本地sentinel-dashboard-1.7.0.jar

在这里插入图片描述

2.2-Sentinel 安装

运行命令
前提
java8环境OK
8080端口不能被占用
命令
java -jar sentinel-dashboard-1.7.0.jar
访问sentinel管理界面
http://localhost:8080
登录账号密码均为sentinel

2.3-Sentinel 示例

初始化演示工程
启动Nacos8848成功
http://localhost:8848/nacos/#/login
Module
cloudalibaba-sentinel-service8401
POM

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>cloud2020</artifactId>
        <groupId>com.atguigu.springcloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>cloudalibaba-sentinel-service8401</artifactId>

    <dependencies>
        <dependency>
            <groupId>com.atguigu.springcloud</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>${project.version}</version>
        </dependency>

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

        <dependency>
            <groupId>com.alibaba.csp</groupId>
            <artifactId>sentinel-datasource-nacos</artifactId>
        </dependency>

        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-sentinel</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.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>cn.hutool</groupId>
            <artifactId>hutool-all</artifactId>
            <version>4.6.3</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

    </dependencies>

</project>

YML

server:
  port: 8401

spring:
  application:
    name: cloudalibaba-sentinel-service
  cloud:
    nacos:
      discovery:
        server-addr: localhost:8848
    sentinel:
      transport:
        dashboard: localhost:8080
        port: 8719  #默认8719，假如被占用了会自动从8719开始依次+1扫描。直至找到未被占用的端口

management:
  endpoints:
    web:
      exposure:
        include: '*'

主启动

package com.atguigu.springcloud.alibaba;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;


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

业务类FlowLimitController

package com.atguigu.springcloud.alibaba.controller;



import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;




@RestController
public class FlowLimitController
{
    @GetMapping("/testA")
    public String testA() {
        return "------testA";
    }

    @GetMapping("/testB")
    public String testB() {

        return "------testB";
    }



}

启动Sentinel8080
java -jar sentinel-dashboard-1.7.0
启动微服务8401
启动8401微服务后查看sentienl控制台
空空如也，啥都没有
Sentinel采用的懒加载说明
执行一次访问即可
http://localhost:8401/testA
http://localhost:8401/testB
效果

在这里插入图片描述

结论
sentinel8080正在监控微服务8401

3-SpringCloud Alibaba Sentinel 配置

3.1-SpringCloud Alibaba Sentinel 流控规则

流控规则
基本介绍
在这里插入图片描述

进一步解释说明
在这里插入图片描述
在这里插入图片描述

流控模式
直接（默认）
直接->快速失败
系统默认
配置及说明
在这里插入图片描述

    测试
      快速点击访问http://localhost:8401/testA
      结果
        Blocked by Sentinel (flow limiting)
      思考？？？
        直接调用默认报错信息，技术方面OK but，是否应该有我们自己的后续处理？
          类似有一个fallback的兜底方法？
  关联
    是什么？
      当关联的资源达到阈值时，就限流自己
      当与A关联的资源B达到阈值后，就限流自己
      B惹事，A挂了
    配置A

在这里插入图片描述

postman模拟并发密集访问testB
在这里插入图片描述

访问testB成功
在这里插入图片描述

      postman里新建多线程集合组

在这里插入图片描述

      将访问地址添加进新线程组

在这里插入图片描述

      Run
        大批量线程高并发访问B，导致A失效了
    运行后发现testA挂了
      点击访问http://localhost:8401/testA
      结果
        Blocked by Sentinel (flow limiting)
  链路
    多个请求调用了同一个微服务
    家庭作业试试

流控效果
直接->快速失败（默认的流控处理）
直接失败，抛出异常
Blocked by Sentinel (flow limiting)
源码
com.alibaba.csp.sentinel.slots.block.flow.controller.DefaultController
预热
说明
公式：阈值除以coldFactor（默认值为3），经过预热时长后才会达到阈值
官网
在这里插入图片描述
在这里插入图片描述

      默认coldFactor为3，即请求QPS从threshold/3开始，经预热时长逐渐升至设定的QPS阈值。
      限流 冷启动
        https://github.com/alibaba/Sentinel/wiki/%E9%99%90%E6%B5%81---%E5%86%B7%E5%90%AF%E5%8A%A8
    源码
      com.alibaba.csp.sentinel.slots.block.flow.controller.WarmUpController
    Warmup配置

在这里插入图片描述

    多次点击http://localhost:8401/testB
      刚开始不行，后续慢慢OK
    应用场景

在这里插入图片描述

  排队等待

在这里插入图片描述

    匀速排队，阈值必须设置为QPS
    官网

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

    源码
      com.alibaba.csp.sentinel.slots.block.flow.controller.RateLimiterController
    测试

在这里插入图片描述

3.2-SpringCloud Alibaba Sentinel 降级规则

降级规则
官网
基本介绍
在这里插入图片描述

在这里插入图片描述

  进一步说明

在这里插入图片描述

  Sentinel的断路器是没有半开状态的
    半开的状态系统自动去检测是否请求有异常，没有异常就关闭断路器恢复使用，有异常则继续打开断路器不可用。具体可以参考Hystrix
    复习Hystrix

在这里插入图片描述

在这里插入图片描述

降级策略实战
  RT
    是什么

在这里插入图片描述

在这里插入图片描述

    测试
      代码

    @GetMapping("/testD")
    public String testD()
    {
        try { TimeUnit.SECONDS.sleep(1); } catch (InterruptedException e) { e.printStackTrace(); }
        log.info("testD 测试RT");

        return "------testD";
    }

      配置

在这里插入图片描述

      jmeter压测
      结论

在这里插入图片描述

在这里插入图片描述

  异常比例
    是什么

在这里插入图片描述

在这里插入图片描述

    测试
      代码

@GetMapping("/testD")
    public String testD()
    {

        log.info("testD 测试RT");
        int age = 10/0;
        return "------testD";
    }
 
 


      配置

在这里插入图片描述

      jmeter

在这里插入图片描述

      结论

在这里插入图片描述

  异常数
    是什么

在这里插入图片描述

异常数是按照分钟统计的

    测试
      代码

@GetMapping("/testE")
public String testE()
{
    log.info("testE 测试异常数");
    int age = 10/0;
    return "------testE 测试异常数";
}
 
 


      配置

在这里插入图片描述

      jmeter

3.3-SpringCloud Alibaba Sentinel 热点 Key 限流

热点key限流
基本介绍
是什么
在这里插入图片描述

官网
  https://github.com/alibaba/Sentinel/wiki/热点参数限流
承上启下复习start

在这里插入图片描述

  @SentinelResource
代码

@GetMapping("/testHotKey")
@SentinelResource(value = "testHotKey",blockHandler = "deal_testHotKey")
public String testHotKey(@RequestParam(value = "p1",required = false) String p1,
                         @RequestParam(value = "p2",required = false) String p2) {
    //int age = 10/0;
    return "------testHotKey";
}
 
//兜底方法
public String deal_testHotKey (String p1, String p2, BlockException exception){
    return "------deal_testHotKey,o(╥﹏╥)o";  
}
 
 


  com.alibaba.csp.sentinel.slots.block.BlockException
配置
  配置

在这里插入图片描述

    1
      @SentinelResource(value = "testHotKey")
      异常打到了前台用户界面看不到，不友好
    2
      @SentinelResource(value = "testHotKey",blockHandler = "deal_testHotKey")
      方法testHostKey里面第一个参数只要QPS超过每秒1次，马上降级处理
      用了我们自己定义的
测试
  error
    http://localhost:8401/testHotKey?p1=abc
  error
    http://localhost:8401/testHotKey?p1=abc&p2=33
  right
    http://localhost:8401/testHotKey?p2=abc
参数例外项
  上述案例演示了第一个参数p1,当QPS超过1秒1次点击后马上被限流
  特殊情况
    普通
      超过1秒钟一个后，达到阈值1后马上被限流
    我们期望p1参数当它是某个特殊值时，它的限流值和平时不一样
    特例
      假如当p1的值等于5时，它的阈值可以达到200
  配置

在这里插入图片描述

  测试
    http://localhost:8401/testHotKey?p1=5
    http://localhost:8401/testHotKey?p1=3
    当p1等于5的时候，阈值变为200
    当p1不等于5的时候，阈值就是平常的1
  前提条件
    热点参数的注意点，参数必须是基本类型或者String
其他
  手贱添加异常看看....
    后面讲

在这里插入图片描述

3.4-SpringCloud Alibaba Sentinel 系统规则

系统规则
是什么
https://github.com/alibaba/Sentinel/wiki/%E7%B3%BB%E7%BB%9F%E8%87%AA%E9%80%82%E5%BA%94%E9%99%90%E6%B5%81
各项配置参数说明
在这里插入图片描述

配置全局QPS

3.5-SpringCloud Alibaba Sentinel @SentinelResource

@SentinelResource
按资源名称限流+后续处理
启动Nacos成功
启动Sentinel成功
Module
cloudalibaba-sentinel-service8401
POM

<dependency>
    <groupId>com.atguigu.springcloud</groupId>
    <artifactId>cloud-api-commons</artifactId>
    <version>${project.version}</version>
</dependency>
 
 


    YML

server:
  port: 8401

spring:
  application:
    name: cloudalibaba-sentinel-service
  cloud:
    nacos:
      discovery:
        server-addr: localhost:8848
    sentinel:
      transport:
        dashboard: localhost:8080
        port: 8719  #默认8719，假如被占用了会自动从8719开始依次+1扫描。直至找到未被占用的端口

management:
  endpoints:
    web:
      exposure:
        include: '*'


    业务类RateLimitController

package com.atguigu.springcloud.alibaba.controller;

import com.alibaba.csp.sentinel.annotation.SentinelResource;
import com.alibaba.csp.sentinel.slots.block.BlockException;

import com.atguigu.springcloud.entities.*;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;


@RestController
public class RateLimitController
{
    @GetMapping("/byResource")
    @SentinelResource(value = "byResource",blockHandler = "handleException")
    public CommonResult byResource()
    {
        return new CommonResult(200,"按资源名称限流测试OK",new Payment(2020L,"serial001"));
    }
    public CommonResult handleException(BlockException exception)
    {
        return new CommonResult(444,exception.getClass().getCanonicalName()+"t 服务不可用");
    }
 


    主启动

package com.atguigu.springcloud.alibaba;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;


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

}
 


  配置流控规则
    配置步骤

在这里插入图片描述

    图形配置和代码关系
    表示1秒钟内查询次数大于1，就跑到我们自定义的处流，限流
  测试
    1秒钟点击1下，OK
    超过上述问题，疯狂点击，返回了自己定义的限流处理信息，限流发送

在这里插入图片描述

  额外问题
    此时关闭微服务8401看看
    Sentinel控制台，流控规则消失了？？？？？
      临时/持久？
按照Url地址限流+后续处理
  通过访问的URL来限流，会返回Sentinel自带默认的限流处理信息
  业务类RateLimitController

@GetMapping("/rateLimit/byUrl")
@SentinelResource(value = "byUrl")
public CommonResult byUrl()
{
    return new CommonResult(200,"按url限流测试OK",new Payment(2020L,"serial002"));
}
 


  访问一次
  Sentinel控制台配置

在这里插入图片描述

  测试
    疯狂点击http://localhost:8401/rateLimit/byUrl
    结果

在这里插入图片描述

上面兜底方法面临的问题

在这里插入图片描述

客户自定义限流处理逻辑
  创建customerBlockHandler类用于自定义限流处理逻辑
  自定义限流处理类

在这里插入图片描述


package com.atguigu.springcloud.alibaba.myhandler;

import com.alibaba.csp.sentinel.slots.block.BlockException;
import com.atguigu.springcloud.entities.*;

public class CustomerBlockHandler {

    public static CommonResult handleException(BlockException exception) {
        return new CommonResult(2020, "自定义限流处理信息....CustomerBlockHandler");

    }
}
 
 


    CustomerBlockHandler
  RateLimitController

@GetMapping("/rateLimit/customerBlockHandler")
@SentinelResource(value = "customerBlockHandler",
        blockHandlerClass = CustomerBlockHandler.class,
        blockHandler = "handlerException2")
public CommonResult customerBlockHandler()
{
    return new CommonResult(200,"按客戶自定义",new Payment(2020L,"serial003"));
}
 


  启动微服务后先调用一次
    http://localhost:8401/rateLimit/customerBlockHandler
  Sentinel控制台配置
  测试后我们自定义的出来了
  进一步说明

在这里插入图片描述

更多注解属性说明

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

  多说一句

在这里插入图片描述

  Sentinel主要有三个核心API
    SphU定义资源
    Tracer定义统计
    ContextUtil定义了上下文

3.6-SpringCloud Alibaba Sentinel 服务熔断

服务熔断功能
sentinel整合ribbon+openFeign+fallback
Ribbon系列
启动nacos和sentinel
提供者9003/9004
新建cloudalibaba-provider-payment9003/9004
POM
YML
记得修改不同的端口号
主启动
业务类
测试地址
http://localhost:9003/paymentSQL/1
消费者84
新建cloudalibaba-consumer-nacos-order84
POM
YML
主启动
业务类
ApplicationContextConfig
CircleBreakerController的全部源码
修改后请重启微服务
热部署对java代码级生效及时
对@SentinelResource注解内属性，有时效果不好
目的
fallback管运行异常
blockHandler管配置违规
测试地址
http://localhost:84/consumer/fallback/1
没有任何配置
给客户error页面，不友好
只配置fallback
编码（那个业务类下面的CircleBreakerController的全部源码）
只配置blockHandler
编码（那个业务类下面的CircleBreakerController的全部源码）
fallback和blockHandler都配置
结果
忽略属性…
编码（那个业务类下面的CircleBreakerController的全部源码）
图说
Feign系列
修改84模块
POM
YML
业务类
带@FeignClient注解的业务接口
fallback = PaymentFallbackService.class
PaymentFallbackService实现类
Controller
主启动
添加@EnableFeignClients启动Feign的功能
http://lcoalhost:84/consumer/openfeign/1
http://lcoalhost:84/consumer/paymentSQL/1
测试84调用9003，此时故意关闭9003微服务提供者，看84消费侧自动降级，不会被耗死
熔断框架比较
在这里插入图片描述
在这里插入图片描述

3.7SpringCloud Alibaba Sentinel 规则持久化

规则持久化
是什么
一旦我们重启应用，Sentinel规则将消失，生产环境需要将配置规则进行持久化
怎么玩
将限流配置规则持久化进Nacos保存，只要刷新8401某个rest地址，sentinel控制台的流控规则就能看到，只要Nacos里面的配置不删除，针对8401上Sentinel上的流控规则持续有效
步骤
修改cloudalibaba-sentinel-service8401
POM

<dependency>
    <groupId>com.alibaba.csp</groupId>
    <artifactId>sentinel-datasource-nacos</artifactId>
</dependency>
 


  YML

server:
  port: 8401

spring:
  application:
    name: cloudalibaba-sentinel-service
  cloud:
    nacos:
      discovery:
        server-addr: localhost:8848 #Nacos服务注册中心地址
    sentinel:
      transport:
        dashboard: localhost:8080 #配置Sentinel dashboard地址
        port: 8719
      datasource:
        ds1:
          nacos:
            server-addr: localhost:8848
            dataId: cloudalibaba-sentinel-service
            groupId: DEFAULT_GROUP
            data-type: json
            rule-type: flow

management:
  endpoints:
    web:
      exposure:
        include: '*'

feign:
  sentinel:
    enabled: true # 激活Sentinel对Feign的支持


 
 


    添加Nacos数据源配置

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

  添加Nacos业务规则配置
    内容解析
  启动8401后刷新sentinel发现业务规则有了
  快速访问测试接口
    http://localhost:8401/rateLimit/byUrl
    默认
  停止8401再看sentinel
  重新启动8401再看sentinel
    扎一看还是没有，稍等一会儿
    多次调用
      http://localhost:8401/rateLimit/byUrl
    重新配置出现了，持久化验证通过

最后

以上就是谦让火车为你收集整理的SpringCloud Alibaba Sentinel 服务熔断与限流1-SpringCloud Alibaba Sentinel 概述2-SpringCloud Alibaba Sentinel 安装3-SpringCloud Alibaba Sentinel 配置的全部内容，希望文章能够帮你解决SpringCloud Alibaba Sentinel 服务熔断与限流1-SpringCloud Alibaba Sentinel 概述2-SpringCloud Alibaba Sentinel 安装3-SpringCloud Alibaba Sentinel 配置所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。

本图文内容来源于网友提供，作为学习参考使用，或来自网络收集整理，版权属于原作者所有。
点赞(49)

相关文章

Spring Cloud使用Sentinel做为Feign的熔断器之Fallback统一处理
Spring Cloud使用Sentinel做为Feign的熔断器之Fallback统一处理
SpringCloud Alibaba微服务中Sentinel整合ribbon+openFeign
SpringCloud Alibaba微服务中Sentinel整合ribbon+openFeign
Sentinel限流逻辑
Sentinel限流逻辑
Feign整合Sentinel实现容错1 引入sentinel的依赖2 在配置文件中开启Feign对Sentinel的支持3 创建容错类4 为被容错的interface指定容错类（容错工厂类）5 修改controller6 进行测试
Feign整合Sentinel实现容错1 引入sentinel的依赖2 在配置文件中开启Feign对Sentinel的支持3 创建容错类4 为被容错的interface指定容错类（容错工厂类）5 修改controller6 进行测试
SpringCloud Alibaba Sentinel 服务熔断与限流1-SpringCloud Alibaba Sentinel 概述2-SpringCloud Alibaba Sentinel 安装3-SpringCloud Alibaba Sentinel 配置
SpringCloud Alibaba Sentinel 服务熔断与限流1-SpringCloud Alibaba Sentinel 概述2-SpringCloud Alibaba Sentinel 安装3-SpringCloud Alibaba Sentinel 配置
抽象方法错误：com.alibaba.cloud.sentinel.feign.SentinelContractHolder.parseAndValidatateMetadata解决办法
抽象方法错误：com.alibaba.cloud.sentinel.feign.SentinelContractHolder.parseAndValidatateMetadata解决办法
feign 整合sentinel_Spring Cloud Alibaba Sentinel对Feign的支持
feign 整合sentinel_Spring Cloud Alibaba Sentinel对Feign的支持
19. Sentinel 主流框架适配
19. Sentinel 主流框架适配

评论列表共有 0 条评论

立即
投稿
返回
顶部