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 {@Beanpublic 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 {@Overridepublic 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);}@Overridepublic Result id(String id) {return null;}@Overridepublic 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("被限流了!");}
重启两个项目,运行一下看效果,就是自己写的方法,也被限流了。
6、其他说明
【1、异常比例】
是发生异常数 / 总请求数。
【2、异常数 】
发生异常次数。
【3、快速失败】
当QPS超过阈值是,直接限流,抛出异常。是默认值,可以用于线程数的限流。
【4、排队等待】
每秒可以处理10个请求,当超出这个值就会等待,等待10000毫秒后,如果还没有被处理会限流。只能用于QPS的限流。
【5、Warm Up】
可以让服务器的QPS“慢慢地”达到阈值,在10秒中之内让QPS到底10。只能用于QPS的限流。
【6、直接拒绝】
只对单一资源,当触发阈值时直接拒绝请求。
【7、关联】
针对两个资源有关联时,当前当前资源会为关联资源让步,保证关联资源有更大的阈值。
【8、链路】
从资源入口开始,整个两路的阈值。
【9、热点限流】
当系统中的某些数据被经常引用,可以对这些数据进行限流,减少服务器压力。
【10、系统规则】
针对硬件层面设置的规则,比如限制CPU的使用率
【11、授权规则】
根据请求的来源设置限流,其实就是黑白名单功能