نمط Outbox — التسليم الموثوق للأحداث Transactional Outbox

الصياغة

BEGIN TRANSACTION
  UPDATE business_table ...
  INSERT INTO outbox (event) VALUES (...)
COMMIT
-- عملية منفصلة تنشر لاحقاً من outbox

📄 مثال

await db.transaction(async (tx) => {
  const order = await tx.orders.save(data);
  await tx.outbox.insert({
    eventType: 'order.created', payload: order, publishedAt: null,
  });
}); // الاثنان ينجحان أو يفشلان معاً

// عملية خلفية منفصلة تنشر لاحقاً
for (const e of await db.outbox.findUnpublished()) {
  await broker.publish(e.eventType, e.payload);
  await db.outbox.markPublished(e.id);
}

أهم النقاط

💡 نصائح عملية

• المستهلك يجب أن يكون Idempotent — الضمان هو at-least-once لا exactly-once
• لو كانت البنية التحتية جاهزة، Transaction Log Tailing (مثل Debezium) أسرع من الاستعلام الدوري

⚠️ أخطاء شائعة

• نسيان إدراج الحدث في outbox عند إضافة مسار كود جديد يعدّل نفس الكيان
• بناء مستهلك يفترض وصول كل حدث مرة واحدة بالضبط بلا تكرار محتمل

خصائص ذات صلة