Sentinel从入门到“精通”，从源码层面学习Sentinel

news2025/1/20 15:42:44

B站视频讲解


文章目录

  • 一、安装
    • 1、原生使用
    • 2、dashboard整合
      • 2-1、非starter整合
        • 2-1-1、公共
        • 2-1-2、Filter
        • 2-1-3、AOP
        • 2-2、starter 整合
    • 3、总结
  • 二、常见的策略
    • 1、限流
      • 1-1、基于QPS 限流
      • 1-2、基于线程数限流
    • 2、降级
      • 2-1、慢调用比例
      • 2-2、异常数（限流异常不算）
      • 2-3、异常比例（限流异常不算）
    • 3、黑白名单
    • 4、其它
  • 三、全局异常拦截
    • 1、对拦截器方式的全局异常处理
      • 1-2、验证拦截器和AOP的双重拦截
    • 3、对AOP方式的全局异常拦截
  • 四、规则持久化


一、安装


Sentinel 是一个嵌入式的限流框架，所以可以在某个服务中引入它，然后用侵入式的方式去编写限流策略，这当然不是我们想要的，所以它也提供了基于控制台来实时编写限流策略（猜测是基于动态的添加代理和删除代理来实现，后续研究），只需要在代码中引入核心包，然后搭配控制台就可以实时的开启/关闭限流。

  • 资源：在Sentinel的世界里任何想要被限制的【代码块】都可以称之为资源

1、原生使用


所谓原生使用就是不搭配控制台。

<dependency>
    <groupId>com.alibaba.csp</groupId>
    <artifactId>sentinel-core</artifactId>
    <version>1.8.6</version>
</dependency>

Demo 代码

import com.alibaba.csp.sentinel.Entry;
import com.alibaba.csp.sentinel.SphU;
import com.alibaba.csp.sentinel.slots.block.BlockException;
import com.alibaba.csp.sentinel.slots.block.RuleConstant;
import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;
import com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager;

import java.util.ArrayList;
import java.util.List;

public class Main {
    public static void main(String[] args) throws InterruptedException {
        // 配置规则.
        initFlowRules();

        while (true) {
            // 1.5.0 版本开始可以直接利用 try-with-resources 特性
            try (Entry entry = SphU.entry("HelloWorld")) {
                // 被保护的逻辑
                System.out.println("hello world");
            } catch (BlockException ex) {
                // 处理被流控的逻辑
                System.out.println("blocked!");
            }
            // 防止打印太多了
            Thread.sleep(900);
        }
    }

    private static void initFlowRules(){
        List<FlowRule> rules = new ArrayList<>();
        FlowRule rule = new FlowRule();
        rule.setResource("HelloWorld");
        rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
        // 限制QPS 为 1个
        rule.setCount(1);
        rules.add(rule);
        FlowRuleManager.loadRules(rules);
    }
}

2、dashboard整合


正常情况，我们不会使用原生方式，代码侵入性太强了，可以搭配 dashboard来动态的添加/删除规则。

dashboard本身就是一个SpringBoot 项目，jar包下载地址


java -jar 启动

在这里插入图片描述


http://127.0.0.1:8080

默认账号密码：sentinel/sentinel

在这里插入图片描述


2-1、非starter整合


2-1-1、公共

通过上面原生使用方式，得知它的本质其实就和加锁差不多，是有代码侵入性的。在JavaWeb里面如果想实现一个通用的功能并且代码无侵入性的话，Filter和AOP是不错的选择。

在进行Filter和AOP实践之前，先来搭建公共的模块。


pom

<!-- 核心包 -->
<dependency>
    <groupId>com.alibaba.csp</groupId>
    <artifactId>sentinel-core</artifactId>
    <version>1.8.6</version>
</dependency>

<!-- 连接客户端，和dashboard交互 -->
<dependency>
    <groupId>com.alibaba.csp</groupId>
    <artifactId>sentinel-transport-simple-http</artifactId>
    <version>1.8.6</version>
</dependency>

测试类

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

@RestController
public class Controller {

    @GetMapping("/one")
    public String one() {
        return "ok";
    }
}

启动的时候加上配置sentinel 的地址 -Dcsp.sentinel.dashboard.server=127.0.0.1:8080


配置入口

在这里插入图片描述


Idea 旧版

在这里插入图片描述


Idea 新版

在这里插入图片描述


Sentinel 是懒加载的，不管使用什么方式，服务启动之后都必须访问 /one 才可以被dashboard监控到


2-1-2、Filter

1、pom文件引入

<dependency>
    <groupId>com.alibaba.csp</groupId>
    <artifactId>sentinel-web-servlet</artifactId>
    <version>1.8.6</version>
</dependency>

2、引入过滤器

在Filter里面加一个优先级很高的 CommonFilter

import com.alibaba.csp.sentinel.adapter.servlet.CommonFilter;
import org.springframework.boot.web.servlet.FilterRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.servlet.Filter;

@Configuration
public class FilterConfig {

    @Bean
    public FilterRegistrationBean sentinelFilterRegistration() {
        FilterRegistrationBean<Filter> registration = new FilterRegistrationBean<>();
        registration.setFilter(new CommonFilter());
        registration.addUrlPatterns("/*");
        registration.setName("sentinelFilter");
        registration.setOrder(1);

        return registration;
    }
}

通过源码发现，其实它就是在执行之前调用了 entry 方法

在这里插入图片描述


2-1-3、AOP

1、pom文件引入

<dependency>
  <groupId>com.alibaba.csp</groupId>
    <artifactId>sentinel-annotation-aspectj</artifactId>
    <version>1.8.6</version>
</dependency>

2、开启代理

@Configuration
public class SentinelAspectConfiguration {
    @Bean
    public SentinelResourceAspect sentinelResourceAspect() {
        return new SentinelResourceAspect();
    }
}

3、定义资源

加上 @SentinelResource

@GetMapping("/one")
@SentinelResource("one")
public String fun() {
    return "one";
}

通过源码发现代理的方式其实也是一样的

在这里插入图片描述


2-2、starter 整合

1、pom文件引入

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

和SpringBoot对应的版本


2、yaml 文件

spring:
  application:
    name: version_11
  cloud:
    sentinel:
      transport:
        dashboard: 127.0.0.1:8080
      eager: true

3、测试代码

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

@RestController
public class Controller {

    @GetMapping("/two")
    public String fun2() {

        return "ok";
    }
}

可以看到使用Starter的方式极其简单，它会把所有的请求都映射成资源。限流结果：

在这里插入图片描述


按照以往的经验，使用stater增强功能的时候，只需要大致看看stater中的 spring.factory 注入了什么，然后依次去看看每个注入带来什么功能

在这里插入图片描述


在SentinelWebAutoConfiguration中注入了一个SentinelWebInterceptor，它里面的 preHandle 方法如下：
在这里插入图片描述


3、总结


Sentinel提出了资源的概念，不管是如何使用本质都是在访问某个“资源”之前，先进行 SphU.entry 。所以这个资源并不一定是接口，可以是我们想要限制的任何代码。

可能有人好奇为啥dashboard 可以实时的添加/删除规则，如果熟悉代理的朋友应该知道，代理是可以动态的添加和删除的。

基于上面实践发现使用Sentinel的限流可以有四种方式

  1. 原生方式
  2. Filter
  3. Interceptor
  4. AOP

二、常见的策略


1、限流

1-1、基于QPS 限流

在这里插入图片描述


多次点击接口，会出现正常和500错误，500就说明被限制了

在这里插入图片描述


1-2、基于线程数限流

在这里插入图片描述

因为测试的demo响应时间在2ms，所以不好测试，在代码里面加上让线程睡眠 1s，就会看到限流异常

在这里插入图片描述


2、降级


当服务出现异常的时候（大部分是并发异常，业务异常基本是必现的），系统可能接受不了那么大的请求，这时候为了避免整个服务被击垮，需要有一个限制瓶颈，当触发这个瓶颈的时候，快速失败。


2-1、慢调用比例

在这里插入图片描述


2-2、异常数（限流异常不算）

在这里插入图片描述


2-3、异常比例（限流异常不算）

在这里插入图片描述


3、黑白名单


Sentinel 提供了一个方法来判断当前请求的服务方，可以基于这个方法去进行黑白名单的限制。

注：建议使用stater的方式这样就不需要单独引入很多包


加入判断请求来源的代码

@Component
public class MyRequestOriginParser implements RequestOriginParser {

        /**
         * 通过request获取来源标识，交给授权规则进行匹配
         * @param request
         * @return
         */
        @Override
        public String parseOrigin(HttpServletRequest request) {

            if (request.getHeader("x-forwarded-for") == null) {
                return request.getRemoteAddr();
            }

            return request.getHeader("x-forwarded-for");
        }
}

在这里插入图片描述

上面的配置就可以限制 127.0.0.1 的请求了。


4、其它


Sentinel的使用还有很多，包括但不限于下面的场景

  1. 可以在网关层面限制请求（可以配置nginx使用） nginx 使用
  2. 可以基于热点参数进行限制，这样就比接口层面更细了
  3. sentinel 官方文档

三、全局异常拦截


为何只是简单配置一个类就可以做到全局拦截？我们要知其然且知其所以然。


1、对拦截器方式的全局异常处理


使用 stater的方式，会同时开启 Interceptor、和AOP，上面已经知道AOP是基于自定义注解实现的，所以没有使用 @SentinelResource 的时候是不会有AOP的，就只有Interceptor。

熟悉SpringMVC流程的朋友应该知道，Filter > Interceptor > AOP，如果使用了@SentinelResource那就相当于两次限流了，相当于两道门。


通过Interceptor的前置拦截方法可以看到它把异常吞掉了，转而用 handleBlockException 去处理了
在这里插入图片描述


handleBlockException它里面是调用了一个 BlockExceptionHandler，实现它然后重写里面的 handle 方法，就可以做到全局自定义异常处理

@Component
public class MyBlockExceptionHandler implements BlockExceptionHandler {
    
    public MyBlockExceptionHandler() {
    }
    
    @Override
    public void handle(HttpServletRequest request, HttpServletResponse response, BlockException e) throws Exception {
        response.setStatus(429);
        PrintWriter out = response.getWriter();
        out.print("My Limiting");
        out.flush();
        out.close();
    }
}

1-2、验证拦截器和AOP的双重拦截


为了更好的帮助大家理解拦截器和AOP的双重拦截，在使用 stater的方式中，我在Controller上面加一个@SentinelResource注解，去Sentinel控制台看看资源情况

  1. /one 是拦截器定义的
  2. org.example.Controller:fun() 就是AOP定义的

在这里插入图片描述


对 org.example.Controller:fun() 限流错误提示为

在这里插入图片描述


对 /one 限流错误提示为

在这里插入图片描述


且当对两个资源同时限流，限流规则一样的时候，org.example.Controller:fun() 的限流不会触发，因为拦截器是在AOP的前面呀

为什么AOP拦截给资源取的名字是这个呢？通过源码可以看到，使用AOP的时候
会先获取注解上的 value做资源名，如果没有就会用方法的权限定名。

# com.alibaba.csp.sentinel.annotation.aspectj.SentinelResourceAspect#invokeResourceWithSentinel

String resourceName = this.getResourceName(annotation.value(), originMethod);
protected String getResourceName(String resourceName, Method method) {
    return StringUtil.isNotBlank(resourceName) ? resourceName : MethodUtil.resolveMethodName(method);
}

3、对AOP方式的全局异常拦截


使用@SentinelResource 的时候可以配置blockHandler和fallback 限流处理和失败处理，但如果我们没有配置的话，最后就会将异常抛出来。（这个流程可以直接一步步源代码看到，下面只给出入口）

在这里插入图片描述


既然是抛异常，又在Spring里面，那就简单了，搞一个全局异常处理器就好了

@ControllerAdvice
public class MyExceptionHandler {

    @ExceptionHandler(value =BlockException.class)
    @ResponseBody
    public String exceptionHandler(BlockException e){

        return "AOP Limiting";
    }
}

注：如果想对不同的资源进行不同的异常处理，那可以配置@SentinelResource 上面对应的blockHandler和fallback就好了，这个很简单。


拦截器是直接基于访问路径当成资源名的，比如上述demo中就是 /one，如果你很俏皮的设置了这样一个注解 @SentinelResource(“/one”) ，这样在控制台就只能看到一个资源了，但如果你对这个资源进行限流，相当于两道门都给限制了。


前面我们讲到有一个黑白名单的策略，在Filter和Interceptor的源码里都可以看到这一处理，但是在AOP中没有，所以要想使用这个功能的话，进行AOP资源限流是不可以的。


Filter

在这里插入图片描述


Interceptor

在这里插入图片描述


AOP

在这里插入图片描述


四、规则持久化


Sentinel 的持久化还是有些复杂的，单独写一篇文章来讲解

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

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

相关文章

《游戏引擎架构》--学习

《游戏引擎架构》--学习

内存管理 优化动态内存分配 维持最低限度的堆分配&#xff0c;并且永不在紧凑循环中使用堆分配 容器 迭代器 未完待续。。。
阅读更多...
深度学习与计算机视觉 | 实用CV开源项目汇总（有github代码链接，建议收藏！）

深度学习与计算机视觉 | 实用CV开源项目汇总（有github代码链接，建议收藏！）

本文来源公众号“深度学习与计算机视觉”&#xff0c;仅用于学术分享&#xff0c;侵权删&#xff0c;干货满满。 原文链接&#xff1a;【建议收藏】实用CV开源项目汇总&#xff08;文末有彩蛋~&#xff09; 01 Trace.moe 图像反向搜索动漫场景&#xff0c;使用动漫截图搜索该…
阅读更多...
债券专题二：可转债估值-二叉树模型

债券专题二：可转债估值-二叉树模型

1. 模型背景 由于可转债自身的属性较多&#xff0c;因此对其定价的难度也会加大&#xff0c;在诸多影响因素中&#xff0c;未来的股价占比最高。由于股价的不可预测性&#xff0c;导致了可转债的定价在实际交易中作用非常有限。随着可转债发行数量和规模的增大&#xff0c;越…
阅读更多...
PHP支持的伪协议

PHP支持的伪协议

php.ini参数设置 在php.ini里有两个重要的参数allow_url_fopen、allow_url_include。 allow_url_fopen:默认值是ON。允许url里的封装协议访问文件&#xff1b; allow_url_include:默认值是OFF。不允许包含url里的封装协议包含文件&#xff1b; 各协议的利用条件和方法 php:/…
阅读更多...
notepad++打开文本文件乱码的解决办法

notepad++打开文本文件乱码的解决办法

目录 第一步 在编码菜单栏下选择GB2312中文。如果已经选了忽略这一步 第二步 点击编码&#xff0c;红框圈出来的一个个试。我切换到UTF-8编码就正常了。 乱码如图。下面分享我的解决办法 第一步 在编码菜单栏下选择GB2312中文。如果已经选了忽略这一步 第二步 点击编码&#…
阅读更多...
伦敦金和现货黄金是一回事吗？

伦敦金和现货黄金是一回事吗？

想进入黄金市场的朋友&#xff0c;在网上一搜相关的讯息&#xff0c;可能就懵了。这个市场中好像有几个品种&#xff0c;又是伦敦金又是现货黄金什么的。很多新手投资者想知道&#xff0c;这些伦敦金、现货黄金分别是指什么&#xff0c;下面我们就来讨论一下。 实际上&#xff…
阅读更多...
Open CASCADE学习|曲线向曲面投影

Open CASCADE学习|曲线向曲面投影

在三维空间中&#xff0c;将曲线向曲面投影通常涉及复杂的几何计算。这个过程可以通过多种方法实现&#xff0c;但最常见的是使用数学和几何库&#xff0c;如OpenCASCADE&#xff0c;来处理这些计算。 在OpenCASCADE中&#xff0c;投影曲线到曲面通常涉及以下步骤&#xff1a;…
阅读更多...
Vue项目启动过程全记录（node.js运行环境搭建）

Vue项目启动过程全记录（node.js运行环境搭建）

一、安装node.js并配置环境变量 1、安装node.js 从Node.js官网下载安装包并安装。然后在安装后的目录&#xff08;如果是下载的压缩文件&#xff0c;则是解压缩的目录&#xff09;下新建node_global和node_cache这两个文件夹。 node_global&#xff1a;npm全局安装位置 node_…
阅读更多...
Python 字符串格式化输出

Python 字符串格式化输出

前些天发现了一个巨牛的人工智能学习网站&#xff0c;通俗易懂&#xff0c;风趣幽默&#xff0c;忍不住分享一下给大家。点击跳转到网站零基础入门的AI学习网站~。 前言 字符串格式化是编程中一个常见的需求&#xff0c;它可以们将不同类型的数据&#xff08;如数字、文本、日…
阅读更多...
【ansible】认识ansible，了解常用的模块

【ansible】认识ansible，了解常用的模块

目录 一、ansible是什么&#xff1f; 二、ansible的特点&#xff1f; 三、ansible与其他运维工具的对比 四、ansible的环境部署 第一步&#xff1a;配置主机清单 第二步&#xff1a;完成密钥对免密登录 五、ansible基于命令行完成常用的模块学习 模块1&#xff1a;comma…
阅读更多...
Shiro反弹shell和权限绕过含工具包

Shiro反弹shell和权限绕过含工具包

★★免责声明★★ 文章中涉及的程序(方法)可能带有攻击性&#xff0c;仅供安全研究与学习之用&#xff0c;读者将信息做其他用途&#xff0c;由Ta承担全部法律及连带责任&#xff0c;文章作者不承担任何法律及连带责任。 1、前言 反序列化漏洞原理和Shiro反序列化漏洞原理请参…
阅读更多...
AI绘画图生图怎么用？

AI绘画图生图怎么用？

AI绘画图生图是指利用人工智能技术&#xff0c;将一张已有的图片转化为另一张具有艺术风格的新图片的过程。这种技术可以应用于多个领域&#xff0c;如室内设计等。 在使用AI绘画图生图功能时&#xff0c;用户需要选择一张参考图片&#xff0c;然后设置生成图片的风格、尺寸、数…
阅读更多...
svg之全局组件，配合雪碧图解决vue2的svg优化问题

svg之全局组件，配合雪碧图解决vue2的svg优化问题

这里是vue2中的svg的完整解决方案的另一篇。 <template><svg :class"svgClass"><use :xlink:href"#${name}"></use></svg> </template><script>export default {name: icon,props: {name: {type: String,requi…
阅读更多...
Bonjour Print Services

Bonjour Print Services

Bonjour Print Services &#xff08;apple mobile&#xff09; https://download.csdn.net/download/spencer_tseng/88845785
阅读更多...
C++ 离散化 算法 （详解）+ 例题

C++ 离散化 算法 （详解）+ 例题

1、性质 把无限空间中有限的个体映射到有限的空间中去&#xff0c;以此提高算法的空间效率。通俗的说&#xff0c;离散化是在不改变数据相对大小的条件下&#xff0c;对数据进行相应的压缩。 适用范围&#xff1a;数的跨度很大&#xff0c;用的数很稀疏 例如&#xff1a;值域…
阅读更多...
Java实现Dfs算法（基本讲解）

Java实现Dfs算法（基本讲解）

目录 一、Dfs算法的概念 二、Dfs算法的设计步骤 三、Dfs算法模板 四、Dfs算法经典例题 &#xff08;1&#xff09;全排列 &#xff08;2&#xff09;N皇后 一、Dfs算法的概念 Depth First Search 即 DFS&#xff0c;意为深度优先搜索&#xff0c;是所有的搜索手段之一。它…
阅读更多...
[Flink03] Flink安装

[Flink03] Flink安装

本文介绍Flink的安装步骤&#xff0c;主要是Flink的独立部署模式&#xff0c;它不依赖其他平台。文中内容分为4块&#xff1a;前置准备、Flink本地模式搭建、Flink Standalone搭建、Flink Standalong HA搭建。 演示使用的Flink版本是1.15.4&#xff0c;官方文档地址&#xff1…
阅读更多...
Shellcode免杀对抗(C/C++)

Shellcode免杀对抗(C/C++)

Shellcode C/C免杀&#xff0c;绕过360安全卫士、火绒安全、Defender C/C基于cs/msf的上线 首先是测试一下shellcode上线&#xff0c;主要是俩种方法 测试环境 攻击机&#xff1a;kali2023 靶机&#xff1a;win10 msf方法 首先是启动msf msfconsole 然后msf生成一个sh…
阅读更多...
每日一题——LeetCode1460.通过翻转子数组使两个数组相等

每日一题——LeetCode1460.通过翻转子数组使两个数组相等

方法一 哈希Map 用两个Map集合分别统计target和arr里出现的元素和出现的次数&#xff0c;在比较两个Map集合看是否出现的元素和次数都相同 var canBeEqual function(target, arr) {let map1 new Map();let map2 new Map();for (let item of target) {map1.set(item, (map1…
阅读更多...
2.18号c++

2.18号c++

1.菱形继承 1.1 概念 菱形继承又称为钻石继承&#xff0c;是由公共基类派生出多个中间子类&#xff0c;又由多个中间子类共同派生出汇聚子类。汇聚子类会得到多份中间子类从公共基类继承下来的数据成员&#xff0c;会造成空间浪费&#xff0c;没有必要。 问题&#xff1a; …
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023