Sentinel如何拦截异常流量

这篇文章主要介绍“Sentinel如何拦截异常流量”，在日常操作中，相信很多人在Sentinel如何拦截异常流量问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”Sentinel如何拦截异常流量”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！

创新互联公司成都网站建设按需定制网站，是成都网站营销公司,为成都咖啡厅设计提供网站建设服务,有成熟的网站定制合作流程，提供网站定制设计服务：原型图制作、网站创意设计、前端HTML5制作、后台程序开发等。成都网站制作热线：028-86922220

各位在家里用电的过程中，一定也经历过「跳闸」。这个「闸」就是在电量超过负荷的时候用来保护我们用电安全的，也被称为「断路器」，还有个响亮的英文名 -- CircuitBreaker。

和用电安全一样，对于「限流」、「降级」、「熔断」...，你我应该也都耳熟能详。我们开发的各类软件、系统、互联网应用等为了不被异常流量压垮，也需要一个断路器。

在 Spring 应用中，使用断路器很方便，我们可以使用 Spring Cloud CircuitBreaker。

Spring Cloud Circuit Breaker 是啥？如果你熟悉 Spring 是什么人的话，你能猜个八九不离十。和Spring Data JPA 这些类似，Spring 他又搞了个抽象的，标准的API 出来。这次他抽象的是关于降级熔断的「断路器」。有了这一层，具体实现是谁可以方便的更换，我们使用的代码里改动基本为0。

我们先来从官方Demo有个初步印象：

@RestControllerpublic class DemoController {  private CircuitBreakerFactory circuitBreakerFactory;  private HttpBinService httpBin;  public DemoController(CircuitBreakerFactory circuitBreakerFactory, HttpBinService httpBinService) {    this.circuitBreakerFactory = circuitBreakerFactory;    this.httpBin = httpBinService;  }  @GetMapping("/delay/{seconds}")  public Map delay(@PathVariable int seconds) {    return circuitBreakerFactory.create("delay").run(httpBin.delaySuppplier(seconds), t -> {      Map fallback = new HashMap<>();      fallback.put("hello", "world");      return fallback;    });  }}

千言万语，总结出来这样一句circuitBreakerFactory.create("delay").run()

因为是抽象，对应的实现就有好多种啦。

目前支持的实现有：

Hystrix
Resilience4j
Sentinel
Spring Retry

而抽象相当于定了个标准，像JDBC一样，无论我们把数据库换成了MySQL，Oracle 还是SQLite，接口等非特定类型的代码都不需要改变。断路器也一样。

这里的断路器工厂，创建方法都是标准的。具体这里执行业务逻辑的时候断路器实现要怎样进行拦截降级，就可以交给具体的实现来完成。

这次，我们以开源的 Sentinel 为例，来看看他们是怎样拦住异常流量的。

首先，因为是Spring Cloud，所以还会基于 Spring Boot 的 Autoconfiguration。以下是配置类，我们看到生成了一个工厂。

public class SentinelCircuitBreakerAutoConfiguration {  @Bean  @ConditionalOnMissingBean(CircuitBreakerFactory.class)  public CircuitBreakerFactory sentinelCircuitBreakerFactory() {    return new SentinelCircuitBreakerFactory();  }  }

在我们实际代码执行逻辑的时候，create 出来的是什么呢？

是个断路器 CircuitBreaker，用来执行代码。

public interface CircuitBreaker {
  default  T run(Supplier toRun) {    return run(toRun, throwable -> {      throw new NoFallbackAvailableException("No fallback available.", throwable);    });  };   T run(Supplier toRun, Function fallback);}

包含两个执行的方法，需要在的时候可以指定fallback逻辑。具体到 Sentinel 是这样的：

  public CircuitBreaker create(String id) {    SentinelConfigBuilder.SentinelCircuitBreakerConfiguration conf = getConfigurations()        .computeIfAbsent(id, defaultConfiguration);    return new SentinelCircuitBreaker(id, conf.getEntryType(), conf.getRules());  }

你会看到创建了一个SentinelCircuitBreaker。我们的业务逻辑，就会在这个断路器里执行,run方法就是各个具体实现的舞台。

@Override  public  T run(Supplier toRun, Function fallback) {    Entry entry = null;    try {      entry = SphU.entry(resourceName, entryType);      // If the SphU.entry() does not throw `BlockException`, it means that the      // request can pass.      return toRun.get();    }    catch (BlockException ex) {      // SphU.entry() may throw BlockException which indicates that      // the request was rejected (flow control or circuit breaking triggered).      // So it should not be counted as the business exception.      return fallback.apply(ex);    }    catch (Exception ex) {      // For other kinds of exceptions, we'll trace the exception count via      // Tracer.trace(ex).      Tracer.trace(ex);      return fallback.apply(ex);    }    finally {      // Guarantee the invocation has been completed.      if (entry != null) {        entry.exit();      }    }  }

OK，到此为止， Spring Cloud CircuitBreaker 已经展现完了。其它的细节都放到了具体实现的「盒子」里。下面我们把这个盒子打开。

Sentinel 是个熔断降级框架，官方这样自我介绍：

面向分布式服务架构的高可用流量控制组件,主要以流量为切入点，从流量控制、熔断降级、系统自适应保护等多个维度来帮助用户保障微服务的稳定性。

Sentinel如何拦截异常流量

官网的这张代码截图简洁的说明了他是怎样工作的

Sentinel如何拦截异常流量

挡在业务代码的前面，有事儿先冲它来，能通过之后才走业务逻辑，和各类闯关还真类似。

在上面 CircuitBreaker 的 run 方法里，咱们一定都注意到了这句

entry = SphU.entry(resourceName, entryType);

这就是一切拦截的秘密。

无论我们是通过前面的CircuitBreaker的方式，还是 @SentinelResource 这种注解形式，还是通过 Interceptor 的方式，没什么本质区别。只是触发点不一样。最后都是通过SphU来搞定。

既然是拦截，那一定要拦下来做这样或那样的检查。

实际检查的时候，entry 里核心代码有这些：

 Entry entryWithPriority(ResourceWrapper resourceWrapper, ...)        throws BlockException {        ProcessorSlot

关于创新互联

Sentinel如何拦截异常流量

其他资讯