/**
 * 自定义sentinel异常返回信息
 * @author user
 */
@Component
public class CustomUrlBlockHandler implements UrlBlockHandler {
    @Override
    public void blocked(HttpServletRequest request,
                        HttpServletResponse response,
                        BlockException e) throws IOException {
        R r = null;
        // BlockException 异常接口，其子类为Sentinel五种规则异常的实现类
        // AuthorityException 授权异常
        // DegradeException 降级异常
        // FlowException 限流异常
        // ParamFlowException 参数限流异常
        // SystemBlockException 系统负载异常
        if (e instanceof FlowException) {
            r = R.error(100, "访问速度过快");
        } else if (e instanceof DegradeException) {
            r = R.error(100, "接口已被降级，暂时无法访问");
        } else if (e instanceof AuthorityException) {
            r = R.error(100, "无权访问");
        } else if (e instanceof ParamFlowException) {
            r = R.error(100, "热点参数限流了");
        } else if (e instanceof SystemBlockException) {
            r = R.error(100, "系统靠不住了，稍等吧");
        }
        response.setStatus(500);
        response.setCharacterEncoding("utf-8");
        response.setHeader("Content-type","application/json;charset=utf-8");
        response.setContentType("application/json;charset=utf-8");
        new ObjectMapper().writeValue(response.getWriter(), r);
    }
}

实现UrlBlockHandler接口，重写blocked方法，对BlockException子异常进行处理。

重启项目再次访问：

这样抛给前端的异常就比较友好了。

降级规则

RT: 单个请求的响应时间超过阈值，则进入准降级状态，接下来 1 S 内连续 5 个请求响应时间均超过阈值，就进行降级，持续时间为时间窗口的值。

异常比例：每秒异常数量占通过量的比例大于阈值，就进行降级处理，持续时间为时间窗口的值。

异常数：1 分钟内的异常数超过阈值就进行降级处理，时间窗口的值要大于 60S，否则刚结束熔断又进入下一次熔断了。

热点规则

热点规则是流控规则的更细粒度操作，可以具体到对某个热点参数的限流，设置限流之后，如果带着限流参数的请求量超过阈值，则进行限流，时间为统计窗口时长。

必须要添加@SentinelResource，即对资源进行流控。

定义接口

@GetMapping("/hot")
@SentinelResource("hot")
public R hot(
        @RequestParam(value = "num1", required = false) Integer num1,
        @RequestParam(value = "num2", required = false) Integer num2) {
    log.info("num1:{}, num2:{}", num1, num2);
    return R.ok();
}

@Slf4j
@Component
@RestControllerAdvice
@Order(Ordered.HIGHEST_PRECEDENCE)
public class GlobalExceptionHandler {

    /**
     * 功能描述: 处理ParamFlowException<br>
     * @param ex
     * @return: {@link R}
     * @Author: Edward
     * @Date: 2021/1/20 10:13
     */
    @ExceptionHandler(value = ParamFlowException.class)
    protected R handleParamFlowException(ParamFlowException ex) {
        //获取所有错误信息
        return R.error(4000,"热点参数限流了");
    }
}

public class RequestOriginParserDefinition implements RequestOriginParser {
    @Override
    public String parseOrigin(HttpServletRequest httpServletRequest) {
        String serviceName = httpServletRequest.getParameter("appType");
        return serviceName;
    }
}

/**
 * @version 1.0
 * @Author: Edward
 * @Date: 2021/1/21 15:21
 * @Description:
 */
@Configuration
public class SentinelConfiguration {
    @PostConstruct
    public void init() {
        WebCallbackManager.setRequestOriginParser(new RequestOriginParserDefinition());
    }
}