六：Gateway网关限流

2021-12-07 21:34:22 阅读：310 来源： 互联网

标签：令牌 exchange Mono 网关限流 org import Gateway

　　gateway默认给我们提供了限流实现，也就是网关拦截器RequestRateLimiter。

6.1 令牌桶限流算法 RequestRateLimiter底层实现是令牌桶算法;

　　令牌桶内存储令牌，令牌桶需要设置令牌容量，也就是系统最大的并发大; 以一定的速率生成令牌(具体速率根据系统性能设置)，放到令牌桶，如果桶慢了，则丢弃; 客户端来一个请求，则先去令牌桶获取令牌，拿到令牌，则处理请求，否则丢弃或者返回失败;

　令牌桶算法的优点:
　　（1）通过恒定的速率生成令牌桶，能够让请求处理更均匀，不会出现短时间大量的请求处理;
　　（2）比较友好的控制高并发;

page17image9779312

6.2 Gateway网关限流实例
　　Spring Cloud Gateway官方提供了 RequestRateLimiterGatewayFilterFactory 过滤器工厂，使用Redis 和 Lua 脚本实现了令牌桶，来实现网关限流; 添加下Redis依赖:

<!-- spring boot redis 缓存引入 --> <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!-- lettuce pool 缓存连接池 --> <dependency>
    <groupId>org.apache.commons</groupId>
    <artifactId>commons-pool2</artifactId>
</dependency>

6.2.1 URI限流

配置类:

package com.java1234.config;
import org.springframework.cloud.gateway.filter.ratelimit.KeyResolver;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import reactor.core.publisher.Mono;
/**
* 限流规则配置类
* @author java1234
*/
@Configuration
public class KeyResolverConfiguration {
    @Bean
    public KeyResolver pathKeyResolver(){
        /*return new KeyResolver() {
            @Override
            public Mono<String> resolve(ServerWebExchange exchange) {
                return Mono.just(exchange.getRequest().getURI().getPath());
} };*/
return exchange -> Mono.just(exchange.getRequest().getURI().getPath()); // URI限流
} }

yml配置:

spring:
  application:
    name: gateway-server
  cloud:
    gateway:
      routes:
        - id: rateLimiter
          uri: http://localhost:8080/
          predicates:
           - Path=/product/**
          filters:
           - name: RequestRateLimiter # 限流过滤器 
             args:            
                    redis-rate-limiter.replenishRate: 1 # 令牌桶每秒填充速率 r
　　　　　　　　　　　　redis-rate-limiter.burstCapacity: 2 # 令牌桶总容量 
　　　　　　　　　　　　redis-rate-limiter.requestedTokens: 1 # 一个请求需要消费的令牌数 
　　　　　　　　　　　　key-resolver: "#{@pathKeyResolver}"
　　redis: # redis配置
　　　　host: 192.168.0.103 # IP
　　　　port: 6379 # 端口
　　　　password: # 密码
　　　　connect-timeout: 10s # 连接超时时间 
　　　　lettuce: # lettuce redis客户端配置
　　　　　　pool: # 连接池配置
　　　　　　　　max-active: 8 # 连接池最大连接数(使用负值表示没有限制) 默认 8 
　　　　　　　　max-wait: 200s # 连接池最大阻塞等待时间(使用负值表示没有限制) 默认 -1 
　　　　　　　　max-idle: 8 # 连接池中的最大空闲连接 默认 8
　　　　　　　　min-idle: 0 # 连接池中的最小空闲连接 默认 0

访问过多之后，报429错误;

6.2.2 参数限流配置类:

package com.java1234.config;
import org.springframework.cloud.gateway.filter.ratelimit.KeyResolver;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import reactor.core.publisher.Mono;
/**
* 限流规则配置类
* @author java1234
*/
@Configuration
public class KeyResolverConfiguration {
    @Bean
    public KeyResolver parameterKeyResolver(){
        /*return new KeyResolver() {
            @Override
            public Mono<String> resolve(ServerWebExchange exchange) {
                return
Mono.just(exchange.getRequest().getQueryParams().getFirst("token"));
            }
};*/
return exchange -> Mono.just(exchange.getRequest().getQueryParams().getFirst("token")); // 参数限流
} }

请求带一个参数:http://localhost/product/32?token=fdafa

6.2.3 IP限流配置类:

package com.java1234.config;



import org.springframework.cloud.gateway.filter.ratelimit.KeyResolver;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;
/**
* 限流规则配置类
* @author java1234
*/
@Configuration
public class KeyResolverConfiguration {
    @Bean
    public KeyResolver ipKeyResolver(){
        /*return new KeyResolver() {
            @Override
            public Mono<String> resolve(ServerWebExchange exchange) {
                return
Mono.just(exchange.getRequest().getRemoteAddress().getHostName());
            }
};*/
return exchange -> Mono.just(exchange.getRequest().getRemoteAddress().getHostName()); // IP限流
} }

标签：令牌,exchange,Mono,网关,限流,org,import,Gateway
来源： https://www.cnblogs.com/cbpm-wuhq/p/15658942.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

六：Gateway网关限流