Sentinel的使用分析

本篇文章给大家分享的是有关Sentinel的使用分析，小编觉得挺实用的，因此分享给大家学习，希望大家阅读完这篇文章后可以有所收获，话不多说，跟着小编一起来看看吧。

成都创新互联的客户来自各行各业，为了共同目标，我们在工作上密切配合，从创业型小企业到企事业单位，感谢他们对我们的要求，感谢他们从不同领域给我们带来的挑战，让我们激情的团队有机会用头脑与智慧不断的给客户带来惊喜。专业领域包括成都网站设计、成都做网站、电商网站开发、微信营销、系统平台开发。

Sentinel能用来做什么？

限流
熔断降级
流量塑形
系统负载保护
热点防护详细概念介绍请阅读：https://github.com/alibaba/Sentinel/wiki/%E4%B8%BB%E9%A1%B5

Sentinel基本概念

资源

资源是 Sentinel 的关键概念。它可以是 Java 应用程序中的任何内容，例如，由应用程序提供的服务，或由应用程序调用的其它应用提供的服务，甚至可以是一段代码。在接下来的文档中，我们都会用资源来描述代码块。只要通过 Sentinel API 定义的代码，就是资源，能够被 Sentinel 保护起来。大部分情况下，可以使用方法签名，URL，甚至服务名称作为资源名来标示资源。

规则

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

使用Sentinel

引入 Sentinel 依赖


    com.alibaba.csp
    sentinel-core
    1.8.0

定义资源和设置规则

以下代码将一段Java方法定义为保护资源，规则设置为每秒钟访问1次，通过控制台输出内容可以发现Sentinel生效。

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

        while (true) {
            // 1.5.0 版本开始可以直接利用 try-with-resources 特性，自动 exit entry
            try (Entry entry = SphU.entry("sentinel-test1")) {
                // 被保护的业务逻辑
                System.out.println("业务资源访问成功！");
            } catch (BlockException ex) {
                // 处理被流控的逻辑
                System.out.println("资源访问失败！！！");
            }
            try {
                Thread.sleep(500);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    private static void initFlowRules(){
        List rules = new ArrayList<>();
        FlowRule rule = new FlowRule();
        rule.setResource("sentinel-test1");
        rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
        // Set limit QPS.
        rule.setCount(1);
        rules.add(rule);
        FlowRuleManager.loadRules(rules);
		}
}

定义资源的几种方法

抛出异常的方式定义资源

// 1.5.0 版本开始可以利用 try-with-resources 特性（使用有限制）
// 资源名可使用任意有业务语义的字符串，比如方法名、接口名或其它可唯一标识的字符串。
try (Entry entry = SphU.entry("resourceName")) {
  // 被保护的业务逻辑
  // do something here...
} catch (BlockException ex) {
  // 资源访问阻止，被限流或被降级
  // 在此处进行相应的处理操作
}

**注意： **

若 entry 的时候传入了热点参数，那么 exit 的时候也一定要带上对应的参数（exit(count, args)），否则可能会有统计错误。这个时候不能使用 try-with-resources 的方式。
通过 Tracer.trace(ex) 来统计异常信息时，由于 try-with-resources 语法中 catch 调用顺序的问题，会导致无法正确统计异常数，因此统计异常信息时也不能在 try-with-resources 的 catch 块中调用 Tracer.trace(ex)。

Entry entry = null;
// 务必保证 finally 会被执行
try {
  // 资源名可使用任意有业务语义的字符串，注意数目不能太多（超过 1K），超出几千请作为参数传入而不要直接作为资源名
  // EntryType 代表流量类型（inbound/outbound），其中系统规则只对 IN 类型的埋点生效
  entry = SphU.entry("自定义资源名");
  // 被保护的业务逻辑
  // do something...
} catch (BlockException ex) {
  // 资源访问阻止，被限流或被降级
  // 进行相应的处理操作
} catch (Exception ex) {
  // 若需要配置降级规则，需要通过这种方式记录业务异常
  Tracer.traceEntry(ex, entry);
} finally {
  // 务必保证 exit，务必保证每个 entry 与 exit 配对
  if (entry != null) {
    entry.exit();
  }
}

热点参数埋点示例：

Entry entry = null;
try {
    // 若需要配置例外项，则传入的参数只支持基本类型。
    // EntryType 代表流量类型，其中系统规则只对 IN 类型的埋点生效
    // count 大多数情况都填 1，代表统计为一次调用。
    entry = SphU.entry(resourceName, EntryType.IN, 1, paramA, paramB);
    // Your logic here.
} catch (BlockException ex) {
    // Handle request rejection.
} finally {
    // 注意：exit 的时候也一定要带上对应的参数，否则可能会有统计错误。
    if (entry != null) {
        entry.exit(1, paramA, paramB);
    }
}

返回布尔值方式定义资源

// 资源名可使用任意有业务语义的字符串
  if (SphO.entry("自定义资源名")) {
    // 务必保证finally会被执行
    try {
      /**
      * 被保护的业务逻辑
      */
    } finally {
      SphO.exit();
    }
  } else {
    // 资源访问阻止，被限流或被降级
    // 进行相应的处理操作
  }

**注意：**SphO.entry(xxx) 需要与 SphO.exit()方法成对出现，匹配调用，位置正确，否则会导致调用链记录异常，抛出ErrorEntryFreeException` 异常。

注解方式定义资源

// 原本的业务方法
// 配置 blockHandler 和 fallback 函数来进行限流之后的处理
@SentinelResource(value="资源名称", 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");
}

详细文档：https://github.com/alibaba/Sentinel/wiki/%E6%B3%A8%E8%A7%A3%E6%94%AF%E6%8C%81

异步调用定义资源

try {
    AsyncEntry entry = SphU.asyncEntry(resourceName);

    // 异步调用.
    doAsync(userId, result -> {
        try {
            // 在此处处理异步调用的结果.
        } finally {
            // 在回调结束后 exit.
            entry.exit();
        }
    });
} catch (BlockException ex) {
    // Request blocked.
    // Handle the exception (e.g. retry or fallback).
}

规则的种类

流量控制规则 (FlowRule)

通过代码定义流量控制规则：

private void initFlowQpsRule() {
    List rules = new ArrayList<>();
    FlowRule rule = new FlowRule(resourceName);
    // set limit qps to 20
    rule.setCount(20);
    rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
    rule.setLimitApp("default");
    rules.add(rule);
    FlowRuleManager.loadRules(rules);
}

**注意：**同一个资源可以同时有多个限流规则，检查规则时会依次检查。详细参考文档：https://github.com/alibaba/Sentinel/wiki/%E6%B5%81%E9%87%8F%E6%8E%A7%E5%88%B6

熔断降级规则 (DegradeRule)

通过代码定义熔断降级规则：

private void initDegradeRule() {
    List rules = new ArrayList<>();
    DegradeRule rule = new DegradeRule();
    rule.setResource(KEY);
    // set threshold RT, 10 ms
    rule.setCount(10);
    rule.setGrade(RuleConstant.DEGRADE_GRADE_RT);
    rule.setTimeWindow(10);
    rules.add(rule);
    DegradeRuleManager.loadRules(rules);
}

**注意：**同一个资源可以同时有多个降级规则。详细参考文档：https://github.com/alibaba/Sentinel/wiki/%E7%86%94%E6%96%AD%E9%99%8D%E7%BA%A7

系统保护规则 (SystemRule)

通过代码定义系统保护规则：

private void initSystemRule() {
    List rules = new ArrayList<>();
    SystemRule rule = new SystemRule();
    rule.setHighestSystemLoad(10);
    rules.add(rule);
    SystemRuleManager.loadRules(rules);
}

**注意：**系统规则只针对入口资源（EntryType=IN）生效。详细参考文档：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

访问控制规则 (AuthorityRule)

很多时候，我们需要根据调用方来限制资源是否通过，这时候可以使用 Sentinel 的访问控制（黑白名单）的功能。黑白名单根据资源的请求来源（origin）限制资源是否通过，若配置白名单则只有请求来源位于白名单内时才可通过；若配置黑名单则请求来源位于黑名单时不通过，其余的请求通过。授权规则，即黑白名单规则（AuthorityRule）非常简单，主要有以下配置项：

resource：资源名，即规则的作用对象
limitApp：对应的黑名单/白名单，不同 origin 用 , 分隔，如 appA,appB
strategy：限制模式，AUTHORITY_WHITE 为白名单模式，AUTHORITY_BLACK 为黑名单模式，默认为白名单模式通过代码定义访问控制规则：

private void initAuthorityRule() {
    AuthorityRule rule = new AuthorityRule();
		rule.setResource("test");
		rule.setStrategy(RuleConstant.AUTHORITY_WHITE);
		rule.setLimitApp("appA,appB");
		AuthorityRuleManager.loadRules(Collections.singletonList(rule));
}

Sentinel Dashboard控制台的启动

从https://github.com/alibaba/Sentinel/releases下载jar包使用如下命令启动：

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

-Dserver.port参数指定控制台端口号 -Dcsp.sentinel.dashboard.server参数指定控制台服务地址 -Dproject.name参数指定项目名访问指定服务地址，用户名、密码都是sentinel

Spring Boot项目连接控制台

添加依赖：


			org.springframework.cloud
			spring-cloud-starter-alibaba-sentinel
			0.9.0.RELEASE

在application.yaml中进行简单的配置：

spring:
  cloud:
    sentinel:
      transport:
        dashboard: localhost:8080 // 控制台地址
  application:
    name: sentinel-demo // 在控制台中项目的名字

server:
  port: 9090

依赖自动识别HTTP协议的接口，在簇点链路中可以看到。在后面的操作按钮中可以进行各种规则限制。 Sentinel的使用分析

以上就是Sentinel的使用分析，小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注创新互联行业资讯频道。

新闻名称：Sentinel的使用分析
链接地址：http://chengdu.cdxwcx.cn/article/pjjeej.html

甜橘子，专注成都网站制作网站设计与营销型网站建设与优化

首页

网站建设

网站制作案例

解决方案

网站设计报价

网站制作动态

关于我们

联系我们

成都网站建设设计将想法与焦点和您一起共享

Sentinel的使用分析

Sentinel能用来做什么？

Sentinel基本概念

资源

规则

使用Sentinel

引入 Sentinel 依赖

定义资源和设置规则

定义资源的几种方法

抛出异常的方式定义资源

返回布尔值方式定义资源

注解方式定义资源

异步调用定义资源

规则的种类

流量控制规则 (FlowRule)

熔断降级规则 (DegradeRule)

系统保护规则 (SystemRule)

访问控制规则 (AuthorityRule)

Sentinel Dashboard控制台的启动

Spring Boot项目连接控制台

其他资讯

合肥短视频运营好吗工资

抖音账号短视频带货运营(抖音账号直播短视频带货要怎么做？)

天津短视频代运营费用多少

河北电商抖音代运营工作室加盟

代运营短视频流程怎么做

甜橘子，专注成都网站制作网站设计与营销型网站建设与优化

成都网站建设设计 将想法与焦点和您一起共享

Sentinel的使用分析

Sentinel能用来做什么？

Sentinel基本概念

资源

规则

使用Sentinel

引入 Sentinel 依赖

定义资源和设置规则

定义资源的几种方法

抛出异常的方式定义资源

返回布尔值方式定义资源

注解方式定义资源

异步调用定义资源

规则的种类

流量控制规则 (FlowRule)

熔断降级规则 (DegradeRule)

系统保护规则 (SystemRule)

访问控制规则 (AuthorityRule)

Sentinel Dashboard控制台的启动

Spring Boot项目连接控制台

其他资讯

合肥短视频运营好吗工资

抖音账号短视频带货运营(抖音账号直播短视频带货要怎么做？)

天津短视频代运营费用多少

河北电商抖音代运营工作室加盟

代运营短视频流程怎么做

成都网站建设设计将想法与焦点和您一起共享