.Net Core 使用 AspNetCoreRateLimit 实现限流

上一篇文章介绍过ASP.NET Core 的 Web Api 实现限流 中间件-CSDN博客

使用.NET 7 自带的中间件 Microsoft.AspNetCore.RateLimiting 可以实现简单的Api限流,但是这个.NET 7以后才集成的中间件,如果你使用的是早期版本的.NET,可以使用第三方库AspNetCoreRateLimit实现Api限流。

AspNetCoreRateLimit 是一种 ASP.NET Core 速率限制解决方案,旨在根据 IP 地址或客户端 ID 控制客户端可以向 Web API 或 MVC 应用发出的请求速率。AspNetCoreRateLimit 包包含一个客户端IP限流中间件(IpRateLimitMiddleware)和一个客户端ID限流中间件(ClientRateLimitMiddleware),例如允许 IP 或客户端在时间间隔内(如每秒、15 分钟等)进行最大调用次数。您可以定义这些限制以处理对 API 发出的所有请求,也可以将限制范围限定为每个 API URL 或 HTTP 谓词和路径。

具体实现如下:

1.安装包 AspNetCoreRateLimit :

Install-Package AspNetCoreRateLimit

2.appsettings.json文件配置

{"Logging": {"LogLevel": {"Default": "Information","Microsoft": "Warning","Microsoft.Hosting.Lifetime": "Information"}},"AllowedHosts": "*","RateLimiting": {//false,则全局将应用限制,并且仅应用具有作为端点的规则*。例如,如果您设置每秒5次调用的限制,则对任何端点的任何HTTP调用都将计入该限制//true, 则限制将应用于每个端点,如{HTTP_Verb}{PATH}。例如,如果您为*:/api/values客户端设置每秒5个呼叫的限制,"EnableEndpointRateLimiting": false,//false,拒绝的API调用不会添加到调用次数计数器上;如 客户端每秒发出3个请求并且您设置了每秒一个调用的限制,则每分钟或每天计数器等其他限制将仅记录第一个调用,即成功的API调用。如果您希望被拒绝的API调用计入其他时间的显示(分钟,小时等),则必须设置StackBlockedRequests为true。"StackBlockedRequests": false,//Kestrel 服务器背后是一个反向代理,如果你的代理服务器使用不同的页眉然后提取客户端IP X-Real-IP使用此选项来设置"RealIpHeader": "X-Real-IP",//取白名单的客户端ID。如果此标头中存在客户端ID并且与ClientWhitelist中指定的值匹配,则不应用速率限制。"ClientIdHeader": "X-ClientId",//限制状态码"HttpStatusCode": 429,IP白名单:支持Ip v4和v6 //"IpWhitelist": [ "127.0.0.1", "::1/10", "192.168.0.0/24" ],端点白名单:支持各种请求;//"EndpointWhitelist": [ "get:/api/license", "*:/api/status" ],客户端白名单//"ClientWhitelist": [ "dev-id-1", "dev-id-2" ],//通用规则"GeneralRules": [{//端点路径"Endpoint": "*",//时间段,格式:{数字}{单位};可使用单位:s, m, h, d"Period": "1s",//限制"Limit": 1},//15分钟只能调用100次{"Endpoint": "*","Period": "15m","Limit": 100},//12H只能调用1000{"Endpoint": "*","Period": "12h","Limit": 1000},//7天只能调用10000次{"Endpoint": "*","Period": "7d","Limit": 10000}]},"IpRateLimitPolicies": {//ip规则"IpRules": [{//IP"Ip": "127.0.0.1",//规则内容"Rules": [//1s请求10次{"Endpoint": "*","Period": "1s","Limit": 10},//15分钟请求200次{"Endpoint": "*","Period": "15m","Limit": 200}]},{//ip支持设置多个"Ip": "192.168.3.22/25","Rules": [//1秒请求5次{"Endpoint": "*","Period": "1s","Limit": 5},//15分钟请求150次{"Endpoint": "*","Period": "15m","Limit": 150},//12小时请求500次{"Endpoint": "*","Period": "12h","Limit": 500}]}]},"ClientRateLimitPolicies": {"ClientRules": [{"ClientId": "client-id-1","Rules": [{"Endpoint": "*","Period": "1s","Limit": 10},{"Endpoint": "*","Period": "15m","Limit": 200}]},{"ClientId": "client-id-2","Rules": [{"Endpoint": "*","Period": "1s","Limit": 5},{"Endpoint": "*","Period": "15m","Limit": 150},{"Endpoint": "*","Period": "12h","Limit": 500}]}]}
}

3.服务的注入与使用

在 Program.cs 添加注入服务的代码:

public static void Main(string[] args)
{var builder = WebApplication.CreateBuilder(args);builder.Services.AddControllers();// Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbucklebuilder.Services.AddEndpointsApiExplorer();builder.Services.AddSwaggerGen();#region 注入限流//需要从appsettings.json加载配置builder.Services.AddOptions();//需要存储速率限制计数器和ip规则builder.Services.AddMemoryCache();//从appsettings.json加载常规配置builder.Services.Configure<IpRateLimitOptions>(builder.Configuration.GetSection("RateLimiting"));//从appsettings.json加载ip规则builder.Services.Configure<IpRateLimitPolicies>(builder.Configuration.GetSection("IpRateLimitPolicies"));//builder.Services.Configure<ClientRateLimitOptions>(builder.Configuration.GetSection("RateLimiting"));//builder.Services.Configure<ClientRateLimitPolicies>(builder.Configuration.GetSection("ClientRateLimitPolicies"));// 注入计数器和规则存储builder.Services.AddInMemoryRateLimiting();//services.AddDistributedRateLimiting<AsyncKeyLockProcessingStrategy>();//services.AddDistributedRateLimiting<RedisProcessingStrategy>();//services.AddRedisRateLimiting();builder.Services.AddSingleton<IRateLimitConfiguration, RateLimitConfiguration>();#endregionvar app = builder.Build();// Configure the HTTP request pipeline.if (app.Environment.IsDevelopment()){app.UseSwagger();app.UseSwaggerUI();}app.UseAuthorization();//启用客户端IP限制速率app.UseIpRateLimiting();//启用客户端ID限制速率//app.UseClientRateLimiting();app.MapControllers();app.Run();
}

4.运行测试

我这里配置的是默认1秒只能请求一次,超出一次返回429 

API calls quota exceeded! maximum admitted 1 per 1s.

错误:

5.基于客户端ID速率限制

如果要启用客户端ID速率限制,需要使用 ClientRateLimitMiddleware 中间件 ,Program.cs中使用app.UseClientRateLimiting();来启用客户端ID限制速率,配置加载也要使用ClientRateLimitOptions和ClientRateLimitPolicies:

在 appsettings.json 增加 ClientRateLimitPolicies配置:

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/627998.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

React函数式组件学习笔记

React是一种用于构建用户界面的JavaScript库&#xff0c;它采用组件化的方式来构建复杂的UI。在React中&#xff0c;函数式组件是一种声明式的方式去描述UI的状态和行为。 React的特性 1.声明式设计-React采用声明范式&#xff0c;可以轻松描述应用 2.高效-React通过对DOM的模…

LaTeX系列1——主结构

初学&#xff0c;可交流&#xff0c;轻喷 \documentclass{book} \begin{document} \title{Book Title} \author{Author Name} \date{\today} \maketitle\chapter{Introduction} This is the introduction chapter of the book.\section{First Section} The first section of t…

【算法】使用栈解决一系列算法题(匹配、表达式、模拟)(C++)

1. 前言&#xff08;栈适用于解哪些题&#xff1f;&#xff09; 栈适合解决需要后进先出&#xff08;LIFO&#xff09;的结构的算法题&#xff0c;例如&#xff1a; 括号匹配问题&#xff1a;判断给定字符串中括号是否匹配。表达式求值问题&#xff1a;将表达式转换为后缀表达…

笙默考试管理系统-MyExamTest----codemirror(71)

笙默考试管理系统-MyExamTest----codemirror&#xff08;71&#xff09; 目录 一、 笙默考试管理系统-MyExamTest----codemirror 二、 笙默考试管理系统-MyExamTest----codemirror 三、 笙默考试管理系统-MyExamTest----codemirror 四、 笙默考试管理系统-MyExamTest---…

C++/WinRT 中的字符串处理

利用 C/WinRT&#xff0c;你可以使用 C 标准库宽字符串类型&#xff08;如 std::wstring&#xff09;调用 Windows 运行时 API&#xff08;注&#xff1a;不要使用窄字符串类型&#xff0c;例如 std::string&#xff09;。 C/WinRT 确实有名为 winrt::hstring 的自定义字符串类…

js 常用基础 老写不出来的问题记录--持续更新

1、result返回一个数组 数组包含多个对象数组对象 要这个数组对象的其中两个属构成新的数组对象 这个时候就使用到了map函数 map可以映射原本数组中的每个元素 返回一个新的数组 result.map(item > { return { id:item.id, name:item.talentsName }})//定义新数组的每项数…

《每天一分钟学习C语言·十二》各种指针问题

1、 int arr; int * restrict pt &arr; *pt 100; *arr 10;注&#xff1a;restrict只能修饰指针&#xff0c;被restrict修饰的指针指向一块内存后这块内存就归这个指针管理了&#xff0c;其他任何指针都不能修改这块内存的内容&#xff0c;这是一个约定&#xff0c;当…

vue+js 实现将变量参数写至Cookie中,并进行读取,可以一次性写入多个值

vuejs 实现将变量参数写至cookie中&#xff0c;并进行读取&#xff0c;可以一次性写入多个值 【使用Vue和JavaScript将变量参数写入cookie并进行读取的示例代码】 <template><div><button click"writeToCookie">写入Cookie</button><but…

BGP安全特性详解(不看后悔!!!)

BGP安全特性 一、MD5认证 BGP认证只支持MD5认证&#xff0c;没有明文认证&#xff1b;BGP报文中没有设计认证字段&#xff0c;认证信息是存放到TCP报文中的option字段携带。 配置命令&#xff1a; peer x.x.x.x password cipher xxxx 二、GTSM GTSM&#xff0c;有效防止基…

微信公众号注册(详细图文教程)

目录 一、公众号注册准备1.1 准备事项1.2 个人注册1.3 企业注册 二、公众号注册2.1 基本信息填写2.2 选择类型2.3 信息登记2.4 公众号信息2.5 修改头像2.6 自动回复消息 三、总结 一、公众号注册准备 1.1 准备事项 公众号名称&#xff1a;公众号名称可以由中文、英文、数字、…

李宏毅LLM——ChatGPT原理剖析

文章目录 Chat-GPT引言关键技术——预训练研究问题玩文字冒险游戏 ChatGPT原理剖析 Chat-GPT引言 直观感受&#xff1a;结果有模有样、每次输出结果都不同、可以追问、幻想出的答案误解&#xff1a;罐头回答、答案是网络搜索的结果真正做的事&#xff1a;文字接龙&#xff0c;…

Spring Cloud中的提供者与消费者

在服务调用关系中&#xff0c;会有两个不同的角色&#xff1a; 服务提供者&#xff1a;一次业务中&#xff0c;被其它微服务调用的服务。&#xff08;提供接口给其它微服务&#xff09; 服务消费者&#xff1a;一次业务中&#xff0c;调用其它微服务的服务。&#xff08;调用…

Artipelag创意艺术展:在斯德哥尔摩的桥边,遇见莫奈!

近期&#xff0c;位于瑞典斯德哥尔摩的Artipelag 艺术博物馆策划了一场名为《想象莫奈》&#xff08;Imagine Monet&#xff09;的艺术展。 Artipelag除了通过传统的社交媒体来做宣传&#xff0c;还联合广告公司Sweet在线下策划了一次特别的宣传活动&#xff0c;以此来致敬这位…

openssl3.2 - 官方demo学习 - signature - EVP_ED_Signature_demo.c

文章目录 openssl3.2 - 官方demo学习 - signature - EVP_ED_Signature_demo.c概述笔记END openssl3.2 - 官方demo学习 - signature - EVP_ED_Signature_demo.c 概述 ED25519 签名/验签算法, 现在是最好的. 产生ED25519私钥/公钥 用私钥对明文签名, 得到签名数据 用公钥对明文…

CF1920 D. Array Repetition [细节规律题]

传送门:CF [前题提要]:一道*1800,本题思路很好想,就是找循环,但是细节较多,故写一篇题解 直接进入正题. 模拟一下题意,最后不难发现我们最后的字符串应该是一个字符串S1的循环加上一个S2的形式.(当然可能没有S2). 更具体的举一个小栗子,设 x , y , z , k x,y,z,k x,y,z,k为字…

Javascript——async、await详解

一、async、await是什么&#xff1f; async用于申明一个function是异步的&#xff1b; 而await则可以认为是 async await的简写形式&#xff0c;是等待一个异步方法执行完成的。**async函数** 通过在函数声明前加上async关键字&#xff0c;可以将任何函数转换为返回Promise的异…

nginx基本优化

安装nginx隐藏版本号 查看百度web服务器 [rootcjq11 ~]# curl -I http://www.baidu.com 隐藏nginx服务器版本号 [rootcjq11 ~]# cd /usr/local/src/nginx-1.22.0/ [rootcjq11 nginx-1.22.0]# vim src/core/nginx.h第13、14行修改版本号和服务器名称 [rootcjq11 nginx-1.2…

HAL库配置RS485通信

在配置好串口的基础上完成RS485的配置 一、使能RS485的发送和接收模式引脚 __HAL_RCC_GPIOG_CLK_ENABLE();//高电平是发送模式&#xff0c;低电平是接收模式&#xff0c;默认是接收模式HAL_GPIO_WritePin(PG4_RS485_DIR1_Port, PG4_RS485_DIR1_Pin, GPIO_PIN_RESET);GPIO_Init…

特征工程-特征处理(三)

特征处理 连续型变量处理&#xff08;二&#xff09; 多特征 降维 PCA PCA是一种常见的数据分析方式&#xff0c;通过数据分解&#xff0c;将高维数据降低为低维数据&#xff0c;同时最大程度保持数据中保存的信息。 from sklearn.decomposition import PCA A np.array([[84…

6、Pandas处理数据类型和缺失值

文章目录 简介数据类型缺失数据解决最常见的阻碍数据处理进展的问题 本节夸克网盘数据集链接:https://pan.quark.cn/s/07400ba46613 提取码:Z9sZ 简介 在本教程中,您将学习如何查看DataFrame或Series中的数据类型。您还将学习如何查找并替换数据。 数据类型 DataFrame或…