Sentinel-热点流控

拿商品举例，当一个商品的查询请求量异常火爆的时候，应该对该商品的查询请求进行限流

操作示例

Controller:

@RestController
    @Slf4j
    public class HotSpotController {
        @RequestMapping("/hotSpot1")
        @SentinelResource(value = "hotSpot1")
        public String hotSpot1(Long productId){
            log.info("订单编号为:{}的商品",productId);
            return "hotSpot1";
        }
    }

新增热点规则：只要所有请求数相加大于100就会被限流

新增参数例外项：只要访问1的请求大于3，访问该请求就会被限流

Sentinel规则-授权

很多时候，我们需要根据调用来源来判断该次请求是否允许放行，这时候可以使用Sentinel的来源访问控制(黑白名单控制)的功能。来源访问控制根据资源的请求来源（origin ）限制资源是否通过，若配置白名单则只有请求来源位于白名单内时才可通过;若配置黑名单则请求来源位于黑名单时不通过，其余的请求通过。

操作示例

获取授权信息:

@Component
    public class RequestOrginParserDefinition implements RequestOriginParser {
        @Override
        public String parseOrigin(HttpServletRequest request) {
            //在请求中如何去获取授权信息
            String type = request.getParameter("type");
            return type;
        }
    }

Controller:

@RestController
    @Slf4j
    public class AutoController {
        @RequestMapping("/auth1")
        public String auth1(String type){
            log.info("应用:{},访问接口",type);
            return "auth1";
        }
    }

授权白名单之后，仅有满足条件的可以通过
授权黑名单之后，仅有满足条件的不可以通过

Sentinel规则-系统规则

系统保护规则是从应用级别的入口流量进行控制，从单台机器的load、CPU使用率、平均RT、入口QPS和并发线程数等几个维度监控应用指标，让系统尽可能跑在最大吞吐量的同时保证系统整体的稳定性。
系统保护规则是应用整体维度的，而不是资源维度的，并且仅对入口流量生效。入口流量指的是进入应用的流量( EntryType.IN )，比如Web服务或 Dubbo服务端接收的请求，都属于入口流量。
系统规则支持以下的模式:
。Load自适应（仅对Linux/Unix-like机器生效)∶系统的load1作为启发指标，进行自适应系统保护。当系统load1超过设定的启发值，且系统当前的并发线程数超过估算的系统容量时才会触发系统保护（BBR阶段)。系统容量由系统的maxQps * minRt估算得出。设定参考值一般是CPU cores * 2.5。
。CPU usage (1.5.0+版本)︰当系统CPU使用率超过阈值即触发系统保护（取值范围0.0-1.0)，比较灵敏。
。平均RT:当单台机器上所有入口流量的平均RT达到阈值即触发系统保护，单位是毫秒。
。并发线程数:当单台机器上所有入口流量的并发线程数达到阈值即触发系统保护。
。入口QPS:当单台机器上所有入口流量的QPS达到阈值即触发系统保护。

Sentinel自定义异常返回

我们在使用用Sentinal的时候无论触发什么保护的时候返回的界面是一样的，不好区分是因为哪种规则导致的异常。所以需要自定义异常返回信息，明确是触发了哪种类型的规则

创建Controller：


@Component
    public class ExceptionHandlePage implements BlockExceptionHandler {
        @Override
        public void handle(HttpServletRequest request, HttpServletResponse response, BlockException e) throws Exception {
            response.setContentType("application/json;charset=utf-8");
            ResultData data = null;
            if(e instanceof FlowException){
                data = new ResultData(-1,"接口被限流了");
            }else if(e instanceof DegradeException){
                data = new ResultData(-2,"接口被降级了");
            }else if(e instanceof ParamFlowException){
                data = new ResultData(-3,"参数限流异常");
            }else if(e instanceof AuthorityException){
                data = new ResultData(-4,"授权异常");
            }else if(e instanceof SystemBlockException){
                data = new ResultData(-5,"接口被降级了");
            }
            response.getWriter().write(JSON.toJSONString(data));
        }
        @Data
            @AllArgsConstructor
            @NoArgsConstructor
            class ResultData{
                private int code;
                private String message;
            }
    }