GateWay结合Redis实现令牌桶限流

&lt;dependency&gt;
    &lt;groupId&gt;com.alibaba.cloud</groupId&gt;
    <artifactId&gt;spring-cloud-alibaba-dependencies</artifactId&gt;
    <version&gt;2.2.5.RELEASE</version&gt;
    <type&gt;pom</type>
    <scope>import</scope>
</dependency>
<!--声明SpringBoot的依赖-->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.3.4.RELEASE</version>
    <type>pom</type>
    <scope>import</scope>
</dependency>

2.在gateway服务里面添加相关依赖

 <!-- 网关依赖 -->
  <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-gateway</artifactId>
      <version>2.2.5.RELEASE</version>
  </dependency>

  <!--redis gateway令牌桶依赖 监控依赖-->
  <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-actuator</artifactId>
  </dependency>

  <!—redis令牌桶依赖-->
  <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-data-redis-reactive</artifactId>
      <version>2.1.2.RELEASE</version>
  </dependency>

3.在gateway服务里面的启动类添加一段代码

/***
 * IP限流
 * @return
 */
@Bean(name="ipKeyResolver")
public KeyResolver userKeyResolver() {
    return new KeyResolver() {
        @Override
        public Mono<String> resolve(ServerWebExchange exchange) {
            //获取远程客户端IP
            String hostName = exchange.getRequest().getRemoteAddress().getAddress().getHostAddress();
            System.out.println("hostName:"+hostName);
            return Mono.just(hostName);
        }
    };
}

4. 在gateway服务里面的application.yml 里面添加配置

spring:
  cloud:
    gateway:
      globalcors:
        corsConfigurations:
          '[/**]': # 匹配所有请求
            allowedOrigins: "*" #跨域处理 允许所有的域
            allowedMethods: # 支持的方法
              - GET
              - POST
              - PUT
              - DELETE
      routes:
        - id: gateway1
          uri: http://localhost:8080
          predicates:
            - Path=/abc/test/**
          filters:
            - StripPrefix=1
            - name: RequestRateLimiter #请求数限流 名字不能随便写 ，使用默认的facatory
              args:
                key-resolver: "#{@ipKeyResolver}" 
                redis-rate-limiter.replenishRate: 1 #是你希望允许用户每秒执行多少请求，而不会丢弃任何请求。这是令牌桶填充的速率
                redis-rate-limiter.burstCapacity: 3 #是指令牌桶的容量，允许在一秒钟内完成的最大请求数,将此值设置为零将阻止所有请求


  application:
    name: gateway-web
  #Redis配置
  redis:
    host: 127.0.0.1
    port: 6379

server:
  port: 8001
management:
  endpoint:
    gateway:
      enabled: true
    web:
      exposure:
        include: true

5. 在测试服务

@RestController
@RequestMapping("test")
public class TestqController {

    @GetMapping("getTest")
    public String getTest(){
        return "成功了！！！！";
    }
}