整合Sentinel实现资源限流
Spring Cloud Gateway默认为我们提供了一种限流方法:RequestRateLimiterGatewayFilterFactory
。但这种方法实际并不能用于生产,并不能随着持久化数据的改变而动态改变限流参数,不能做到实时根据流量来改变流量阈值。本文就不介绍RequestRateLimiterGatewayFilterFactory
了,直接为大家介绍生产中最常用的Spring Cloud Gateway结合sentinel实现限流功能。
Sentinel 从 1.6.0 版本开始提供了 Spring Cloud Gateway 的适配模块,可以提供两种资源维度的限流:
- route 维度:即在 Spring 配置文件中配置的路由条目,资源名为对应的 routeId
- 自定义 API 维度:用户可以利用 Sentinel 提供的 API 来自定义一些 API 分组
一、Gateway网关集成sentinel
通过maven坐标在微服务模块zimug-server-gateway中加入sentinel客户端
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
在项目的配置文件中加上sentinel配置,因为我是用了nacos,所以去nacos配置中心修改配置文件。如果你的服务没有使用配置中心,在项目本地的application.yml里面配置就可以了。
spring:
cloud:
sentinel:
transport:
port: 8719
dashboard: 192.168.161.3:8774
二、测试一下
zimug-server-gateway项目在nacos中配置文件中有如下两条网关路由
我们先对这两条路由进行一下访问(本章前面小节多次写过),然后登陆sentinel控制台,看到如下信息,说明我们的网关route已经正确的被sentinel管理,我们可以针对route资源进行相关的流控、降级等配置。
我们针对"/sysuser/pwd/reset"所代表的路由资源设置QPS=1的流控限制(每秒最大请求数1)
然后我们快速点击向http://127.0.0.1:8777/sysuser/pwd/reset
发送请求,得到如下结果,说明针对该路由资源的访问在网关层面就被拦截了。
三、深入解析
上面的流控回调信息是在DefaultBlockRequestHandler
默认定义实现的,当被限流时会返回类似于下面的错误信息:Blocked by Sentinel: FlowException
。
如果你想针对限流进行定制化的信息响应(其实没有必要),您可以在WebFluxCallbackManager
注册回调自定义的BlockHandler:
自定义的BlockHandler代码如下,就是实现接口返回一个自定义的限流信息返回值:"系统繁忙,请稍后再试!"。其中Mono是webflux编程场景下的返回值使用方法之一。
public class MySentinelBlockHandler implements BlockRequestHandler {
@Override
public Mono<ServerResponse> handleRequest(ServerWebExchange exchange, Throwable t) {
ErrorResult errorResult = new MySentinelBlockHandler.ErrorResult(
HttpStatus.TOO_MANY_REQUESTS.value(),
"系统繁忙,请稍后再试!");
// JSON result by default.
return ServerResponse.status(HttpStatus.TOO_MANY_REQUESTS)
.contentType(MediaType.APPLICATION_JSON_UTF8)
.body(fromObject(errorResult));
}
private static class ErrorResult {
private final int code;
private final String message;
ErrorResult(int code, String message) {
this.code = code;
this.message = message;
}
public int getCode() {
return code;
}
public String getMessage() {
return message;
}
}
}
仿造本文第二小节的测试方法,在测试一次,返回结果如下:
标签:code,自定义,sentinel,限流,Sentinel,message,gateway From: https://www.cnblogs.com/nextgg/p/17192198.html