تحديد معدل الطلبات في Rust: مكتبات للتحكم في تواتر الطلبات

تحديد معدل الطلبات في Rust: إدارة فعالة للحمل

تحديد معدل الطلبات (Rate limiting) هو آلية أساسية لحماية وتحسين خدمات الويب وواجهات برمجة التطبيقات (API) وتطبيقات الشبكات. في نظام Rust البيئي، توجد عدة مكتبات ناضجة تنفذ خوارزميات مختلفة: من خوارزمية token-bucket الكلاسيكية إلى الأساليب التكيفية الحديثة. في هذه المقالة، سنستعرض ثلاث مكتبات رئيسية: governor و leaky-bucket و ratelimit، مع أمثلة على الكود وتوصيات للاختيار.

1. مكتبة governor — المعيار الذهبي

governor هي المكتبة الأكثر شيوعًا ومرونة لتحديد معدل الطلبات. تنفذ خوارزمية Generic Cell Rate Algorithm (GCRA)، والتي تضمن الالتزام الدقيق بالحدود بأقل تأخير. تدعم الأوضاع المتزامنة وغير المتزامنة، و middleware لإطارات Actix-web و Axum و Rocket.

مثال أساسي مع governor

use governor::{DefaultKeyedRateLimiter, Quota, RateLimiter};\nuse std::num::NonZeroU32;\nuse std::time::Duration;\n\nfn main() {\n    // السماح بـ 5 طلبات في الثانية\n    let quota = Quota::per_second(NonZeroU32::new(5).unwrap());\n    let limiter = RateLimiter::direct(quota);\n\n    for i in 0..10 {\n        match limiter.check() {\n            Ok(_) => println!("الطلب {} مسموح به", i),\n            Err(_) => println!("الطلب {} مرفوض (تجاوز الحد)", i),\n        }\n        std::thread::sleep(Duration::from_millis(100));\n    }\n}

النسخة غير المتزامنة مع الانتظار

use governor::{Quota, RateLimiter};\nuse std::num::NonZeroU32;\nuse tokio::time::{sleep, Duration};\n\n#[tokio::main]\nasync fn main() {\n    let limiter = RateLimiter::direct(Quota::per_second(\n        NonZeroU32::new(2).unwrap(),\n    ));\n\n    for i in 0..5 {\n        limiter.until_ready().await;\n        println!("تمت معالجة الطلب {}", i);\n        sleep(Duration::from_millis(300)).await;\n    }\n}

الإمكانيات الرئيسية لـ governor:

\n
• دعم الحدود المفتاحية (لكل عنوان IP، لكل مستخدم) عبر KeyedRateLimiter
\n
• التكامل مع tower middleware لخوادم HTTP
\n
• استراتيجيات قابلة للتخصيص: الانتظار، الرفض، التباطؤ التكيفي
\n
• استهلاك ضئيل للذاكرة (عداد ذري واحد لكل محدد)
\n

2. مكتبة leaky-bucket — البساطة والموثوقية

leaky-bucket تنفذ خوارزمية "الدلو المتسرب" الكلاسيكية. وهي مثالية لتنعيم الأحمال الذروة، عندما تحتاج لضمان تدفق متساوٍ للطلبات. المكتبة خفيفة الوزن ولا تتطلب تبعيات خارجية.

مثال مع leaky-bucket

use leaky_bucket::RateLimiter;\nuse std::time::Duration;\n\n#[tokio::main]\nasync fn main() {\n    let limiter = RateLimiter::builder()\n        .initial(10)        // المخزون الأولي من الرموز\n        .interval(Duration::from_secs(1))  // فترة إعادة التعبئة\n        .refill(5)          // عدد الرموز المضافة خلال الفترة\n        .max(20)            // الحد الأقصى لعدد الرموز\n        .build();\n\n    for i in 0..15 {\n        limiter.acquire_one().await;\n        println!("تم تنفيذ الطلب {}", i);\n    }\n}

مميزات leaky-bucket:

\n
• دعم واجهات برمجة التطبيقات غير المتزامنة والحاجزة
\n
• إمكانية ضبط وضع "الانفجار" (الارتفاعات المؤقتة)
\n
• تحرير تلقائي للرموز عند الخمول
\n

3. مكتبة ratelimit — نهج بسيط

ratelimit هي أبسط مكتبة، تنفذ نافذة منزلقة بفواصل زمنية ثابتة. مناسبة للسيناريوهات البسيطة التي لا تتطلب دقة عالية.

مثال مع ratelimit

use ratelimit::Ratelimiter;\nuse std::time::Duration;\n\nfn main() {\n    let mut limiter = Ratelimiter::builder(10, Duration::from_secs(1))\n        .