Sentinel的熔断降级、资源规则详解与实例

 更新时间:2023年09月12日 10:30:35   作者:小威要向诸佬学习呀  
这篇文章主要介绍了Sentinel的熔断降级、资源规则详解与实例,Sentinel是阿里巴巴开源的一款流量控制和熔断降级的框架,它主要用于保护分布式系统中的服务稳定性,Sentinel通过对服务进行流量控制和熔断降级,可以有效地保护系统的稳定性,需要的朋友可以参考下

Sentinel资源和规则

Sentinel是阿里巴巴开源的一款流量控制和熔断降级的框架,它主要用于保护分布式系统中的服务稳定性。在分布式系统中,当某个服务出现故障或者异常时,可能会导致整个系统的不稳定,甚至会引起系统的崩溃。

Sentinel通过对服务进行流量控制和熔断降级,可以有效地保护系统的稳定性。

  1. 熔断降级是Sentinel的主要功能之一,它通过对服务进行监控和限流,当服务出现异常或者超时时,会自动触发熔断降级策略,将请求流量转移到备用的服务上,从而避免整个系统的崩溃。在Sentinel中,可以通过定义资源和规则来实现熔断降级功能。
  2. 资源是指需要进行流量控制和熔断降级的服务或者方法,可以是一个HTTP接口、一个RPC接口、一个数据库访问、一个MQ消费等等。在Sentinel中,可以通过定义资源来对服务进行监控和限流。
  3. 规则是指对资源进行流量控制和熔断降级的策略,可以定义在资源级别或者全局级别。在Sentinel中,可以通过定义规则来实现熔断降级功能。规则可以包括以下几种类型:
  • 流控规则:用于限制资源的访问流量,包括QPS、线程数、并发数等等。
  • 熔断规则:用于对资源进行熔断降级,当资源出现异常或者超时时,会自动触发熔断降级策略,将请求流量转移到备用的服务上。
  • 降级规则:用于对资源进行降级处理,当资源出现异常或者超时时,会自动触发降级处理策略,返回默认值或者错误信息。

下面是一个简单的Sentinel示例,演示如何定义资源和规则来实现熔断降级功能:

定义资源

@SentinelResource(value = "hello", blockHandler = "handleBlock")
public String hello(String name) {
    return "Hello " + name;
}
public String handleBlock(String name, BlockException ex) {
    return "Blocked by Sentinel: " + ex.getClass().getSimpleName();
}

在上面的代码中,我们定义了一个名为hello的资源,用于处理一个名为name的参数,并返回一个字符串。同时,我们还定义了一个名为handleBlock的方法,用于处理资源被限流或者熔断降级时的情况。

定义规则

FlowRule rule = new FlowRule();
rule.setResource("hello");
rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
rule.setCount(10);
FlowRuleManager.loadRules(Collections.singletonList(rule));

在上面的代码中,我们定义了一个流控规则,用于限制资源hello的QPS为10。同时,我们通过FlowRuleManager.loadRules方法将规则加载到Sentinel中。

通过上面的示例,我们可以看到,Sentinel通过定义资源和规则来实现熔断降级功能,从而保护系统的稳定性。同时,Sentinel还提供了丰富的监控和报警功能,可以帮助开发人员及时发现和解决系统中的问题。

Sentinel实际案例使用

假设我们有一个分布式系统,其中包含一个名为“order”的服务,它提供了一个名为“createOrder”的API,用于创建订单。我们想要使用Sentinel来保护这个API,以避免系统被恶意攻击。

首先,我们需要定义一个资源,用于表示“createOrder”API。我们可以使用Sentinel提供的@SentinelResource注解来定义这个资源。以下是一个示例代码:

@SentinelResource(value = "createOrder", blockHandler = "handleCreateOrderBlock")
public void createOrder() {
    // 实现创建订单的逻辑
}
public void handleCreateOrderBlock(BlockException ex) {
    // 处理被限流或降级的情况
}

在上面的代码中,我们使用@SentinelResource注解来定义了一个名为“createOrder”的资源。该注解还指定了一个名为“handleCreateOrderBlock”的方法,用于处理被限流或降级的情况。

接下来,我们需要定义规则来保护这个资源。我们可以使用Sentinel提供的规则配置文件来定义规则。以下是一个示例规则配置文件:

[
  {
    "resource": "createOrder",
    "limitApp": "default",
    "grade": 1,
    "count": 10,
    "strategy": 0,
    "controlBehavior": 0,
    "clusterMode": false
  }
]

在上面的规则配置文件中,我们定义了一个名为“createOrder”的资源,并指定了以下规则:

  • limitApp:指定限流的应用程序,默认为"default"。
  • grade:指定限流的方式,0表示根据QPS限流,1表示根据并发线程数限流。
  • count:指定限流的阈值,当QPS或并发线程数超过该阈值时,将触发限流。
  • strategy:指定限流的策略,0表示快速失败,1表示匀速排队。
  • controlBehavior:指定限流的行为,0表示直接拒绝,1表示慢启动模式,2表示渐进式限流。
  • clusterMode:指定是否为集群模式,false表示单机模式。

通过以上的代码和规则配置文件,我们就可以使用Sentinel来保护我们的分布式系统中的资源免受各种类型的攻击。

Sentinel熔断降级规则

Sentinel熔断降级是一种流量控制的方式,通过对系统的流量进行监控和限制,可以防止系统因为流量过大而崩溃或者服务不可用的情况发生。在Sentinel中,熔断降级规则是用来控制系统流量的重要手段。

熔断降级规则主要包括以下几个方面:

  1. 阈值设定:设置触发熔断降级的阈值,例如QPS、响应时间等。
  2. 熔断模式:设置熔断触发后的处理方式,包括直接拒绝、慢调用比例限制、异常比例限制等。
  3. 熔断恢复:设置熔断触发后的恢复策略,包括半开状态等待时间、恢复成功率等。
  4. 降级处理:设置触发降级的条件和处理方式,例如限流、返回固定结果等。

Sentinel中的熔断降级规则可以通过代码或者配置文件的方式进行定义和配置。以下是一个示例代码,用于定义一个QPS阈值为100,熔断模式为异常比例限制,异常比例为50%的熔断降级规则:

public class SentinelDemo {
    public static void main(String[] args) {
        // 定义资源
        String resourceName = "com.example.demo.service.DemoService:hello(java.lang.String)";
        Entry entry = null;
        try {
            // 获取资源的entry
            entry = SphU.entry(resourceName);
            // 执行业务逻辑
            // ...
        } catch (BlockException e) {
            // 处理熔断降级逻辑
            // ...
        } finally {
            if (entry != null) {
                entry.exit();
            }
        }
    }
    // 定义熔断降级规则
    @PostConstruct
    public void initRules() {
        String resourceName = "com.example.demo.service.DemoService:hello(java.lang.String)";
        // 定义熔断降级规则
        List<FlowRule> rules = new ArrayList<>();
        FlowRule rule = new FlowRule();
        rule.setResource(resourceName);
        rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
        rule.setCount(100);
        rule.setLimitApp("default");
        rules.add(rule);
        DegradeRule degradeRule = new DegradeRule();
        degradeRule.setResource(resourceName);
        degradeRule.setCount(50);
        degradeRule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_RATIO);
        degradeRule.setTimeWindow(10);
        degradeRule.setMinRequestAmount(5);
        degradeRule.setStatIntervalMs(10000);
        degradeRule.setSlowRatioThreshold(0.5);
        DegradeRuleManager.loadRules(Collections.singletonList(degradeRule));
        FlowRuleManager.loadRules(rules);
    }
}

在以上代码中,我们通过定义资源名和规则来实现了熔断降级的功能。

其中,资源名是通过定义方法名和参数列表来确定的,规则则是通过FlowRule和DegradeRule类来定义的。

FlowRule用于定义流量控制规则,DegradeRule用于定义熔断降级规则

  • 在initRules方法中,我们通过FlowRuleManager和DegradeRuleManager来加载和管理规则。
  • 在main方法中,我们通过SphU.entry方法获取资源的entry,然后在try-catch语句块中执行业务逻辑。如果entry被BlockException捕获,说明触发了熔断降级规则,此时可以在catch语句块中处理熔断降级逻辑。最后,在finally语句块中,我们调用entry.exit()方法来释放资源。

到此这篇关于Sentinel的熔断降级、资源规则详解与实例的文章就介绍到这了,更多相关Sentinel熔断降级与资源规则内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • 关于@RequestParam的使用所遇到的404问题

    关于@RequestParam的使用所遇到的404问题

    这篇文章主要介绍了关于@RequestParam的使用所遇到的404问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-08-08
  • springboot+mybatis通过实体类自动生成数据库表的方法

    springboot+mybatis通过实体类自动生成数据库表的方法

    这篇文章主要介绍了springboot+mybatis通过实体类自动生成数据库表的方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-07-07
  • java日志LoggerFactory.getLogger的用法及说明

    java日志LoggerFactory.getLogger的用法及说明

    这篇文章主要介绍了java日志LoggerFactory.getLogger的用法及说明,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2023-02-02
  • Java使用Jdbc连接Oracle执行简单查询操作示例

    Java使用Jdbc连接Oracle执行简单查询操作示例

    这篇文章主要介绍了Java使用Jdbc连接Oracle执行简单查询操作,结合实例形式详细分析了java基于jdbc实现Oracle数据库的连接与查询相关操作技巧,需要的朋友可以参考下
    2019-09-09
  • Springboot @Import 详解

    Springboot @Import 详解

    这篇文章主要介绍了Springboot @Import 详解,仔细看了下Springboot关于@Import的处理过程,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2018-11-11
  • spring通过jdbc连接数据库

    spring通过jdbc连接数据库

    这篇文章主要为大家详细介绍了spring通过jdbc连接数据库的相关代码,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2019-08-08
  • SpringBoot升级3.2报错Invalid value type for attribute ‘factoryBeanObjectType‘: java.lang.String的解决方案

    SpringBoot升级3.2报错Invalid value type for 

    这篇文章给大家介绍了SpringBoot升级3.2报错Invalid value type for attribute ‘factoryBeanObjectType‘: java.lang.String的解决方案,文中有详细的原因分析,需要的朋友可以参考下
    2023-12-12
  • Java中replace、replaceAll和replaceFirst函数的用法小结

    Java中replace、replaceAll和replaceFirst函数的用法小结

    相信会java的同学估计都用过replace、replaceAll、replaceFirst这三个函数,可是,我们真的懂他们吗?下面通过这篇文章大家再来好好学习学习下这几个函数。
    2016-09-09
  • 吊打Java面试官之Lambda表达式 Stream API

    吊打Java面试官之Lambda表达式 Stream API

    这篇文章主要介绍了吊打Java之jdk8的新特性包括Lambda表达式、函数式接口、Stream API全面刨析,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2021-09-09
  • MongoDB整合Spring实例详细讲解(含代码)

    MongoDB整合Spring实例详细讲解(含代码)

    这篇文章主要介绍了MongoDB整合Spring实例详细讲解(含代码),小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-01-01

最新评论