feat: add token bucket design doc

README.md

@@ -494,6 +494,10 @@ async_simple::coro::Lazy<void> test_websocket() {
 }
 ```
 
+## 流控设计文档
+
+[流量控制设计](lang/token_bucket.md)
+
 ## 基于cinatra客户端的http/https压测工具使用
 
 cinatra提供了一个高性能的http1.1 压测工具, 它是基于coro_http_client 实现的，内部通过多线程和协程实现了高效的压测，能够在单核或多核cpu上发送大量请求以此来测试服务器性能。

include/cinatra/token_bucket.hpp

@@ -116,7 +116,7 @@ class token_bucket_storage {
 
   static constexpr size_t align_zero_time =
       constexpr_max(align::value, alignof(atom<double>));
-  alignas(align_zero_time) atom<double> zero_time_;  // Ô­×Ó±äÁ¿
+  alignas(align_zero_time) atom<double> zero_time_;
 };
 
 template <typename policy = token_bucket_policy_default>
@@ -154,7 +154,6 @@ class basic_dynamic_token_bucket {
           return available < to_consume ? 0.0 : to_consume;
         });
 
-    assert(consumed == to_consume || consumed == 0.0);
     return consumed == to_consume;
   }
 

lang/token_bucket.md

@@ -0,0 +1,125 @@
+# 流量控制
+
+应用服务器需要实现限制流量过大或过载自我保护等功能时，就需要流量控制的功能。流量控制不仅仅适用于服务端同时也适用于客户端，客户端也可以使用当前实现的令牌桶算法来进行发送速率的限制。
+
+# 令牌桶设计
+
+令牌桶算法核心在于模拟一个桶。
+
+1. 当需要执行某种操作的时候需要从桶中获取令牌才运行执行，当此时桶中令牌数小于1的时候不允许该操作。
+2. 该桶会以恒定的速率源源不断地产生令牌。
+
+下图是令牌桶的图示:
+
+![](https://media.geeksforgeeks.org/wp-content/uploads/20240116162804/Blank-diagram-(7).png)
+
+令牌桶的算法逻辑如下:
+
+生成令牌的逻辑: 每 1/r 秒就会向桶中添加一个令牌。
+
+消耗令牌的逻辑:
+
+1. 桶最多可以容纳b个令牌。如果桶满时令牌到达，则将其丢弃。
+2. 当一个n占比的行为到达时，如果桶中至少有n个令牌，则从桶中删除n个令牌，并运行该行为。
+3. 如果可用令牌少于 n 个，则不会从桶中删除任何令牌，并且该行为被视为不合格。
+
+下面是消耗令牌的伪代码:
+
+```c
+when(b):
+  Bt = now()
+  Wb = (Bt - At) * r
+  W = min(W + Wb, C)
+  if (W > 1.0):
+    W--
+    return true
+  else:
+    return false
+```
+
+以服务器为例，当请求到来的时候。
+
+Bt为当前时间，At为上一次令牌消耗时间(或者为初始化令牌桶时的时间)，Wb为应该生成的令牌数。C为令牌桶最大令牌数。
+
+核心代码为`min(W + Wb, C)`，当前可用令牌数取生成的令牌加上此时桶中的令牌以及令牌桶容量两者中的最小值。
+
+这里有一个好处那就是当前令牌的计算是线性的，只于时间有关。
+
+# cinatra中的令牌桶算法设计
+
+为了适用更多场景，采用原子操作来实现。
+
+提供了4个API:
+
+```cpp
+/*
+ * 尝试消耗一定数量的token。首先根据自上次尝试消耗令牌以来经过的时间将令牌添加到存储桶中。
+ * 注意：尝试消耗比桶令牌最大大小更多的令牌总是会失败。
+ * @param to_consume 要消耗的令牌数量。
+ * @param now_in_seconds 当前时间（以秒为单位）。应从此令牌桶构造函数中指定的 now_in_seconds 单调递增。
+ * @return 如果速率限制检查通过则返回 true，否则返回 false。
+*/
+bool consume(double to_consume, double now_in_seconds = default_clock_now())
+/*
+ * 与consume类似，但总是消耗一定数量的token。如果桶包含足够的令牌则消耗 to_consume 令牌。否则桶会被清空。
+*/
+bool consume_or_drain(double to_consume, double now_in_seconds = default_clock_now())
+/*
+ * 预留令牌同时返回令牌数量到达当前令牌的等待时间(但是立即返回)，以便预留与存储桶配置兼容。
+*/
+bool consume_with_borrow_nonblocking(double to_consume, double now_in_seconds = default_clock_now())
+/*
+ * 储备令牌。如果需要的大于当前桶中存储的会阻塞，直到令牌数量得到满足。
+*/
+bool consume_with_borrow_and_wait(double to_consume, double now_in_seconds = default_clock_now())
+```
+
+具体实现和上述伪代码逻辑一致。
+
+# cinatra全局令牌桶逻辑
+
+在coro_http_server.hpp中的`coro_http_server`类中添加令牌桶成员变量:
+
+```cpp
+  bool need_rate_limiter_ = false;
+  // 100 tokens are generated per second
+  // and the maximum number of token buckets is 100
+  token_bucket token_bucket_ = token_bucket{100, 100};
+```
+
+一个是是否需要速率限制的标记，一个是令牌桶。
+
+增加一个开启令牌桶功能的API:
+
+```cpp
+  void set_rate_limiter(bool is_enable, int gen_rate = 0, int burst_size = 0) {
+    need_rate_limiter_ = is_enable;
+    if (need_rate_limiter_) {
+      token_bucket_.reset(gen_rate, burst_size);
+    }
+  }
+```
+
+最后将令牌桶逻辑嵌入到`accept()`函数中,将之前的`start_one(conn).via(&conn->get_executor()).detach()`改为如下:
+
+```cpp
+
+if (need_rate_limiter_) {
+  if (token_bucket_.consume(1)) {
+    // there are enough tokens to allow request.
+    start_one(conn).via(&conn->get_executor()).detach();
+  }
+  else {
+    conn->close();
+  }
+}
+else {
+  start_one(conn).via(&conn->get_executor()).detach();
+}
+```
+
+当没有设置流控时走原来的处理逻辑。当走流控时，每次请求来的时候消耗一个令牌，若桶中没有令牌了则直接关闭连接，此时客户端会收到404错误。
+
+这就是全局令牌桶的逻辑。
+
+通过提供的令牌桶算法，用户可以很轻松的通过cinatra的切片功能完成每IP流控等功能。