Tokio Rust: الطرق، الأمثلة، التثبيت

ما هو Tokio ولماذا نحتاجه؟

\n\n

Tokio هو بيئة تشغيل غير متزامنة (async runtime) للغة البرمجة Rust. يوفر البنية التحتية لكتابة تطبيقات شبكية سريعة وموثوقة وقابلة للتوسع. إذا كنت تكتب في Rust شيئًا يتعامل مع الشبكة أو الملفات أو يتطلب معالجة متوازية للطلبات دون حظر الخيوط، فأنت بحاجة إلى Tokio.

\n\n

على عكس النهج التقليدي متعدد الخيوط، حيث تتم معالجة كل طلب في خيط نظام تشغيل منفصل (وهو مكلف ومحدود)، يستخدم Tokio نموذج الإدخال/الإخراج غير المتزامن القائم على الأحداث. يمكن لخيط واحد معالجة آلاف الاتصالات المفتوحة في وقت واحد، والتبديل بين المهام فقط عندما تنتظر المهمة الحالية (مثل القراءة من مقبس).

\n\n

Tokio ليس مجرد مكتبة، بل هو نظام بيئي. يتضمن:

بيئة التشغيل — جدولة المهام ومشغلات الأحداث (epoll/kqueue/IOCP)
بروتوكولات الشبكة القياسية — TCP, UDP, Unix sockets
المؤقتات — sleep, interval, deadline
المزامنة — كائنات المزامنة (mutexes)، الإشارات (semaphores)، الحواجز (barriers) للكود غير المتزامن
الإدخال/الإخراج للملفات — القراءة/الكتابة غير المتزامنة للملفات
الأدوات المساعدة — القنوات (mpsc, oneshot, broadcast)، المخازن المؤقتة، برامج الترميز

\n\n

Tokio هو الأساس لمشاريع معروفة مثل إطار الويب Axum، وعميل HTTP Reqwest، ومآخذ الويب Tungstenite، وقواعد البيانات SQLx وغيرها الكثير.

\n\n

التثبيت

\n\n

على عكس Python (pip) أو Node.js (npm)، يستخدم Rust نظام الحزم Cargo. لتثبيت Tokio، أضف التبعية إلى ملف Cargo.toml:

\n\n

[dependencies]\ntokio = { version = "1", features = ["full"] }

\n\n

العلامة features = ["full"] تُفعّل جميع إمكانيات Tokio. بالنسبة للمشاريع الإنتاجية، يُنصح باختيار الميزات المطلوبة فقط لتقليل وقت التجميع وحجم الملف الثنائي:

\n\n

[dependencies]\ntokio = { version = "1", features = ["rt", "macros", "net", "io-util", "time", "sync"] }

\n\n

الميزات الرئيسية:

rt — بيئة تشغيل متعددة الخيوط
macros — وحدات الماكرو #[tokio::main] و tokio::select!
net — TCP, UDP, Unix sockets
io-util — Reader/Writer غير متزامنين
time — المؤقتات و sleep
sync — بدائيات المزامنة
fs — العمل غير المتزامن مع نظام الملفات
process — تشغيل الأوامر غير المتزامن
signal — معالجة إشارات نظام التشغيل

\n\n

بداية سريعة

\n\n

لنقم بإنشاء خادم HTTP بسيط يرد بـ "Hello, World!" على أي طلب. للقيام بذلك، سنحتاج أيضًا إلى crate hyper (مكتبة HTTP فوق Tokio):

\n\n

// Cargo.toml\n// [dependencies]\n// tokio = { version = "1", features = ["full"] }\n// hyper = { version = "1", features = ["server", "http1"] }\n\nuse hyper::service::service_fn;\nuse hyper::{Request, Response, Server};\nuse hyper::body::Incoming;\nuse std::convert::Infallible;\n\nasync fn handle_request(_req: Request<Incoming>) -> Result<Response<String>, Infallible> {\n    Ok(Response::new("Hello, World!".to_string()))\n}\n\n#[tokio::main]\nasync fn main() {\n    let addr = ([127, 0, 0, 1], 3000).into();\n    let server = Server::bind(&addr).serve(service_fn(handle_request));\n    println!("Server running on http://{}", addr);\n    if let Err(e) = server.await {\n        eprintln!("Server error: {}", e);\n    }\n}

\n\n

قم بتشغيل cargo run وافتح http://127.0.0.1:3000 في المتصفح. سترى "Hello, World!".

\n\n