PHP应用中处理限流和API节流的最佳实践

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

// 定义限流参数
$user_ip = $_SERVER['REMOTE_ADDR'];
$rate_limit = 100; // 每分钟最大 100 个请求
$time_window = 60; // 60 秒

// 用于跟踪请求的 Redis 键
$redis_key = "rate_limit:$user_ip";

// 获取当前时间戳
$current_time = time();

// 移除过期请求（比时间窗口更早）
$redis->zRemRangeByScore($redis_key, 0, $current_time - $time_window);

// 获取时间窗口内的当前请求数
$request_count = $redis->zCard($redis_key);

// 如果超过限流，拒绝请求
if ($request_count >= $rate_limit) {
    header('HTTP/1.1 429 Too Many Requests');
    echo "Rate limit exceeded. Try again later.";
    exit;
}

// 记录当前请求时间戳
$redis->zAdd($redis_key, $current_time, $current_time);

// 为键设置过期时间，确保在时间窗口后清理
$redis->expire($redis_key, $time_window);

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

// 定义滑动窗口参数
$user_ip = $_SERVER['REMOTE_ADDR'];
$time_window = 60; // 60 秒
$rate_limit = 100; // 每分钟最大 100 个请求

// 用户请求历史的 Redis 键
$redis_key = "sliding_window:$user_ip";

// 当前时间戳
$current_time = time();

// 将当前请求时间戳添加到有序集合
$redis->zAdd($redis_key, $current_time, $current_time);

// 移除比时间窗口更早的时间戳
$redis->zRemRangeByScore($redis_key, 0, $current_time - $time_window);

// 获取当前窗口内的请求数
$request_count = $redis->zCard($redis_key);

// 如果请求数超过限制，拒绝访问
if ($request_count > $rate_limit) {
    echo "Rate limit exceeded. Please try again later.";
    exit;
}

// 继续处理请求
echo "Request allowed!";

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

// 令牌桶参数
$user_ip = $_SERVER['REMOTE_ADDR'];
$bucket_capacity = 100; // 桶中的最大令牌数
$refill_rate = 1; // 每秒添加的令牌数

// 令牌计数的 Redis 键
$redis_key = "token_bucket:$user_ip";

// 当前时间
$current_time = time();

// 获取最后填充时间和当前令牌计数
$last_refill_time = $redis->get($redis_key . ':last_refill');
$tokens_available = $redis->get($redis_key) ?: $bucket_capacity; // 如果没有设置令牌，默认为最大容量

// 根据经过的时间填充桶
if ($last_refill_time) {
    $tokens_availa编程ble = min($tokens_available + ($current_time - $last_refill_time) * $refill_rate, $bucket_capacity);
}

// 检查请求是否有令牌可用
if ($tokens_available > 0) {
    // 为请求使用 1 个令牌
    $redis->set($redis_key, $tokens_available - 1);
    $redis->set($redis_key . ':last_refill', $current_time);
} else {
    echo "Rate limit exceeded. Please try again later.";
    exit;
}

echo "Request allowed!";

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

// 根据用户层级定义限流参数
$api_key = $_SERVER['HTTP_API_www.chinasem.cnKEY']; // 在请求头中发送的 API 密钥
$rate_limits = [
    'free' => 50,    // 每分钟 50 个请求
    'premium' => 200 // 每分钟 200 个请求
];

// 根据 API 密钥确定用户的限流
$user_tier = getUserTierFromApiKey($api_key);
$rate_limit = $rate_limits[$user_tier];

// 用于跟踪用户请求的 Redis 键
$redis_key = "rate_limit:$api_key";

// 从 Redis 获取当前请求计数
$request_count = $redis->get($redis_key);

// 如果请求计数为空，初始化计数器
if ($request_count === false) {
    $redis->setex($redis_key, 60, 1); // 将请求计数设置为 1，并设置过期时间www.chinasem.cn（60 秒）
} else {
 http://www.chinasem.cn   // 如果超过限流，拒绝请求
    if ($request_count >= $rate_limit) {
        echo "Rate limit exceeded. Please try again later.";
        exit;
    }
    // 增加请求计数
    $redis->incr($redis_key);
}

echo "Request processed successfully!";