面试官：Sentinel如何实现接口流量控制？

布满荆棘的人生 2022-09-04 10:40 156阅读 0赞

![ad8d02c44bc5a83a5e5ddaf21504a566.png][]

*  Sentinel控制台搭建
 *  Sentinel 客户端
 *   *  项目搭建
     *  如何定义资源
     *  启动控制台
 *  控制台配置规则

Hello,大家好,我是麦洛,今天带大家来了解一下SpringBoot如何继承Sentinel来实现接口流量控制

假如大家有什么问题或者建议,可以关注公众号,回复"加群"就可以获取到我的个人微信二维码,可以拉大家进交流群一起讨论学习;

## Sentinel控制台搭建    ##

在我的上一篇文章[阿里出品的Sentinel到底是个什么玩意?][Sentinel]中,已经介绍过如何准备Sentinel控制台,大家可以直接参考;

## Sentinel 客户端 ##

### 项目搭建 ###

首先我们来创建一个测试项目,这里初始化项目的`url`建议大家填写**阿里云**的地址,会有惊喜????

http://start.aliyun.com

![1b1a45beca4c4e3d94d6fa331f9ac5dd.png][]

接下来就是常规操作,一路next,在下图的位置稍微注意一下

![01d0016ee2e9ead0c3fddac0f3eb89b6.png][]

> 说明:
> 
> 同大家以前创建项目一样,只需要在这里勾选Sentinel就可以啦????

项目创建好以后,我们发现pom文件中引入了下面的依赖

![87e07789259b596abc2dabaadcafacc0.png][]

有的小伙伴看网上博客,也会有下面的方式,指定版本号

<dependency>
       <groupId>com.alibaba.cloud</groupId>
       <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
       <version>2.1.0.RELEASE</version>
      </dependency>

如果你使用我推荐的阿里云的Url,会发现Sentinel的版本号都定义父工程,Cloud的各个组件的兼容性就不要大家操心了

<dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-dependencies</artifactId>
                    <version>${spring-boot.version}</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
                <dependency>
                    <groupId>com.alibaba.cloud</groupId>
                    <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                    <version>${spring-cloud-alibaba.version}</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>

打开项目配置文件,会发现它已经为我们自动加好了配置,真的超级方便????

server.port=8083
    # 应用名称
    spring.application.name=springcloud-sentinel
    # Sentinel 控制台地址
    spring.cloud.sentinel.transport.dashboard=localhost:8080
    # 取消Sentinel控制台懒加载
    # 默认情况下 Sentinel 会在客户端首次调用的时候进行初始化，开始向控制台发送心跳包
    # 配置 sentinel.eager=true 时，取消Sentinel控制台懒加载功能
    spring.cloud.sentinel.eager=true
    # 如果有多套网络，又无法正确获取本机IP，则需要使用下面的参数设置当前机器可被外部访问的IP地址，供admin控制台使用
    # spring.cloud.sentinel.transport.client-ip=# sentinel 配置
    spring.application.name=frms
    spring.cloud.sentinel.transport.dashboard=localhost:8080
    spring.cloud.sentinel.transport.heartbeat-interval-ms=500

### 如何定义资源 ###

#### 编程式定义 ####

官网提供的demo

package com.milo.sentinel;
    
    import com.alibaba.csp.sentinel.Entry;
    import com.alibaba.csp.sentinel.SphU;
    import com.alibaba.csp.sentinel.slots.block.BlockException;
    import com.alibaba.csp.sentinel.slots.block.RuleConstant;
    import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;
    import com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    
    import java.util.ArrayList;
    import java.util.List;
    
    /**
     * 项目入口
     * @author Milo Lee
     * @date 2021-3-20 19:07
     *
     */
    @SpringBootApplication
    public class SentinelApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(SentinelApplication.class, args);
    
            // 配置规则.
            initFlowRules();
            while (true) {
                // 1.5.0 版本开始可以直接利用 try-with-resources 特性
                try (Entry entry = SphU.entry("HelloWorld")) {
                    // 被保护的逻辑
                    Thread.sleep(300);
                    System.out.println("hello world");
                } catch (BlockException | InterruptedException ex) {
                    // 处理被流控的逻辑
                    System.out.println("blocked!");
                }
            }
    
        }
    
        private static void initFlowRules(){
            List<FlowRule> rules = new ArrayList<>();
            FlowRule rule = new FlowRule();
            rule.setResource("HelloWorld");
            rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
            // Set limit QPS to 20.
            rule.setCount(20);
            rules.add(rule);
            FlowRuleManager.loadRules(rules);
        }
    
    }

#### 注解式定义 ####

@SpringBootApplication
    public class Application {
    
        public static void main(String[] args) {
            SpringApplication.run(ServiceApplication.class, args);
        }
    }
    
    @Service
    public class TestService {
    
        @SentinelResource(value = "sayHello")
        public String sayHello(String name) {
            return "Hello, " + name;
        }
    }
    
    @RestController
    public class TestController {
    
        @Autowired
        private TestService service;
    
        @GetMapping(value = "/hello/{name}")
        public String apiHello(@PathVariable String name) {
            return service.sayHello(name);
        }
    }

`@SentinelResource` 注解用来标识资源是否被限流、降级。上述例子上该注解的属性 `sayHello` 表示资源名。

### 启动控制台 ###

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

![86252dce4420a8deb584b0e7d81aa731.png][]

## 控制台配置规则 ##

控制台的操作我们用编程式定义的例子来演示,大家启动我们的服务

![b51393030fda9ee38582d960dd4f877f.png][]

我们会发现除了**sentinel-dashboard**之外,多了一个**milolee-sentinel**,这个就是我们的服务,它的名称其实对应我们配置文件定义的应用名称:

# 应用名称
    spring.application.name=milolee-sentinel

点击机器列表,这这里如果能发现你的机器,那就是成功上线了

![ad81f5ed60eb6f74ae2f2bb67fe9b8f6.png][]

#### 实时监控 ####

![32f43e92a0859f203a6bb0c24ac6896f.png][]

#### 簇点链路 ####

![85e8398efc5ef660b94890d6c48a65b1.png][]

#### 流控规则配置 ####

给我们的资源`HelloWorld`配置流控规则，它的`QPS`(每秒请求数)为1，如图：

![e731c1bfa49fe00b1f067bda7b180fea.png][]

通过查看实时监控,我们发现已经生效

![70db2e1e9498b6ccd7e8378765fb36d5.png][]

#### 降级规则配置 ####

给我们的资源`HelloWorld`添加一个降级规则配置，如果`QPS`大于1，且平均响应时间大于`20ms`，则接口下来接口在2秒钟无法访问，之后自动恢复。

![da667c05506b280e232f4cf1b313064a.png][]

目前这些规则**仅在内存态生效**，应用重启之后，该规则会丢失。后续文章我们会继续学习动态规则

![c90f97aae9a00e95b96b78acc6806a79.png][]

????关于控制台的使用,大家可以参考官方文档,比较详细https://sentinelguard.io/zh-cn/docs/dashboard.html

好了，今天就分享到这里，感谢你的阅读。

![44974d44ad6f6cb3407a6118bab79874.png][]

**如果喜欢，求点赞、在看、转发！**

推荐阅读

*  [离职后，10天面试 4 家公司的总结][10_4]
 *  [一套Spring Cloud Alibaba视频教程][Spring Cloud Alibaba]  
    
 *  [后端开发人员，学习之路][Link 1]
 *  [美团面试：接口被恶意狂刷，怎么办？][Link 2]  
    
 *  [112期面试汇总，建议收藏][112]

[ad8d02c44bc5a83a5e5ddaf21504a566.png]: /images/20220829/6134b6aff77f4055858597dc75a49b2b.png
[Sentinel]: http://mp.weixin.qq.com/s?__biz=Mzg3MDA4Mzc1NQ%3D%3D&chksm=ce926f2ff9e5e63955cce37fd5d6cee8e65197bcf34641072f2d4e8c3a86ebf2d213d6c0912f&idx=1&mid=2247488235&scene=21&sn=c609ede84c29991d370fe23f591e37b4#wechat_redirect
[1b1a45beca4c4e3d94d6fa331f9ac5dd.png]: /images/20220829/df9c1d83291c425aa742add0c69f8eec.png
[01d0016ee2e9ead0c3fddac0f3eb89b6.png]: /images/20220829/2575cdcb6d244e0aa90a19fb385eeb9e.png
[87e07789259b596abc2dabaadcafacc0.png]: /images/20220829/fec8caa37f71434da4057b4f95f969fd.png
[86252dce4420a8deb584b0e7d81aa731.png]: /images/20220829/0847d919be1e4af0815ce6e6876f54d9.png
[b51393030fda9ee38582d960dd4f877f.png]: /images/20220829/b985c8bea4624b8288170bbc1fa1d39d.png
[ad81f5ed60eb6f74ae2f2bb67fe9b8f6.png]: /images/20220829/5178fb5eb7a6478f8c429eccbdfd1e02.png
[32f43e92a0859f203a6bb0c24ac6896f.png]: /images/20220829/f068cbc4d9c2493880064f774d33a175.png
[85e8398efc5ef660b94890d6c48a65b1.png]: /images/20220829/c62be72c352145eca8c7452f503629a4.png
[e731c1bfa49fe00b1f067bda7b180fea.png]: /images/20220829/990ab08d6dff4666905e83a0bdbd7374.png
[70db2e1e9498b6ccd7e8378765fb36d5.png]: /images/20220829/ab5bc30962294b5ca4f7ac8551d029d4.png
[da667c05506b280e232f4cf1b313064a.png]: /images/20220829/5e9df341eccc40359dd51feb8013f532.png
[c90f97aae9a00e95b96b78acc6806a79.png]: /images/20220829/4db65494e00a4269a1ac370ded095f9f.png
[44974d44ad6f6cb3407a6118bab79874.png]: /images/20220829/2ab29ef0192d4c478f340a74539ed94d.png
[10_4]: http://mp.weixin.qq.com/s?__biz=MzU4MDM3MDgyMA%3D%3D&chksm=fd556459ca22ed4faf44bc01dbab47030bae7995cb0bcaa91b55a9e130b2a9e0be119dea29ef&idx=1&mid=2247503026&scene=21&sn=183d38a1172e3eb4d31f60783c477c38#wechat_redirect
[Spring Cloud Alibaba]: http://mp.weixin.qq.com/s?__biz=MzU4MDM3MDgyMA%3D%3D&chksm=fd556225ca22eb33a3859702053e4f6817f646264cf58fabe5c9f18144da347305a2a6d8b0e6&idx=2&mid=2247502542&scene=21&sn=efbdc5883e72041b423df9dd229723f1#wechat_redirect
[Link 1]: http://mp.weixin.qq.com/s?__biz=MzU4MDM3MDgyMA%3D%3D&chksm=fd555753ca22de4522b62563737854b0359847f046b416df20cdfa099ea81d8e03c8bb22f4d1&idx=1&mid=2247499704&scene=21&sn=e3a867f360e8a8cccf8d79e0652c36c0#wechat_redirect
[Link 2]: http://mp.weixin.qq.com/s?__biz=MzU4MDM3MDgyMA%3D%3D&chksm=fd557a94ca22f382326479915ee56139a95ac500a84f057544d8a279be42cfe468c29fd64638&idx=1&mid=2247504511&scene=21&sn=307daa44f37c3d55464e696f0423325d#wechat_redirect
[112]: http://mp.weixin.qq.com/s?__biz=MzU4MDM3MDgyMA%3D%3D&chksm=fd556527ca22ec310441fb12453e0bd624fb0e4bfa18919d1141d3641b9c462a9a28113dc95a&idx=2&mid=2247503308&scene=21&sn=0464ed003b29d85ae47f5b330cade32e#wechat_redirect