阿里巴巴哨兵Sentinel简介 | Baeldung


顾名思义,Sentinel是微服务的强大后卫。它提供了流量控制,并发限制,电路中断和自适应系统保护等功能,以确保其可靠性。这是阿里巴巴集团积极维护的开源组件。此外,它正式是Spring Cloud Circuit Breaker的一部分
在本教程中,我们将了解Sentinel的一些主要功能。此外,我们将看到一个有关如何使用它,其注释支持以及其监视仪表板的示例。
Sentinel控制随机传入请求的速度,以避免微服务过载。这样可以确保我们的服务不会因流量激增而中断。它支持多种流量调整策略。当每秒查询数(QPS)太高时,这些策略会自动将流量调整为适当的形状。
这些流量整形策略包括:

  • 直接拒绝模式–当每秒请求数超过设置的阈值时,它将自动拒绝其他请求
  • 慢启动热身模式-如果流量突然激增,此模式可确保请求计数持续递增,直到达到上限

当一个服务同步调用另一个服务时,另一种服务可能由于某种原因而关闭。在这种情况下,线程将被阻塞,因为它们继续等待其他服务做出响应。这可能导致资源耗尽,并且呼叫者服务也将无法处理其他请求。这被称为级联效应,它可能会破坏我们的整个微服务体系结构。
断路器可防止此类情况,它将立即阻止对其他服务的所有后续调用。超时时间过后,一些请求将通过。如果它们成功,则断路器将恢复正常流量。否则,超时时间将再次开始。
Sentinel使用最大并发限制的原理来实现断路。通过限制并发线程数,它减少了不稳定资源的影响。
Sentinel还会降级不稳定的资源。当资源的响应时间过长时,将在指定的时间窗口中拒绝对资源的所有调用。这样可以防止呼叫变得非常慢的情况,从而导致级联效果。
如果系统负载过高,Sentinel可以保护我们的服务器。它使用load1(系统负载)作为度量标准来启动流量控制。在以下情况下,该请求将被阻止:
  • 当前系统负载(load1)>阈值(maximumSystemLoad);
  • 当前并发请求(线程数)>估计容量(最小响应时间*最大QPS)

 
添加Maven依赖:
<dependency>
    <groupId>com.alibaba.csp</groupId>
    <artifactId>sentinel-core</artifactId>
    <version>1.8.0</version>
</dependency>

让我们使用Sentinel API在try-catch 块中用相应的业务逻辑定义资源:
try (Entry entry = SphU.entry("HelloWorld")) {
   
// Our business logic here.
    System.out.println(
"hello world");
} catch (BlockException e) {
   
// Handle rejected request.
}

这个try-catch代码与资源名称“HelloWorld”的区块,作为切入点,我们的业务逻辑,由哨兵Sentinel把守。
 
定义流控制规则

这些规则控制着流向我们资源的流量,例如阈值计数或控制行为,例如,直接拒绝或启动缓慢。让我们使用FlowRuleManager.loadRules()来配置流规则:
List<FlowRule> flowRules = new ArrayList<>();
FlowRule flowRule = new FlowRule();
flowRule.setResource(RESOURCE_NAME);
flowRule.setGrade(RuleConstant.FLOW_GRADE_QPS);
flowRule.setCount(1);
flowRules.add(flowRule);
FlowRuleManager.loadRules(flowRules);

此规则定义我们的资源“ RESOURCE_NAME”每秒最多可以响应一个请求。
 
定义降级规则
使用降级规则,我们可以配置断路器的阈值请求计数,恢复超时和其他设置。让我们使用DegradeRuleManager.loadRules()配置降级规则:

List<DegradeRule> rules = new ArrayList<DegradeRule>();
DegradeRule rule = new DegradeRule();
rule.setResource(RESOURCE_NAME);
rule.setCount(10);
rule.setTimeWindow(10);
rules.add(rule);
DegradeRuleManager.loadRules(rules);

此规则指定当我们的资源RESOURCE_NAME无法满足10个请求(阈值计数)时,电路将断开。Sentinel将阻止对该资源的所有后续请求10秒钟(时间窗口)。
 
定义系统保护规则
使用系统保护规则,我们可以配置并确保自适应系统保护(load1的阈值,平均响应时间,并发线程数)。让我们使用SystemRuleManager.loadRules()方法配置系统规则:
List<SystemRule> rules = new ArrayList<>();
SystemRule rule = new SystemRule();
rule.setHighestSystemLoad(10);
rules.add(rule);
SystemRuleManager.loadRules(rules);

该规则指定,对于我们的系统,最高的系统负载是每秒10个请求。如果当前负载超过此阈值,则所有其他请求都将被阻止。

 
Sentinel还提供了一个监视仪表板。这样,我们可以监视客户端并动态配置规则。我们可以实时查看到我们定义的资源的传入流量。需要下载Sentinel Dashboard jar。然后,我们可以使用以下命令启动仪表板:

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

在我们的pom.xml中添加sentinel-transport-simple-http依赖项:
<dependency>
    <groupId>com.alibaba.csp</groupId>
    <artifactId>sentinel-transport-simple-http</artifactId>
    <version>1.8.0</version>
</dependency>

启动应用程序时,我们需要添加仪表板IP地址:
-Dcsp.sentinel.dashboard.server=consoleIp:port

现在,无论何时调用资源,仪表板都会从我们的应用程序接收到心跳信号。还可以使用仪表板动态地控制流程,降级和系统规则。
相应的示例可以在GitHub上找到
相关:
Spring Cloud Gateway的API速率限制