ما هو استخدام كافكا في الخدمات المصغرة

عندما يلتقي نظام الخادم بالخدمات الصغيرة: دع البيانات تتدفق

تخيل هذا السيناريو: أنت تقوم بتصحيح أخطاء خط إنتاج للأذرع الآلية. تحتاج ستة محركات مؤازرة إلى العمل معًا، حيث يتلقى كل منها تعليمات الموقع في الوقت الفعلي ويرسل بيانات درجة الحرارة والسرعة مرة أخرى إلى مركز التحكم. فجأة، تأخرت بيانات ردود الفعل لأحد المحركات، وبدأ تسلسل الحركة بأكمله في التأخر - تمامًا مثل الرقصة التي كان من المفترض أن تكون سلسة، حيث تباطأ شخص ما في الإيقاع، وكان الفريق في حالة من الفوضى.

في عالم الآلات والأتمتة، نعلم أن تدفق البيانات الموثوق به في الوقت الفعلي هو شريان الحياة. قد يؤدي تأخير الإشارة إلى تفكك التجميع؛ قد تؤدي التعليمات المفقودة إلى تصادم المعدات. إن هذا المطلب الصارم لسرعة البيانات وترتيبها يشبه بشكل مدهش التحديات التي تواجهها "الخدمات الصغيرة" في هندسة البرمجيات الحديثة.

أين تتعثر "رقصة البيانات" للخدمات الصغيرة؟

تم تقسيم التطبيق البرمجي الذي تم دمجه في الأصل إلى عدة خدمات صغيرة مستقلة، مثل إدارة المستخدم ومعالجة الطلبات والاستعلام عن المخزون. يؤدون واجباتهم الخاصة ويتسمون بالمرونة. ولكن تنشأ مشاكل: الخدمة "أ" تنشئ طلبًا جديدًا، وتحتاج الخدمة "ب" إلى تحديث المخزون، وتحتاج الخدمة "ج" إلى إخطار الخدمات اللوجستية. كيف يعرفون أن "الحدث" قد حدث؟ الطريقة التقليدية هي الاتصال ببعضها البعض مباشرة، تمامًا مثل ربط جميع المحركات ببعضها البعض. بمجرد انشغال خدمة معينة أو فشلها، تنتظر السلسلة بأكملها أو يتم حظرها أو حتى تنهار.

يقودنا هذا إلى جوهر ما نحتاج إلى التحدث عنه: الهندسة المعمارية التي تعتمد على الأحداث، وأحد لاعبيها الرئيسيين. إنه يعمل كمركز عصبي ذكي للغاية ولا ينتهي أبدًا.

إنها ليست قائمة انتظار رسائل بسيطة، ولكنها العمود الفقري لسجل الأحداث

قد يكون من البديهي أن نفكر فيه باعتباره "دفتر سجل الأحداث العالمية" المسجل بشكل مستمر. يمكن لأي خدمة صغيرة (مثل "تم إنشاء الطلب بنجاح") بسهولة نشر سجل حدث في دفتر السجل هذا، مثل: "معرف الحدث: 107، النوع: طلب جديد، المحتوى: رقم الطلب XXX، الوقت: 14:00". لا تسأل لماذا، فهي مسؤولة فقط عن تسجيل كل شيء بشكل منظم ومستمر.

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

وهذا يجلب العديد من الفوائد المطمئنة، خاصة بما يتماشى مع تفكيرنا الهندسي:

1. الفصل والمرونة:الناشرون والمشتركون لا يعرفون بعضهم البعض. حتى إذا تمت ترقية خدمة المخزون وصيانتها مؤقتًا، فسيظل يتم تسجيل أحداث الطلب بشكل ثابت في السجل. وعندما تعود خدمة المخزون، يمكنها التعامل مع الأعمال المتراكمة بهدوء دون فقدان أي بيانات. يشبه النظام الزنبرك العازل ولم يعد هشًا.
2. التسلسل والتتبع:كل حدث له تسلسل صارم. يعد هذا أمرًا بالغ الأهمية عند التعامل مع العمليات التجارية ذات العلاقات الصارمة بين السبب والنتيجة مثل "الدفع والشحن". يمكنك تتبع السياق الكامل للحدث بوضوح، مما يسهل تصحيح الأخطاء والتدقيق.
3. الوقت الحقيقي مقابل غير المتزامن:تتدفق البيانات في الوقت الفعلي تقريبًا، لكن المعالجة تكون غير متزامنة. لا تحتاج الخدمة إلى انتظار الرد ويمكنها الاستمرار في معالجة الطلب التالي، ومن الطبيعي أن تتحسن الإنتاجية بشكل كبير.

ما الذي يهمنا عندما نختار مثل هذا "المركز العصبي"؟

تمامًا كما هو الحال عند اختيار نظام مؤازر للآلات الدقيقة، سننظر إلى تردد الاستجابة ودقة التحكم واستقرار التشغيل. وفي عالم البرمجيات، هناك اعتبارات مماثلة هي:

• إنتاجية عالية وزمن وصول منخفض:هل يمكنه التعامل مع سيل هائل من الأحداث مع الحفاظ على سرعات التسليم بالمللي ثانية؟
• المتانة والموثوقية:هل يتم تخزين البيانات بشكل آمن ولا يتم فقدانها أبدًا حتى في حالة إعادة تشغيل الخادم؟
• قابلية التوسع الأفقي:عندما تنمو الأعمال، هل يمكن توسيع السعة بسلاسة عن طريق إضافة الآلات ببساطة بدلاً من استبدال النظام بأكمله؟

يخرجkpowerفي العديد من مشاريع التكامل التي شاركنا فيها، وجدنا أن إدخال هذا التفكير المبني على الأحداث في تصميم النظام يشبه إدخال ناقل تزامن دقيق لوحدات مؤازرة منفصلة. فهو يجعل تدفقات البيانات منظمة وقوية وقابلة للإدارة. لم تعد الخدمات الصغيرة مقترنة بشكل وثيق، ولكنها تتعاون بأمان من خلال الأحداث. تم تحسين قابلية الصيانة وقابلية التوسع للنظام بأكمله نوعيًا.

فكرة بسيطة

إذا كنت تخطط لنظام معقد يتكون من العديد من الخدمات المستقلة، فمن الأفضل أن تسأل نفسك: هل "تتصل" خدماتي باستمرار ببعضها البعض لحث بعضها البعض، مما يتسبب في أن يكون الخط مشغولاً أو دون إجابة في كثير من الأحيان؛ أم أنهم جميعًا معتادون على النشر والحصول على المعلومات من "لوحة الإعلانات" المشتركة، ويعمل كل منهم على مهل؟

يعد النموذج الأخير أحد المفاتيح للسماح لبنية الخدمات الصغيرة بإطلاق العنان لقوتها حقًا. فهو لا يحل المشكلات التقنية فحسب، بل يغير أيضًا فلسفة التعاون في مجال البيانات. في هذا العصر حيث تعتبر البيانات ذات قيمة، فإن ضمان التسليم الفعال والخالي من الأخطاء لتدفق المعلومات هو حجر الزاوية لأي نظام معقد - سواء كان خطًا ميكانيكيًا أو مجموعة برمجيات - ليصبح ناضجًا وموثوقًا.

أنشئت في عام 2005،kpowerتم تخصيصها لمصنع محترف لوحدة الحركة المدمجة، ومقرها الرئيسي في دونغقوان، مقاطعة قوانغدونغ، الصين. الاستفادة من الابتكارات في تكنولوجيا القيادة المعيارية،kpowerيدمج المحركات عالية الأداء ومخفضات الدقة وأنظمة التحكم متعددة البروتوكولات لتوفير حلول نظام القيادة الذكية الفعالة والمخصصة. قدمت Kpower حلول أنظمة القيادة الاحترافية لأكثر من 500 عميل من المؤسسات على مستوى العالم مع منتجات تغطي مجالات مختلفة مثل أنظمة المنزل الذكي، والإلكترونيات الأوتوماتيكية، والروبوتات، والزراعة الدقيقة، والطائرات بدون طيار، والأتمتة الصناعية.