微服务sentinel解析部署使用全流程

sentinel源码地址：介绍 · alibaba/Sentinel Wiki · GitHub

sentinel官方文档： https://sentinelguard.io/zh-cn/docs/introduction.html

Sprong Cloud alibaba Sentinel文档【小例子】 : Sentinel · alibaba/spring-cloud-alibaba Wiki · GitHub

1、sentinel概念

2、入门例子

0、启动nacos和redis

1、使用openfeign项目

2、引入依赖

3、下载sentinel服务

4、启动服务

5、登录sentinel

6、添加sentinel配置信息

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

编辑

【概念了解】

3、自定义流控响应

1、添加过滤器SentinelFilterConfig

2、添加配置类SentinelConfig

3、运行结果

4、熔断feign

1、添加配置

2、修改feign接口注解

3、添加feign接口实现类

4、查看运行结果

5、熔断资源

1、try方式

2、注解方式

6、其他说明

1、sentinel概念

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

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

2、入门例子

0、启动nacos和redis

1、使用openfeign项目

详细可见微服务 OpenFeign 解析部署使用全流程-CSDN博客

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、启动服务

找到当前jar包位置输入cmd

执行

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网站，设置限流】

http://localhost:8080/#/dashboard/identity/openfeignDemo1

Sentinel Dashboard

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

【限流的效果】

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

但是快速点击的时候，就显示被限流了：

【概念了解】

【1、什么是QPS】

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

【2、什么是RT】

响应时间。

【3、慢调用】

响应时间大于一定值。

【4、慢调用比例】

慢调用 / 总调用比例值。

【5、比例阈值】

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

3、自定义流控响应

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

1、添加过滤器SentinelFilterConfig

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

package com.jr.config;

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、添加配置类SentinelConfig

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

package com.jr.config;

import com.alibaba.csp.sentinel.adapter.servlet.callback.WebCallbackManager;
import com.alibaba.fastjson.JSON;
import com.jr.util.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接口注解

/**
 * openfeignDemo2是springsession-1在nacos注册的项目名（）
 * ScoreFeignImpl.classs是实现类的名字
 * //fallback 一旦出现熔断，要走哪个类。
 */
@FeignClient(value = "openfeignDemo2", fallback = ScoreFeignImpl.class)

3、添加feign接口实现类

package com.jr.feign.impl;

import com.jr.entry.Score;
import com.jr.entry.UserDto;
import com.jr.feign.ScoreFeign;
import com.jr.util.Result;
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("list",list);
    }

    @Override
    public Result id(String id) {
        return null;
    }

    @Override
    public Result add(UserDto 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;

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

    public Result setMessage(String message) {
        this.message = message;
        return this;
    }

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

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("被限流了！");
    }