@ absolutejs/ rate- 限制
头等舱,从-scratch出道,为 Bun + Elysia 的2026 速率限制. GCRA 默认
(算法花纹使用——精确,每键有O(1)内存,无边界效应),,
IETF 第09号草案 RateLimit-* 页眉, (中文(简体) ), IPv6/64 分组, (中文(简体) ),
X-Forwarded-For 信任模式, (中文(简体) ), Bigint 纳秒 TAT (没有漂浮),
可插件商店(LRU in-memory bunded).
import { Elysia } from 'elysia';
import { rateLimit, gcra } from '@absolutejs/rate-limit';
new Elysia()
.use(rateLimit({
algorithm: gcra({ requestsPerPeriod: 100, periodMs: 60_000, burst: 20 }),
key: 'ip',
trustedProxies: 1, // single CDN/LB hop trusted
}))
.get('/', () => 'ok')
.listen(3000);
为什么不直接利用现有的图书馆
爱丽西亚生态系统的领先者是射线飞/爱丽西亚-速率限. 用一个
符号桶在 a 以上 Map 带有 setInterval 清净相. 没关系,但每个
选择从2020年开始。 2026出自-scrach的回答是:
| 关切 | 别人做什么 | 我们做什么 |
|---|---|---|
| 算法 | 托肯桶(再填入边界时短暂冲出) | 加纳 默认。 准确的,没有边界效应,每个密钥一个 BigInt 状态. 手提桶和滑动窗口也捆绑着,只要你想. |
| 时间精确度 | Date.now() ms(从长生键上漂移) | 大英寸纳秒 为GCRA TAT。 漂浮无所取. |
| IPv6 请检查url=值 (帮助) | 每128个(每个装置1个盖-a) /64 使用 N 设备的用户获得 N× 它们的盖) | 每64人组 默认(RIR分配=一个用户). 相会相会. |
| 代理信任 | 信托 X-Forwarded-For 盲从或忽略它 | trustedProxies: N ——只尊重最后的N跳;默认情况下可防跳(N=0) (中文(简体) ). |
| 页眉 | X-RateLimit-* (遗产GitHub风格) | IETF 第09号草案 RateLimit-* + 键 RateLimit-Policy 默认。 遗产+ both 模式也可用. |
| 存储清理 | setInterval 扫描器(每个过程的计时器;迭代的锁定争议) | 懒 TTL 检查时间。 无背景计时器 . |
| 热路 | 甚至在记忆存储器上同步 | 商店同步时同步只有在必须时才会发出警报. |
| CDN 页眉 | 仅 预算外 | 预算外 + cf-connecting-ip + 键 fly-client-ip + 键 true-client-ip + 键 x-real-ip。 。 。 . |
表面
爱丽西亚插件( E)@absolutejs/rate-limit(中文(简体) )
rateLimit({
algorithm: gcra({ requestsPerPeriod: 100, periodMs: 60_000, burst: 20 }),
store: memoryStore({ maxKeys: 100_000 }),
// key — defaults to 'ip' (uses extractIp).
key: 'ip', // built-in
// key: 'authorization', // built-in
// key: (ctx) => ctx.request.headers.get('x-user') ?? null, // custom
trustedProxies: 1, // honor only the last hop of XFF (typical: 1)
ipv6Prefix: 64, // group IPv6 by /64
skip: (ctx) => ctx.request.headers.get('authorization') === ADMIN_TOKEN,
headers: 'standard', // 'standard' | 'legacy' | 'both' | false
onLimit: (ctx, info) => new Response(JSON.stringify({
ok: false,
retryAfterSec: info.decision.retryAfterSec,
}), { status: 429, headers: { 'Content-Type': 'application/json' } }),
})
算术( E)@absolutejs/rate-limit/core(中文(简体) )
import { gcra, tokenBucket, slidingWindow, memoryStore } from '@absolutejs/rate-limit/core';
const limiter = gcra({ requestsPerPeriod: 100, periodMs: 60_000, burst: 20 });
const store = memoryStore();
const decision = limiter.check(store, 'user-42', Date.now());
// → { allowed, limit, remaining, retryAfterSec, resetSec, policy }
对非 HTTP 速率限制直接使用核心 – WebSocket- message 速率 限制 排队 消费者节奏 人工智能呼叫配额.
存储接口
type Store = {
update<T>(key: string, ttlMs: number, fn: (prev: T | null) => T): T | Promise<T>;
delete?(key: string): void | Promise<void>;
clear?(): void | Promise<void>;
};
执行 update 解剖(read-modify-write);其余为可选. 对于
Bun 正在处理中的使用 memoryStore(). 多审制 Bun 服务由
PostgreSQL 可以使用捆绑的耐用适配器:
import { SQL } from 'bun';
import { postgresStore } from '@absolutejs/rate-limit/postgres';
const store = postgresStore({
sql: new SQL(process.env.DATABASE_URL),
table: 'absolute_rate_limit_entries',
});
应用程序拥有表格迁移 。 这需要 key text PRIMARY KEY, (中文(简体) ),
value jsonb NOT NULL, (中文(简体) ), expires_at timestamp NOT NULL,以及
updated_at timestamp NOT NULL。每个键 PostgreSQL 交易咨询锁
线性化复制更新,包括行前的第一次更新
已存在。 过期的行在下一次更新时被粗略地替换;
activeEntries() 当前报告 pruneExpired() 页:1
为已丢弃的密钥进行范围化操作员清理 .
算法拾取器
- 加纳 - 选这个 除非你有理由不选 准确,O(1)记忆,
无边界效应, BigInt 数学=无漂移。 桶可配置; 设置
burst: 0为严格的节奏. - 脚桶 当你特别想要"填满"时,就选这个 桶并让用户一举一动"的行为. 更干净的心理 最终用户模式.
- 滑动窗口 ——选择这个,当顾客的故事是"你" 在最后M秒有N请求。" 这是一个近似可以 在重聚时低于~1位数,但它是最直观的 在状态页面上解释.
许可证
BSL 1.1对主机速率限制 / WAF / API 网关减速类(Cloudflare WAF + 速率限制,AWS WAF + API 网关减速类,Kong, Tyk, Imperva, Akamai, GCP Cloud Armor, Azure Front Door 速率限制, Upstash rate限制, Frece的API 网关减速类)有命名的例外. 见 自由主义. 更改日期: 4 从首次发布起; 更改许可证: Apache 2.0.
sqlStore(client, table?) 从 @absolutejs/rate-limit/postgres 支持主机管理 PostgreSQL 交易而不需要 Bun SQL 。 供应 query(text, params) -> { rows } 财务报告和审定财务报表 transaction(callback)。它的日记主机拥有的表格 key text primary key, (中文(简体) ), value jsonb, (中文(简体) ), expires_at timestamptz,以及 updated_at timestamptz。更新和删除共享 PostgreSQL 咨询锁。 现有 postgresStore({ sql }) 现保留.