微服务组件Sentinel的学习（3）

Sentinel

隔离和降级
- Feign整合Sentinel
- 线程隔离
- 熔断降级
- - 熔断策略
授权规则：
自定义异常

隔离和降级

虽然限流可以尽量避免因高并发而引起的服务故障，但服务还会因为其它原因而故障。而要将这些故障控制在一定范用避免雪崩，就要靠线程隔离(舱壁模式)和熔断降级。

Feign整合Sentinel

步骤一：修改application.yml文件，开启Feign的Sentinel功能

  cloud:feign:sentinel:enabled: true

步骤二：给FeignClient编写失败后的降级逻辑
方式（1）：FallbackClass，无法对远程调用的异常做处理
方式（2）：FallbackFactory，可以对远程调用的异常做处理，

用FallbackFactory举例：
第一步：

public class UserClientFallbackFactory implements FallbackFactory<UserQuery> {@Overridepublic UserQuery create(Throwable throwable) {return new UserQuery() {@Overridepublic User findById(Long id) {log.error("查询用户失败！", throwable);return new User();}};}
}

第二步：

@Bean
public UserQueryFallbackFactory userQueryFallbackFactory(){return new UserQueryFallbackFactory();
}

第三步：

@FeignClient(value = "userservice", fallbackFactory = UserQueryFallbackFactory.class) 
public interface UserQuery {@GetMapping("/user/{id}")User findById(@PathVariable("id") Long id);
}

线程隔离

线程数:是该资源能使用的tomcat线程数的最大值。也就是通过限制线程数量，实现舱壁模式。下面图片中，就可以直接指定线程数。
在这里插入图片描述
线程隔离的两种手段是?
（1）信号量隔离
（2）线程池隔离
信号量隔离的特点是?
基于计数器模式，简单，开销小
线程池隔离的特点是?
基于线程池模式，有额外开销，但隔离控制更强

熔断降级

熔断降级是解决雪崩问题的重要手段。其思路是由断路器统计服务调用的异常比例、慢请求比例，如果超出阈值则会熔断该服务。即拦截访问该服务的一切请求，而当服务恢复时，断路器会放行访问该服务的请求。其主要分为以下几个状态：
在这里插入图片描述

熔断策略

断路器熔断策略有三种:慢调用、异常比例、异常数
慢调用:业务的响应时长(RT)大于指定时长的请求认定为慢调用请求。在指定时间内，如果请求数量超过设定的最小数量，慢调用比例大于设定的阈值，则触发熔断。例如:
在这里插入图片描述
RT超过500ms的调用是慢调用，统计最近1000ms内的请求，如果请求量超过10次，并且慢调用比例不低于0.5则触发熔断，熔断时长为5秒。然后进入half-open状态，放行一次请求做测试。

异常比例或异常数
异常比例或异常数:统计指定时间内的调用，如果调用次数超过指定请求数，并且出现异常的比例达到设定的比例阈值(或超过指定异常数)，则触发熔断。
在这里插入图片描述
统计最近1000ms内的请求，如果请求量超过10次，并且异常比例不低于0.5，则触发熔断，熔断时长为5秒。然后进入half-open状态，放行一次请求做测试。

授权规则：

授权规则可以对调用方的来源做控制，有以下两种方式：
白名单:来源在白名单内的调用者允许访问
黑名单:来源在黑名单内的调用者不允许访问
在这里插入图片描述
Sentinel是通过RequestOriginParser这个接口的parseOrigin来获取请求的来源的

public interface RequestOriginParser {    String parseOrigin(HttpServletRequest request);}

例如，尝试从request中获取一个名为origin的请求头，作为origin的值:

public class HeaderOriginParser implements RequestOriginParser {@Overridepublic String parseOrigin(HttpServletRequest httpServletRequest) {String origin = httpServletRequest.getHeader("origin");if(StringUtils.isEmpty(origin)){return "black";}return origin;}
}

还需要在gateway服务中，利用网关的过滤器添加名为gateway的origin头:

spring:cloud:gateway:default-filters: # 默认过滤器，会对所有的路由请求都生效- AddRequestHeader=origin, gateway # Sentinel授权规则，只有从网关服务的才合法，通过添加请求头标识

自定义异常

默认情况下，发生限流、降级、授权拦截时，都会抛出异常到调用方。如果要自定义异常时的返回结果，需要实现BlockExceptionHandler接口:

@Component
public class SentinelExceptionHandler implements BlockExceptionHandler {@Overridepublic void handle(HttpServletRequest request, HttpServletResponse response, BlockException e) throws Exception {String msg = "未知异常";int status = 429;if (e instanceof FlowException) {msg = "请求被限流了";} else if (e instanceof ParamFlowException) {msg = "请求被热点参数限流";} else if (e instanceof DegradeException) {msg = "请求被降级了";} else if (e instanceof AuthorityException) {msg = "没有权限访问";status = 401;}response.setContentType("application/json;charset=utf-8");response.setStatus(status);response.getWriter().println("{\"msg\": " + msg + ", \"status\": " + status + "}");}
}