هندسة النظم والخدمات المصغرة (Microservices)٦ أكتوبر ٢٠٢٦ • ٢٨ دقيقة قراءة

هندسة الخدمات المصغرة: استراتيجيات الاتصال الموزع وإدارة المعاملات عبر نمط SAGA

معالجة تحديات اتساق البيانات في البنى الموزعة، استبدال معاملات ACID التقليدية بآليات التعويض (Compensating Transactions)، وتنظيم تدفق الأحداث بين الخدمات المستقلة في بيئات الإنتاج الكبرى.

1. المقدمة والتحول المعماري (Monolithic to Microservices)

بينما توفر معمارية الخدمات المصغرة (Microservices Architecture) مرونة عالية في التوسع المستقل ونشر الفرق البرمجية، إلا أنها تفرض تعقيدات تشييدية كبرى على مستوى البيانات. في النظام المتجانس (Monolith)، تضمن معاملات قاعدة البيانات التقليدية (ACID Transactions) اتساق البيانات across operations. أما في الخدمات المصغرة، حيث تمتلك كل خدمة قاعدة بيانات مستقلة تماماً (Database-per-service)، يصبح تنفيذ معاملة واحدة تمتد عبر عدة خدمات تحدياً هندسياً معقداً.

2. أنماط الاتصال الموزع (Distributed Communication Patterns)

تتواصل الخدمات المصغرة غالباً عبر نمطين رئيسيين:

• الاتصال المتزامن (Synchronous): مثل REST APIs أو gRPC. يتميز بالبساطة ولكنه يسبب اقتراناً شديداً (Tight Coupling) وانهياراً متسلسلاً (Cascading Failures) في حال توقف إحدى الخدمات.
• الاتصال غير المتزامن (Asynchronous Messaging): عبر وسط رسائل (Message Brokers مثل Apache Kafka أو RabbitMQ)، وهو النمط المفضل لضمان فك الاقتران ورفع المرونة وتحمل الضغط (Decoupling & Fault Tolerance).

معمارية التواصل غير المتزامن عبر Message Broker

رسم بياني معماري توضيحي (مُنشأ برمجياً)

Order Service

[ Publish Event ]

Message Broker (Kafka)

[ Consume Event ]

Payment Service

Inventory Service

3. إدارة المعاملات الموزعة عبر نمط SAGA Pattern

بما أننا لا نستطيع استخدام قفل قاعدة البيانات الموزعة (Distributed Two-Phase Commit / 2PC) نظراً لتأثيره المدمر على الأداء والتوافر، يُستخدم نمط SAGA كبديل معتمد. يتكون الـ SAGA من سلسلة من المعاملات المحلية (Local Transactions) حيث تقوم كل خدمة بتحديث بياناتها وإصدار حدث (Event) أو رسالة لتحفيز الخطوة التالية.

في حال فشل أي خطوة في منتصف السلسلة، ينفذ النظام معاملات تعويضية (Compensating Transactions) للتراجع عن التغييرات السابقة واستعادة التناسق (Eventual Consistency).

4. نموذج برمجي لتنفيذ خطوات الـ SAGA

مثال توضيحي لتسلسل معالجة الطلب وإطلاق معاملات التعويض عند حدوث خطأ في المخزون:

javascript

async function executeOrderSaga(orderPayload) {
  let paymentProcessed = false;
  try {
    // الخطوة 1: إنشاء الطلب محلياً
    const order = await orderService.create(orderPayload);

    // الخطوة 2: خصم المبلغ المالي
    await paymentService.charge(order.id, order.total);
    paymentProcessed = true;

    // الخطوة 3: خصم الكمية من المخزون (قد يفشل لنفاد المنتج)
    await inventoryService.deductStock(order.items);

    return { status: 'SUCCESS', orderId: order.id };
  } catch (error) {
    console.error('Saga Failed, initiating compensation...', error);

    // تنفيذ المعاملات التعويضية في الاتجاه المعاكس
    if (paymentProcessed) {
      await paymentService.refund(orderPayload.userId, orderPayload.total);
    }
    await orderService.markAsFailed(orderPayload.id);

    throw new Error('Order processing failed and compensated.');
  }
}