redis实现网关限流(限制API调用次数1000次/分)

<dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency>
 <groupId>org.apache.commons</groupId>
 <artifactId>commons-pool2</artifactId>
</dependency>

spring:
  redis:
    database: 0
    host: localhost
    port: 6379
    lettuce:                  # 这里标明使用lettuce配置
      pool:
        max-active: 8         # 连接池最大连接数
        max-wait: -1ms        # 连接池最大阻塞等待时间(使用负值表示没有限制
        max-idle: 5           # 连接池中的最大空闲连接
        min-idle: 0           # 连接池中的最小空闲连接
    timeout: 10000ms          # 连接超时时间

Long size = redisTemplate.opsForList().size("apiRequest");
if (size < 1000) {
 redisTemplate.opsForList().leftPush("apiRequest", System.currentTimeMillis());
} else {
 Long start = (Long) redisTemplate.opsForList().index("apiRequest", -1);
 if ((System.currentTimeMillis() - start) < 60000) {
  throw new RuntimeException("超过限流阈值");
 } else {
  redisTemplate.opsForList().leftPush("apiRequest", System.currentTimeMillis());
  redisTemplate.opsForList().trim("apiRequest", -1, -1);
 }
}

Integer count = (Integer) redisTemplate.opsForValue().get("apiKey");
Integer integer = Optional.ofNullable(count).orElse(0);
if (integer > 1000) {
 throw new RuntimeException("超过限流阈值");
}
if (redisTemplate.getExpire("apiKey", TimeUnit.SECONDS).longValue() < 0) {
 redisTemplate.multi();
 redisTemplate.opsForValue().increment("apiKey", 1);
 redisTemplate.expire("apiKey", 60, TimeUnit.SECONDS);
 redisTemplate.exec();
} else {
 redisTemplate.opsForValue().increment("apiKey", 1);
}