Sentinel-高并发方法论及应用

简介

1、熔断降级限流

Sentinel的基本概念

官方文档
1、定义资源

2、定义规则

3、检验规则是否生效

整合SpringBoot

1、引入依赖

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

2、查看核心版本为1.6.3 下载 对应版本控制台 启动sentinel java -jar sentinel-dashboard-1.6.3.jar --server.port=8333 设置配置

spring.cloud.sentinel.transport.port=8719
spring.cloud.sentinel.transport.dashboard=localhost:8333

在控制台调整参数，默认控制台配置保存在内存中，重启失效

自定义流控响应

每一个微服务都引入审计模块，可以实时统计应用健康状况信息或请求的调用信息等

<!--引入 actuator统计审计信息 配合sentinel management.endpoints.web.exposure.include=* -->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

配置management.endpoints.web.exposure.include=* 暴露所有端点给审计模块以统计

自定义返回

添加一个流空资源后，自定义这个资源等流控返回

@Configuration
public class SecKillSentinelConfig {
    public SecKillSentinelConfig(){
    WebCallbackManager.setUrlBlockHandler(new UrlBlockHandler() {
    @Overridepublic void blocked(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, BlockException e) throws IOException {
    R error = R.error(BizCodeEnum.TO_MANY_REQUEST.getCode(), BizCodeEnum.TO_MANY_REQUEST.getMessage());httpServletResponse.setCharacterEncoding("UTF-8");httpServletResponse.setContentType("application/json");httpServletResponse.getWriter().write(JSON.toJSONString(error));}});}
}

全服务引入

给每一个服务都引入审计模块依赖并配置

流控模式&效果

各个流控效果的设置，详细参见官方文档

熔断降级

降级：保护两个服务之间的 远程调用，让远程服务直接返回错误信息，不做具体业务
对feign的熔断支持
保护远程服务，A调用B 那么给A加入感知 feign.sentinel.enabled=true 配置开启

在feign接口 设置熔断处理类

@FeignClient(value = "gulimall-seckill",fallback = SecKillFeignServiceFallBack.class)
public interface SecKillFeignService {
    @GetMapping("/sku/seckill/{skuId}")R getSkuSeckillInfo(@PathVariable("skuId") Long skuId);
}

熔断处理类实现feign接口，并定义熔断返回细节

@Component
public class SecKillFeignServiceFallBack implements SecKillFeignService {
    @Overridepublic R getSkuSeckillInfo(Long skuId) {
    log.error("熔断方法调用...getSkuSeckillInfo");return R.error(BizCodeEnum.TO_MANY_REQUEST.getCode(),BizCodeEnum.TO_MANY_REQUEST.getMessage());}
}

手动指定降级规则

参照官方文档
RT的时间单位为毫秒，这个设置表示，1秒内5个请求的平均响应时间超过RT ，则接下来 的 10秒时间窗口内，这个远程调用都会被熔断，随后尝试恢复

给每一个服务都加上feign的熔断保护

自定义受保护资源

自定义一个代码块中的受保护资源

try (Entry entry = SphU.entry("secKillSKUs")){
    //受保护的代码块
}catch (BlockException e){
    log.error("资源被限流，{}",e.getMessage());
}

给方法加上注解@SentinelResource ，blockHandler为处理返回的自定方法，只能和资源写在一个类中 且返回值、权限修饰符、和参数要一致

public List<SecKillSkuRedisTo> blockHandler(BlockException e){
    return null;
}//返回当前时间可以参与的秒杀商品信息
@SentinelResource(value = "getCurrentSecKillSkus",blockHandler = "blockHandler")
@Override
public List<SecKillSkuRedisTo> getCurrentSecKillSkus() {
    
}

出了定义 blockHandler 的处理方法，还可定义 fallback （不好用）

网关流控

在网关模块引入sentinel跟网管层的整合

<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-alibaba-sentinel-gateway</artifactId><version>2.1.0.RELEASE</version>
</dependency>//和alibaba 的版本管理一致
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-alibaba-dependencies</artifactId><version>2.1.0.RELEASE</version><type>pom</type><scope>import</scope>
</dependency>

需使用 1.7.1及以上的控制台

直接在网关层控制住了流量

限制指定请求头

API分组

定制网关流控返回

@Configuration
public class SentinelGatewayConfig {
    public SentinelGatewayConfig(){
    GatewayCallbackManager.setBlockHandler(new BlockRequestHandler() {
    //网关限流了请求，就会调用此回调 Mono@Overridepublic Mono<ServerResponse> handleRequest(ServerWebExchange serverWebExchange, Throwable throwable) {
    R error = R.error(BizCodeEnum.TO_MANY_REQUEST.getCode(), BizCodeEnum.TO_MANY_REQUEST.getMessage());String s = JSON.toJSONString(error);Mono<ServerResponse> body = ServerResponse.ok().body(Mono.just(s), String.class);return body;}});}
}

Sleuth-链路追踪-基本概念&整合

因为要整合Zipkin，所以可忽略

整合Zipkin效果

1、docker安装zipkin服务器
docker run -d -p 9411:9411 openzipkin/zipkin
2、

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-zipkin</artifactId>
</dependency>

3、

虚拟机ip:9411 打开 zipkin 客户端

zipkin数据持久化

Zipkin界面分析