小白学习gateway集成sentinel

女爷i 2024-04-29 03:19 69阅读 0赞

### 网关流控定义 ###

Sentinel支持对Spring Cloud Gateway、Zuul等主流的API Gataway 进行限流，作用在网关的流控称之为`网关流控`，其实现原理请点击[网关限流][Link 1]进入官方Wiki查看。

这里只把原理图从官方文档摘出来，需多关注图中提到的模块名和几个类名，因为都是**核心**级别的存在。

![image.png][]

规则类型`gw-flow`和`gw-api-group`为网关流控规则，具体类型请查看规则类型枚举`RuleType`

java

复制代码

`/** * flow 流控规则 */ FLOW("flow", FlowRule.class), /** * degrade 降级规则 */ DEGRADE("degrade", DegradeRule.class), /** * param flow 热点规则 */ PARAM_FLOW("param-flow", ParamFlowRule.class), /** * system 系统规则 */ SYSTEM("system", SystemRule.class), /** * authority 授权规则 */ AUTHORITY("authority", AuthorityRule.class), /** * gateway flow 网关限流规则 */ GW_FLOW("gw-flow","com.alibaba.csp.sentinel.adapter.gateway.common.rule.GatewayFlowRule"), /** * api 用户自定义的 API 定义分组，可以看做是一些 URL 匹配的组合 */ GW_API_GROUP("gw-api-group","com.alibaba.csp.sentinel.adapter.gateway.common.api.ApiDefinition");`

![image.png][image.png 1]

### 网关流控规则 ###

<table> 
 <thead> 
  <tr> 
   <th>Field</th> 
   <th>说明</th> 
   <th>默认值</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>resource</td> 
   <td>资源名称，网关route或自定义API分组名称（注：网关route这里的值不是route.id,可调试</td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>resourceMode</td> 
   <td>限流资源类型，网关route【0】或自定义API分组【1】（详细查看<code>GatewayFlowRule</code>和<code>SentinelGatewayConstants</code>）</td> 
   <td>网关route</td> 
  </tr> 
  <tr> 
   <td>grade</td> 
   <td>限流阈值类型，QPS【1】或线程数【0】</td> 
   <td>QPS</td> 
  </tr> 
  <tr> 
   <td>count</td> 
   <td>限流阈值，QPS阈值或线程数值</td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>intervalSec</td> 
   <td>统计时间间隔，单位秒</td> 
   <td>1秒</td> 
  </tr> 
  <tr> 
   <td>controlBehavior</td> 
   <td>流控效果，目前支持快速失败【0】和匀速排队【1】</td> 
   <td>快速失败</td> 
  </tr> 
  <tr> 
   <td>burst</td> 
   <td>应对突发请求时额外允许的请求数目</td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>maxQueueingTimeoutMs</td> 
   <td>匀速排队模式下的最长排队时间，单位毫秒，仅在匀速排队模式下生效</td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>paramItem</td> 
   <td>参数属性配置，parseStrategy：提取参数策略(0：Clien IP，1：Remote HOST，2：Header，3：请求参数，4：Cookie)；fieldName：若提取策略是Header模式或者URL参数模式，则需要指定header名称或URL参数名称；pattern：参数值的匹配模式；matchStrategy：参数值的匹配策略，支持精确匹配，子串匹配和正则匹配。</td> 
   <td></td> 
  </tr> 
 </tbody> 
</table>

### 网关流控客户端标识 ###

网关流控和普通流控有很多区别，其中网关流控类型是`gw-flow`，普通流控类型是`flow`

怎么标识流控是网关类型呢？

很多博客文章都没有着重此点，因为前阵子纠结于网关流控的面板和普通流控的面板不一致而去搜相关的资料，最后还是在Sentinel官方文档中找到此开关，就是需要在`gateway-sentinel`网关应用添加JVM启动参数。

ini

复制代码

`# 注：通过 Spring Cloud Alibaba Sentinel 自动接入的 API Gateway 整合则无需此参数 -Dcsp.sentinel.app.type=1`

具体如下图：

![image.png][image.png 2]

或者在启动类中`main`方法中添加如下代码：

java

复制代码

`// 添加此代码，在Sentinel控制台中做判断使用 System.setProperty("csp.sentinel.app.type", "1");`

### 集成 ###

1.  新建`gateway-sentinel`模块，并导入如下依赖

pom

复制代码

` <dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId> </dependency>  <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-gateway</artifactId> </dependency>  <dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-alibaba-sentinel-gateway</artifactId> </dependency>  <dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId> </dependency>  <dependency> <groupId>com.alibaba.csp</groupId> <artifactId>sentinel-datasource-nacos</artifactId> <version>1.8.7</version> </dependency>`

1.  网关配置，在`application.yml`添加`nacos`和`Sentinel`的配置，同时配置路由转发

yml

复制代码

`server: port: 10015 spring: application: name: gateway-sentinel cloud: # 整合sentinel，配置sentinel控制台的地址 sentinel: web-context-unify: false datasource: gw-api-group: nacos: server-addr: ${spring.cloud.nacos.discovery.server-addr} username: ${spring.cloud.nacos.discovery.username} password: ${spring.cloud.nacos.discovery.password} namespace: ${spring.cloud.nacos.discovery.namespace} group-id: SENTINEL_GROUP data-id: ${spring.application.name}-gateway-api-rules # 规则类型：flow、degrade、param-flow、system、authority、gw-flow、gw-api-group rule-type: gw-api-group gw-flow: nacos: server-addr: ${spring.cloud.nacos.discovery.server-addr} username: ${spring.cloud.nacos.discovery.username} password: ${spring.cloud.nacos.discovery.password} namespace: ${spring.cloud.nacos.discovery.namespace} group-id: SENTINEL_GROUP data-id: ${spring.application.name}-gateway-flow-rules # 规则类型：flow、degrade、param-flow、system、authority、gw-flow rule-type: gw-flow # 熔断降级 degrade: nacos: server-addr: ${spring.cloud.nacos.discovery.server-addr} username: ${spring.cloud.nacos.discovery.username} password: ${spring.cloud.nacos.discovery.password} namespace: ${spring.cloud.nacos.discovery.namespace} group-id: SENTINEL_GROUP data-id: ${spring.application.name}-degrade-rules rule-type: degrade # 系统规则 system: nacos: server-addr: ${spring.cloud.nacos.discovery.server-addr} username: ${spring.cloud.nacos.discovery.username} password: ${spring.cloud.nacos.discovery.password} namespace: ${spring.cloud.nacos.discovery.namespace} group-id: SENTINEL_GROUP data-id: ${spring.application.name}-system-rules rule-type: system transport: ## 指定控制台的地址，默认端口8080 dashboard: 192.168.0.102:6005 client-ip: 192.168.0.104 port: 8719 eager: true nacos: # 注册中心配置 discovery: # nacos的服务地址，nacos-server中IP地址:端口号 server-addr: 192.168.0.102:8848 username: nacos password: nacos namespace: gateway: # 路由 routes: # id只要唯一即可，名称任意 - id: nacos-sentinel uri: http://localhost:9004 ## 配置断言 predicates: - Path=/sentinel/** management: endpoints: web: exposure: ## yml文件中存在特殊字符，必须用单引号包含，否则启动报错 include: '*'`

> 这里解释下配置中的datasource，因为在Sentinel添加流控规则之后，如果重启服务，之前配置的规则就会消失，所>以这里需要持久化Sentinel配置，从上面的配置可以看出选择的是Nacos。

### 网关流控测试 ###

1.  启动`gateway-sentinel`模块
2.  启动`nacos-sentinel`模块
3.  打开`sentinel`控制台，给`nacos-sentinel`api添加流控规则，设置阈值为5，即1秒最多发5次请求
    
    ![image.png][image.png 3]
4.  打开`jmeter`，添加`Thread Group`，设置1秒10次请求
    
    ![image.png][image.png 4]
    
    ![image.png][image.png 5]
5.  添加HTTP请求
    
    ![image.png][image.png 6]
    
    ![image.png][image.png 7]
6.  添加察看结果树，因为要看请求的响应，所以这里添加察看结果树
    
    ![image.png][image.png 8]
7.  启动线程组，每秒15次认证请求
    
    > 需要注意的是，如果测试计划有多个线程组，需禁用除了测试之外的其他线程组。
8.  点击`查看结果树`查看请求的情况
    
    ![image.png][image.png 9]
9.  进入Sentinel控制台，查看实时监控
    
    ![image.png][image.png 10]

### 自定义网关流控异常 ###

上面Sentinel限流的默认异常响应如下

json

复制代码

`{"code":429,"message":"Blocked by Sentinel: ParamFlowException"}`

假如想自定义网关流控异常响应，该如何实现呢？

可以通过在GatewayCallbackManager上通过setBlockHandler方法注册回调实现，当请求被限流后，实现自定义的异常响应。

![image.png][image.png 11]

自定义异常代码：

java

复制代码

`package com.example.config; import com.alibaba.csp.sentinel.adapter.gateway.sc.callback.BlockRequestHandler; import com.alibaba.csp.sentinel.adapter.gateway.sc.callback.GatewayCallbackManager; import com.example.enums.CodeEnum; import com.example.utils.ResponseResult; import org.springframework.context.annotation.Configuration; import org.springframework.http.MediaType; import org.springframework.web.reactive.function.BodyInserters; import org.springframework.web.reactive.function.server.ServerResponse; import javax.annotation.PostConstruct; @Configuration public class SentinelConfig { @PostConstruct private void initBlockHandler() { BlockRequestHandler blockRequestHandler = (exchange, t) -> ServerResponse.status(CodeEnum.FLOW_LIMIT.getCode()) .contentType(MediaType.APPLICATION_JSON) .body(BodyInserters.fromValue(ResponseResult.builder().error(CodeEnum.FLOW_LIMIT).build())); GatewayCallbackManager.setBlockHandler(blockRequestHandler); } }`

JMeter中查看被限流的响应，可以看到已按照自定义的响应异常返回

![image.png][image.png 12]

> Java开发手册上的关于`系统限流`的错误码默认为`B0210`

[Link 1]: https://link.juejin.cn/?target=https%3A%2F%2Fgithub.com%2Falibaba%2FSentinel%2Fwiki%2F%25E7%25BD%2591%25E5%2585%25B3%25E9%2599%2590%25E6%25B5%2581
[image.png]: https://img-blog.csdnimg.cn/img_convert/5fba36487f8a893fd001f099dc371e6b.webp?x-oss-process=image/format,png
[image.png 1]: https://img-blog.csdnimg.cn/img_convert/2c927095fe89f9821bf018663222558f.webp?x-oss-process=image/format,png
[image.png 2]: https://img-blog.csdnimg.cn/img_convert/9bfe8205614ca7c5f09364bb64ce795f.webp?x-oss-process=image/format,png
[image.png 3]: https://img-blog.csdnimg.cn/img_convert/a40bf86101bdb073b3862d361d711f6f.webp?x-oss-process=image/format,png
[image.png 4]: https://img-blog.csdnimg.cn/img_convert/8b285c35517cfdef115c48709430b17f.webp?x-oss-process=image/format,png
[image.png 5]: https://img-blog.csdnimg.cn/img_convert/5741067b3a7f151777d0a6a6bcfde162.webp?x-oss-process=image/format,png
[image.png 6]: https://img-blog.csdnimg.cn/img_convert/1273bdec9d7169bcbd28b3120cdef430.webp?x-oss-process=image/format,png
[image.png 7]: https://img-blog.csdnimg.cn/img_convert/fac19cca0eaf02903f925bd26aa4379f.webp?x-oss-process=image/format,png
[image.png 8]: https://img-blog.csdnimg.cn/img_convert/762b8d7ab6d979494fe772f362e85272.webp?x-oss-process=image/format,png
[image.png 9]: https://img-blog.csdnimg.cn/img_convert/5487aa0347e2b2a7e599be89207e1d2c.webp?x-oss-process=image/format,png
[image.png 10]: https://img-blog.csdnimg.cn/img_convert/be4f3f81a564eeb0f61f8240ecaa1e4e.webp?x-oss-process=image/format,png
[image.png 11]: https://img-blog.csdnimg.cn/img_convert/a767072b32e043902c3e2fd10b05fe5e.webp?x-oss-process=image/format,png
[image.png 12]: https://img-blog.csdnimg.cn/img_convert/592eab796386983e30a3f75daf3c46c9.webp?x-oss-process=image/format,png