Sentinel网关限流与SpringCloud Gateway整合过程
网关如何限流？
Spring Cloud Gateway本身自带的限流实现，过滤器是RequestRateLimiterGatewayFilterFactory，不过这种比较简单，有兴趣的可以实现下。
今天的重点是集成阿里的Sentinel实现网关限流，sentinel顾名思义：卫兵；在Redis中叫做哨兵，用于监控主从切换，但是在微服务中叫做流量防卫兵。Sentinel 以流量为切入点，从流量控制、熔断降级、系统负载保护等多个维度保护服务的稳定性。
Sentinel 具有以下特征：
- 丰富的应用场景：Sentinel 承接了阿里巴巴近 10 年的双十一大促流量的核心场景，例如秒杀（即突发流量控制在系统容量可以承受的范围）、消息削峰填谷、集群流量控制、实时熔断下游不可用应用等。
- 完备的实时监控：Sentinel 同时提供实时的监控功能。您可以在控制台中看到接入应用的单台机器秒 级数据，甚至 500 台以下规模的集群的汇总运行情况。
- 广泛的开源生态：Sentinel 提供开箱即用的与其它开源框架/库的整合模块，例如与 Spring Cloud、Apache Dubbo、gRPC、Quarkus 的整合。您只需要引入相应的依赖并进行简单的配置即可快速地接入 Sentinel。同时 Sentinel 提供 Java/Go/C++ 等多语言的原生实现。
- 完善的 SPI 扩展机制：Sentinel 提供简单易用、完善的 SPI 扩展接口。您可以通过实现扩展接口来快速地定制逻辑。例如定制规则管理、适配动态数据源等。
Sentinel 的主要特性如下图：
从1.6.0版本开始，Sentinel提供了SpringCloud Gateway的适配模块，可以提供两种资源维度的限流：
**route维度：**即在配置文件中配置的路由条目，资源名为对应的routeId，这种属于粗粒度的限流，一般是对某个微服务进行限流。
**自定义API维度：**用户可以利用Sentinel提供的API来自定义一些API分组，这种属于细粒度的限流，针对某一类的uri进行匹配限流，可以跨多个微服务。
项目实践
新建一个gateway-service模块，添加如下依赖：
<!--nacos注册中心-->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<!--spring cloud gateway-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-gateway</artifactId>
</dependency>
<!-- spring cloud gateway整合sentinel的依赖-->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-alibaba-sentinel-gateway</artifactId>
</dependency>
<!-- sentinel的依赖-->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>配置文件
配置文件中主要指定以下三种配置：
- nacos的地址
- sentinel控制台的地址
- 网关路由的配置
配置如下
server:
port: 8100
logging:
path: d:/
spring:
application:
name: gateway-service
cloud:
nacos:
server-addr: localhost:8848
sentinel:
transport:
dashboard: localhost:8080
gateway:
routes:
- id: mqtt-service-route
uri: lb://mqtt-service
predicates:
- Path=/mqtt/**
- id: usermgr-service-route
uri: lb://usermgr-service
predicates:
- Path=/usermgr/**上述配置中设置了一个路由usermgr-service-route，只要请求路径满足http://127.0.0.1:8100/usermgr/user/id都会被路由到usermgr-service这个服务中
限流配置
经过上述两个步骤其实已经整合好了Sentinel，此时访问一下接口：http://127.0.0.1:8100/usermgr/user/id
然后在sentinel控制台可以看到已经被监控了，监控的路由是usermgr-service，如下图：
上图中对usermgr-service这个路由做出了限流，QPS阈值为1。
此时快速访问：http://127.0.0.1:8100/usermgr/user/id，看到已经被限流了，如下图：
以上route维度的限流已经配置成功，小伙伴可以自己照着上述步骤尝试一下。
API分组限流
首先需要定义一个分组，API管理-> 新增API分组，如下图：
匹配模式选择了精确匹配（还有前缀匹配，正则匹配），因此只有这个uri：http://127.0.0.1:8100/usermgr/user/id会被限流。
第二步需要对这个分组添加流控规则，流控规则->新增网关流控，如下图
API名称那里选择对应的分组即可，新增之后，限流规则就生效了。
如何自定义限流异常信息？
从上面的演示中可以看到默认的异常返回信息是：“Block…”，这种肯定是客户端不能接受的，因此需要定制自己的异常返回信息。
下面介绍两种不同的方式定制异常返回信息，开发中自己选择其中一种。
直接配置文件中定制
开发者可以直接在配置文件中直接修改返回信息，配置如下：
spring:
cloud:
## 整合sentinel，配置sentinel控制台的地址
sentinel:
#配置限流之后，响应内容
scg:
fallback:
## 两种模式，一种是response返回文字提示信息，
## 一种是redirect，重定向跳转，需要同时配置redirect(跳转的uri)
mode: response
## 响应的状态
response-status: 200
## 响应体
response-body: '{"code": 200,"message": "请求失败，稍后重试！"}'上述配置中mode配置的是response，一旦被限流了，将会返回JSON串
{
"code": 200,
"message": "请求失败，稍后重试！"
}重定向的配置
如下：
spring:
cloud:
## 整合sentinel，配置sentinel控制台的地址
sentinel:
#配置限流之后，响应内容
scg:
fallback:
## 两种模式，一种是response返回文字提示信息，一种是redirect，重定向跳转，需要同时配置redirect(跳转的uri)
mode: redirect
## 跳转的URL
redirect: http://www.baidu.com一旦被限流，将会直接跳转到：http://www.baidu.com
编码定制
这种就不太灵活了，通过硬编码的方式，完整代码如下：
package com.spacetime.gateway.config;
import com.alibaba.csp.sentinel.adapter.gateway.sc.callback.BlockRequestHandler;
import com.alibaba.csp.sentinel.adapter.gateway.sc.callback.GatewayCallbackManager;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.web.reactive.function.BodyInserters;
import org.springframework.web.reactive.function.server.ServerResponse;
import javax.annotation.PostConstruct;
import java.util.HashMap;
import java.util.Map;
@Configuration
public class GatewayConfig {
/**
* 自定义限流处理器
*/
@PostConstruct
public void initBlockHandlers() {
BlockRequestHandler blockHandler = (serverWebExchange, throwable) -> {
Map map = new HashMap();
map.put("code",200);
map.put("message","请求失败，稍后重试！");
return ServerResponse.status(HttpStatus.OK)
.contentType(MediaType.APPLICATION_JSON_UTF8)
.body(BodyInserters.fromObject(map));
};
GatewayCallbackManager.setBlockHandler(blockHandler);
}
}总结
文章介绍了Spring Cloud Gateway整合Sentinel对网关层进行限流，以及关于限流的一些思考。
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。
相关文章
这篇文章主要为大家介绍了Java 泛型 Generic机制实例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2022-11-11
Springboot中Dependency not found解决方案
本文主要介绍了Springboot中Dependency not found解决方案,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧2023-11-11
这篇文章主要介绍了Springcloud-nacos实现配置和注册中心的方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-07-07
遗传算法（Genetic Algorithm，GA）最早是由美国的John holland于20世纪70年代提出,该算法是根据大自然中生物体进化规律而设计提出的。本文将利用遗传算法求解最短路径问题，需要的可以参考一下2022-06-06
stopWatch 是org.springframework.util 包下的一个工具类,使用它可直观的输出代码执行耗时,以及执行时间百分比,下面就跟随小编一起来看看它的具体用法吧2024-12-12
这篇文章主要介绍了浅谈一下Java中的ReentrantLock,这个类是JUC工具包中对线程安全问题提供的一种解决方案,它主要是用来给对象上锁,保证同一时间这能有一个线程在访问当前对象,需要的朋友可以参考下2023-09-09
本篇文章给大家带来的内容是关于Java中HashMap集合的常用方法详解，有一定的参考价值，有需要的朋友可以参考一下，希望对你有所帮助。下面我们就来学习一下吧2021-11-11
在Spring Boot应用程序中,定义Bean是非常常见的操作,它是构建应用程序的基础,pring Boot提供了多种方式来定义Bean,每种方式都有其适用的场景和优势,本文将介绍Spring Boot中定义Bean的几种常见方式,需要的朋友可以参考下2023-12-12
这篇文章主要介绍了详解Spring DI依赖注入的方式和类型,DI是由容器动态的将某个依赖关系注入到组件之中。依赖注入的目的并非为软件系统带来更多功能，而是为了提升组件重用的频率，并为系统搭建一个灵活、可扩展的平台,需要的朋友可以参考下2023-05-05
这篇文章主要介绍了java 中如何实现 List 集合去重，List 去重指的是将 List 中的重复元素删除掉的过程，下文操作操作过程介绍需要的小伙伴可以参考一下2022-05-05
最新评论