limiteron 0.3.0-rc.4

Unified flow control framework for Rust
Documentation
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
# ❓ Limiteron 常见问题

本文档按主题汇总 Limiteron 的常见问题与解答,覆盖通用问题、安装设置、使用功能、性能、安全与故障排除。系统性教程请见 [用户指南](USER_GUIDE.md),API 细节请见 [API 参考](API_REFERENCE.md)。

[🏠 首页](../README.md) • [📖 用户指南](USER_GUIDE.md) • [📘 API 参考](API_REFERENCE.md)

---

## 📋 目录

<details open>
<summary>📑 目录</summary>

- [🤔 一般问题]#-一般问题
- [📦 安装和设置]#-安装和设置
- [💡 使用和功能]#-使用和功能
- [⚡ 性能]#-性能
- [🔒 安全]#-安全
- [🔧 故障排除]#-故障排除
- [🤝 贡献]#-贡献
- [📄 许可证]#-许可证

</details>

---

## 🤔 一般问题

<details>
<summary><b>❓ 什么是 Limiteron?</b></summary>

<br>

**Limiteron** 是一个 Rust 统一流量控制框架,提供:

- 多种限流算法(令牌桶、滑动/分片滑动/固定窗口、并发控制、GCRA、HTB 分层令牌桶、AIMD 自适应)
- 封禁管理(IP / 用户 / MAC / Geo / CIDR 封禁、自动封禁、封禁优先级、YAML 批量加载)
- 配额管理(周期配额、配额告警、配额透支)
- 熔断与降级(自动熔断、状态恢复、降级策略)

它为需要保护 API 服务免受滥用和突发流量冲击的开发者设计。

**了解更多:** [用户指南](USER_GUIDE.md)

</details>

<details>
<summary><b>❓ Limiteron 的核心能力有哪些?</b></summary>

<br>

| 能力 | 说明 |
|------|------|
| 多维限流 | 令牌桶、滑动/分片滑动/固定窗口、并发控制、GCRA、HTB、AIMD 自适应 |
| 纵深管控 | 封禁、配额、熔断、降级沿一条决策链协同执行 |
| 可插拔底座 | 内存存储开箱即用,经 dbnexus 与 oxcache 接入持久化与分布式缓存 |
| 生产可观测 | Prometheus 指标、OTLP 追踪导出、HMAC 链式审计日志、K8s 探针端点 |
| 声明式接入 | `#[flow_control]` 过程宏、Tower 中间件、Admin REST API、`limiteron-cli` |

**关键优势:**

- 🚀 高性能(令牌桶吞吐 12M+ ops/s,P99 延迟 < 1µs,见[性能]#-性能)
- 💡 简洁的 API 设计与声明式宏支持
- 📖 完善的文档与 21 个可运行示例
- 🌟 全面的功能(限流、封禁、配额、熔断、降级)

</details>

<details>
<summary><b>❓ 这个项目可以用于生产环境吗?</b></summary>

<br>

**可以。** 当前 0.3.0-rc.x 发布线已在真实项目中验证核心能力:

- ✅ 核心限流与存储抽象稳定,默认构建零外部存储依赖
- ✅ 3298 个测试的分层测试体系与 llvm-cov ≥80% 行覆盖门禁(见[测试指南]TESTING.md)
- ✅ CI 覆盖 fmt / clippy / 三平台构建 / cargo-deny / cargo-audit / CodeQL
- ✅ 性能数据可经仓库自带 criterion 基准复现(`cargo bench --features full`)

> **注意:** 升级版本前请查看[更新日志]CHANGELOG.md,破坏性变更均有标注。

</details>

<details>
<summary><b>❓ 支持哪些平台?</b></summary>

<br>

| 平台 | 架构 | 状态 | 说明 |
|------|------|------|------|
| Linux | x86_64 / ARM64 | ✅ 支持 | CI 三平台矩阵覆盖 |
| macOS | x86_64 / ARM64 | ✅ 支持 | Apple Silicon 覆盖 |
| Windows | x86_64 | ✅ 支持 | CI windows runner 覆盖 |

</details>

<details>
<summary><b>❓ 支持哪些编程语言?</b></summary>

<br>

**Rust** 原生支持,完整 API 访问,docs.rs 在线文档见 [docs.rs/limiteron](https://docs.rs/limiteron)。其他语言经 FFI 接入属于远期设想,当前没有官方绑定。

</details>

---

## 📦 安装和设置

<details>
<summary><b>❓ 如何安装 Limiteron?</b></summary>

<br>

**对于 Rust 项目:**

```toml
[dependencies]
limiteron = { version = "0.3.0-rc.3", features = ["macros"] }
```

或使用 cargo:

```bash
cargo add limiteron --features macros
```

**从源码安装:**

```bash
git clone https://github.com/Kirky-X/limiteron
cd limiteron
cargo build --release
```

**验证安装:**

```rust
use limiteron::limiters::TokenBucketLimiter;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let limiter = TokenBucketLimiter::new(10, 1);
    println!("✅ 安装成功!");
    Ok(())
}
```

**另请参阅:** [用户指南](USER_GUIDE.md#安装)

</details>

<details>
<summary><b>❓ 系统要求是什么?</b></summary>

<br>

| 组件 | 要求 | 推荐 |
|------|------|------|
| Rust 版本 | 1.97.1+([rust-toolchain.toml]../rust-toolchain.toml 锁定) | 最新稳定版 |
| 内存 | 512 MB | 2 GB+ |
| 磁盘空间 | 50 MB | 100 MB |
| CPU | 1 核心 | 4+ 核心 |

**可选:**

- PostgreSQL / MySQL / SQLite(经 dbnexus 持久化存储)
- Redis(经 oxcache 缓存与分布式限流)
- Docker(容器化部署)

</details>

<details>
<summary><b>❓ 遇到编译错误怎么办?</b></summary>

<br>

**常见解决方案:**

1. **更新 Rust 工具链:**
   ```bash
   rustup update stable
   ```

2. **清理构建产物:**
   ```bash
   cargo clean
   cargo build
   ```

3. **检查 Rust 版本:**
   ```bash
   rustc --version
   # 应该是 1.97.1 或更高
   ```

4. **检查 feature 组合:** `postgres` / `sqlite` / `mysql` 三种存储驱动互斥,`--all-features` 会触发 dbnexus 编译错误,请使用显式特性组合。

**还有问题?**
- 📝 查看 [故障排除]#-故障排除
- 🐛 [创建 issue]https://github.com/Kirky-X/limiteron/issues 并附上错误详情

</details>

<details>
<summary><b>❓ 可以在 Docker 中使用吗?</b></summary>

<br>

**可以!** 这是一个示例 Dockerfile:

```dockerfile
FROM rust:1.97-slim AS builder

WORKDIR /app
COPY . .
RUN cargo build --release

FROM debian:bookworm-slim
COPY --from=builder /app/target/release/limiteron /usr/local/bin/

CMD ["limiteron"]
```

**Docker Compose:**

```yaml
services:
  app:
    build: .
    ports:
      - "8080:8080"
    environment:
      - RUST_LOG=info
```

**使用 docker-compose 启动服务:**

```bash
docker-compose up -d
```

</details>

---

## 💡 使用和功能

<details>
<summary><b>❓ 如何开始基础使用?</b></summary>

<br>

**5 分钟快速开始:**

```rust
use limiteron::limiters::{Limiter, TokenBucketLimiter};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 1. 创建限流器
    let limiter = TokenBucketLimiter::new(10, 1);

    // 2. 检查限流
    for i in 0..15 {
        match limiter.allow(1).await {
            Ok(true) => println!("请求 {} ✅", i),
            Ok(false) => println!("请求 {} ❌", i),
            Err(e) => println!("请求 {} 错误: {:?}", i, e),
        }
    }

    Ok(())
}
```

**下一步:**
- 📖 [用户指南]USER_GUIDE.md
- 💻 [更多示例]../examples/

</details>

<details>
<summary><b>❓ 支持哪些限流算法?</b></summary>

<br>

**令牌桶、滑动窗口(已弃用导出)与分片滑动窗口、固定窗口、并发控制、GCRA(`gcra` 特性)、HTB 分层令牌桶、AIMD 自适应并发(`adaptive-limiting` 特性)**。各算法的类型与适用场景对照见[用户指南](USER_GUIDE.md#1️-限流器),构造签名与特性要求见[算法详情](API_REFERENCE.md#-限流器)。

</details>

<details>
<summary><b>❓ 可以同时使用多个限流器吗?</b></summary>

<br>

**可以!** 使用决策链组合多个限流器:

```rust
use limiteron::Governor;
use limiteron::adapters::StorageFactory;
use limiteron::matchers::RequestContext;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 创建存储
    let mut factory = StorageFactory::from_dsn("postgresql://localhost/limiteron");
    factory.initialize(None).await?;
    let storage = factory.create_storage().await?;
    let ban_storage = factory.create_ban_storage().await?;

    // 创建 Governor
    let governor = Governor::builder()
        .with_storage(storage)
        .with_ban_storage(ban_storage)
        .build()
        .await?;

    // 决策链会按优先级依次检查所有限流器
    let context = RequestContext::new()
        .with_header("X-User-Id", "user123")
        .with_path("/api/v1/users")
        .with_method("GET");

    let decision = governor.check(&context).await?;
    match decision {
        limiteron::error::Decision::Allowed(_) => { /* 处理请求 */ }
        _ => { /* 拒绝或封禁处理 */ }
    }

    Ok(())
}
```

**好处:**
- 🔒 多层保护
- 🎯 更精细的控制
- 📊 更好的安全性

</details>

<details>
<summary><b>❓ 如何正确处理错误?</b></summary>

<br>

**推荐模式:**

```rust
use limiteron::error::LimiteronError;
use limiteron::limiters::TokenBucketLimiter;

async fn process_request(limiter: &TokenBucketLimiter) -> Result<(), LimiteronError> {
    match limiter.allow(1).await {
        Ok(true) => {
            println!("✅ 成功");
            Ok(())
        }
        Ok(false) => {
            println!("⚠️ 速率限制");
            Ok(())
        }
        Err(LimiteronError::RateLimitExceeded(msg)) => {
            println!("⚠️ 速率限制: {}", msg);
            Ok(())
        }
        Err(LimiteronError::BanError(msg)) => {
            eprintln!("❌ 已封禁: {}", msg);
            Err(LimiteronError::BanError(msg))
        }
        Err(e) => {
            eprintln!("❌ 错误: {:?}", e);
            Err(e)
        }
    }
}
```

**错误类型:**
- [错误参考]API_REFERENCE.md#-错误处理

</details>

<details>
<summary><b>❓ 支持 async/await 吗?</b></summary>

<br>

**完全支持。** 全部核心 API 均为异步(基于 tokio),限流器同时实现 `Send + Sync` 可跨任务共享。

**示例:**

```rust
use limiteron::limiters::{Limiter, TokenBucketLimiter};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let limiter = TokenBucketLimiter::new(10, 1);

    match limiter.allow(1).await {
        Ok(true) => println!("✅ 请求允许"),
        Ok(false) => println!("❌ 请求被限流"),
        Err(e) => println!("❌ 错误: {:?}", e),
    }

    Ok(())
}
```

**使用宏:**

```rust
use limiteron::flow_control;

#[flow_control(rate = "10/s")]
async fn api_handler() -> Result<String, limiteron::error::LimiteronError> {
    Ok("Success".to_string())
}
```

</details>

---

## ⚡ 性能

<details>
<summary><b>❓ 性能如何?</b></summary>

<br>

**令牌桶检查 12M+ ops/s(P99 < 1µs)、固定窗口检查 20M+ ops/s、并发检查 12M+ ops/s**(2026-01-19 实测;完整吞吐/延迟分位表见 [README 性能](../README.md#-性能))。可用 `cargo bench --features full` 自行复现。

</details>

<details>
<summary><b>❓ 如何提高性能?</b></summary>

<br>

**优化技巧:**

1. **启用 Release 模式:**
   ```bash
   cargo build --release
   ```

2. **利用 L1 负缓存:**
   ```rust
   // L1 负缓存默认启用,且为负缓存语义——仅缓存"拒绝/封禁"决策,
   // "允许"决策永不入缓存,因此任何一次请求都会重新执行限流/封禁检查。
   let governor = Governor::builder()
       .with_l1_cache_enabled(true)
       .build()
       .await?;
   ```

3. **使用全局共享实例:**
   ```rust
   use limiteron::limiters::TokenBucketLimiter;
   use std::sync::LazyLock;

   static LIMITER: LazyLock<TokenBucketLimiter> =
       LazyLock::new(|| TokenBucketLimiter::new(10, 1));
   ```

4. **使用宏:**
   ```rust
   #[flow_control(rate = "100/s")]
   async fn api_handler() -> Result<String, limiteron::error::LimiteronError> {
       Ok("Success".to_string())
   }
   ```

</details>

<details>
<summary><b>❓ 内存使用如何?</b></summary>

<br>

**内存特征(定性):**

| 组件 | 内存特征 | 说明 |
|------|---------|------|
| 核心限流器 | 单实例 KB 级 | 原子计数器状态 |
| L1 负缓存 | 受容量上限约束 | 默认 1000 条,可经 `L1CacheConfig` 调整 |
| MemoryStorage | 随活跃 key 数增长 | 限流器管理器带 LRU 淘汰(上限 100,000 条)防刷爆 |
| 持久化后端 | 由连接池配置决定 | dbnexus 连接池参数可控 |

**减少内存使用:**

```rust
// 通过限制 L1 负缓存容量来减少内存使用
let governor = Governor::builder()
    .with_l1_cache_config(L1CacheConfig::new(Duration::from_secs(60), 1000))
    .build()
    .await?;
```

**内存安全:**
- ✅ Rust 内存安全保证
- ✅ 限流器管理器 LRU 淘汰防无界增长
- ✅ 后台任务 `Drop` 防泄漏

</details>

---

## 🔒 安全

<details>
<summary><b>❓ 这个库安全吗?</b></summary>

<br>

**安全设计贯穿始终。** 输入防线、算法边界、Admin 自保护、数据保护、传输防线与供应链六类机制均可在源码与[安全文档](SECURITY.md#️-安全设计概览)中对应,逐项机制说明见该文档的安全设计概览。

</details>

<details>
<summary><b>❓ 如何报告安全漏洞?</b></summary>

<br>

**请负责任地报告安全问题:** 不要创建公开 issue 披露漏洞细节,优先使用 GitHub 私密漏洞报告(仓库页 → Security → Report a vulnerability)。维护者承诺 48 小时内确认、7 天内给出初步评估,采用协调披露。

报告内容要求(受影响版本、feature 组合、复现步骤、影响评估)与完整流程见[安全文档](SECURITY.md#-漏洞报告流程)。

</details>

<details>
<summary><b>❓ 数据存储如何?</b></summary>

<br>

**数据存储选项:**

| 方法 | 适用场景 | 说明 |
|------|---------|------|
| 内存 | 开发、测试 | 开箱即用,重启即失 |
| SQLite(经 dbnexus) | 单机部署 | 嵌入式持久化,无需外部服务 |
| PostgreSQL / MySQL(经 dbnexus) | 生产部署 | 参数化查询防注入,建议启用 TLS |
| Redis(经 oxcache / lua-script) | 分布式缓存与限流 | Lua 脚本原子操作 |

**最佳实践:**

```rust
// 1. 使用环境变量管理连接串
let dsn = std::env::var("DATABASE_URL")?;

// 2. 设置适当的权限
// 确保数据库访问权限最小化
```

</details>

<details>
<summary><b>❓ 有已知漏洞吗?</b></summary>

<br>

**当前状态:** ✅ **无已知未修复漏洞**

**我们如何维护安全:**

1. **依赖扫描:**
   ```bash
   cargo audit
   cargo deny check
   ```

2. **定期更新:** CI 与 pre-push 钩子持续运行安全审计;对已知漏洞依赖做最低版本锁定(如 rustls-webpki,CVE-2025-48369)

3. **测试:** 安全测试套件(`security_tests`、`admin_security_tests`)与静态分析(CodeQL)

**保持知情:**
- 🔔 关注此仓库
- 📰 查看 [Security Advisories]https://github.com/Kirky-X/limiteron/security/advisories

</details>

---

## 🔧 故障排除

<details>
<summary><b>❓ 限流不生效</b></summary>

<br>

**问题:**

```text
所有请求都通过了限流
```

**原因:** 每次请求都创建了新的 limiter 实例。

**解决方案:**

```rust
use limiteron::limiters::{Limiter, TokenBucketLimiter};
use std::sync::Arc;

// 使用 Arc 共享 limiter 实例
let limiter = Arc::new(TokenBucketLimiter::new(10, 1));

// 在多个请求中使用同一个实例
for i in 0..100 {
    let limiter_clone = Arc::clone(&limiter);
    tokio::spawn(async move {
        match limiter_clone.allow(1).await {
            Ok(true) => println!("请求 {} 允许", i),
            Ok(false) => println!("请求 {} 被限流", i),
            Err(e) => println!("请求 {} 错误: {:?}", i, e),
        }
    });
}
```

</details>

<details>
<summary><b>❓ 性能比预期慢</b></summary>

<br>

**常见原因**:未在 release 模式运行、未启用 L1 负缓存、限流器实例未跨请求共享。对应优化命令与代码见[性能优化技巧](#-性能);完整吞吐/延迟数据见 [README 性能](../README.md#-性能)。

</details>

<details>
<summary><b>❓ 内存使用过高</b></summary>

<br>

**解决方案:** 调低 L1 负缓存容量即可降低内存占用;调优代码与各组件内存特征见[性能](#-性能)。

</details>

**更多问题?** 查看 [用户指南故障排除](USER_GUIDE.md#-故障排除)

---

## 🤝 贡献

<details>
<summary><b>❓ 如何贡献?</b></summary>

<br>

**贡献方式:**

| 代码贡献 | 非代码贡献 |
|---------|-----------|
| 🐛 修复 bug | 📖 编写教程 |
| ✨ 添加功能 | 🌍 翻译文档 |
| 📝 改进文档 | 💬 回答问题 |
| ✅ 编写测试 | 🎨 优化示例 |

**开始:**

1. 🍴 Fork 仓库
2. 🌱 创建分支
3. ✏️ 进行修改
4. ✅ 添加测试
5. 📤 提交 PR

详细流程见[贡献指南](CONTRIBUTING.md)。

</details>

<details>
<summary><b>❓ 发现了 bug,怎么办?</b></summary>

<br>

**报告前:**

1. ✅ 查看 [现有 issues]https://github.com/Kirky-X/limiteron/issues
2. ✅ 尝试最新版本
3. ✅ 查看 [故障排除指南]USER_GUIDE.md#-故障排除

**创建好的 bug 报告:**

```markdown
### 描述
bug 的清晰描述

### 复现步骤
1. 步骤一
2. 步骤二
3. 看到错误

### 预期行为
应该发生什么

### 实际行为
实际发生了什么

### 环境
- OS: Ubuntu 22.04
- Rust version: 1.97.1
- limiteron version: 0.3.0-rc.3

### 其他上下文
任何其他相关信息
```

**提交:** [创建 Issue](https://github.com/Kirky-X/limiteron/issues/new)

</details>

<details>
<summary><b>❓ 在哪里可以获得帮助?</b></summary>

<br>

| 渠道 | 用途 |
|------|------|
| 🐛 [GitHub Issues]https://github.com/Kirky-X/limiteron/issues | Bug 报告和功能请求 |
| 💬 [GitHub Discussions]https://github.com/Kirky-X/limiteron/discussions | 问答和想法 |
| 📦 [GitHub 仓库]https://github.com/Kirky-X/limiteron | 查看源代码 |

</details>

---

## 📄 许可证

<details>
<summary><b>❓ 使用什么许可证?</b></summary>

<br>

**本项目基于 MIT + Commons Clause 许可证发布**,商业使用需单独授权。完整条款见 [LICENSE](../LICENSE);MIT 基础许可自 v0.2.3 起沿用(此前为 Apache-2.0),变更记录见[更新日志](CHANGELOG.md)。

</details>

<details>
<summary><b>❓ 可以在商业项目中使用吗?</b></summary>

<br>

**需单独授权。** 项目采用 MIT + Commons Clause 许可,商业使用需单独授权,条款详见 [LICENSE](../LICENSE)。

</details>

---

### 🎯 还有其他问题?

| 渠道 | 入口 |
|------|------|
| 🐛 创建 Issue | [Issues]https://github.com/Kirky-X/limiteron/issues |
| 💬 开始讨论 | [Discussions]https://github.com/Kirky-X/limiteron/discussions |
| 🏠 GitHub 仓库 | [Kirky-X/limiteron]https://github.com/Kirky-X/limiteron |

---

[📖 用户指南](USER_GUIDE.md) • [📘 API 参考](API_REFERENCE.md) • [🏠 返回首页](../README.md)