如何使用redis中的zset实现滑动窗口限流

ZSet<String> zset = redisTemplate.opsForZSet().create("rateLimiter");

long currentTimeMillis = System.currentTimeMillis();
String userId = "user1";
redisTemplate.opsForZSet().add("rateLimiter", userId, currentTimeMillis);

long windowSizeInSeconds = 60;
long currentTimeMillis = System.currentTimeMillis();
// 获取ZSet中所有元素
List<ZSetElement<String>> elements = redisTemplate.opsForZSet().reverseRangeWithScores("rateLimiter", 0, -1);
for (ZSetElement<String> element : elements) {
    long elementTimestamp = element.getScore();
    if (currentTimeMillis - elementTimestamp > windowSizeInSeconds * 1000) {
        redisTemplate.opsForZSet().remove("rateLimiter", element.getValue());
    }
}

int limit = 100; // 每分钟的请求限制
long size = redisTemplate.opsForZSet().size("rateLimiter");
if (size >= limit) {
    // 超过限制，拒绝请求...
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
@Component
public class ApiCallCounter {
    private static final String API_CALLS = "api_calls:";
    @Autowired
    private RedisTemplate<String, String> redisTemplate;
    public void incrementApiCallCount(String apiName) {
        String key = API_CALLS + apiName + ":current";
        redisTemplate.opsForValue().increment(key);
    }
}