.NET Redis限制接口请求频率 滑动窗口算法

在.NET中使用Redis来限制接口请求频率（每10秒只允许请求一次）
NuGet setup
StackExchange.Redis
实现速率限制逻辑：
在控制器或服务层中，编写Redis速率限制计数器。
设置Redis键：
为每个用户或每个IP地址设置一个唯一的键。这个键将用于存储最后一次请求的时间戳和/请求计数。
检查时间戳：
当请求到达时，从Redis中获取该键的值（时间戳）。如果键不存在或时间戳超过10秒，则允许请求并更新键的值（设置为当前时间戳）。
处理超过速率的请求：
如果时间戳在10秒内，则拒绝或限制该请求（返回限制状态码）。

1.    private static readonly Lazy<ConnectionMultiplexer> LazyConnection = new Lazy<ConnectionMultiplexer>(() =>
2.    {
3.        // 配置Redis连接字符串 "localhost,abortConnect=false"  
4.        return ConnectionMultiplexer.Connect("localhost:6379");
5.    });
7.    private static ConnectionMultiplexer Connection => LazyConnection.Value;
9.    private static IDatabase Db => Connection.GetDatabase();
11.    public async Task<ActionResult> MyAction()
12.    {
14.        IPAddress clientIpAddress = HttpContext.Connection.RemoteIpAddress;
15.        string ipAddress = clientIpAddress.ToString();
16.        string redisKey = $"rate-limit:{ipAddress}"; // 构建Redis键名  
17.   
18.        // 获取当前时间戳（可以是Unix时间戳或任何你选择的格式）  
19.        long currentTimestamp = DateTimeOffset.UtcNow.ToUnixTimeSeconds();
21.        // 尝试从Redis获取时间戳  
22.        var redisValue = await Db.StringGetAsync(redisKey);
23.        long lastTimestamp = redisValue.HasValue ? (long)redisValue : 0;
25.        // 检查是否超过10秒  
26.        if (currentTimestamp - lastTimestamp >= 10)
27.        {
28.            // 如果超过10秒，则允许请求并更新Redis键  
29.            await Db.StringSetAsync(redisKey, currentTimestamp, TimeSpan.FromSeconds(10)); // 设置键的过期时间为10秒  
30.                                                                                        
31.            return Content("Request allowed.");
32.        }
33.        else
34.        {
35.            // 如果未超过10秒，则拒绝请求  
36.            HttpResponseMessage response = new HttpResponseMessage(HttpStatusCode.TooManyRequests)
37.            {
38.                ReasonPhrase = "Too Many Requests",
39.                Content = new StringContent("Rate limit exceeded. Please try again later.")
40.            };
41.            // 处理请求
42.            return Content("Please try again later. ");// throw new HttpResponseException(response); // 或者返回自定义的ActionResult  
43.        }
44.    }

复制代码

扩展为参数

1. MyAction(string p)
2. //...
3. string redisKey = $"rate-limit:{p}";

复制代码

请求
/MyAction?p=2
/MyAction?p=3
滑动窗口算法

滑动窗口算法（Sliding Window Algorithm）是一种用于解决字符串/数组 问题的算法，它通过维护一个窗口（即一个连续的子串或子数组），并在字符串或数组上滑动这个窗口来寻找满足特定条件的子串或子数组。以下是滑动窗口算法的重要内容和特点：
维护窗口：通过两个指针（左指针和右指针）来界说窗口的界限。
移动窗口：通过移动右指针来扩展窗口，同时根据问题的要求调整左指针来缩小窗口。
更新信息：在窗口滑动的过程中，根据需要更新一些数据结构（如哈希表）来保存所需的信息。
实现方法
步调1.初始化：界说左指针和右指针，并初始化它们的位置。
步调2.扩展窗口：向右移动右指针，扩展窗口，同时更新所需的信息（如字符频率的哈希表）。
步调3.检查条件：当窗口满足特定条件时，开始紧缩窗口。
步调4.紧缩窗口：向右移动左指针，缩小窗口，同时更新所需的信息。
步调5.更新最优解：在紧缩窗口的过程中，不断更新最优解（如最长子串、最短子串等）。
重复步调：重复步调2到步调5，直到右指针到达字符串或数组的末端。
在Redis中维护一个窗口内的请求时间戳列表，而不是仅仅存储最后一次请求的时间戳。移除超过窗口巨细的时间戳。检查剩余的时间戳数是否超过了最大请求数 MaxRequests。如果超过，则返回超过的响应；否则，记录当前时间戳并允许请求。

1.                         private const int MaxRequests = 5; // 最大请求数
2.                         private const int WindowSizeInSeconds = 10; // 窗口大小（秒）
3.                         //...
5.             // 获取Redis中存储的时间戳列表
6.             var redisValue = await Db.ListRangeAsync(redisKey);
7.             var timestamps = redisValue.Select(value => (long)value).ToList();
9.             // 移除窗口之外的时间戳
10.             timestamps = timestamps.Where(timestamp => currentTimestamp - timestamp <= WindowSizeInSeconds).ToList();
12.             if (timestamps.Count >= MaxRequests)
13.             {
14.                 // 如果请求数超过限制，则拒绝请求
15.                 HttpResponseMessage response = new HttpResponseMessage(HttpStatusCode.TooManyRequests)
16.                 {
17.                     ReasonPhrase = "Too Many Requests",
18.                     Content = new StringContent("Rate limit exceeded. Please try again later.")
19.                 };
20.                 return Content("Please try again later.");
21.             }
22.             else
23.             {
24.                 // 如果请求数未超过限制，则允许请求并记录当前时间戳
25.                 timestamps.Add(currentTimestamp);
26.                 await Db.ListRightPushAsync(redisKey, timestamps.Select(timestamp => (RedisValue)timestamp).ToArray());
27.                 await Db.KeyExpireAsync(redisKey, TimeSpan.FromSeconds(WindowSizeInSeconds)); // 设置键的过期时间为窗口大小
29.                 return Content("Request allowed.");
30.             }

复制代码

End

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。