首页 > 其他分享 >gateway整合Sentinel实现资源限流

gateway整合Sentinel实现资源限流

时间:2023-03-08 15:45:34浏览次数:63  
标签:code 自定义 sentinel 限流 Sentinel message gateway

转:整合Sentinel实现资源限流

整合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

相关文章

  • kepware高级插件IOT Gateway_Rest Client和NodeRed实操
    1,安装Kepware软件,使用Iot高级插件需要有Java环境,下载地址为: https://www.oracle.com/文件名称为:jdk-7u79-windows-i5862,RestClient配置     ......
  • Ubuntu 22.04.1 LTS 静态IP WARNING **: 10:29:10.417: `gateway4` has been depreca
    vi/etc/netplan/00-installer-config.yaml network:ethernets:ens33:addresses:[192.168.66.106/24]gateway4:192.168.66.254nameservers:......
  • springcloud-gateway配置跨域
    跨域有两种解决方式:一是将前端和后端通过nginx部署在同一域名下,后端通过location/admin这种方式转发,避免浏览器因为协议,主机和端口号不同造成的跨域二是非简单请求,浏览......
  • springcloud-引入gateway
    gateway其实和MVC框架路由逻辑相似,mvc路由是将请求url交给对应的控制器方法处理,gateway是将请求转发给对应的服务来处理。1,gateway需要引入nacos注册和配置中心2,gateway......
  • redis sentinel 部署
    redissentinel部署服务器说明192.168.2.200masterredis-serverredis-sentinel192.168.2.201slave1redis-serverredis-sentinel192.168.2.202slave2r......
  • Sentinel安装&配置使用&规则持久化
    目录Sentinel是什么安装部署1.下载2.运行3.访问项目连接Sentinel新建一个项目POMYML启动类Controller启动项目Sentinel规则配置流控规则a.直接-快速失败b.关联-快速失败c.......
  • 接口限流常见算法方案原理 及其 实现(Guava RateLimiter,Redis+AOP+Lua)
    (目录)什么是限流?为什么要限流?限流,这个词其实并不陌生,在我们生活中也随处可见。做核酸时,工作人员会在核酸检测点的空地上摆放着弯弯曲曲的围栏,人们排着队左拐右拐的往前......
  • 限流算法汇总
    计数器算法:原理:在指定时间周期内累加访问次数,达到设定的阈值时,触发限流策略。下一个时间周期进行访问时,访问次数清零。实现:此算法无论是在单机还是分布式环境下......
  • Gateway集成Netty服务
    Gateway和Netty都有盲区的感觉;一、Netty简介Netty是一个异步的,事件驱动的网络应用框架,用以快速开发高可靠、高性能的网络应用程序。传输服务:提供网络传输能力的管理;......
  • 网关Gateway
    网关功能身份认证和权限校验服务路由、负载均衡请求限流相关技术搭建网关创建新的module,引入SpringCloudGateway的依赖nacos的服务发现依赖:<!--nacos服务发现......