资讯

历史

科技

环境与自然

成长

游戏

财经

文学与艺术

美食

健康

家居

文化

情感

汽车

三农

军事

旅行

运动

教育

生活

星座命理

Sentinel详细使用教学

创作时间:

作者:

@小白创作中心

Sentinel详细使用教学

引用

CSDN

https://blog.csdn.net/weixin_62951914/article/details/145947193

Sentinel是阿里巴巴开源的流量控制组件，主要面向分布式、多语言异构化服务架构，从流量路由、流量控制、流量整形、熔断降级、系统自适应过载保护、热点流量防护等多个维度来帮助开发者保障微服务的稳定性。

1. 概念

随着微服务的流行，服务和服务之间的稳定性变得越来越重要。Sentinel 是面向分布式、多语言异构化服务架构的流量治理组件，主要以流量为切入点，从流量路由、流量控制、流量整形、熔断降级、系统自适应过载保护、热点流量防护等多个维度来帮助开发者保障微服务的稳定性。

流量路由，流量控制，流量整形：流量从另外一个角度，也叫请求。

2. 入门例子

0. 启动nacos和redis

1. 使用openfeign项目

2. 引入依赖

给两个项目都添加如下依赖：

<dependency>
  <groupId>com.alibaba.cloud</groupId>
  <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
<dependency>
  <groupId>com.alibaba.csp</groupId>
  <artifactId>sentinel-web-servlet</artifactId>
</dependency>

3. 下载sentinel服务

下载sentinel服务路径：https://github.com/alibaba/Sentinel/releases

注意版本号对应

我们用的是1.8.0版本，下载服务端时下载对应的版本。

4. 启动服务

执行java -jar sentinel-dashboard.jar

5. 登录sentinel

http://localhost:8080/#/login

用户名和密码都是sentinel。

6. 添加sentinel配置信息

给两个项目的application.yml配置文件里添加如下配置：

spring:
 cloud:
  sentinel:
   transport:
    dashboard: localhost:8080

7. 启动并访问两项目查看结果

【访问sentinel网站，设置限流】

注意：设置的单机阈（yu四声）（一秒钟访问的数量）值改为2，这样可以尽快看见限流。

【限流的效果】

一下一下点击访问的时候，还可以看见正常响应：

【概念了解】

【1、什么是QPS】

每秒请求的数量，要求发送请求并得到响应的整体时间。

【2、什么是RT】

响应时间。

【3、慢调用】

响应时间大于一定值。

【4、慢调用比例】

慢调用 / 总调用比例值。

【5、比例阈值】

输入0到1之间的浮点型，代表百分比，0是0%，1是100%。

3. 自定义流控响应

当被限流的时候，浏览器中展示的效果如下，用户体验度不好，可以进行以下操作。

1. 添加过滤器

在user工程里，添加此过滤器。

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 SentinelFilterConfig {
    @Bean
    public FilterRegistrationBean<Filter> filterFilterRegistrationBean(){
        FilterRegistrationBean<Filter> result = new FilterRegistrationBean<>(new CommonFilter());
        result.addUrlPatterns("/*");
        return result;
    }
}

2. 添加配置类

在user工程里，添加此过配置类。

import com.alibaba.csp.sentinel.adapter.servlet.callback.WebCallbackManager;
import com.alibaba.fastjson.JSON;
import org.jsoft.demo.utils.Result;
import org.springframework.context.annotation.Configuration;
@Configuration
public class SentinelConfig {
    public SentinelConfig() {
        WebCallbackManager.setUrlBlockHandler((request, response, e) -> {
            Result error = Result.error();
            error.setMessage("被限流了！");
            response.setCharacterEncoding("UTF-8");
            response.setContentType("text/html;charset=utf-8");
            response.getWriter().write(JSON.toJSONString(error));
        });
    }
}

3. 运行结果

重启user项目，重新添加流量阈值，查看运行结果。

4. 熔断feign

官方地址：https://github.com/alibaba/Sentinel/wiki/%E7%86%94%E6%96%AD%E9%99%8D%E7%BA%A7

1. 添加配置

在user工程里开启feign的sentinel，写properties文件中可以，写在yaml文件也可以

feign.sentinel.enabled=true

2. 修改feign接口注解

import org.jsoft.demo.feign.impl.ScoreFeignImpl;
import org.jsoft.demo.utils.Result;
import org.jsoft.demo.vo.User;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
@FeignClient(value = "demo-sentinel-s", fallback = ScoreFeignImpl.class) //fallback 一旦出现熔断，要走哪个类。
public interface ScoreFeign {
    @GetMapping("/score/info")
    Result info();
    @GetMapping("/score/{id}")
    Result id(@PathVariable String id);
    @PostMapping("/score/add")
    Result add(@RequestBody User user);
}

3. 添加feign接口实现类

import org.jsoft.demo.feign.ScoreFeign;
import org.jsoft.demo.utils.Result;
import org.jsoft.demo.vo.Score;
import org.jsoft.demo.vo.User;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.List;
@Service
public class ScoreFeignImpl implements ScoreFeign {
    @Override
    public Result info() {
        List<Score> list = new ArrayList<>();
        for (int i = 0; i < 3; i++) {
            Score score = new Score();
            score.setName("name" + i);
            score.setScore(99.99);
            list.add(score);
        }
         return  Result.ok().put("data",list);
    }
    @Override
    public Result id(String id) {
        return null;
    }
    @Override
    public Result add(User user) {
        return null;
    }
}

FeignClient注解中的fallback属性配置了如果熔断，应该访问的Feign接口实现类。当发生熔断时，会访问ScoreFeignImpl中对接口的实现方法。

4. 查看运行结果

关掉Score工程，模拟宕机效果。在使用user工程去访问Score工程，就可以看见熔断处理了。

当遇到宕机的时候，就访问了自己工程里的feign实现类方法。

5. 熔断资源

熔断资源官网地址：https://github.com/alibaba/Sentinel/wiki/%E7%86%94%E6%96%AD%E9%99%8D%E7%BA%A7

资源（是自己写的处理器方法，要对自己写的方法进行限流）是自定义的一个名称，这个名称会在Sentinel中显示，就可以对其进行熔断、降级等管理。

实现对资源管理的常用方式有两种，分别是try和注解。

1. try方式

在user工程的UserController里，添加如下方法：

@GetMapping("/try")
public Result trySources(){
    String sourcesName = "testTry";
    try(Entry entry = SphU.entry(sourcesName)) { //SphU.entry方法通过传入资源名称和其他参数来获取访问令牌。如果获取到令牌，则可以访问目标资源；如果没有获取到令牌，则无法访问对应资源。
        return Result.ok();
    } catch (BlockException e) {
        return Result.error().setMessage("被限流了！");
    }
}

注意Entry引包

import com.alibaba.csp.sentinel.Entry;

重启两个项目，运行一下看效果，就是自己写的方法，也被限流了。

2. 注解方式

在user工程的UserController里，添加如下方法：

@GetMapping("/annotation")
@SentinelResource(value = "testAnnotation", blockHandler = "annotationSourcesError")
public Result annotationSources() {
    return Result.ok();
}
public Result annotationSourcesError(BlockException e) {
    return Result.error().setMessage("被限流了！");
}

重启两个项目，运行一下看效果，就是自己写的方法，也别限流了。