أنظمة الوقت الفعلي
نبني أنظمة تعالج الأحداث لحظة وقوعها بدلا من دفعات ليلية: تتبع مواقع حي، تغيرات حالة الطلبات، تحديثات الأسعار، بيانات استشعار تُبث إلى لوحة بيانات خلال ثوانٍ. محرك رصد الحالات الشاذة البحرية لدينا، مشروع بحثي داخلي، يتتبع مواقع سفن AIS الحية ويرصد أنماط الاقتراب الوثيق باستخدام رصد تقارب قائم على جيوهاش، مبني على Kafka وNeo4j.
نصمم خط معالجة الأحداث حول ما يجب أن يحدث خلال ثوانٍ مقابل ما يمكن أن ينتظر: تدفع اتصالات WebSocket التحديثات إلى المتصفح في الوقت الفعلي، بينما تُصفّف Kafka الأحداث وتخزنها مؤقتا بين الخدمات بحيث لا يحجب مستهلك بطيء بقية النظام. وحيث تهم العلاقات بين الكيانات، مثل السفن المرتبطة ببعضها، نستخدم قاعدة بيانات رسم بياني بدلا من فرض تلك البنية على جداول علائقية.
- بث أحداث قائم على Kafka بين الخدمات
- اتصالات WebSocket لتحديثات لوحة البيانات الحية
- رصد علاقات وتقارب قائم على الرسم البياني
- مراقبة وتنبيه على خطوط معالجة الأحداث
التقنية: Java 21 وSpring WebFlux وKafka وNeo4j وWebSocket وAWS.