ToB企服应用市场:ToB评测及商务社交产业平台

标题: 并发哀求太多，服务器崩溃了？试试使用 ASP.NET Core Web API 操纵筛选器对 [打印本页]

---

作者: 万万哇    时间: 2024-10-19 16:33
标题: 并发哀求太多，服务器崩溃了？试试使用 ASP.NET Core Web API 操纵筛选器对

媒介

哀求限流（Rate Limiting）重要是一种用于控制客户端对服务器的哀求频率的机制。
其目的是限制客户端在一定时间内可以发送的哀求数量，保护服务器免受过多哀求的影响，确保系统的稳固性和可靠性。
哀求限流通常会基于以下几个因素来举行限制：

• 时间窗口：规定了在多长时间内答应的哀求次数
  
• 哀求配额：在时间窗口内答应的最大哀求数量
  
• 客户端标识：根据客户端的 IP 地点、用户标识或其他标识符来举行限流
  

哀求限流技术可以应用在很多场景，本文重要讲述 ASP.NET Core Web API 如何使用操纵筛选器对哀求举行限流。
Step By Step 步骤

• 创建一个ASP.NET Core Web API 项目
  
• 编写自定义的操纵筛选器 RateLimitFilter，实现 "1s内只答应最多有一个来自同一个IP地点的哀求"（注意注释）
  1. using Microsoft.AspNetCore.Mvc;
  2. using Microsoft.AspNetCore.Mvc.Filters;
  3. using Microsoft.Extensions.Caching.Memory;
  5. public class RateLimitFilter : IAsyncActionFilter
  6. {
  7.         private readonly IMemoryCache memCache;
  9.         // 注入的IMemoryCache
  10.         public RateLimitFilter(IMemoryCache memCache)
  11.         {
  12.                 this.memCache = memCache;
  13.         }
  15.         public Task OnActionExecutionAsync(
  16.                 ActionExecutingContext context,
  17.                 ActionExecutionDelegate next)
  18.         {
  19.                 // 通过注入的 IMemoryCache 来记录用户上一次访问的时间戳
  20.                 // 在分布式系统下可以改用分布式缓存来代替内存缓存
  21.                 string removeIP = context.HttpContext.Connection.RemoteIpAddress!.ToString();
  22.                 string cacheKey = $"LastVisitTick_{removeIP}";
  23.                
  24.                 // 从缓存中获取这个客户端IP地址上一次访问服务器的时间
  25.                 long? lastTick = memCache.Get<long?>(cacheKey);
  26.                 if (lastTick == null || Environment.TickCount64 - lastTick > 1000)
  27.                 {
  28.                         // 如果缓存中不存在上一次访问时间或者上一次访问时间距离现在已经超过 1s，则通过 next 来执行后面的筛选器
  29.                         memCache.Set(cacheKey, Environment.TickCount64, TimeSpan.FromSeconds(10));
  30.                         return next();
  31.                 }
  32.                 else
  33.                 {
  34.                         // 否则说明 IP 频繁访问，不执行 next，相当于终止操作方法的执行
  35.                         context.Result = new ContentResult { StatusCode = 429 };
  36.                         return Task.CompletedTask;
  37.                 }
  38.         }
  39. }

  复制代码
  代码中的内存缓存和分布式缓存可以参考本人之前文章《看看 Asp.net core Webapi 项目如何优雅地使用内存缓存》和《看看 Asp.net core Webapi 项目如何优雅地使用分布式缓存》
  
• 打开 Program.cs，注册这个操纵筛选器
  1. using Microsoft.AspNetCore.Mvc;
  3. var builder = WebApplication.CreateBuilder(args);
  5. // Add services to the container.
  7. builder.Services.AddControllers();
  8. // Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle
  9. builder.Services.AddEndpointsApiExplorer();
  10. builder.Services.AddSwaggerGen();
  12. // 注册内存缓存服务
  13. builder.Services.AddMemoryCache();
  15. // 注册请求限流过滤器
  16. builder.Services.Configure<MvcOptions>(options => {
  17.         options.Filters.Add<RateLimitFilter>();
  18. });
  20. var app = builder.Build();
  22. // Configure the HTTP request pipeline.
  23. if (app.Environment.IsDevelopment())
  24. {
  25.         app.UseSwagger();
  26.         app.UseSwaggerUI();
  27. }
  29. app.UseHttpsRedirection();
  31. app.UseAuthorization();
  33. app.MapControllers();
  35. app.Run();

  复制代码

测试

启动项目，而且访问接口，如果访问频率不高的话，接口可以或许正常工作。
如果访问频率很高的话，服务器就会提示 "Only once per second!"
总结

在操纵筛选器中，通过 await next() 来执行下一个筛选器，
如果没有下一个筛选器，程序就会执行目标操纵方法。
如果不调用 await next()，就可以终止操纵方法的执行了

我是老杨，一个执着于编程乐趣、至今奋斗在一线的 10年+ 资深研发老鸟，是软件项目管理师，也是快乐的程序猿，持续免费分享全栈实用编程技巧、项目管理履历和职场发展心得！欢迎关注老杨的公众号（名称：代码掌控者），和你共同探索代码世界的奥秘！

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

---

欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/)

Powered by Discuz! X3.4