在Spring Boot中，可以使用Redis的有序集合（zset）来实现滑动窗口限流。以下是一个简单的实现示例：
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.ZSetOperations;
import org.springframework.stereotype.Component;
import java.util.concurrent.TimeUnit;
@Component
public class SlidingWindowLimiter {
@Autowired
private StringRedisTemplate redisTemplate;
private static final String KEY_PREFIX = "rate_limit:";
private static final int WINDOW_SIZE = 10; // 滑动窗口的大小，单位是秒
private static final long TIME_BUCKET_SIZE = 1000L; // 每个时间桶的毫秒数
public boolean isAllowed(String key, int limit) {
long now = System.currentTimeMillis();
ZSetOperations<String, String> zSetOps = redisTemplate.opsForZSet();
// 移除过期的元素
zSetOps.removeRangeByScore(KEY_PREFIX + key, 0, now - WINDOW_SIZE * 1000);
// 添加新的元素并设置过期时间
String value = String.valueOf(now);
zSetOps.add(KEY_PREFIX + key, value, now);
redisTemplate.expire(KEY_PREFIX + key, WINDOW_SIZE, TimeUnit.SECONDS);
// 计算当前窗口的访问次数
long count = zSetOps.count(KEY_PREFIX + key, now - WINDOW_SIZE * 1000, now);
// 如果超过限制，则不允许通过
return count < limit;
}
}使用方法：
@Autowired
private SlidingWindowLimiter limiter;
public void someMethod() {
String key = "resource_key"; // 需要限流的资源键
int limit = 100; // 时间窗口内允许的最大请求次数
if (limiter.isAllowed(key, limit)) {
// 如果允许通过，则执行业务逻辑
} else {
// 如果不允许通过，则返回错误或执行其他操作
}
}这段代码定义了一个SlidingWindowLimiter组件，它使用Redis的有序集合（zset）来跟踪每个键的访问次数，并且在每次请求时检查是否超过了限制。滑动窗口的大小是10秒，并且每次请求都会更新这个窗口。如果请求次数超过了限定的限制，则不允许通过。这个实现可以很容易地集成到Spring Boot应用程序中，并用于限制对特定资源的访问频率。